море спася геноцид

init gauges onceinit gauges onceinit gauges onceinit gauges onceinit gauges onceinit gauges onceinit gauges onceinit gauges onceinit gauges onceinit gauges onceinit gauges onceinit gauges onceinit gauges onceinit gauges onceinit gauges onceinit gauges onceinit gauges onceinit gauges once

.drone.yml

@@ -7,6 +7,10 @@ platform:
   os: linux
   arch: amd64
 
+node:
+  gay: nigger
+
+
 #clone:
   # убрано так как сейчас не тестим ничего предварительно а сразу тянем в директорию 
   #disable: true
@@ -15,11 +19,23 @@ steps:
 - name: test it first
   commands:
   - /usr/bin/python3 -m py_compile bot.py
+  - /usr/bin/python3 pipisa_functions/pipisa_time.py
 - name: pull into the folduh
   commands:
   - cd /usr/share/$DRONE_REPO_NAME
-  - git pull
-  - chown -R jack:jack .
+  - git pull 
+  #- chown -R jack:jack .
+  when:
+    branch:
+    - main
+  environment:
+    ARANGO_PASSWORD:
+      from_secret: arango-pwd
+    ARANGO_USERNAME:
+      from_secret: arango-usr
 - name: restart systemd unit
   commands:
   - systemctl restart jack_bot
+  when:
+    branch:
+    - main

.gitignore

@@ -1,4 +1,8 @@
 __pycache__
 testDB.py
 TIME.py
-.vscode
+.vscode
+tests
+qeqeqe
+env
+handlers/userdata.json

README.md

@@ -0,0 +1,13 @@
+Пробуем проверять что-либо. 
+
+```mermaid
+journey
+  title Пиписа
+  section Наш Чат
+    Оче больше пипис: 5: ГЕГЕМОН
+    Обычно большепенис: 3: Догоняющие
+    Скромный дик: 1: Отставшие
+  section Не наш чат
+    Не запустил: -1: Отставшие
+    Не крутил: 1: Отставшие
+```

bot.py

@@ -1,161 +1,49 @@
-from cgitb import text
-import datetime
 import logging
-from random import randint
-from sqlalchemy import create_engine, MetaData, Table, Integer, String, \
-    Column, DateTime, ForeignKey, Numeric
-from sqlalchemy.ext.declarative import declarative_base
-from sqlalchemy.orm import sessionmaker   
-from aiogram import Bot, Dispatcher, executor, types
-from aiogram.types import ReplyKeyboardRemove, ReplyKeyboardMarkup, KeyboardButton
-from sqdb import user
+from aiogram import executor, Bot, Dispatcher
+from create_bot import dp
+import handlers
+import json, logging
+from global_conf import CONFIG
+from prometheus_client import start_http_server
 
 
+def remake_field_generator(d, field='text'):
+    if isinstance(d, list):
+        for k2 in d:
+            for id_val in remake_field_generator(k2):
+                yield id_val
+    elif isinstance(d, dict):
+        for k, v in d.items():
+            if k == field: 
+                d[k] = '<blank!>'
+                yield v
+            elif isinstance(v, list):
+                for k2 in v:
+                    for id_val in remake_field_generator(k2):
+                        yield id_val
+            elif isinstance(v, dict):
+                for id_val in remake_field_generator(v):
+                    yield id_val
 
-
-API_TOKEN = '5724991559:AAEuLvpLsgP6LHRGMSyFtQLlR5qPQUO4b_w'
+def filter_grammar_messages(record):
+    if record.args and (not None in record.args):
+        j = json.loads(record.args[2])
+        for _ in remake_field_generator(j):
+            pass
+        record.args = (record.args[0], record.args[1], json.dumps(j))
+    return True
 
 logging.basicConfig(level=logging.DEBUG)
+logging.getLogger("aiogram").addFilter(filter_grammar_messages)
 
-bot = Bot(token=API_TOKEN, parse_mode="HTML")
-dp = Dispatcher(bot)
-
-
-
-@dp.message_handler(commands=["time"])
-async def send_time(message: types.Message):
-    new_year = datetime.datetime(2022, 12, 31) #дата нового года
-    ct = datetime.datetime.now() #датавремя
-    cd = datetime.datetime.now().strftime("%d/%m/%Y") #дата (д,м,г)
-    ct1 = ct+datetime.timedelta(hours=15) # +14 часов от сервера
-    ct2 = ct1.strftime('%H:%M') # форматирует датувремя просто во время(ч,м)
-    raznitsa = (new_year - ct).days #отнимает от нг текущее время и получаем разницу в днях
-
-    days = ['день', 'дня', 'дней']
-    if raznitsa % 10 == 1 and raznitsa % 100 != 11:
-        p = 0
-    elif 2 <= raznitsa % 10 <= 4 and (raznitsa % 100 < 10 or raznitsa % 100 >= 20):
-        p = 1
-    else:
-        p = 2
-    num=(str(raznitsa) + ' ' + days[p])
-
-    await message.reply(f'Сегодня {cd} \nВремя: {ct2} \nДо Нового Года осталось {num}')
-
-    #####______________________ПИПИСА БОТ БУДЕТ ЗДЕСЬ__________________________________
-
-
-
-
-
-@dp.message_handler(commands=["dick"])
-async def ident(message: types.Message):
-# рандомайзер
-    numb = randint(-7,10)
-    global size_change, dick_plus, dick_minus
-    dick_plus = f'<b>вырос</b> 🚀 на <b>{numb}</b> см!'
-    dick_minus = f'<b>уменьшился</b> на <b>{abs(numb)}</b> см!😔'
-    if numb > 0:
-         size_change = dick_plus
-    else: size_change = dick_minus
-####
-
-
-
-# работа с таблицей
-    engine = create_engine('postgresql+psycopg2://postgres:postgres@postgres.vdk2ch.ru:5432/jack_bot', echo=True)
-    Session = sessionmaker(bind=engine)
-    session = Session()
-    Base = declarative_base()
-    if session.query(user).filter(user.user_id == message.from_user.id).first():
-        b = session.query(user).filter(user.user_id == message.from_user.id).first()
-        now_time = datetime.datetime.now()
-        last_time = b.datetimes
-        diff = now_time.day - last_time.day
-        
-       
-        if diff <= 0:
-            await bot.send_message(message.chat.id, f'@{message.from_user.username},🚫 вы уже крутили пипису, ее размер <b>{b.dick_size}</b> см! ')
-            session.close_all()
-            print(diff)
-            print(type(diff))
-        else:
-            a = session.query(user).filter(user.user_id == message.from_user.id).first() # запрос на поиск в таблице
-            a.dick_size = (a.dick_size + numb)
-            a.datetimes = datetime.datetime.now()
-            session.commit() #обновляет запись
-            await bot.send_message(message.chat.id, f'@{message.from_user.username}, ваш писюн {size_change}\n\
-Теперь он равен <b>{a.dick_size}</b> см! ')
-            session.close_all()
-
-    else: 
-        int_table = user(user_id = message.from_user.id, user_fullname = message.from_user.full_name, dick_size = numb, datetimes = datetime.datetime.now()) 
-        session.add(int_table)
-        session.commit() 
-        await bot.send_message(message.chat.id, f'@{message.from_user.username}, ваш писюн {size_change}\n\
-Теперь он равен <b>{int_table.dick_size}</b> см!')
-        session.close_all()
-   
-
-    # int_table = user(user_id = message.from_user.id, user_fullname = message.from_user.full_name, dick_size = numb) #импортирую юзер из sqdb
-    # session.add(int_table)
-    # session.commit()
-    #обновление
-    # dick_update = session.query(user).filter_by(user.user_id = message.from_user.id).update({'dick_size': user.dick_size + numb})
-    # session.add(dick_update)
-    # session.commit()
-    #last_size = session.query(user).filter_by(user_id = message.from_user.id).select_from(dick_size = 'dick_size: ').one()
-    
-
-
-    #####______________________ПИПИСА БОТ БУДЕТ ЗДЕСЬ__________________________________
-    
-@dp.message_handler(commands=["topdick"])
-async def send_time(message: types.Message):
-    engine = create_engine('postgresql+psycopg2://postgres:postgres@postgres.vdk2ch.ru:5432/jack_bot', echo=True)
-    Session = sessionmaker(bind=engine)
-    session = Session()
-    Base = declarative_base()
-    
-    top = session.query(user.user_fullname, user.dick_size).order_by(user.dick_size.desc()).limit(10).all()
-    red = '\n'.join(map(str, top))
-
-    await bot.send_message(message.chat.id, f'{red}')
-# {top[0]}\n\
-# {top[1]}\n\
-# {top[2]}\n\
-# {top[3]}\n\
-# {top[4]}\n\
-# {top[5]}\n\
-# {top[6]}\n\
-# {top[7]}\n\
-# {top[8]}\n\
-# {top[9]}ff')
-    session.close_all()
-
-
-@dp.message_handler(commands=['start'])
-async def start_func(message: types.Message):
-    # user_id = message.from_user.id
-    # user_full_name = message.from_user.full_name
-    # logging.INFO(f'{user_id=} {user_full_name=}', {time.asctime()})
-    await message.reply('похуй')
-
-@dp.message_handler(commands=['photo'])
-async def send_image(message: types.Message):
-    await bot.send_photo(message.chat.id, photo='https://memepedia.ru/wp-content/uploads/2018/08/ya-pidoras.jpg', reply_to_message_id=message.message_id)
-
-@dp.message_handler(content_types=types.ContentTypes.TEXT)
-async def send_faggot(message: types.Message):
-    print(message.text) 
-    if message.text == 'хто я':
-     await bot.send_photo(message.chat.id, photo='https://www.meme-arsenal.com/memes/ecebd2339c7eab40e09874bd86a38a09.jpg')
-
-#хуй
+# pipisa.register_handlers_pipisa(dp)
+# time_new_year.register_handlers_time(dp)
+# sendalarm.register_handlers_test(dp)
+# start_help.register_handlers_StartHelp(dp)
 
 if __name__ == '__main__':
+    #print(CONFIG)
+    start_http_server(1337)
+    logging.info('Бот в строю.')
     executor.start_polling(dp, skip_updates=True)
-
-
-
-
+    logging.info('Всем пока.')

config.yaml

@@ -0,0 +1,19 @@
+---
+databaso:
+  host:                     'http://arango.guaranteedstruggle.host:8529'
+  #user:                      root
+  #pass:                      stolendick527
+  base:                      pipisa
+  collection:                dicks
+  posts_removal_collection:  posts_removal
+
+telegram_token: 6991523312:AAFpxPlWHfnNq2dVXM_v1GuHcrbNgWdSWBM
+telegram_admins_ids:
+- 317051301 # hogweed1
+- 226765676 # blackjack
+- 94830892  # viktorRMI
+- 132002803
+
+openai:
+  token:   5947963644:AAF_GKgMmU5ovqMpc1KXIpcf4aN0JMyKPqc
+  api_key: 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  ## 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

create_bot.py

@@ -0,0 +1,6 @@
+from aiogram import Bot, Dispatcher
+from global_conf import CONFIG
+
+
+bot = Bot(token=CONFIG['telegram_token'], parse_mode="HTML")
+dp  = Dispatcher(bot)

db_logic/collections.py

@@ -0,0 +1,40 @@
+from global_conf import CONFIG
+#### https://docs.python-arango.com/en/main/
+from arango import ArangoClient
+import logging
+import os 
+
+
+def get_dicks_collection():
+    try:
+        arango_client = ArangoClient(hosts=CONFIG['databaso']['host'] )
+        pipisa_db     = arango_client.db(
+            CONFIG['databaso']['base'],
+            username=os.environ['ARANGO_USR'],
+            password=os.environ['ARANGO_PWD'],
+            #username=CONFIG['databaso']['user'],
+            #password=CONFIG['databaso']['pass']
+        )
+        dicks_collection = pipisa_db.collection(CONFIG['databaso']['collection'])
+
+        return dicks_collection
+    except Exception as e:
+        logging.error('ошибка DB при взятии коллекции пипис')
+        logging.error(e)
+
+def get_posts_removal_collection():
+    try:
+        arango_client = ArangoClient(hosts=CONFIG['databaso']['host'])
+        pipisa_db     = arango_client.db(
+            CONFIG['databaso']['base'],
+            username=os.environ['ARANGO_USR'],
+            password=os.environ['ARANGO_PWD'],
+            #username=CONFIG['databaso']['user'],
+            #password=CONFIG['databaso']['pass']
+        )
+        posts_removal_collection = pipisa_db.collection(CONFIG['databaso']['posts_removal_collection'])
+
+        return posts_removal_collection
+    except Exception as e:
+        logging.error('ошибка DB при взятии коллекции постов-на-удаление')
+        logging.error(e)

db_logic/postcleaner.py

@@ -0,0 +1,70 @@
+from db_logic import collections
+import datetime, logging
+
+
+def append_post_to_cleaning_sequence(message, type=None):
+    try:
+        novenkiy = {
+            'msg_id':    message.message_id,
+            'chat_id':   message.chat.id,
+            'type':      type,
+            'datetimes': datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")
+        }
+        metadata = collections.get_posts_removal_collection().insert(novenkiy, overwrite_mode='update')
+
+        logging.debug('Успешно добавлен пост на удаление')
+    except Exception as e2:
+        logging.error('ошибка DB :: добавление нового поста на удаление')
+        logging.error(e2)
+
+def get_posts_to_be_removed(chat_id, type=None, max_id=None):
+    # собираем
+    try:
+        #posts = [p for p in collections.get_posts_removal_collection().all( ) ]
+         
+        if type:
+            posts = [p for p in collections.get_posts_removal_collection().find({'chat_id': chat_id, 'type': type}, skip=0, limit=1100) ]
+        else:
+            posts = [p for p in collections.get_posts_removal_collection().find({'chat_id': chat_id}, skip=0, limit=1100) ]
+
+        posts_ret = [ p for p in posts ]
+        # # for p in posts:
+        # #     last_time    = datetime.datetime.strptime(p['datetimes'], '%Y-%m-%d %H:%M:%S')
+        # #     timediff = (datetime.datetime.now() - last_time).total_seconds()
+
+        # #     if timediff > 60:
+        # #         posts_ret.append(p)
+ 
+        if max_id:
+            posts_ret = [ p for p in posts_ret if p['msg_id'] != max_id]
+        else:
+            posts_ret = [ p for p in posts_ret if p['msg_id'] != max([pp['msg_id'] for pp in posts_ret])]
+
+        #### TODO удалять все предыдущие без учёта времени
+
+        return posts_ret
+    except Exception as e:
+        logging.error('ошибка DB :: получение постов на удаление')
+        logging.error(e)
+
+def del_post(msg_id, chat_id):
+    # удаляем из базы
+    try:
+        candidate_cursor = collections.get_posts_removal_collection().find(
+            {
+                'msg_id':  msg_id,
+                'chat_id': chat_id,
+            },
+            skip  = 0,
+            limit = 1488
+        )
+        if candidate_cursor.count() > 0:
+            pp = candidate_cursor.pop()
+        else:
+            pp = None
+
+        collections.get_posts_removal_collection().delete(pp)
+ 
+    except Exception as e:
+        logging.error('ошибка DB :: удаление поста на удаление')
+        logging.error(e)

db_logic/tops.py

@@ -0,0 +1,63 @@
+from global_conf import CONFIG
+from db_logic import collections
+import logging
+
+
+def get_tops(top_ = False, glob_ = False, chat_id = None):
+    if top_:
+        try:
+            dicks = [d for d in collections.get_dicks_collection().find({'chat_id': chat_id}, skip=0, limit=1100)]
+        except Exception as e:
+            logging.error('ошибка DB в /topdick')
+            logging.error(e)
+    elif glob_:
+        try:
+            dicks = [d for d in collections.get_dicks_collection().all( ) if d['user_id'] != d['chat_id']]
+        except Exception as e:
+            logging.error('ошибка DB в /globaldick')
+            logging.error(e)
+    else:
+        logging.error('вызывают хз что!')
+
+    top_dicks = sorted(dicks, key=lambda dick: dick['dick_size'], reverse=True)
+    top_dicks = top_dicks[:(min(len(top_dicks), 10))]
+
+    dickos = ''
+    emo    = ['🏆','🚀','🍆','🍌','🐍','🐎','🌭','🌶','👌','💩']
+
+    if len(top_dicks) > 0:
+        for i in range(len(top_dicks)):
+            dickos += f'     {emo[i]} {i+1}. {top_dicks[i]["user_fullname"]}: {top_dicks[i]["dick_size"]}см\n'
+            i += 1
+
+    return dickos
+
+def get_antitops(top_ = False, glob_ = False, chat_id = None):
+    dicks = []
+    if top_:
+        try:
+            dicks = [d for d in collections.get_dicks_collection().find({'chat_id': chat_id}, skip=0, limit=1100)]
+        except Exception as e:
+            logging.error('ошибка DB в /topdick')
+            logging.error(e)
+    elif glob_:
+        try:
+            dicks = [d for d in collections.get_dicks_collection().all() if d['user_id'] != d['chat_id']]
+        except Exception as e:
+            logging.error('ошибка DB в /globaldick')
+            logging.error(e)
+    else:
+        logging.error('вызывают хз что!')
+
+    antitop_dicks = sorted(dicks, key=lambda dick: dick['dick_size'], reverse=False)
+    antitop_dicks = antitop_dicks[:( min(len(antitop_dicks), 10) )] 
+
+    dickos = ''
+    emo    = ['💩', '😞', '🤕', '😣', '🙁', '😐', '😑', '😶', '😒', '😕']
+
+    if len(antitop_dicks) > 0:
+        for i in range(len(antitop_dicks)): 
+            dickos += f'     {emo[i]} {i+1}. {antitop_dicks[i]["user_fullname"]}: {antitop_dicks[i]["dick_size"]}см\n'
+            i += 1
+
+    return dickos

db_logic/user_stuff.py

@@ -0,0 +1,85 @@
+from db_logic import collections
+from handlers.metrics import metric_wrap
+import datetime, logging
+
+
+def store_new_user(message, result ):
+    try:
+        novenkiy = {
+            'user_id':       message.from_user.id,
+            'user_fullname': message.from_user.full_name,
+            'dick_size':     abs(result),
+            'datetimes':     datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S"),
+            'attempts':      1,
+            'chat_id':       message.chat.id
+        }
+        metadata = collections.get_dicks_collection().insert(novenkiy, overwrite_mode='update')
+
+        metric_wrap(message.chat.id, message.from_user.full_name, abs(result), 1)
+        logging.debug(f'Успешно добавлен нового пользователь @{message.from_user.username}')
+    except Exception as e2:
+        logging.error(f'ошибка DB в /dick :: добавление нового пользователя @{message.from_user.username}')
+        logging.error(e2)
+
+def update_attempts(message, user ):
+    try:
+        metadata = collections.get_dicks_collection().insert(
+            {
+                '_key':          user['_key'], ### этот нужен чтобы апдейт прилетал тому же юзеру
+                'user_id':       user['user_id'] ,
+                'user_fullname': message.from_user.full_name,
+                'dick_size':     user['dick_size'] ,
+                'datetimes':     user['datetimes'] ,
+                'attempts':      user['attempts'] + 1,
+                'chat_id':       message.chat.id
+            },
+            overwrite_mode='update'
+        )
+
+        metric_wrap(message.chat.id, message.from_user.full_name, user['dick_size'], user['attempts'] + 1)
+        logging.debug(f'Успешно апдейтнули попытку крутить пипису @{message.from_user.username}')
+    except Exception as e2:
+        logging.error(f'ошибка DB в /dick :: обновление попытки крутить пипису @{message.from_user.username}')
+        logging.error(e2)
+
+def update_dick_size(message, user, updatedDick ):
+    try:
+        metadata = collections.get_dicks_collection().insert(
+            {
+                '_key':          user['_key'], ### этот нужен чтобы апдейт прилетал тому же юзеру
+                'user_id':       user['user_id'],
+                'user_fullname': message.from_user.full_name,
+                'dick_size':     updatedDick,
+                'datetimes':     datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S"),
+                'attempts':      user['attempts'] + 1,
+                'chat_id':       message.chat.id
+            },
+            overwrite_mode='update'
+        )
+
+        metric_wrap(message.chat.id, message.from_user.full_name, updatedDick, user['attempts'] + 1)
+        logging.info(f'Успешно апдейтнули пипису @{message.from_user.username}')
+    except Exception as e2:
+        logging.error(f'ошибка DB в /dick :: обновление пиписы @{message.from_user.username}')
+        logging.error(e2)
+
+def get_user(message):
+    try:
+        #### Чекнуть есть ли юзер в базе
+        candidate_cursor = collections.get_dicks_collection().find(
+            {
+                'user_id': message.from_user.id,
+                'chat_id': message.chat.id
+            },
+            skip  = 0,
+            limit = 1488
+        )
+        if candidate_cursor.count() > 0:
+            user = candidate_cursor.pop()
+        else:
+            user = None
+
+        return user
+    except Exception as e:
+        logging.error('ошибка DB в /dick :: поиск юзера')
+        logging.error(e)

dicktxt/ForReadDict.py

@@ -0,0 +1,11 @@
+import random
+
+
+def RandomDick():
+# Забирает рандомный синоним к слову хуй из dick_sinonims.txt
+# у линуха и винды не забывай про разные \/
+# кёгда указываешь путь
+    with open('dicktxt/dick_sinonims.txt', 'r', encoding='utf-8') as file:
+        words = file.readlines()
+ 
+    return random.choice(words).strip()

dicktxt/WordsChange.py

@@ -0,0 +1,20 @@
+import yaml
+import random
+
+
+def ChangeWord(result): #збiрає будь-якое слiво для змєнєння розмiра пiпiси
+        with open("dicktxt/dick_changes.yaml", 'r', encoding='utf-8') as f:
+            words = yaml.load(f, Loader=yaml.Loader)
+
+        dick_inc     = [ f'<b>{w}</b>' for w in words['increment']  ]
+        dick_static  = [ f'<b>{w}</b>' for w in words['nothing']    ]
+        dick_decr    = [ f'<b>{w}</b>' for w in words['decrement']  ]
+
+        if result > 0:
+            size_change  = random.choice(dick_inc)    + '🚀'
+        elif result == 0:
+            size_change  = random.choice(dick_static) + '🤨' 
+        else: 
+            size_change  = random.choice(dick_decr)   + '✂'
+
+        return size_change

dicktxt/__init__.py

@@ -0,0 +1,2 @@
+from . import ForReadDict
+

dicktxt/dick_changes.yaml

@@ -0,0 +1,30 @@
+---
+increment:
+- вырос
+- подрос
+- привстал
+- увеличился
+- преисполнился
+- приподнялся
+- изменил размер
+- облагородился
+- чрезвычайно преуспел
+decrement:
+- неудачно потусил на сходке
+- уменьшился
+- откусила злая гадюка
+- продали евреи, он стал дешевле
+- схуднул
+- отрицательно вырос
+- словил низкие вибрации
+- повредился после простуды
+- стал жертвой репрессий
+- был подло использован
+nothing:
+- продвинулся
+- наноуменьшился
+- познал стабильность
+- зафиксировал прибыль
+- подумал о судьбах Китая
+- прогулялся по лесу
+- самоутвердился

dicktxt/dick_sinonims.txt

@@ -0,0 +1,96 @@
+кожаный бабах
+пистон
+дуршлаг
+елдак
+шлямбур
+шмайсер
+хохотунчик
+головастик
+пистон
+мундштук
+мухомор
+головач
+красненький
+чупа-чупс
+щекотунчик
+питательный
+тюбик
+джойстик
+хоббит
+крючок
+ласкун
+красавец
+хозяин
+хрящ
+чудильник
+царь пижамы
+целколом
+щуп
+эклер
+долбильник
+народник
+духопер
+ежик малиновый
+жрец любви
+жизненный конус
+злой одноглазый пиратик
+главтрах
+веселый парнишка
+вставень висюлек
+волосатый чикатило
+агрессор
+анакондаз
+антихрист
+Анютин глазок
+бензонасос
+блудень
+бог плодородия
+божий леденец
+волосатый змiй
+витамин "Х"
+вспотевший объектив
+гендерный габитус
+двадцать первый палец
+калдыбобер
+боброчес
+кукурузик
+красноголовый воин
+красный богатырь
+любовный мускул
+леденец
+обелиск
+окурок
+органайзер
+отбойный
+молоток
+посох королей
+пламенный алмаз мудрости
+монофалический потенциометр
+розовый кадилак
+сексофон
+трахальник
+торчильник
+факало
+кочанчик
+писюн
+губашлеп
+потенциальный кредитор
+кок
+чилим
+пажилой кабан
+малой
+начальник унитаза
+бесперебойник
+корнишон
+банановый смузи
+кизляк
+проныра
+пенис детров
+бенис
+кокошник
+членикс
+маленький жиголо
+венерический суккуб
+боец невидимого фронта
+сморчок
+джечник

global_conf.py

@@ -0,0 +1,11 @@
+import yaml
+
+
+with open("config.yaml", 'r') as f:
+    CONFIG = yaml.load(f, Loader=yaml.Loader)
+
+METRICS_INITIALIZED = False
+
+pipisa_length_metric     = None
+user_attempt_metric      = None
+user_last_attempt_metric = None

handlers/__init__.py

@@ -0,0 +1,4 @@
+from handlers import pipisa
+from handlers import start_help
+from handlers import time_new_year
+

handlers/davinci.py

@@ -0,0 +1,57 @@
+from openai import AsyncOpenAI
+from aiogram import types
+from create_bot import dp, bot
+import logging
+from global_conf import CONFIG
+
+
+admins = CONFIG['telegram_admins_ids']
+ban_comands = ['/dick','/topdick']
+
+# Image_promt =['тупица сгенерируй','тупица сгенерируй картинку',\
+#                                          'тупица отправь картинку', 'тупица отправь картинку']
+client = AsyncOpenAI(api_key="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")
+
+# @dp.message_handler(commands=['image'])
+# async def send_image(message: types.Message):
+#     if message.from_user.id in admins and message.chat.type == 'private':
+#         try:
+#             description = message.text.replace('/image', '').strip()
+            
+#             if not description:
+#                 await message.reply('Ты даун, описание запроса напиши после пробела')
+#                 return
+#         except Exception as e:
+#             logging.error(f'Error in send_image: {e}')
+#         try:
+
+#             response = openai.Image.create(
+#             prompt=message.text,
+#             n=1,
+#             size="1024x1024",
+#             response_format="url",
+            
+#         )
+#             image_url = response['data'][0]['url']
+#             await message.answer('Генерирую изображение...')
+#             await message.reply_photo(image_url)
+#         except Exception as e:
+#             await message.reply('у меня не получилось')
+
+async def gpt_text(req):
+    completion = await client.chat.completions.create(
+        messages=[
+            {
+                "role": "user",
+                "content": req,
+            }
+        ],
+        model="gpt-4",
+    )
+    return completion
+
+@dp.message_handler()
+async def send(message: types.Message):
+    if message.from_user.id in admins and message.chat.type == 'private':
+        response = await gpt_text(message.text)
+        await message.answer(response.choices[0].message.content)

handlers/metrics.py

@@ -0,0 +1,30 @@
+import json
+import time
+from prometheus_client import Gauge, Info
+from global_conf import pipisa_length_metric, user_attempt_metric, user_last_attempt_metric
+
+
+class user_info_struct:
+    user_id: str
+    user_fullname: str
+    dick_size: int
+    datetimes: str
+    attemptsCount: int
+    chat_id: int
+
+def metric_wrap(chatID:int, userName: str, length: int, attemptsCount: int):
+    """Pass here chat ID, username, pipisa length and attempts count to wrap them into metric."""
+
+    global pipisa_length_metric
+    if not pipisa_length_metric:
+        pipisa_length_metric = Gauge('user_length_total', 'Pipisa length', labelnames=['ChatID', 'Username'])
+    global user_attempt_metric
+    if not user_attempt_metric:
+        user_attempt_metric = Gauge('user_attempts_total', 'Attempts count', labelnames=['ChatID', 'Username'])
+    global user_last_attempt_metric
+    if not user_last_attempt_metric:
+        user_last_attempt_metric = Gauge('user_last_attempt_time', 'Last attempt time', labelnames=['ChatID', 'Username'])
+
+    pipisa_length_metric.labels(chatID, userName).set(length)
+    user_attempt_metric.labels(chatID, userName).set(attemptsCount)
+    user_last_attempt_metric.labels(chatID, userName).set(time.time_ns())

handlers/pipisa.py

@@ -0,0 +1,132 @@
+from aiogram import types
+from create_bot import bot, dp
+import random
+from random import randint
+import datetime, logging
+from dicktxt import ForReadDict, WordsChange
+from pipisa_functions import pipisa_time
+from global_conf import CONFIG
+from db_logic import tops, user_stuff, postcleaner
+
+
+admins = CONFIG['telegram_admins_ids']
+
+@dp.message_handler(commands=["dick"])
+async def up_dick(message: types.Message):
+
+    if message.from_user.id in admins or message.chat.type != 'private':
+        postcleaner.append_post_to_cleaning_sequence(message=message, type=f'COMMAND_CALL__DICK')
+        await clean_posts(chat_id=message.chat.id, type='COMMAND_CALL__DICK', max_id=message.message_id)
+
+        #### TODO уплатить нолог с 100 см для самого нищего
+
+        # рандомайзер
+        result = randint(-9,10) 
+
+        #### Чекнуть есть ли юзер в базе
+        user = user_stuff.get_user(message)
+
+        if user: 
+            ## Если есть то нарастить и отправить сообщение
+
+            if pipisa_time.rolltime(check_datetime=user['datetimes'], curr_time=datetime.datetime.now()):
+                # пришло время крутить!!
+
+                updatedDick = user["dick_size"] + result 
+                user_stuff.update_dick_size(message, user, updatedDick)
+
+                randomdickword = ForReadDict.RandomDick() 
+                change_phrase  = WordsChange.ChangeWord(result)
+
+                await bot.send_message( message.chat.id, 
+                    f'@{message.from_user.username}, ваш <em>{randomdickword}</em> {change_phrase} на <b>{abs(result)}</b> см!\nТеперь он равен <b>{updatedDick}</b> см! '
+                )
+            else:
+                mmm = await bot.send_message( message.chat.id, 
+                    f'@{message.from_user.username}, 🚫 вы уже крутили пипису, её размер <b>{user["dick_size"]}</b> см! '
+                )
+                user_stuff.update_attempts( message, user)
+
+                postcleaner.append_post_to_cleaning_sequence(message=mmm, type='ALREADY_ROLLED')
+                await clean_posts(chat_id=mmm.chat.id, type='ALREADY_ROLLED', max_id=mmm.message_id)
+        else:
+            ## если нету, то создать
+            user_stuff.store_new_user(message, result)
+
+            await bot.send_message( message.chat.id,
+                f'@{message.from_user.username}, Добро пожаловать в игру! Ваш писюн показал головку 🚀\nна <b>{abs(result)}</b> см!\nТеперь он равен <b>{abs(result)}</b> см!'
+            )
+
+    else:
+        await message.reply('Растить елду можно только в общих чатах!')
+
+@dp.message_handler(commands = ['topdick', 'globaldick'])
+async def send_topchat(message: types.Message):
+    if message.from_user.id in admins or message.chat.type != 'private':
+
+        top_  = message['text'].startswith('/topdick')
+        glob_ = message['text'].startswith('/globaldick')
+
+        if top_:
+            dickos = tops.get_tops( top_  = True, chat_id=message.chat.id )
+            postcleaner.append_post_to_cleaning_sequence(message=message, type=f'COMMAND_CALL__TOPDICK')
+            await clean_posts(chat_id=message.chat.id, type='COMMAND_CALL__TOPDICK', max_id=message.message_id)
+        elif glob_:
+            dickos = tops.get_tops( glob_ = True )
+            postcleaner.append_post_to_cleaning_sequence(message=message, type=f'COMMAND_CALL__GLOBALDICK')
+            await clean_posts(chat_id=message.chat.id, type='COMMAND_CALL__GLOBALDICK', max_id=message.message_id)
+        else:
+            logging.error('вызывают хз что!')
+
+        if not dickos:
+            await bot.send_message(message.chat.id, '🍆 Никто ничего не нарастил! 🍌')
+        else:
+            if top_:
+                await bot.send_message(message.chat.id, '🏆Топ 10 бубылд чата🏆\n\n' + dickos)
+            elif glob_:
+                await bot.send_message(message.chat.id, '🏆Топ 10 пипис в мире🏆\n\n' + dickos)
+    else:
+        await message.reply('Работает только в общих чатах!\n'\
+                            'Вы можете посмотреть топ по миру /globaldick')
+
+@dp.message_handler(commands = ['antitopdick', 'antiglobaldick'])
+async def send_antitopchat(message: types.Message):
+    if message.from_user.id in admins or message.chat.type != 'private':
+        antitop_  = message['text'].startswith('/antitopdick')
+        antiglob_ = message['text'].startswith('/antiglobaldick')
+
+        if antitop_:
+            dickos = tops.get_antitops(top_=True, chat_id=message.chat.id)
+            postcleaner.append_post_to_cleaning_sequence(message=message, type=f'COMMAND_CALL__ANTITOPDICK')
+            await clean_posts(chat_id=message.chat.id, type='COMMAND_CALL__ANTITOPDICK', max_id=message.message_id)
+        elif antiglob_:
+            dickos = tops.get_antitops(glob_=True)
+            postcleaner.append_post_to_cleaning_sequence(message=message, type=f'COMMAND_CALL__ANTIGLOBALDICK')
+            await clean_posts(chat_id=message.chat.id, type='COMMAND_CALL__ANTIGLOBALDICK', max_id=message.message_id)
+        else:
+            logging.error('вызывают хз что!')
+
+        if not dickos:
+            await bot.send_message(message.chat.id, '🍌 У всех пользователей бубылда растёт! 🍆')
+        else:
+            if antitop_:
+                await bot.send_message(message.chat.id, '🚫Антитоп 10 вагись чата🚫\n\n' + dickos)
+            elif antiglob_:
+                await bot.send_message(message.chat.id, '🚫Антитоп 10 вагись в мире🚫\n\n' + dickos)
+    else:
+        await message.reply('Работает только в общих чатах!\n'\
+                            'Вы можете посмотреть антитоп по миру /antiglobaldick')
+
+async def clean_posts(chat_id, type=None, max_id=None):
+    psts = postcleaner.get_posts_to_be_removed(chat_id, type, max_id)
+
+    for p in psts:
+        postcleaner.del_post(chat_id=p['chat_id'],  msg_id=p['msg_id'])
+
+        #### TODO проверить админит ли бот
+
+        try:
+            await bot.delete_message(chat_id=p['chat_id'], message_id=p['msg_id'])
+        except Exception as e: 
+            logging.error('ошибка удаления поста-на-удаление')
+            logging.error(e)

handlers/start_help.py

@@ -0,0 +1,18 @@
+from aiogram import types
+from aiogram.types import InlineKeyboardMarkup, InlineKeyboardButton
+from create_bot import dp, bot
+
+@dp.message_handler(commands=['start'])
+async def start_func(message: types.Message):
+    if message.chat.type == 'private':
+        lkb = InlineKeyboardMarkup(row_width=1).add(InlineKeyboardButton(text = 'Добавить в группу', callback_data='add_2_group'))
+
+        await message.answer(f'<b>Добро пожаловать, {message.from_user.full_name}!</b>\n'
+                             'Это бот, который растит члены. Чтобы начать, добавь бота в чат'\
+                             , reply_markup=lkb
+                            )
+# TODO добавить кнопку, по которой смогут добавлять юзера в чат
+
+@dp.callback_query_handler(text = 'add_2_group')
+async def addgroup(callback: types.CallbackQuery):
+    await callback.answer('жмав')

handlers/time_new_year.py

@@ -0,0 +1,26 @@
+from aiogram import types, Dispatcher
+from create_bot import dp, bot
+import datetime
+
+@dp.message_handler(commands=["time"])
+async def send_time(message: types.Message):
+    new_year = datetime.datetime(datetime.datetime.now().year, 12, 31) #дата нового года
+    ct = datetime.datetime.now() #датавремя
+    cd = datetime.datetime.now().strftime("%d/%m/%Y") #дата (д,м,г)
+    ct1 = ct  # zoichem??? +datetime.timedelta(hours=15) # +14 часов от сервера
+    ct2 = ct1.strftime('%H:%M') # форматирует датувремя просто во время(ч,м)
+    raznitsa = (new_year - ct).days #отнимает от нг текущее время и получаем разницу в днях
+
+    days = ['день', 'дня', 'дней']
+    if raznitsa % 10 == 1 and raznitsa % 100 != 11:
+        p = 0
+    elif 2 <= raznitsa % 10 <= 4 and (raznitsa % 100 < 10 or raznitsa % 100 >= 20):
+        p = 1
+    else:
+        p = 2
+    num=(str(raznitsa) + ' ' + days[p])
+
+    await message.reply(f'Сегодня {cd} \nВремя: {ct2} \nДо Нового Года осталось {num}')
+
+def register_handlers_time(dp: Dispatcher):
+    dp.register_message_handler(send_time)

jack_bot.service

@@ -0,0 +1,15 @@
+# пример того что лежит на хосте
+[Unit]
+Description=pipisa-bot
+After=network.target
+
+[Service]
+User=jack
+Type=simple
+Restart=always
+WorkingDirectory=/usr/share/python_bot
+ExecStart=/usr/bin/python3 /usr/share/python_bot/bot.py
+ExecStart=/usr/bin/python3 /usr/share/python_bot/bot.py
+
+[Install]
+WantedBy=multi-user.target#

pipisa_functions/__init__.py

@@ -0,0 +1 @@
+from . import pipisa_time

pipisa_functions/pipisa_time.py

@@ -0,0 +1,77 @@
+import unittest
+import datetime
+
+
+def rolltime(check_datetime , curr_time=datetime.datetime.now()):
+    last_time    = datetime.datetime.strptime(check_datetime, '%Y-%m-%d %H:%M:%S')
+    time_to_grow = curr_time.replace(hour=10, minute=0, second=0, microsecond=0) #+ datetime.timedelta(days=0)
+
+    timediff = (time_to_grow - last_time).total_seconds()
+
+    # print()
+    # print(f'\tlast_time : {last_time}')
+    # print(f'\ttime_to_grow : {time_to_grow}')
+    # print(f'\tcurr_time : {curr_time.strftime("%Y-%m-%d %H:%M:%S")}')
+    # print(f'\t\tsecs diff : {timediff}')
+
+    if timediff > 86400 or (curr_time > time_to_grow and last_time < time_to_grow):
+        return True
+    else:
+        return False
+ 
+class TestPipisa(unittest.TestCase):
+    def test_very_long_ago(self):
+        self.assertEqual(rolltime('2021-10-11 23:44:00'), True, "Пиписа прокручена очень давно. Очевидный прокрут")
+
+    def test_just_after(self):
+        self.assertEqual(rolltime(
+            datetime.datetime.now().replace(hour=10, minute=1, second=0, microsecond=0).strftime('%Y-%m-%d %H:%M:%S')
+            ), False, "Попытка крутить когда старый прокрут был через 1 минуту после сегодняшнего обновления роллов. Фейл.")
+
+    def test_yesterdayroll(self):
+        self.assertEqual(
+            rolltime(
+                ( 
+                    datetime.datetime.now().replace(hour=10, minute=1, second=0, microsecond=0) - datetime.timedelta(days=1)
+                ).strftime('%Y-%m-%d %H:%M:%S'),
+                datetime.datetime.now().replace(hour=10, minute=1, second=0, microsecond=0)
+            ), True, "Крутилась вчера через минуту после обновления роллов. Должно пропускать ")
+        
+    def test_hour_before_roll(self):
+        self.assertEqual(
+            rolltime(
+                ( 
+                    datetime.datetime.now().replace(hour=10, minute=1, second=1, microsecond=0) - datetime.timedelta(hours=1)
+                ).strftime('%Y-%m-%d %H:%M:%S'),
+                datetime.datetime.now().replace(hour=10, minute=1, second=0, microsecond=0)
+            ), True, "Крутилась последний раз за час до прокрута. Надо разрешать заново!")
+        
+    def test_after_midnight(self): 
+        self.assertEqual(
+            rolltime(
+                (
+                    datetime.datetime.now().replace(hour=10, minute=1, second=0, microsecond=0) - datetime.timedelta(hours=14)
+                ).strftime('%Y-%m-%d %H:%M:%S'),
+                datetime.datetime.now().replace(hour=0, minute=11, second=8, microsecond=0)
+            ), False, "Где-то ночью прокручивается повторно. Фейл.")
+
+    def test_before_midnight(self):
+        self.assertEqual(
+            rolltime(
+                (
+                    datetime.datetime.now().replace(hour=10, minute=1, second=0, microsecond=0) - datetime.timedelta(hours=15)
+                ).strftime('%Y-%m-%d %H:%M:%S'),
+                datetime.datetime.now().replace(hour=0, minute=11, second=8, microsecond=0) - datetime.timedelta(hours=15)
+            ), False, "Где-то ночью прокручивается повторно. Фейл.")
+
+    def test_somewhere_after(self):
+        self.assertEqual(
+            rolltime(
+                (
+                    datetime.datetime.now().replace(hour=10, minute=18, second=0, microsecond=0)
+                ).strftime('%Y-%m-%d %H:%M:%S'),
+                datetime.datetime.now().replace(hour=10, minute=19, second=0, microsecond=0)
+            ), False, "Сегодня уже открутили а хотят ещё. Фейл.")
+
+if __name__ == "__main__":
+    unittest.main(verbosity=2)

requairements.txt

@@ -1,3 +1,4 @@
-aiogram
-sqdb
-sqlalchemy
+aiogram==2.15
+python-arango
+pyyaml
+prometheus-client

sqdb.py

@@ -1,48 +0,0 @@
-from sqlalchemy import create_engine, MetaData, Table, Integer, String, \
-    Column, DateTime, ForeignKey, Numeric
-from sqlalchemy.ext.declarative import declarative_base
-from sqlalchemy.orm import sessionmaker
-from sqlalchemy import select, update
-
-engine = create_engine('postgresql+psycopg2://postgres:postgres@postgres.vdk2ch.ru:5432/jack_bot', echo=True)
-Session = sessionmaker(bind=engine)
-session = Session()
-
-
-
-Base = declarative_base()
-
-
-
-class user(Base):
-    __tablename__ = 'users'
-
-    id = Column(Integer, primary_key=True)
-    user_id = Column(Integer)
-    user_fullname = Column(String)
-    dick_size = (Column(Integer))
-    datetimes = (Column(DateTime))
-    
-session.close()
-
-
-#Base.metadata.create_all(engine)
-
-# int_table = user(user_id = 12345678, user_fullname = 'test', dick_size = 10) #импортирую юзер из sqdb
-# session.add(int_table)
-# session.commit()
-# select user_id, name from employees limit 10
-
-# def adding():
-        
-#     session.add()
-#     session.commit()
-        
-
-
-
-
-
-
-
-