Initial commit

config.py

@@ -0,0 +1,15 @@
+token = ""  # group token
+login = ""  # user login
+password = ""  # user password
+two_factor = True  #
+group_id = 0  # group id
+log_file = 'file.log'  # file for logs
+exceed_file = "posts.pickle"  # file for exceeded posts saving
+
+# messages
+write_message = "Напишите сообщение чтобы мы могли сделать пост"
+post_successful = f"Ваш пост уже в нашей группе!"
+post_queue = f"Вы в очереди на пост, перед вами: {0}"
+group_join = f"Напишите сообщение чтобы сделать анонимный пост"
+group_leave = f"Возвращайтесь!"
+# messages

main.py

@@ -0,0 +1,142 @@
+import os
+import pickle
+import random
+import logging
+from collections import deque
+from time import sleep
+
+from vk_api import VkApi
+from vk_api.bot_longpoll import VkBotEventType
+from vk_api.exceptions import VkApiError
+from vk_api.longpoll import VkLongPoll, VkEventType
+from threading import Thread, Lock
+import config
+
+
+class Bot:
+    def __init__(self):
+        self.logger = logging.getLogger("logger")
+        self.logger.setLevel(logging.INFO)
+
+        fh = logging.FileHandler(config.log_file)
+        formatter = logging.Formatter('%(asctime)s | %(name)s : %(levelname)s - %(message)s')
+        fh.setFormatter(formatter)
+        self.logger.addHandler(fh)
+
+        self.vk = VkApi(token=config.token)
+        self.longpoll = VkLongPoll(self.vk)
+        self.vk = self.vk.get_api()
+
+        if not config.two_factor:
+            self.user_vk = VkApi(login=config.login, password=config.password)
+        else:
+            def two_factor(): return input("Write your code: "), True
+            self.user_vk = VkApi(config.login, config.password, auth_handler=two_factor)
+
+        self.user_vk.auth()
+        self.user_vk = self.user_vk.get_api()
+
+        self.posts_to_do = deque()
+        if os.path.exists(config.exceed_file):
+            self.logger.info("Uploading from file")
+            with open(config.exceed_file, 'rb') as file:
+                self.posts_to_do = pickle.load(file)
+
+        self.exceed_thread = Thread(target=self.post_exceed)
+
+    def start(self):
+        self.logger.info("Starting the bot")
+        self.exceed_thread.start()
+        self.listen()
+
+    def listen(self):
+        try:
+            for event in self.longpoll.listen():
+                if event.type == VkEventType.MESSAGE_NEW and not event.from_me and event.from_user:
+                    post_message = self.new_post(event)
+                    self.send_message(event.peer_id, post_message)
+
+                elif event.type == VkBotEventType.GROUP_JOIN:
+                    self.logger.info(f"New user {event.user_id}")
+                    self.send_message(event.peer_id, config.group_join)
+
+                elif event.type == VkBotEventType.GROUP_LEAVE:
+                    self.logger.info(f"User {event.user_id} left")
+                    self.send_message(event.peer_id, config.group_leave)
+
+        except Exception as exc:
+            self.logger.error(exc)
+
+    def send_message(self, where, message, attachments=None):
+        self.logger.info(f"Message '{message}' sent to {where} with {attachments}")
+        self.vk.messages.send(peer_id=where, message=message,
+                              attachments=attachments, random_id=random.randint(0, 100000))
+
+    def post_exceed(self):
+        lock = Lock()
+
+        while True:
+            try:
+                lock.acquire()
+                post = self.posts_to_do.pop()
+                self.post(post)
+                self.send_message(post.user_id, config.post_successful)
+                self.save()
+
+            except IndexError:
+                pass
+
+            except VkApiError:
+                pass
+
+            finally:
+                lock.release()
+
+    def post(self, event):
+        attachments = []
+
+        for i in range(0, len(event.attachments), 2):
+            attachment_type = event.attachments[f'attach{i + 1}_type']
+            attachment = event.attachments[f'attach{i + 1}']
+            attachments.append(f"{attachment_type}{attachment}")
+
+        post_id = self.user_vk.wall.post(message=event.text, attachments=attachments, owner_id=config.group_id)
+        self.logger.info(f"Post done {post_id['post_id']}")
+
+    def new_post(self, event):
+        try:
+            self.post(event)
+            return config.post_successful
+
+        except VkApiError as exc:
+            if exc.code == 100:
+                return config.write_message
+
+            else:
+                with Lock():
+                    self.posts_to_do.append(event)
+                return config.post_queue.format(len(self.posts_to_do))
+
+    def save(self):
+        with open(config.exceed_file, 'wb') as file:
+            pickle.dump(self.posts_to_do, file)
+        self.logger.info("Posts are saved!")
+
+
+if __name__ == '__main__':
+    bot = Bot()
+    print("\033[38;2;{};{};{}m{} \033[38;2;255;255;255m".format(0, 250, 0, """
+ _                     _    _                                       _       
+| |                   | |  | |                                     | |      
+| | ___ __  _   _  ___| | _| | ___  ___ _   _  __ _  __ _ _ __   __| | __ _ 
+| |/ / '_ \| | | |/ __| |/ / |/ _ \/ __| | | |/ _` |/ _` | '_ \ / _` |/ _` |
+|   <| | | | |_| | (__|   <| |  __/\__ \ |_| | (_| | (_| | | | | (_| | (_| |
+|_|\_\_| |_|\__,_|\___|_|\_\_|\___||___/\__,_|\__, |\__,_|_| |_|\__,_|\__,_|
+                                               __/ |                        
+                                              |___/        
+    https://github.com/knucklesuganda   
+    https://github.com/knucklesuganda
+    https://github.com/knucklesuganda
+"""))
+    bot.start()
+    print("Goodbye")

requirements.txt

@@ -0,0 +1 @@
+vk_api