Skip to content

Commit

Permalink
Add more logging for feed updating logic
Browse files Browse the repository at this point in the history
  • Loading branch information
aigoncharov committed Sep 1, 2024
1 parent b454c78 commit 9d86067
Showing 1 changed file with 15 additions and 0 deletions.
15 changes: 15 additions & 0 deletions telegram_to_rss/poll_telegram.py
Original file line number Diff line number Diff line change
Expand Up @@ -70,6 +70,9 @@ async def create_feed(self, dialog: custom.Dialog):
async def update_feed(self, dialog: custom.Dialog):
feed = await Feed.get(id=dialog.id)
last_feed_entry = await FeedEntry.filter(feed=feed).order_by("-date").first()
logging.debug(
f"TelegramPoller.update_feed -> last feed entry {last_feed_entry}",
)

get_dialog_messages_args = {}
if last_feed_entry:
Expand All @@ -85,6 +88,18 @@ async def update_feed(self, dialog: custom.Dialog):
dialog=dialog, **get_dialog_messages_args
)

for new_message in new_dialog_messages:
if new_message.date is None:
logging.warning(
f"TelegramPoller.update_feed {feed.name} ({feed.id}) -> message without a date! WTF? {new_message}"
)
continue
if last_feed_entry and new_message.date <= last_feed_entry.date:
logging.warning(
f"TelegramPoller.update_feed {feed.name} ({feed.id}) -> TG sent a message older than we requested! WTF? TG sent ut {new_message}, our last known message {last_feed_entry}"
)
continue

feed_entries = await self._process_new_dialog_messages(
feed, new_dialog_messages
)
Expand Down

0 comments on commit 9d86067

Please sign in to comment.