release

Author: pygoov

README.md

@@ -1,9 +1,20 @@
 # Coin bot
-Bot for click on telegram
+Async bot for click on telegram bots @Dogecoin_click_bot and etc.
 
+The bot works simultaneously with many accounts, makes requests from different proxy servers received automatically.
 
 ## Required
 
 python 3.7 >=
 
-`pip install -r requirements.txt`
+`pip install -r requirements.txt`
+
+## Running
+
+1) Configurate your `config.json` file
+
+2) Run command
+
+```
+$ python -u .\main.py -c .\config.json
+```

main.py

@@ -67,16 +67,14 @@ async def main():
         for cfg in config_data['clients']
     ]
 
-    proxy_manager = ProxyManager()
+    proxy_manager = ProxyManager('https://api.telegram.org')
 
     while True:
         run_tasks = []
 
-        await proxy_manager.load_proxys()
-
         print('run init bots')
         for bot in bots:
-            proxy = await proxy_manager.get_proxy('https://api.telegram.org')
+            proxy = await proxy_manager.get_proxy()
             await bot.client_init(proxy)
             run_tasks.append(bot.run())
 

proxy.py

@@ -8,6 +8,9 @@
 from aiohttp_socks import ProxyType, ProxyConnector, ChainProxyConnector
 
 
+RE_PROXY = r'\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}:\d{2,6}'
+
+
 class ProxyObject:
     def __init__(self, ip, port):
         self.ip = ip
@@ -26,7 +29,7 @@ async def check_url(self, url):
         try:
             connector = ProxyConnector.from_url(self.get_str())
             async with aiohttp.ClientSession(connector=connector) as _sess:
-                response = await _sess.get(url, timeout=2)
+                response = await _sess.get(url, timeout=1)
                 if response.status == 200:
                     return True
         except Exception as e:
@@ -37,9 +40,19 @@ async def check_url(self, url):
 
 
 class ProxyManager:
-    def __init__(self):
-        self.biffer_proxys = []
-        self.proxys = []
+    def __init__(self,  test_url):
+        self.test_url = test_url
+        self.queue_proxys = asyncio.Queue()
+
+        loop = asyncio.get_event_loop()
+        loop.create_task(self.load_loop())
+
+    async def load_loop(self):
+        while True:
+            if self.queue_proxys.empty():
+                await self.load_proxys()
+
+            await asyncio.sleep(10)
 
     async def load_proxys(self):
         print("run load proxy")
@@ -60,25 +73,32 @@ async def load_proxys(self):
                 raise Exception(f'Failed request to "{url}" url')
 
             text = await response.text()
-            x = re.findall(r'\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}:\d{2,6}', text)
 
-        pxs = [x.split(':') for x in text.split('\n')]
-        self.biffer_proxys = [ProxyObject(x[0], x[1]) for x in pxs if len(x) == 2]
-        print(f'load {len(self.proxys)} proxys')
+        proxys = []
 
-    async def get_proxy(self, test_url):
-        print('getting proxy')
-        count_try = 0
-        while count_try < 10:
-            if len(self.proxys) == 0:
-                await self.load_proxys()
+        for line in re.findall(RE_PROXY, text):
+            sp = line.split(':')
+            if len(sp) != 2:
+                continue
+            proxy = ProxyObject(sp[0], sp[1])
+            proxys.append(proxy)
+
+        print(f'find {len(proxys)} proxys')
+
+        while len(proxys) > 0:
+            batch_proxys = proxys[:20]
+            proxys = proxys[20:]            
 
-            proxy = self.proxys.pop()
+            checked = await asyncio.gather(*[
+                proxy.check_url(self.test_url)
+                for proxy in batch_proxys
+            ])
 
-            if await proxy.check_url(test_url):
-                print(f"Proxy {proxy} find success")
-                return proxy
+            print(f'checked {len(checked)} proxys')
 
-            await asyncio.sleep(1)
+            for i, proxy in enumerate(batch_proxys):
+                if checked[i]:
+                    self.queue_proxys.put_nowait(proxy)
 
-        raise Exception("Max count trys getting proxy =(")
+    async def get_proxy(self):
+        return await self.queue_proxys.get()

requirements.txt

@@ -1,3 +1,4 @@
 telethon
 pysocks
-aiohttp
+aiohttp
+aiohttp_socks