fix #53

aahnik · Jun 2, 2021 · 50ff89d · 50ff89d
1 parent b21b048
commit 50ff89d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/tgcf/past.py b/tgcf/past.py
@@ -26,6 +26,8 @@ async def forward_job() -> None:
             async for message in client.iter_messages(
                 forward.source, reverse=True, offset_id=forward.offset
             ):
+                if forward.end and last_id > forward.end:
+                    continue
                 if isinstance(message, MessageService):
                     continue
                 try:
@@ -36,7 +38,7 @@ async def forward_job() -> None:
                     for destination in forward.dest:
                         await send_message(destination, tm)
                     tm.clear()
-                    last_id = str(message.id)
+                    last_id = message.id
                     logging.info(f"forwarding message with id = {last_id}")
                     forward.offset = last_id
                     write_config(CONFIG)