bakatrouble/telegram_bots
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

add get_hashes rpc endpoint

Browse Source
This commit is contained in:
bakatrouble 2025-07-25 14:21:12 +03:00
parent 7f47ac6849
commit 62b76735d1
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
bots/modules/channel_helper.py
View File

@ -39,6 +39,7 @@ class ChannelHelperBotModuleConfig(TelegramBotModuleConfig):
self.rpc_dispatcher = RPCDispatcher() self.rpc_dispatcher = RPCDispatcher()
self.rpc_dispatcher['post_photo'] = self.rpc_post_photo self.rpc_dispatcher['post_photo'] = self.rpc_post_photo
self.rpc_dispatcher['post_gif'] = self.rpc_post_gif self.rpc_dispatcher['post_gif'] = self.rpc_post_gif
self.rpc_dispatcher['get_hashes'] = self.rpc_get_hashes
def rpc_post_photo(self, photo, is_base64=False, note=''): def rpc_post_photo(self, photo, is_base64=False, note=''):
config._reload_maybe() config._reload_maybe()
@ -97,6 +98,12 @@ class ChannelHelperBotModuleConfig(TelegramBotModuleConfig):
upload_animation_rpc.delay(qi.pk, fpath_output, note or None) upload_animation_rpc.delay(qi.pk, fpath_output, note or None)
return True return True
def rpc_get_hashes(self):
config._reload_maybe()
return (self.queued_items.filter(type='photo', processed=False)
.exclude(image_hash__isnull=True)
.values_list('image_hash', flat=True))
def periodic_task(self, bot: Bot): def periodic_task(self, bot: Bot):
i = self.queued_items.filter(processed=False).order_by('?').first() # type: QueuedItem i = self.queued_items.filter(processed=False).order_by('?').first() # type: QueuedItem