Fix empty query crash in context assembly + telegram offset

- context_assembly.py: pass attention_text to search_hybrid instead of
  empty string (pre-existing bug, crashed on first real message)
- telegram_peripheral.py: fix drop_pending_updates offset calculation
  to prevent replaying old messages on startup

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: stonks-git

src/context_assembly.py

@@ -43,6 +43,7 @@ async def assemble_context(
     cognitive_state_report: str,
     conversation: list[dict],
     total_budget: int = 131072,
+    attention_text: str = "",
 ) -> dict:
     """Assemble the full context for an LLM call.
 
@@ -94,6 +95,7 @@ async def assemble_context(
     if situational_budget > 0 and attention_embedding is not None:
         situational = await _get_situational_memories(
             memory_store, attention_embedding, situational_budget,
+            query_text=attention_text,
         )
         for mem in situational:
             parts["situational"].append(
@@ -222,14 +224,13 @@ async def _get_top_identity_memories(memory_store, top_n: int) -> list[dict]:
 
 async def _get_situational_memories(
     memory_store, attention_embedding: np.ndarray, budget: int,
+    query_text: str = "",
 ) -> list[dict]:
     """Retrieve situationally relevant memories within token budget."""
-    # Use hybrid search for retrieval
+    if not query_text:
+        return []  # Can't search without query text
     candidates = await memory_store.search_hybrid(
-        # We need the query text, but we have the embedding.
-        # For now, use search_similar which accepts embeddings via text.
-        # This will be improved when retrieval pipeline is fully wired.
-        query="",  # placeholder — will use attention embedding directly later
+        query=query_text,
         top_k=10,
     )
 

src/loop.py

@@ -441,6 +441,7 @@ async def cognitive_loop(config, layers, memory, shutdown_event, input_queue: as
                 cognitive_state_report=cognitive_report,
                 conversation=conversation,
                 total_budget=131072,
+                attention_text=winner.content,
             )
 
             system_prompt = render_system_prompt(context)

src/telegram_peripheral.py

@@ -68,8 +68,12 @@ async def run(self, shutdown_event: asyncio.Event):
                 return
 
             # Drop pending updates from before this session
-            await self._api("getUpdates", {"offset": -1})
-            self._offset = 0
+            drop = await self._api("getUpdates", {"offset": -1})
+            if drop:
+                last_id = max(u.get("update_id", 0) for u in drop)
+                self._offset = last_id + 1
+            else:
+                self._offset = 0
 
             # Main polling loop
             while not shutdown_event.is_set():