Kostiantyn Kuleshov
853c3c7cea
* Config file changes * Commands `/remove`, `/import` and `/export` Co-authored-by: profitroll <vozhd.kk@gmail.com> Co-authored-by: Profitroll <47523801+profitrollgame@users.noreply.github.com> Co-authored-by: Renovate <renovate@git.end-play.xyz> Reviewed-on: #19
99 lines
3.3 KiB
Python
99 lines
3.3 KiB
Python
from os import path, remove, sep
|
|
from shutil import rmtree
|
|
from typing import Tuple, Union
|
|
from pyrogram.client import Client
|
|
from pyrogram.types import Message
|
|
from classes.exceptions import SubmissionDuplicatesError, SubmissionUnavailableError
|
|
from modules.api_client import upload_pic
|
|
from modules.database import col_submitted
|
|
from bson import ObjectId
|
|
from modules.logger import logWrite
|
|
|
|
from modules.utils import configGet
|
|
|
|
|
|
class PosterClient(Client):
|
|
def __init__(self, name: str, **kwargs): # type: ignore
|
|
super().__init__(name, **kwargs)
|
|
self.owner = configGet("owner")
|
|
self.admins = configGet("admins") + [configGet("owner")]
|
|
|
|
async def submit_photo(
|
|
self, id: str
|
|
) -> Tuple[Union[Message, None], Union[str, None]]:
|
|
db_entry = col_submitted.find_one({"_id": ObjectId(id)})
|
|
submission = None
|
|
|
|
if db_entry is None:
|
|
raise SubmissionUnavailableError()
|
|
else:
|
|
if db_entry["temp"]["uuid"] is not None:
|
|
if not path.exists(
|
|
path.join(
|
|
configGet("data", "locations"),
|
|
"submissions",
|
|
db_entry["temp"]["uuid"],
|
|
db_entry["temp"]["file"],
|
|
)
|
|
):
|
|
raise SubmissionUnavailableError()
|
|
else:
|
|
filepath = path.join(
|
|
configGet("data", "locations"),
|
|
"submissions",
|
|
db_entry["temp"]["uuid"],
|
|
db_entry["temp"]["file"],
|
|
)
|
|
try:
|
|
submission = await self.get_messages(
|
|
db_entry["user"], db_entry["telegram"]["msg_id"]
|
|
)
|
|
except:
|
|
pass
|
|
else:
|
|
try:
|
|
submission = await self.get_messages(
|
|
db_entry["user"], db_entry["telegram"]["msg_id"]
|
|
)
|
|
filepath = await self.download_media(
|
|
submission, file_name=configGet("tmp", "locations") + sep
|
|
)
|
|
except:
|
|
raise SubmissionUnavailableError()
|
|
|
|
response = await upload_pic(
|
|
str(filepath), allow_duplicates=configGet("allow_duplicates", "submission")
|
|
)
|
|
|
|
if len(response[1]) > 0:
|
|
raise SubmissionDuplicatesError(str(filepath), response[1])
|
|
|
|
col_submitted.find_one_and_update(
|
|
{"_id": ObjectId(id)}, {"$set": {"done": True}}
|
|
)
|
|
|
|
try:
|
|
if db_entry["temp"]["uuid"] is not None:
|
|
rmtree(
|
|
path.join(
|
|
configGet("data", "locations"),
|
|
"submissions",
|
|
db_entry["temp"]["uuid"],
|
|
),
|
|
ignore_errors=True,
|
|
)
|
|
else:
|
|
remove(str(filepath))
|
|
except (FileNotFoundError, NotADirectoryError):
|
|
logWrite(
|
|
f"Could not delete '{filepath}' on submission accepted", debug=True
|
|
)
|
|
|
|
return submission, response[2]
|
|
|
|
async def ban_user(self, id: int) -> None:
|
|
pass
|
|
|
|
async def unban_user(self, id: int) -> None:
|
|
pass
|