add X-Connector-Id header to all connectors

_template_/provider/__init__.py

@@ -29,4 +29,5 @@ def create_app() -> connexion.FlaskApp:
     # load environment variables prefixed with the name of the current directory
     config_prefix = os.path.split(os.getcwd())[1].upper().replace("_", "")
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app

_template_/provider/app.py

@@ -43,7 +43,7 @@ def search(body):
         },
     ]
 
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 # This function is run for all endpoints to ensure requests are using a valid API key

agilitycms/provider/__init__.py

@@ -26,4 +26,5 @@ def create_app() -> connexion.FlaskApp:
     flask_app = app.app
     config_prefix = os.path.split(os.getcwd())[1].upper()
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app

agilitycms/provider/app.py

@@ -22,7 +22,7 @@ def search(body):
         logger.error(f"AgilityCMS config error: {error}")
         abort(502, f"AgilityCMS config error: {error}")
 
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

agora/provider/__init__.py

@@ -26,4 +26,5 @@ def create_app() -> connexion.FlaskApp:
     flask_app = app.app
     config_prefix = os.path.split(os.getcwd())[1].upper()
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app

agora/provider/app.py

@@ -22,7 +22,7 @@ def search(body):
         logger.error(f"Agora config error: {error}")
         abort(502, f"Agora config error: {error}")
 
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

aha/provider/__init__.py

@@ -26,4 +26,5 @@ def create_app() -> connexion.FlaskApp:
     flask_app = app.app
     config_prefix = os.path.split(os.getcwd())[1].upper()
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app

aha/provider/app.py

@@ -21,7 +21,7 @@ def search(body):
         logger.error(f"Aha config error: {error}")
         abort(502, f"Aha config error: {error}")
 
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

algolia/provider/__init__.py

@@ -28,5 +28,6 @@ def create_app() -> connexion.FlaskApp:
         1
     ].upper()  # Current directory name, upper-cased
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     flask_app.config.from_mapping(dotenv_values())
     return flask_app

algolia/provider/app.py

@@ -14,7 +14,7 @@ def search(body):
     except UpstreamProviderError as error:
         logger.error(f"Upstream search error: {error.message}")
         abort(502, error.message)
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

asana/provider/__init__.py

@@ -29,4 +29,5 @@ def create_app() -> connexion.FlaskApp:
         1
     ].upper()  # Current directory name, upper-cased
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app

asana/provider/app.py

@@ -14,7 +14,7 @@ def search(body):
     except UpstreamProviderError as error:
         logger.error(f"Upstream search error: {error.message}")
         abort(502, error.message)
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

atera/provider/__init__.py

@@ -30,4 +30,5 @@ def create_app() -> connexion.FlaskApp:
         1
     ].upper()  # Current directory name, upper-cased
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app

atera/provider/app.py

@@ -14,7 +14,7 @@ def search(body):
     except UpstreamProviderError as error:
         logger.error(f"Upstream search error: {error.message}")
         abort(502, error.message)
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

backstage/provider/__init__.py

@@ -29,4 +29,5 @@ def create_app() -> connexion.FlaskApp:
         1
     ].upper()  # Current directory name, upper-cased
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app

backstage/provider/app.py

@@ -20,7 +20,7 @@ def search(body):
     except AssertionError as error:
         logger.error(f"Solr config error: {error}")
         abort(502, f"Solr config error: {error}")
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

basecamp/provider/__init__.py

@@ -26,4 +26,5 @@ def create_app() -> connexion.FlaskApp:
     flask_app = app.app
     config_prefix = os.path.split(os.getcwd())[1].upper()
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app

basecamp/provider/app.py

@@ -22,7 +22,7 @@ def search(body):
         logger.error(f"Basecamp config error: {error}")
         abort(502, f"Basecamp config error: {error}")
 
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

bigquery/provider/__init__.py

@@ -29,4 +29,5 @@ def create_app() -> connexion.FlaskApp:
         1
     ].upper()  # Current directory name, upper-cased
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app

bigquery/provider/app.py

@@ -14,7 +14,7 @@ def search(body):
     except UpstreamProviderError as error:
         logger.error(f"Upstream search error: {error.message}")
         abort(502, error.message)
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

blogger/provider/__init__.py

@@ -26,5 +26,6 @@ def create_app():
     flask_app = app.app
     config_prefix = os.path.split(os.getcwd())[1].upper()
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
 
     return flask_app

blogger/provider/app.py

@@ -18,7 +18,7 @@ def search(body):
         logger.error(f"Blogger config error: {error}")
         abort(502, f"Blogger config error: {error}")
 
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

box/provider/__init__.py

@@ -27,4 +27,5 @@ def create_app() -> connexion.FlaskApp:
     flask_app = app.app
     config_prefix = os.path.split(os.getcwd())[1].upper()
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app

box/provider/app.py

@@ -17,7 +17,7 @@ def search(body):
         logger.error(f"Upstream search error: {error.message}")
         abort(502, error.message)
 
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

cockroach/provider/__init__.py

@@ -29,4 +29,5 @@ def create_app() -> connexion.FlaskApp:
         1
     ].upper()  # Current directory name, upper-cased
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app

cockroach/provider/app.py

@@ -20,7 +20,7 @@ def search(body):
     except AssertionError as error:
         logger.error(f"Cockroach config error: {error}")
         abort(502, f"Cockroach config error: {error}")
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

coda/provider/__init__.py

@@ -29,4 +29,5 @@ def create_app() -> connexion.FlaskApp:
         1
     ].upper()  # Current directory name, upper-cased
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app

coda/provider/app.py

@@ -14,7 +14,7 @@ def search(body):
     except UpstreamProviderError as error:
         logger.error(f"Upstream search error: {error.message}")
         abort(502, error.message)
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

confluence/provider/__init__.py

@@ -26,4 +26,5 @@ def create_app() -> connexion.FlaskApp:
     flask_app = app.app
     config_prefix = os.path.split(os.getcwd())[1].upper()
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app

confluence/provider/app.py

@@ -19,7 +19,7 @@ def search(body):
         logger.error(f"Upstream search error: {error.message}")
         abort(502, error.message)
 
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

contentful/provider/__init__.py

@@ -26,4 +26,5 @@ def create_app() -> connexion.FlaskApp:
     flask_app = app.app
     config_prefix = os.path.split(os.getcwd())[1].upper()
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app

contentful/provider/app.py

@@ -22,7 +22,7 @@ def search(body):
         logger.error(f"Contentful config error: {error}")
         abort(502, f"Contentful config error: {error}")
 
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

copper/provider/__init__.py

@@ -26,4 +26,5 @@ def create_app() -> connexion.FlaskApp:
     flask_app = app.app
     config_prefix = os.path.split(os.getcwd())[1].upper()
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app

copper/provider/app.py

@@ -22,7 +22,7 @@ def search(body):
         logger.error(f"Copper provider error: {error}")
         abort(502, f"Copper config error: {error}")
 
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

couchbase/provider/__init__.py

@@ -29,4 +29,5 @@ def create_app() -> connexion.FlaskApp:
         1
     ].upper()  # Current directory name, upper-cased
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app

couchbase/provider/app.py

@@ -19,7 +19,7 @@ def search(body):
         logger.error(f"Couchbase config error: {error}")
         abort(502, f"Couchbase config error: {error}")
 
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

courier/provider/__init__.py

@@ -30,4 +30,5 @@ def create_app() -> connexion.FlaskApp:
         1
     ].upper()  # Current directory name, upper-cased
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app

courier/provider/app.py

@@ -14,7 +14,7 @@ def search(body):
     except UpstreamProviderError as error:
         logger.error(f"Upstream search error: {error.message}")
         abort(502, error.message)
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

discourse/provider/__init__.py

@@ -26,4 +26,5 @@ def create_app() -> connexion.FlaskApp:
     flask_app = app.app
     config_prefix = os.path.split(os.getcwd())[1].upper()
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app

discourse/provider/app.py

@@ -18,7 +18,7 @@ def search(body):
         logger.error(f"Upstream search error: {error.message}")
         abort(502, error.message)
 
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

docusign/provider/__init__.py

@@ -29,4 +29,5 @@ def create_app() -> connexion.FlaskApp:
         1
     ].upper()  # Current directory name, upper-cased
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app

docusign/provider/app.py

@@ -22,7 +22,7 @@ def search(body):
         logger.error(f"Docusign config error: {error}")
         abort(502, f"Docusign config error: {error}")
 
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

egnyte/provider/__init__.py

@@ -29,4 +29,5 @@ def create_app() -> connexion.FlaskApp:
         1
     ].upper()  # Current directory name, upper-cased
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app

egnyte/provider/app.py

@@ -14,7 +14,7 @@ def search(body):
     except UpstreamProviderError as error:
         logger.error(f"Upstream search error: {error.message}")
         abort(502, error.message)
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

elastic/provider/__init__.py

@@ -29,4 +29,5 @@ def create_app() -> connexion.FlaskApp:
         1
     ].upper()  # Current directory name, upper-cased
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app

elastic/provider/app.py

@@ -17,7 +17,7 @@ def search(body):
         logger.error(f"Upstream search error: {error.message}")
         abort(502, error.message)
 
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

fifteenfive/provider/__init__.py

@@ -29,4 +29,5 @@ def create_app() -> connexion.FlaskApp:
         1
     ].upper()  # Current directory name, upper-cased
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app

fifteenfive/provider/app.py

@@ -19,7 +19,7 @@ def search(body):
         logger.error(f"GDrive config error: {error}")
         abort(502, f"GDrive config error: {error}")
 
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

fireflies/provider/__init__.py

@@ -26,4 +26,5 @@ def create_app() -> connexion.FlaskApp:
     flask_app = app.app
     config_prefix = os.path.split(os.getcwd())[1].upper()
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app

fireflies/provider/app.py

@@ -22,7 +22,7 @@ def search(body):
         logger.error(f"FireFlies config error: {error}")
         abort(502, f"FireFlies config error: {error}")
 
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

freshdesk/provider/__init__.py

@@ -29,4 +29,5 @@ def create_app() -> connexion.FlaskApp:
         1
     ].upper()  # Current directory name, upper-cased
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app

freshdesk/provider/app.py

@@ -14,7 +14,7 @@ def search(body):
     except UpstreamProviderError as error:
         logger.error(f"Upstream search error: {error.message}")
         abort(502, error.message)
-    return {"results": data}
+    return {"results": data}, 200, {"X-Connector-Id": app.config.get("APP_ID")}
 
 
 def apikey_auth(token):

freshsales/provider/__init__.py

@@ -29,4 +29,5 @@ def create_app() -> connexion.FlaskApp:
         1
     ].upper()  # Current directory name, upper-cased
     flask_app.config.from_prefixed_env(config_prefix)
+    flask_app.config["APP_ID"] = config_prefix
     return flask_app