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

use telegram time for measure avocado timeout

Browse source
This commit is contained in:
Your Name 2024-12-09 16:18:28 +03:00
parent 316ec6dc20
commit 31a47f8c85
1 changed files with 10 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
ubot.py
View file

@ -51,7 +51,7 @@ class states:
auto_bioeb_stop = False auto_bioeb_stop = False
last_sent_bioeb = 0 # for measure time between reply avocado and bioeb last_sent_bioeb = 0 # for measure time between reply avocado and bioeb
last_reply_bioeb_avocado = 0 # same as above last_reply_bioeb_avocado = 0 # same as above
avocado_reply_timeout = 3000 # increase interval if lag more than this timeout in ms avocado_reply_timeout = 3 # increase interval if lag more than this timeout in secs
stats_medkit = 0 stats_medkit = 0
@ -389,13 +389,15 @@ async def main():
remaining_in_stack = len(e_info) remaining_in_stack = len(e_info)
logger.info(f'remaining patiences in current stack: {remaining_in_stack}') logger.info(f'remaining patiences in current stack: {remaining_in_stack}')
random.shuffle(e_info) random.shuffle(e_info)
states.last_sent_bioeb = time.time() states.last_sent_bioeb = int(datetime.timestamp(m.date))
if states.last_reply_bioeb_avocado == 0: # reduce negative ping -123456789 ms if states.last_reply_bioeb_avocado == 0: # reduce negative ping
states.last_reply_bioeb_avocado = time.time() states.last_reply_bioeb_avocado = int(datetime.timestamp(m.date))
await asyncio.sleep(3.3) await asyncio.sleep(3.3)
await client.delete_messages(event.chat_id, m.id) await client.delete_messages(event.chat_id, m.id)
delta_avocado = int((states.last_reply_bioeb_avocado - states.last_sent_bioeb) * 1000) delta_avocado = states.last_reply_bioeb_avocado - states.last_sent_bioeb
logger.debug(f'latency avocado reply: {delta_avocado} ms') if delta_avocado < 0:
delta_avocado = delta_avocado * -1
logger.debug(f'latency avocado reply: {delta_avocado} secs')
if delta_avocado > states.avocado_reply_timeout: if delta_avocado > states.avocado_reply_timeout:
logger.debug(f'bioeb sleep [increased, because avocado have lag]: {rs}s') logger.debug(f'bioeb sleep [increased, because avocado have lag]: {rs}s')
await asyncio.sleep(rs + random.uniform(34, 69)) await asyncio.sleep(rs + random.uniform(34, 69))
@ -438,7 +440,6 @@ async def main():
if result.message: if result.message:
logger.info(f'avocado says: {result.message}') logger.info(f'avocado says: {result.message}')
@client.on(events.NewMessage(pattern='🌡 У вас горячка вызванная')) @client.on(events.NewMessage(pattern='🌡 У вас горячка вызванная'))
async def need_h(event): async def need_h(event):
m = event.message m = event.message
@ -455,13 +456,13 @@ async def main():
delete=False, delete=False,
) )
states.stats_medkit += 1 states.stats_medkit += 1
states.last_reply_bioeb_avocado = time.time() states.last_reply_bioeb_avocado = int(datetime.timestamp(event.date))
logger.debug(ah.text) logger.debug(ah.text)
logger.warning('Used medkit') logger.warning('Used medkit')
elif m.mentioned: elif m.mentioned:
# alternative method: just waiting, this reduce bio-res usage # alternative method: just waiting, this reduce bio-res usage
states.auto_bioeb_sleep_interval = (3600, 3600) states.auto_bioeb_sleep_interval = (3600, 3600)
states.last_reply_bioeb_avocado = time.time() states.last_reply_bioeb_avocado = int(datetime.timestamp(event.date))
logger.warning('Waiting for infection release... [For skip just bioeb somebody]') logger.warning('Waiting for infection release... [For skip just bioeb somebody]')
#################################################################### ####################################################################