(self, query)
| 106 | ) |
| 107 | |
| 108 | async def query_org_repos(self, query): |
| 109 | repos = [] |
| 110 | url = f"{self.base_url}/orgs/{self.helpers.quote(query)}/repos?per_page=100&page=" + "{page}" |
| 111 | agen = self.api_page_iter(url, _json=False) |
| 112 | try: |
| 113 | async for r in agen: |
| 114 | if r is None: |
| 115 | break |
| 116 | status_code = getattr(r, "status_code", 0) |
| 117 | if status_code == 403: |
| 118 | self.warning("Github is rate-limiting us (HTTP status: 403)") |
| 119 | break |
| 120 | if status_code != 200: |
| 121 | break |
| 122 | try: |
| 123 | j = r.json() |
| 124 | except Exception as e: |
| 125 | self.warning(f"Failed to decode JSON for {r.url} (HTTP status: {status_code}): {e}") |
| 126 | break |
| 127 | if not j: |
| 128 | break |
| 129 | for item in j: |
| 130 | html_url = item.get("html_url", "") |
| 131 | repos.append(html_url) |
| 132 | finally: |
| 133 | await agen.aclose() |
| 134 | return repos |
| 135 | |
| 136 | async def query_org_members(self, query): |
| 137 | members = [] |
no test coverage detected