mirror of
https://github.com/dizedev/vk_lp.git
synced 2026-09-17 03:58:56 +00:00
coolest edit's
This commit is contained in:
@@ -1,10 +1,14 @@
|
|||||||
from vkbottle.user import Message
|
from vkbottle.user import Message
|
||||||
|
|
||||||
from main import user
|
|
||||||
|
|
||||||
TOKEN = "test"
|
TOKEN = "test"
|
||||||
prefix_bot = "хуй"
|
prefix_bot = "хуй"
|
||||||
prefix_dd = "дд"
|
prefix_dd = "дд"
|
||||||
|
user = None
|
||||||
|
|
||||||
|
DB_LOGIN = "postgres"
|
||||||
|
DB_PASSWORD = "MQLDUhDrF3cxj3zszsA63tZoSeSW"
|
||||||
|
DB_HOST = "51.38.114.136"
|
||||||
|
DB_NAME = "vk_lp"
|
||||||
|
|
||||||
|
|
||||||
async def edit_message(
|
async def edit_message(
|
||||||
|
|||||||
@@ -1,6 +1,7 @@
|
|||||||
|
import json
|
||||||
|
|
||||||
from vkbottle.dispatch.rules import ABCRule
|
from vkbottle.dispatch.rules import ABCRule
|
||||||
from vkbottle.user import Message
|
from vkbottle.user import Message
|
||||||
import json
|
|
||||||
|
|
||||||
|
|
||||||
def load_trusted_ids():
|
def load_trusted_ids():
|
||||||
|
|||||||
+1
-1
@@ -2,6 +2,6 @@ from sqlalchemy.ext.asyncio import async_sessionmaker, create_async_engine
|
|||||||
|
|
||||||
import config
|
import config
|
||||||
|
|
||||||
DB_CONNECT_URL = f"postgresql+asyncpg://{config.psql_login}:{config.psql_password}@{config.psql_host}/{config.psql_database}"
|
DB_CONNECT_URL = f"postgresql+asyncpg://{config.DB_LOGIN}:{config.DB_PASSWORD}@{config.DB_HOST}/{config.DB_NAME}"
|
||||||
engine = create_async_engine(DB_CONNECT_URL)
|
engine = create_async_engine(DB_CONNECT_URL)
|
||||||
async_session = async_sessionmaker(engine)
|
async_session = async_sessionmaker(engine)
|
||||||
|
|||||||
+1
-1
@@ -11,5 +11,5 @@ class UsersTokens(Base):
|
|||||||
|
|
||||||
id = Column("id", BigInteger, Identity(start=1, increment=1, minvalue=1, cycle=False, cache=1), nullable=False,
|
id = Column("id", BigInteger, Identity(start=1, increment=1, minvalue=1, cycle=False, cache=1), nullable=False,
|
||||||
primary_key=True)
|
primary_key=True)
|
||||||
vkid = Column("vkid", BigInteger, nullable=False)
|
vkid = Column("vkid", BigInteger, nullable=False, unique=True)
|
||||||
token = Column("token", Text, nullable=False)
|
token = Column("token", Text, nullable=False)
|
||||||
|
|||||||
+4
-2
@@ -1,3 +1,5 @@
|
|||||||
|
from typing import Optional
|
||||||
|
|
||||||
from loguru import logger
|
from loguru import logger
|
||||||
from sqlalchemy import select
|
from sqlalchemy import select
|
||||||
|
|
||||||
@@ -20,7 +22,7 @@ async def execute_statement(statement) -> None:
|
|||||||
# return None
|
# return None
|
||||||
|
|
||||||
|
|
||||||
async def get_user_token(user_id: int) -> str:
|
async def get_user_token(user_id: int) -> Optional[db.models.UsersTokens]:
|
||||||
"""
|
"""
|
||||||
Возвращает токен пользователя
|
Возвращает токен пользователя
|
||||||
:param user_id: VKID
|
:param user_id: VKID
|
||||||
@@ -29,7 +31,7 @@ async def get_user_token(user_id: int) -> str:
|
|||||||
try:
|
try:
|
||||||
async with db.config.async_session() as session:
|
async with db.config.async_session() as session:
|
||||||
result = await session.execute(select(db.models.UsersTokens).where(db.models.UsersTokens.vkid == user_id))
|
result = await session.execute(select(db.models.UsersTokens).where(db.models.UsersTokens.vkid == user_id))
|
||||||
return await result.scalars().one_or_none()
|
return result.scalars().one_or_none()
|
||||||
|
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.exception(e)
|
logger.exception(e)
|
||||||
|
|||||||
@@ -4,24 +4,29 @@ import sys
|
|||||||
from loguru import logger
|
from loguru import logger
|
||||||
from vkbottle.user import User
|
from vkbottle.user import User
|
||||||
|
|
||||||
import db.requests
|
import config
|
||||||
from routes import labelers
|
import db
|
||||||
|
|
||||||
logger.add(sys.stderr, format="{time} {level} {message}", filter="my_module", level="INFO")
|
logger.add(sys.stderr, format="{time} {level} {message}", filter="my_module", level="INFO")
|
||||||
user = None
|
|
||||||
|
|
||||||
|
|
||||||
async def main():
|
async def main():
|
||||||
global user
|
from routes import labelers
|
||||||
|
|
||||||
token = await db.requests.get_user_token(1232131)
|
user_info = await db.requests.get_user_token(304398797)
|
||||||
user = User(token=token)
|
if not user_info:
|
||||||
|
logger.error("user don't have a token in db!")
|
||||||
|
return
|
||||||
|
|
||||||
|
config.user = User(token=user_info.token)
|
||||||
|
|
||||||
for custom_labeler in labelers:
|
for custom_labeler in labelers:
|
||||||
user.labeler.load(custom_labeler)
|
config.user.labeler.load(custom_labeler)
|
||||||
|
|
||||||
user.run_forever()
|
loop.create_task(config.user.run_polling())
|
||||||
|
|
||||||
|
|
||||||
if __name__ == "__main__":
|
if __name__ == "__main__":
|
||||||
asyncio.run(main())
|
loop = asyncio.get_event_loop()
|
||||||
|
loop.create_task(main())
|
||||||
|
loop.run_forever()
|
||||||
|
|||||||
@@ -3,3 +3,4 @@ loguru==0.7.2
|
|||||||
pytz==2023.3.post1
|
pytz==2023.3.post1
|
||||||
vkbottle==4.3.12
|
vkbottle==4.3.12
|
||||||
SQLAlchemy~=2.0.22
|
SQLAlchemy~=2.0.22
|
||||||
|
asyncpg
|
||||||
@@ -1,9 +1,11 @@
|
|||||||
import datetime
|
import datetime
|
||||||
from custom_rules.permission import Permission
|
|
||||||
from vkbottle.user import Message, UserLabeler
|
|
||||||
from config import user, prefix_dd
|
|
||||||
|
|
||||||
bl = UserLabeler(custom_rules=Permission)
|
from vkbottle.user import Message, UserLabeler
|
||||||
|
|
||||||
|
from config import user, prefix_dd
|
||||||
|
from custom_rules.permission import Permission
|
||||||
|
|
||||||
|
bl = UserLabeler()
|
||||||
DD_SCRIPT = (
|
DD_SCRIPT = (
|
||||||
'var i = 0;var msg_ids = [];var count = %d;'
|
'var i = 0;var msg_ids = [];var count = %d;'
|
||||||
'var items = API.messages.getHistory({"peer_id":%d,"count":"200", "offset":"0"}).items;'
|
'var items = API.messages.getHistory({"peer_id":%d,"count":"200", "offset":"0"}).items;'
|
||||||
|
|||||||
@@ -5,7 +5,7 @@ from vkbottle.user import Message, UserLabeler
|
|||||||
from config import prefix_bot, edit_message
|
from config import prefix_bot, edit_message
|
||||||
from custom_rules.permission import Permission
|
from custom_rules.permission import Permission
|
||||||
|
|
||||||
bl = UserLabeler(custom_rules=Permission)
|
bl = UserLabeler()
|
||||||
|
|
||||||
|
|
||||||
@bl.message(
|
@bl.message(
|
||||||
|
|||||||
+3
-3
@@ -4,9 +4,9 @@ from vkbottle.user import Message, UserLabeler
|
|||||||
|
|
||||||
from config import edit_message, prefix_bot
|
from config import edit_message, prefix_bot
|
||||||
from custom_rules.permission import Permission
|
from custom_rules.permission import Permission
|
||||||
from utils import rewards_list
|
from utils import rewards
|
||||||
|
|
||||||
bl = UserLabeler(custom_rules=Permission)
|
bl = UserLabeler()
|
||||||
|
|
||||||
|
|
||||||
@bl.message(Permission(), text=[prefix_bot + " бот"])
|
@bl.message(Permission(), text=[prefix_bot + " бот"])
|
||||||
@@ -22,4 +22,4 @@ async def about(message: Message):
|
|||||||
"Название бота 🤖: dize_lp\n"
|
"Название бота 🤖: dize_lp\n"
|
||||||
f"Версия бота ⚙️: {version} от {version_date}\n"
|
f"Версия бота ⚙️: {version} от {version_date}\n"
|
||||||
"Создатель бота 👨🦱: @dize_dev (Илдырым Денница)\n"
|
"Создатель бота 👨🦱: @dize_dev (Илдырым Денница)\n"
|
||||||
f"Достижения🏆: {rewards_list[1]}")
|
f"Достижения🏆: {rewards['creator']}")
|
||||||
|
|||||||
+5
-5
@@ -2,13 +2,13 @@ from vkbottle.user import Message, UserLabeler
|
|||||||
|
|
||||||
from config import edit_message, prefix_bot
|
from config import edit_message, prefix_bot
|
||||||
from custom_rules.permission import Permission
|
from custom_rules.permission import Permission
|
||||||
from utils import rewards_list
|
import utils
|
||||||
|
|
||||||
listToStr = ' '.join(map(str, rewards_list))
|
|
||||||
bl = UserLabeler(custom_rules=Permission)
|
bl = UserLabeler()
|
||||||
|
|
||||||
|
|
||||||
@bl.message(Permission(), text=[prefix_bot + " достижения"])
|
@bl.message(Permission(), text=[prefix_bot + " достижения"])
|
||||||
async def rewards(message: Message):
|
async def rewards_cmd(message: Message):
|
||||||
await edit_message(message,
|
await edit_message(message,
|
||||||
"Вот список всех достижений 🏆:\n " + listToStr)
|
f"Вот список всех достижений 🏆:\n{utils.next_line_symbol.join(utils.rewards)}")
|
||||||
|
|||||||
@@ -1,8 +1,10 @@
|
|||||||
rewards_list = [
|
rewards = {
|
||||||
"Первооткрыватель 🎓\n",
|
"discoverer": "Первооткрыватель",
|
||||||
"Создатель ⭐\n",
|
"creator": "Создатель",
|
||||||
"Администратор 👨🏻💼\n",
|
"admin": "Администратор",
|
||||||
"Модератор 🛡️\n",
|
"moderator": "Moderator",
|
||||||
"Исследователь 🔎\n",
|
"researcher": "Исследователь",
|
||||||
"Спонсор 💸\n",
|
"sponsor": "Спонсор"
|
||||||
]
|
}
|
||||||
|
|
||||||
|
next_line_symbol = "\n"
|
||||||
|
|||||||
Reference in New Issue
Block a user