airbyte-lib: Refactor connectors (#34552)

Author: Joe Reuter

airbyte-integrations/connectors/source-activecampaign/main.py

@@ -2,12 +2,7 @@
 # Copyright (c) 2023 Airbyte, Inc., all rights reserved.
 #
 
-
-import sys
-
-from airbyte_cdk.entrypoint import launch
-from source_activecampaign import SourceActivecampaign
+from source_activecampaign.run import run
 
 if __name__ == "__main__":
-    source = SourceActivecampaign()
-    launch(source, sys.argv[1:])
+    run()

airbyte-integrations/connectors/source-activecampaign/setup.py

@@ -16,13 +16,30 @@
 ]
 
 setup(
+    entry_points={
+        "console_scripts": [
+            "source-activecampaign=source_activecampaign.run:run",
+        ],
+    },
     name="source_activecampaign",
     description="Source implementation for Activecampaign.",
     author="Airbyte",
     author_email="[email protected]",
     packages=find_packages(),
     install_requires=MAIN_REQUIREMENTS,
-    package_data={"": ["*.json", "*.yaml", "schemas/*.json", "schemas/shared/*.json"]},
+    package_data={
+        "": [
+            # Include yaml files in the package (if any)
+            "*.yml",
+            "*.yaml",
+            # Include all json files in the package, up to 4 levels deep
+            "*.json",
+            "*/*.json",
+            "*/*/*.json",
+            "*/*/*/*.json",
+            "*/*/*/*/*.json",
+        ]
+    },
     extras_require={
         "tests": TEST_REQUIREMENTS,
     },

airbyte-integrations/connectors/source-activecampaign/source_activecampaign/run.py

@@ -0,0 +1,14 @@
+#
+# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
+#
+
+
+import sys
+
+from airbyte_cdk.entrypoint import launch
+from source_activecampaign import SourceActivecampaign
+
+
+def run():
+    source = SourceActivecampaign()
+    launch(source, sys.argv[1:])

airbyte-integrations/connectors/source-adjust/main.py

@@ -2,12 +2,7 @@
 # Copyright (c) 2023 Airbyte, Inc., all rights reserved.
 #
 
-
-import sys
-
-from airbyte_cdk.entrypoint import launch
-from source_adjust import SourceAdjust
+from source_adjust.run import run
 
 if __name__ == "__main__":
-    source = SourceAdjust()
-    launch(source, sys.argv[1:])
+    run()

airbyte-integrations/connectors/source-adjust/setup.py

@@ -16,13 +16,30 @@
 ]
 
 setup(
+    entry_points={
+        "console_scripts": [
+            "source-adjust=source_adjust.run:run",
+        ],
+    },
     name="source_adjust",
     description="Source implementation for Adjust.",
     author="Airbyte",
     author_email="[email protected]",
     packages=find_packages(),
     install_requires=MAIN_REQUIREMENTS,
-    package_data={"": ["*.json", "*.yaml", "schemas/*.json", "schemas/shared/*.json"]},
+    package_data={
+        "": [
+            # Include yaml files in the package (if any)
+            "*.yml",
+            "*.yaml",
+            # Include all json files in the package, up to 4 levels deep
+            "*.json",
+            "*/*.json",
+            "*/*/*.json",
+            "*/*/*/*.json",
+            "*/*/*/*/*.json",
+        ]
+    },
     extras_require={
         "tests": TEST_REQUIREMENTS,
     },

airbyte-integrations/connectors/source-adjust/source_adjust/run.py

@@ -0,0 +1,14 @@
+#
+# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
+#
+
+
+import sys
+
+from airbyte_cdk.entrypoint import launch
+from source_adjust import SourceAdjust
+
+
+def run():
+    source = SourceAdjust()
+    launch(source, sys.argv[1:])

airbyte-integrations/connectors/source-aha/main.py

@@ -2,12 +2,7 @@
 # Copyright (c) 2023 Airbyte, Inc., all rights reserved.
 #
 
-
-import sys
-
-from airbyte_cdk.entrypoint import launch
-from source_aha import SourceAha
+from source_aha.run import run
 
 if __name__ == "__main__":
-    source = SourceAha()
-    launch(source, sys.argv[1:])
+    run()

airbyte-integrations/connectors/source-aha/setup.py

@@ -16,13 +16,30 @@
 ]
 
 setup(
+    entry_points={
+        "console_scripts": [
+            "source-aha=source_aha.run:run",
+        ],
+    },
     name="source_aha",
     description="Source implementation for Aha.",
     author="Airbyte",
     author_email="[email protected]",
     packages=find_packages(),
     install_requires=MAIN_REQUIREMENTS,
-    package_data={"": ["*.json", "*.yaml", "schemas/*.json", "schemas/shared/*.json"]},
+    package_data={
+        "": [
+            # Include yaml files in the package (if any)
+            "*.yml",
+            "*.yaml",
+            # Include all json files in the package, up to 4 levels deep
+            "*.json",
+            "*/*.json",
+            "*/*/*.json",
+            "*/*/*/*.json",
+            "*/*/*/*/*.json",
+        ]
+    },
     extras_require={
         "tests": TEST_REQUIREMENTS,
     },

airbyte-integrations/connectors/source-aha/source_aha/run.py

@@ -0,0 +1,14 @@
+#
+# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
+#
+
+
+import sys
+
+from airbyte_cdk.entrypoint import launch
+from source_aha import SourceAha
+
+
+def run():
+    source = SourceAha()
+    launch(source, sys.argv[1:])

airbyte-integrations/connectors/source-aircall/main.py

@@ -2,12 +2,7 @@
 # Copyright (c) 2023 Airbyte, Inc., all rights reserved.
 #
 
-
-import sys
-
-from airbyte_cdk.entrypoint import launch
-from source_aircall import SourceAircall
+from source_aircall.run import run
 
 if __name__ == "__main__":
-    source = SourceAircall()
-    launch(source, sys.argv[1:])
+    run()