From 15e143fcff39d64c5acc2d93f61c2f00f65c2ee0 Mon Sep 17 00:00:00 2001
From: jesopo
Date: Mon, 8 Jul 2019 11:43:09 +0100
Subject: implement utils.http.request_many as a tonado ioloop yield

---
 src/utils/http.py | 20 +++++++++++++++++++-
 1 file changed, 19 insertions(+), 1 deletion(-)

(limited to 'src/utils/http.py')

diff --git a/src/utils/http.py b/src/utils/http.py
index 2885ebee..d12a978b 100644
--- a/src/utils/http.py
+++ b/src/utils/http.py
@@ -1,7 +1,7 @@
 import ipaddress, re, signal, socket, traceback, typing
 import urllib.error, urllib.parse
 import json as _json
-import bs4, netifaces, requests
+import bs4, netifaces, requests, tornado.gen, tornado.httpclient, tornado.ioloop
 from src import utils
 
 REGEX_URL = re.compile("https?://[A-Z0-9{}]+".format(re.escape("-._~:/%?#[]@!$&'()*+,;=")), re.I)
@@ -109,6 +109,24 @@ def request(url: str, method: str="GET", get_params: dict={},
 
     return Response(response.status_code, data, response_headers)
 
+def request_many(urls: typing.List[str]) -> typing.Dict[str, Response]:
+    responses = {}
+
+    @tornado.gen.coroutine
+    def _request():
+        for url in urls:
+            client = tornado.httpclient.AsyncHTTPClient()
+            request = tornado.httpclient.HTTPRequest(url, method="GET",
+                connect_timeout=2, request_timeout=2)
+            response = yield client.fetch(request)
+
+            headers = utils.CaseInsensitiveDict(dict(response.headers))
+            data = response.body.decode("utf8")
+            responses[url] = Response(response.code, data, headers)
+
+    tornado.ioloop.IOLoop.current().run_sync(_request)
+    return responses
+
 def strip_html(s: str) -> str:
     return bs4.BeautifulSoup(s, "lxml").get_text()
 
-- 
cgit v1.3.1-10-gc9f91