teleo/teleo-infrastructure
8
0
Fork 0
Code Issues Pull requests 2 Projects Releases Packages Wiki Activity Actions 1

feat: atomic extract-and-connect + stale PR monitor + response audit #4

Merged
m3taversal merged 70 commits from epimetheus/atomic-connect-and-stale-monitor into main 2026-03-30 11:03:35 +00:00
Conversation 0 Commits 70 Files changed 58 +9 -9
1 changed files with 9 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit 0759655688 - Show all commits

18
telegram/bot.py
View file

@ -820,17 +820,17 @@ IMPORTANT: Two special tags you can append at the end of your response (after yo
# Log the exchange for audit trail # Log the exchange for audit trail
logger.info("Rio responded to @%s (msg_id=%d)", user.username if user else "?", msg.message_id) logger.info("Rio responded to @%s (msg_id=%d)", user.username if user else "?", msg.message_id)
# Detect and fetch URLs for pipeline ingestion # Detect and fetch URLs for pipeline ingestion (all URLs, not just first)
urls = _extract_urls(text) urls = _extract_urls(text)
url_content = None url_content = None
if urls: for url in urls[:5]: # Cap at 5 URLs per message
logger.info("Fetching URL: %s", urls[0]) logger.info("Fetching URL: %s", url)
url_content = await _fetch_url_content(urls[0]) content = await _fetch_url_content(url)
if url_content: if content:
logger.info("Fetched %d chars from %s", len(url_content), urls[0]) logger.info("Fetched %d chars from %s", len(content), url)
# Create standalone source file for the article (separate from conversation) if url_content is None:
# This enters the extraction pipeline as a proper source, attributed to contributor url_content = content # First URL's content for conversation archive
_archive_standalone_source(urls[0], url_content, user) _archive_standalone_source(url, content, user)
# Archive the exchange as a source for pipeline (slow path) # Archive the exchange as a source for pipeline (slow path)
_archive_exchange(text, response, user, msg, url_content=url_content, urls=urls) _archive_exchange(text, response, user, msg, url_content=url_content, urls=urls)