|
|
|
@ -122,19 +122,20 @@ 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 = 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)
|
|
|
|
|
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)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@dp.message(filters.Command('add'), ChatFilter)
|
|
|
|
|