(self)
| 48 | |
| 49 | @Slot() |
| 50 | def run(self): |
| 51 | try: |
| 52 | responses = [] |
| 53 | for item in self.cmds: |
| 54 | if self.is_stopped(): |
| 55 | break |
| 56 | try: |
| 57 | response = None |
| 58 | if item["cmd"] in self.plugin.allowed_cmds and self.plugin.has_cmd(item["cmd"]): |
| 59 | |
| 60 | # -------- Auth (user mode) -------- |
| 61 | if item["cmd"] == "tg_login_begin": |
| 62 | response = self.cmd_tg_login_begin(item) |
| 63 | elif item["cmd"] == "tg_login_complete": |
| 64 | response = self.cmd_tg_login_complete(item) |
| 65 | elif item["cmd"] == "tg_logout": |
| 66 | response = self.cmd_tg_logout(item) |
| 67 | |
| 68 | # -------- Info -------- |
| 69 | elif item["cmd"] == "tg_mode": |
| 70 | response = self.cmd_tg_mode(item) |
| 71 | elif item["cmd"] == "tg_me": |
| 72 | response = self.cmd_tg_me(item) |
| 73 | |
| 74 | # -------- Messaging -------- |
| 75 | elif item["cmd"] == "tg_send_message": |
| 76 | response = self.cmd_tg_send_message(item) |
| 77 | elif item["cmd"] == "tg_send_photo": |
| 78 | response = self.cmd_tg_send_photo(item) |
| 79 | elif item["cmd"] == "tg_send_document": |
| 80 | response = self.cmd_tg_send_document(item) |
| 81 | |
| 82 | # -------- Chats -------- |
| 83 | elif item["cmd"] == "tg_get_chat": |
| 84 | response = self.cmd_tg_get_chat(item) |
| 85 | |
| 86 | # -------- Updates / Files (bot) -------- |
| 87 | elif item["cmd"] == "tg_get_updates": |
| 88 | response = self.cmd_tg_get_updates(item) |
| 89 | elif item["cmd"] == "tg_download_file": |
| 90 | response = self.cmd_tg_download_file(item) |
| 91 | |
| 92 | # -------- Contacts / Dialogs / History (user) -------- |
| 93 | elif item["cmd"] == "tg_contacts_list": |
| 94 | response = self.cmd_tg_contacts_list(item) |
| 95 | elif item["cmd"] == "tg_dialogs_list": |
| 96 | response = self.cmd_tg_dialogs_list(item) |
| 97 | elif item["cmd"] == "tg_messages_get": |
| 98 | response = self.cmd_tg_messages_get(item) |
| 99 | |
| 100 | if response: |
| 101 | responses.append(response) |
| 102 | |
| 103 | except Exception as e: |
| 104 | responses.append(self.make_response(item, self.throw_error(e))) |
| 105 | |
| 106 | if responses: |
| 107 | self.reply_more(responses) |
no test coverage detected