Added man-in-the-middle attack for proper HTTPS header checking.

.gitignore

@@ -7,3 +7,6 @@ __pycache__
 .cache
 build
 dist
+pip-wheel-metadata
+.ropeproject
+.python-version

proxybroker/api.py

@@ -59,7 +59,7 @@ def __init__(
         providers=None,
         verify_ssl=False,
         loop=None,
-        **kwargs
+        **kwargs,
     ):
         self._loop = loop or asyncio.get_event_loop()
         self._proxies = queue or asyncio.Queue(loop=self._loop)
@@ -133,7 +133,7 @@ async def find(
         strict=False,
         dnsbl=None,
         limit=0,
-        **kwargs
+        **kwargs,
     ):
         """Gather and check proxies from providers or from a passed data.
 
@@ -280,9 +280,9 @@ def serve(self, host='127.0.0.1', port=8888, limit=100, **kwargs):
             timeout=self._timeout,
             max_tries=kwargs.pop('max_tries', self._max_tries),
             loop=self._loop,
-            **kwargs
+            **kwargs,
         )
-        self._server.start()
+        asyncio.ensure_future(self._server.start())
 
         task = asyncio.ensure_future(self.find(limit=limit, **kwargs))
         self._all_tasks.append(task)
@@ -412,7 +412,7 @@ def stop(self):
         if self._server:
             self._server.stop()
             self._server = None
-        log.info('Stop!')
+        log.debug('Stop!')
 
     def _done(self):
         log.debug('called done')
@@ -421,7 +421,7 @@ def _done(self):
             if not task.done():
                 task.cancel()
         self._push_to_result(None)
-        log.info('Done! Total found proxies: %d' % len(self.unique_proxies))
+        log.debug('Done! Total found proxies: %d' % len(self.unique_proxies))
 
     def show_stats(self, verbose=False, **kwargs):
         """Show statistics on the found proxies.

proxybroker/cli.py

@@ -426,8 +426,7 @@ def cli(args=sys.argv[1:]):
             strict=ns.strict,
             dnsbl=ns.dnsbl,
         )
-        print('Server started at http://%s:%d' % (ns.host, ns.port))
-
+
     try:
         if tasks:
             loop.run_until_complete(asyncio.gather(*tasks, loop=loop))