update api
This commit is contained in:
parent
49faf9f746
commit
cad71a1971
4
e621.py
4
e621.py
@ -155,8 +155,8 @@ class E621PostVersion:
|
|||||||
source_changed: bool
|
source_changed: bool
|
||||||
description_changed: bool
|
description_changed: bool
|
||||||
version: int
|
version: int
|
||||||
obsolete_added_tags: str
|
obsolete_added_tags: Optional[str]
|
||||||
obsolete_removed_tags: str
|
obsolete_removed_tags: Optional[str]
|
||||||
unchanged_tags: str
|
unchanged_tags: str
|
||||||
updater_name: str
|
updater_name: str
|
||||||
|
|
||||||
|
18
main.py
18
main.py
@ -175,24 +175,6 @@ async def check_updates():
|
|||||||
await sleep(1)
|
await sleep(1)
|
||||||
await redis.set('e621:last_version', last_post_version)
|
await redis.set('e621:last_version', last_post_version)
|
||||||
|
|
||||||
# random.shuffle(tag_list)
|
|
||||||
# for tl_idx in range(0, len(tag_list), PAGE_SIZE):
|
|
||||||
# tags = ' '.join(f'~{tag}' for tag in tag_list[tl_idx: tl_idx + PAGE_SIZE])
|
|
||||||
# logging.warning(tags)
|
|
||||||
# posts = await e621.get_posts(tags)
|
|
||||||
# if not posts:
|
|
||||||
# return
|
|
||||||
# already_sent: List = await redis.smismember('e621:sent', [p.id for p in posts])
|
|
||||||
# # last_index = len(posts)
|
|
||||||
# # if already_sent.count(True):
|
|
||||||
# # last_index = already_sent.index(True)
|
|
||||||
# # await redis.sadd('e621:sent', *[posts[i].id for i in range(last_index, len(posts))])
|
|
||||||
# for i in list(range(len(posts)))[::-1]:
|
|
||||||
# if already_sent[i]:
|
|
||||||
# continue
|
|
||||||
# await send_post(posts[i], tag_list)
|
|
||||||
# await sleep(1)
|
|
||||||
|
|
||||||
|
|
||||||
@dp.message(filters.Command('resend_after'), ChatFilter)
|
@dp.message(filters.Command('resend_after'), ChatFilter)
|
||||||
async def resend_after(msg: Message):
|
async def resend_after(msg: Message):
|
||||||
|
Loading…
Reference in New Issue
Block a user