my-dev
/
uploader-bot
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

stars fixes

This commit is contained in:
user 2025-03-01 13:38:40 +03:00
parent c9871b95e1
commit 45af09da0d
2 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app/api/routes/content.py
View File

@ -80,16 +80,18 @@ async def s_api_v1_content_view(request, content_address: str):
if request.ctx.user.telegram_id in [5587262915, 6861699286]: if request.ctx.user.telegram_id in [5587262915, 6861699286]:
stars_cost = 2 stars_cost = 2
invoice_id = f"access_{uuid.uuid4().hex}"
exist_invoice = request.ctx.db_session.query(StarsInvoice).filter( exist_invoice = request.ctx.db_session.query(StarsInvoice).filter(
and_( and_(
StarsInvoice.user_id == request.ctx.user.id, StarsInvoice.user_id == request.ctx.user.id,
StarsInvoice.created > datetime.now() - timedelta(minutes=25), StarsInvoice.created > datetime.now() - timedelta(minutes=25),
StarsInvoice.amount == stars_cost,
StarsInvoice.external_id == invoice_id
) )
).first() ).first()
if exist_invoice: if exist_invoice:
invoice_url = exist_invoice.invoice_url invoice_url = exist_invoice.invoice_url
else: else:
invoice_id = f"access_{uuid.uuid4().hex}"
invocie_url = None invocie_url = None
try: try:
invoice_url = await Bot(token=CLIENT_TELEGRAM_API_KEY).create_invoice_link( invoice_url = await Bot(token=CLIENT_TELEGRAM_API_KEY).create_invoice_link(

3
app/client_bot/routers/stars.py
View File

@ -7,6 +7,9 @@ router = Router()
async def t_pre_checkout_query_stars_processing(pre_checkout_query: types.PreCheckoutQuery, user=None, db_session=None, async def t_pre_checkout_query_stars_processing(pre_checkout_query: types.PreCheckoutQuery, user=None, db_session=None,
chat_wrap=None, **extra): chat_wrap=None, **extra):
make_log('t_pre_checkout_query_stars_processing', f"PreCheckoutQuery: {pre_checkout_query}")
make_log('t_pre_checkout_query_stars_processing', f"User: {user}, db_session: {db_session}, chat_wrap: {chat_wrap}, extra: {extra}")
invoice_id = pre_checkout_query.invoice_payload invoice_id = pre_checkout_query.invoice_payload
existing_invoice = db_session.query(StarsInvoice).filter( existing_invoice = db_session.query(StarsInvoice).filter(