daemons/poll.py

@@ -26,10 +26,10 @@ class Daemon(base.Daemon):
                             print(f'process for {project_name} {bot_name} is alive')
                             continue
                         new_process = multiprocessing.Process(target=self.start_polling, args=[bot_info['secrets']['telegram_token'], bot_info['queue']])
-                        print(f'starting process for {project_name} {bot_name}')
+                        print(f'starting process for {project_name} {bot_name} is alive')
                         new_process.start()
                         self.telegram_pollers[project_name][bot_name] = new_process
-                        print(f'started process for {project_name} {bot_name}')
+                        print(f'started process for {project_name} {bot_name} is alive')
                     else:
                         if process is None or not process.is_alive:
                             print(f'process for {project_name} {bot_name} is not alive')

local_platform.json

@@ -1,19 +0,0 @@
-{
-    "configs": {
-        "bots": {
-            "pizda-bot": {
-                "telegram-bot": {
-                    "type": "telegram",
-                    "poll_enabled": true,
-                    "mailbox_enabled": false,
-                    "queue": "pizda_bot_worker",
-                    "secrets": {
-                        "telegram_token": "5652624181:AAFFVjcHJjea7wlW6MRaxjFY_eu2XWPwOns"
-                    }
-                }
-            }
-        }
-    },
-    "experiments": {},
-    "platform_staff": {}
-}

main.py

@@ -1,17 +1,15 @@
 import sys
 
 
-# arg = sys.argv[-1]
+arg = sys.argv[-1]
-arg = 'poll'
 
-if __name__ == '__main__':
+if arg == "poll":
-    if arg == "poll":
+    print("poll is starting")
-        print("poll is starting")
+    from daemons.poll import Daemon
-        from daemons.poll import Daemon
+elif arg == 'mailbox':
-    elif arg == 'mailbox':
+    print("mailbox is starting")
-        print("mailbox is starting")
+    from daemons.mailbox import Daemon
-        from daemons.mailbox import Daemon
+else:
-    else:
+    raise ValueError(f"Unknown param {arg}")
-        raise ValueError(f"Unknown param {arg}")
 
-    Daemon().execute()
+Daemon().execute()

utils/platform.py

@@ -88,6 +88,6 @@ class PlatformClient:
 
 platform_client = PlatformClient(
     'Botalka',
-    os.getenv('STAGE', 'local'),
+    os.getenv('STAGE'),
     need_poll=True,
 )