Fix Github check connection for organizations with large number of re…

.pre-commit-config.yaml

@@ -22,7 +22,11 @@ repos:
     hooks:
       - id: prettier
         types_or: [yaml, json]
-        exclude: ^.github/
+        exclude: |
+          (?x)^.*(
+              .github/|
+              source_specs.yaml
+          ).?$
 
   - repo: https://gitlab.com/pycqa/flake8
     rev: 3.8.4

airbyte-config/init/src/main/resources/seed/source_definitions.yaml

@@ -184,7 +184,7 @@
 - name: GitHub
   sourceDefinitionId: ef69ef6e-aa7f-4af1-a01d-ef775033524e
   dockerRepository: airbyte/source-github
-  dockerImageTag: 0.2.4
+  dockerImageTag: 0.2.5
   documentationUrl: https://docs.airbyte.io/integrations/sources/github
   icon: github.svg
   sourceType: api

airbyte-config/init/src/main/resources/seed/source_specs.yaml

@@ -1643,7 +1643,7 @@
     supportsNormalization: false
     supportsDBT: false
     supported_destination_sync_modes: []
-- dockerImage: "airbyte/source-github:0.2.4"
+- dockerImage: "airbyte/source-github:0.2.5"
   spec:
     documentationUrl: "https://docs.airbyte.io/integrations/sources/github"
     connectionSpecification:

airbyte-integrations/connectors/source-github/Dockerfile

@@ -12,5 +12,5 @@ RUN pip install .
 ENV AIRBYTE_ENTRYPOINT "python /airbyte/integration_code/main.py"
 ENTRYPOINT ["python", "/airbyte/integration_code/main.py"]
 
-LABEL io.airbyte.version=0.2.4
+LABEL io.airbyte.version=0.2.5
 LABEL io.airbyte.name=airbyte/source-github

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

@@ -10,10 +10,7 @@
     "vcrpy==4.1.1",
 ]
 
-TEST_REQUIREMENTS = [
-    "pytest~=6.1",
-    "source-acceptance-test",
-]
+TEST_REQUIREMENTS = ["pytest~=6.1", "source-acceptance-test", "responses==0.13.3"]
 
 setup(
     name="source_github",

airbyte-integrations/connectors/source-github/source_github/source.py

@@ -44,24 +44,40 @@
 )
 
 TOKEN_SEPARATOR = ","
+# To scan all the repos within orgnaization, organization name could be
+# specified by using asteriks i.e. "airbytehq/*"
+ORGANIZATION_PATTERN = re.compile("^.*/\\*$")
 
 
 class SourceGithub(AbstractSource):
     @staticmethod
-    def _generate_repositories(config: Mapping[str, Any], authenticator: MultipleTokenAuthenticator) -> List[str]:
+    def _generate_repositories(config: Mapping[str, Any], authenticator: MultipleTokenAuthenticator) -> Tuple[List[str], List[str]]:
+        """
+        Parse repositories config line and produce two lists of repositories.
+        Args:
+            config (dict): Dict representing connector's config
+            authenticator(MultipleTokenAuthenticator): authenticator object
+        Returns:
+            Tuple[List[str], List[str]]: Tuple of two lists: first representing
+            repositories directly mentioned in config and second is
+            organization repositories from orgs/{org}/repos request.
+        """
         repositories = list(filter(None, config["repository"].split(" ")))
 
         if not repositories:
             raise Exception("Field `repository` required to be provided for connect to Github API")
 
-        repositories_list = [repo for repo in repositories if not re.match("^.*/\\*$", repo)]
+        repositories_list: set = {repo for repo in repositories if not ORGANIZATION_PATTERN.match(repo)}
         organizations = [org.split("/")[0] for org in repositories if org not in repositories_list]
+        organisation_repos = set()
         if organizations:
             repos = Repositories(authenticator=authenticator, organizations=organizations)
             for stream in repos.stream_slices(sync_mode=SyncMode.full_refresh):
-                repositories_list += [r["full_name"] for r in repos.read_records(sync_mode=SyncMode.full_refresh, stream_slice=stream)]
+                organisation_repos = organisation_repos.union(
+                    {r["full_name"] for r in repos.read_records(sync_mode=SyncMode.full_refresh, stream_slice=stream)}
+                )
 
-        return list(set(repositories_list))
+        return list(repositories_list), list(organisation_repos)
 
     @staticmethod
     def _get_authenticator(config: Dict[str, Any]):
@@ -114,21 +130,28 @@ def _get_branches_data(selected_branches: str, full_refresh_args: Dict[str, Any]
     def check_connection(self, logger: AirbyteLogger, config: Mapping[str, Any]) -> Tuple[bool, Any]:
         try:
             authenticator = self._get_authenticator(config)
-            repositories = self._generate_repositories(config=config, authenticator=authenticator)
+            # In case of getting repository list for given organization was
+            # successfull no need of checking stats for every repository within
+            # that organization.
+            # Since we have "repo" scope requested it should grant access to private repos as well:
+            # https://docs.github.com/en/developers/apps/building-oauth-apps/scopes-for-oauth-apps#available-scopes
+            repositories, _ = self._generate_repositories(config=config, authenticator=authenticator)
 
             repository_stats_stream = RepositoryStats(
                 authenticator=authenticator,
                 repositories=repositories,
             )
             for stream_slice in repository_stats_stream.stream_slices(sync_mode=SyncMode.full_refresh):
-                next(repository_stats_stream.read_records(sync_mode=SyncMode.full_refresh, stream_slice=stream_slice))
+                next(repository_stats_stream.read_records(sync_mode=SyncMode.full_refresh, stream_slice=stream_slice), None)
             return True, None
         except Exception as e:
             return False, repr(e)
 
     def streams(self, config: Mapping[str, Any]) -> List[Stream]:
         authenticator = self._get_authenticator(config)
-        repositories = self._generate_repositories(config=config, authenticator=authenticator)
+        repos, organization_repos = self._generate_repositories(config=config, authenticator=authenticator)
+        repositories = repos + organization_repos
+
         organizations = list({org.split("/")[0] for org in repositories})
         full_refresh_args = {"authenticator": authenticator, "repositories": repositories}
         incremental_args = {**full_refresh_args, "start_date": config["start_date"]}

airbyte-integrations/connectors/source-github/unit_tests/test_source.py

@@ -0,0 +1,54 @@
+#
+# Copyright (c) 2021 Airbyte, Inc., all rights reserved.
+#
+
+from unittest.mock import MagicMock
+
+import responses
+from airbyte_cdk.models import AirbyteConnectionStatus, Status
+from source_github.source import SourceGithub
+
+
+def check_source(repo_line: str) -> AirbyteConnectionStatus:
+    source = SourceGithub()
+    config = {"access_token": "test_token", "repository": repo_line}
+    logger_mock = MagicMock()
+    return source.check(logger_mock, config)
+
+
+@responses.activate
+def test_check_connection_repos_only():
+    responses.add("GET", "https://api.github.com/repos/airbyte", json={})
+
+    status = check_source("airbyte airbyte airbyte")
+    assert not status.message
+    assert status.status == Status.SUCCEEDED
+    # Only one request since 3 repos have same name
+    assert len(responses.calls) == 1
+
+
+@responses.activate
+def test_check_connection_repos_and_org_repos():
+    repos = [{"name": f"name {i}", "full_name": f"full name {i}"} for i in range(1000)]
+    responses.add("GET", "https://api.github.com/repos/airbyte/test", json={})
+    responses.add("GET", "https://api.github.com/repos/airbyte/test2", json={})
+    responses.add("GET", "https://api.github.com/orgs/airbytehq/repos", json=repos)
+    responses.add("GET", "https://api.github.com/orgs/org/repos", json=repos)
+
+    status = check_source("airbyte/test airbyte/test2 airbytehq/* org/*")
+    assert not status.message
+    assert status.status == Status.SUCCEEDED
+    # Two requests for repos and two for organization
+    assert len(responses.calls) == 4
+
+
+@responses.activate
+def test_check_connection_org_only():
+    repos = [{"name": f"name {i}", "full_name": f"full name {i}"} for i in range(1000)]
+    responses.add("GET", "https://api.github.com/orgs/airbytehq/repos", json=repos)
+
+    status = check_source("airbytehq/*")
+    assert not status.message
+    assert status.status == Status.SUCCEEDED
+    # One request to check organization
+    assert len(responses.calls) == 1

docs/integrations/sources/github.md

@@ -92,6 +92,7 @@ Your token should have at least the `repo` scope. Depending on which streams you
 
 | Version | Date | Pull Request | Subject |
 | :--- | :--- | :--- | :--- |
+| 0.2.5 | 2021-11-21 | [8170](https://github.com/airbytehq/airbyte/pull/8170) | Fix slow check connection for organizations with a lot of repos |
 | 0.2.4 | 2021-11-11 | [7856](https://github.com/airbytehq/airbyte/pull/7856) | Resolve $ref fields in some stream schemas |
 | 0.2.3 | 2021-10-06 | [6833](https://github.com/airbytehq/airbyte/pull/6833) | Fix config backward compatability |
 | 0.2.2 | 2021-10-05 | [6761](https://github.com/airbytehq/airbyte/pull/6761) | Add oauth worflow specification |