S1S13AF7/ub4tg
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

backup stealing txt support

Browse source
This commit is contained in:
Your Name 2024-12-14 13:14:37 +03:00
parent a0857c2888
commit 7635615d5a
1 changed files with 54 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

69
ubot.py
View file

@ -601,25 +601,63 @@ async def main():
reply = await client.get_messages(event.peer_id, ids=event.reply_to.reply_to_msg_id) reply = await client.get_messages(event.peer_id, ids=event.reply_to.reply_to_msg_id)
file_path = await reply.download_media(file=f"{default_directory}") file_path = await reply.download_media(file=f"{default_directory}")
logger.success(f'backup file saved to {file_path}') logger.success(f'backup file saved to {file_path}')
victims = None
raw_victims = None
file_format = None
with open(file_path, 'r') as stealed_backup: with open(file_path, 'r') as stealed_backup:
victims = json.load(stealed_backup) if file_path.lower().endswith('.json'):
victims = json.load(stealed_backup)
file_format = 'json'
elif file_path.lower().endswith('.txt'):
raw_victims = stealed_backup.readlines()
file_format = 'txt'
else:
await event.edit('Format not supported, avalaible: txt, json')
return
added = 0 added = 0
my_victims_ids = [] my_victims_ids = []
for v in victims: if file_format == 'json':
user_id = int(v['user_id']) for v in victims:
profit = v['profit'] user_id = int(v['user_id'])
when = v['from_infect'] profit = v['profit']
expr = v['until_infect'] when = v['from_infect']
if cmd == 'me': expr = v['until_infect']
my_victims_ids.append(user_id) if cmd == 'me':
c.execute("INSERT OR REPLACE INTO avocado(user_id,when_int,bio_str,bio_int,expr_int) VALUES (?, ?, ?, ?, ?)", my_victims_ids.append(user_id)
(int(user_id), int(when), str(profit), int(profit), int(expr))) c.execute("INSERT OR REPLACE INTO avocado(user_id,when_int,bio_str,bio_int,expr_int) VALUES (?, ?, ?, ?, ?)",
added += 1 (int(user_id), int(when), str(profit), int(profit), int(expr)))
else:
if not c.execute(f'SELECT user_id FROM avocado WHERE user_id == {user_id}').fetchone():
c.execute("INSERT INTO avocado(user_id,when_int,bio_str,bio_int,expr_int) VALUES (?, ?, ?, ?, ?)",
(int(user_id), int(when), str(profit), int(profit), 0))
added += 1 added += 1
else:
if not c.execute(f'SELECT user_id FROM avocado WHERE user_id == {user_id}').fetchone() and not c.execute(f'SELECT user_id FROM avocado_exclude WHERE user_id == {user_id}').fetchone():
c.execute("INSERT INTO avocado(user_id,when_int,bio_str,bio_int,expr_int) VALUES (?, ?, ?, ?, ?)",
(int(user_id), int(when), str(profit), int(profit), 0))
added += 1
elif file_format == 'txt':
when = int(datetime.timestamp(event.date))
for raw_v in raw_victims:
if raw_v == '':
continue
user_id = re.findall(r'tg://openmessage\?user_id=(\d+)', raw_v)
if not user_id:
continue
user_id = int(user_id[0])
profit = re.findall(r'([0-9\.\,k]+) опыта', raw_v)
if not profit:
continue
profit = profit[0]
if ',' in profit:
profit = re.sub(r',', r'.', profit)
if 'k' in profit:
profit_int = int(
float(re.sub('k', '', profit)) * 1000)
else:
profit_int = int(profit)
if not c.execute(f'SELECT user_id FROM avocado WHERE user_id == {user_id}').fetchone() and not c.execute(f'SELECT user_id FROM avocado_exclude WHERE user_id == {user_id}').fetchone():
c.execute("INSERT INTO avocado(user_id,when_int,bio_str,bio_int,expr_int) VALUES (?, ?, ?, ?, ?)",
(int(user_id), int(when), str(profit), int(profit_int), 0))
added += 1
logger.debug(f'added {user_id} - {profit_int}')
conn.commit() conn.commit()
logger.success('backup success stealed') logger.success('backup success stealed')
if cmd == 'me': if cmd == 'me':
@ -629,6 +667,7 @@ async def main():
logger.success('database rebased') logger.success('database rebased')
del my_victims_ids del my_victims_ids
del victims # free memory del victims # free memory
del raw_victims
if cmd == 'me': if cmd == 'me':
rebased = len(result) rebased = len(result)
await event.edit(f'Success added/updated {added} patients\nOther {rebased} patients reset to 0') await event.edit(f'Success added/updated {added} patients\nOther {rebased} patients reset to 0')