1 files changed, 32 insertions, 0 deletions
diff --git a/src/lib/Bcfg2/Reporting/Transport/__init__.py b/src/lib/Bcfg2/Reporting/Transport/__init__.py
new file mode 100644
index 000000000..ec39a1628
--- /dev/null
+++ b/src/lib/Bcfg2/Reporting/Transport/__init__.py
@@ -0,0 +1,32 @@
+"""
+Public transport routines
+"""
+
+import traceback
+
+from Bcfg2.Reporting.Transport.base import TransportError, \
+    TransportImportError
+
+def load_transport(transport_name, setup):
+    """
+    Try to load the transport.  Raise TransportImportError on failure
+    """
+    try:
+        mod_name = "%s.%s" % (__name__, transport_name)
+        mod = getattr(__import__(mod_name).Reporting.Transport, transport_name)
+    except ImportError:
+        try:
+            mod = __import__(transport_name)
+        except:
+            raise TransportImportError("Unavailable")
+    try:
+        cls = getattr(mod, transport_name)
+        return cls(setup)
+    except:
+        raise TransportImportError("Transport unavailable: %s" %
+            traceback.format_exc().splitlines()[-1])
+
+def load_transport_from_config(setup):
+    """Load the transport in the config... eventually"""
+    return load_transport('LocalFilesystem', setup)
+