From ae931aa4df81d19514bc0ab017a7388940082b13 Mon Sep 17 00:00:00 2001
From: Mike <1960272+gouline@users.noreply.github.com>
Date: Wed, 29 Jan 2020 17:16:10 +1100
Subject: [PATCH] Allow HTTP connection to Metabase (#2)

---
 dbtmetabase/__init__.py | 11 +++++++----
 dbtmetabase/metabase.py |  9 ++++++---
 2 files changed, 13 insertions(+), 7 deletions(-)

diff --git a/dbtmetabase/__init__.py b/dbtmetabase/__init__.py
index 2c3c5739..0aca12d3 100644
--- a/dbtmetabase/__init__.py
+++ b/dbtmetabase/__init__.py
@@ -3,12 +3,12 @@
 from .dbt import DbtReader
 from .metabase import MetabaseClient
 
-__version__ = '0.1.4'
+__version__ = '0.1.5'
 
 def export(dbt_path: str, 
-        mb_host: str, mb_user: str, mb_password: str, 
+        mb_host: str, mb_user: str, mb_password: str,
         database: str, schema: str,
-        sync = True, sync_timeout = 30):
+        mb_https = True, sync = True, sync_timeout = 30):
     """Exports models from dbt to Metabase.
     
     Arguments:
@@ -20,11 +20,12 @@ def export(dbt_path: str,
         schema {str} -- Target schema name.
     
     Keyword Arguments:
+        mb_https {bool} -- Use HTTPS to connect to Metabase instead of HTTP. (default: {True})
         sync {bool} -- Synchronize Metabase database before export. (default: {True})
         sync_timeout {int} -- Synchronization timeout in seconds. (default: {30})
     """
 
-    mbc = MetabaseClient(mb_host, mb_user, mb_password)
+    mbc = MetabaseClient(mb_host, mb_user, mb_password, mb_https)
     models = DbtReader(dbt_path).read_models()
 
     if sync:
@@ -47,6 +48,7 @@ def main(args: list = None):
     parser.add_argument('--mb_host', metavar='HOST', required=True, help="Metabase hostname")
     parser.add_argument('--mb_user', metavar='USER', required=True, help="Metabase username")
     parser.add_argument('--mb_password', metavar='PASS', required=True, help="Metabase password")
+    parser.add_argument('--mb_https', metavar='HTTPS', type=bool, default=True, help="use HTTPS to connect to Metabase instead of HTTP")
     parser.add_argument('--database', metavar='DB', required=True, help="target database name")
     parser.add_argument('--schema', metavar='SCHEMA', required=True, help="target schema name")
     parser.add_argument('--sync', metavar='ENABLE', type=bool, default=True, help="synchronize Metabase database before export")
@@ -59,6 +61,7 @@ def main(args: list = None):
             mb_host=parsed.mb_host,
             mb_user=parsed.mb_user,
             mb_password=parsed.mb_password,
+            mb_https=parsed.mb_https,
             database=parsed.database,
             schema=parsed.schema,
             sync=parsed.sync,
diff --git a/dbtmetabase/metabase.py b/dbtmetabase/metabase.py
index 816b2cc0..d176250b 100644
--- a/dbtmetabase/metabase.py
+++ b/dbtmetabase/metabase.py
@@ -11,16 +11,20 @@ class MetabaseClient:
 
     _SYNC_PERIOD_SECS = 5
 
-    def __init__(self, host: str, user: str, password: str):
+    def __init__(self, host: str, user: str, password: str, https = True):
         """Constructor.
         
         Arguments:
             host {str} -- Metabase hostname.
             user {str} -- Metabase username.
             password {str} -- Metabase password.
+        
+        Keyword Arguments:
+            https {bool} -- Use HTTPS instead of HTTP. (default: {True})
         """
 
         self.host = host
+        self.protocol = "https" if https else "http"
         self.session_id = self.get_session_id(user, password)
         logging.info("Session established successfully")
     
@@ -283,10 +287,9 @@ def api(self, method: str, path: str, authenticated = True, critical = True, **k
         if authenticated:
             headers['X-Metabase-Session'] = self.session_id
 
-        response = requests.request(method, f"https://{self.host}{path}", **kwargs)
+        response = requests.request(method, f"{self.protocol}://{self.host}{path}", **kwargs)
         if critical:
             response.raise_for_status()
         elif not response.ok:
             return False
         return json.loads(response.text)
-