(self, query)
| 35 | ) |
| 36 | |
| 37 | async def query(self, query): |
| 38 | results = set() |
| 39 | urls = self.config.get("search_urls", []) |
| 40 | urls = [url.replace("<query>", self.helpers.quote(query)) for url in urls] |
| 41 | async for url, response in self.helpers.request_batch(urls): |
| 42 | keyserver = self.helpers.urlparse(url).netloc |
| 43 | response = await self.helpers.request(url) |
| 44 | if response is not None: |
| 45 | for email in await self.helpers.re.extract_emails(response.text): |
| 46 | email = email.lower() |
| 47 | if email.endswith(query): |
| 48 | results.add((email, keyserver)) |
| 49 | return results |
no test coverage detected