diff --git a/main.py b/main.py index 0ef90ad..fe387b9 100644 --- a/main.py +++ b/main.py @@ -122,20 +122,21 @@ async def check_updates(): for tl_idx in range(0, len(tag_list), 40): tags = ' '.join(f'~{tag}' for tag in tag_list[tl_idx: tl_idx + 40]) logging.warning(tags) + posts = [] for page in range(1, 11): - posts = await e621.get_posts(tags, page) - 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) + posts.extend(await e621.get_posts(tags, page)) + 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('add'), ChatFilter)