(self, query)
| 162 | return members |
| 163 | |
| 164 | async def query_user_repos(self, query): |
| 165 | repos = [] |
| 166 | url = f"{self.base_url}/users/{self.helpers.quote(query)}/repos?per_page=100&page=" + "{page}" |
| 167 | agen = self.api_page_iter(url, _json=False) |
| 168 | try: |
| 169 | async for r in agen: |
| 170 | if r is None: |
| 171 | break |
| 172 | status_code = getattr(r, "status_code", 0) |
| 173 | if status_code == 403: |
| 174 | self.warning("Github is rate-limiting us (HTTP status: 403)") |
| 175 | break |
| 176 | if status_code != 200: |
| 177 | break |
| 178 | try: |
| 179 | j = r.json() |
| 180 | except Exception as e: |
| 181 | self.warning(f"Failed to decode JSON for {r.url} (HTTP status: {status_code}): {e}") |
| 182 | break |
| 183 | if not j: |
| 184 | break |
| 185 | for item in j: |
| 186 | html_url = item.get("html_url", "") |
| 187 | repos.append(html_url) |
| 188 | finally: |
| 189 | await agen.aclose() |
| 190 | return repos |
| 191 | |
| 192 | async def validate_org(self, org): |
| 193 | is_org = False |
no test coverage detected