1 files changed, 17 insertions, 5 deletions
diff --git a/src/lib/Bcfg2/Reporting/Transport/base.py b/src/lib/Bcfg2/Reporting/Transport/base.py
index cca7beda0..530011e47 100644
--- a/src/lib/Bcfg2/Reporting/Transport/base.py
+++ b/src/lib/Bcfg2/Reporting/Transport/base.py
@@ -2,26 +2,38 @@
 The base for all server -> collector Transports
 """
 
-import os.path
-import logging 
+import os
+import sys
+from Bcfg2.Server.Plugin import Debuggable
+
 
 class TransportError(Exception):
     """Generic TransportError"""
     pass
 
+
 class TransportImportError(TransportError):
     """Raised when a transport fails to import"""
     pass
 
-class TransportBase(object):
+
+class TransportBase(Debuggable):
     """The base for all transports"""
 
     def __init__(self, setup):
         """Do something here"""
         clsname = self.__class__.__name__
-        self.logger = logging.getLogger(clsname)
-        self.logger.debug("Loading %s transport" % clsname)
+        Debuggable.__init__(self, name=clsname)
+        self.debug_log("Loading %s transport" % clsname)
         self.data = os.path.join(setup['repo'], 'Reporting', clsname)
+        if not os.path.exists(self.data):
+            self.logger.info("%s does not exist, creating" % self.data)
+            try:
+                os.makedirs(self.data)
+            except OSError:
+                self.logger.warning("Could not create %s: %s" %
+                                    (self.data, sys.exc_info()[1]))
+                self.logger.warning("The transport may not function properly")
         self.setup = setup
         self.timeout = 2