fix: report an oversized wire record as an incomplete sync pass

A wire record larger than the pending cap now marks the pass truncated instead of leaving the index reporting ready with an unindexed tail, and a regression test pins the state.

Author: elkaix

packages/agent-gateway/src/search/indexCore.ts

@@ -749,6 +749,7 @@ export class SearchIndexCore {
     let byteCursor = offset;
     let position = offset;
     let wireError: unknown;
+    let pendingOverflow = false;
     try {
       let pending: Buffer = EMPTY_BUFFER;
       let finishing = false;
@@ -802,7 +803,10 @@ export class SearchIndexCore {
           pending.length > 0
             ? Buffer.concat([pending, slice.subarray(start)])
             : Buffer.from(slice.subarray(start));
-        if (pending.length > MAX_WIRE_PENDING_BYTES) break;
+        if (pending.length > MAX_WIRE_PENDING_BYTES) {
+          pendingOverflow = true;
+          break;
+        }
         if (finishing && completedRecord) break;
         if (ops.length >= WIRE_BATCH_OPS) {
           ops.push({ op: 'set', key: metaKey, value: fileMeta(byteCursor, turnState, stepState) });
@@ -818,7 +822,7 @@ export class SearchIndexCore {
       await handle.close();
     }
 
-    const truncated = position < size && syncBudgetExhausted(budget);
+    const truncated = pendingOverflow || (position < size && syncBudgetExhausted(budget));
     if (byteCursor !== offset || legacyKey !== null) {
       ops.push({ op: 'set', key: metaKey, value: fileMeta(byteCursor, turnState, stepState) });
       if (legacyKey !== null) ops.push({ op: 'del', key: legacyKey });

packages/agent-gateway/test/search/searchService.test.ts

@@ -423,6 +423,17 @@ describe('GlobalSearchService', () => {
     expect(page.items.length).toBe(2);
     expect(page.items.some((h) => h.snippet.includes('appended'))).toBe(true);
   });
+  it('keeps the index incomplete while a wire record exceeds the pending cap', async () => {
+    const s1 = summary('s1', 'overflow', T1);
+    const file = await writeWire(home!, 's1', 'main', [userLine('\u82F9\u679C head', T1)]);
+    await appendFile(file, `{"kind":"step","pad":"${'x'.repeat(5 * 1024 * 1024)}"`, 'utf8');
+    const service = track(makeService(home!, staticIndex([s1])));
+
+    await service.reindex();
+    const page = await service.search({ query: '\u82F9\u679C' });
+    expect(page.items.length).toBe(1);
+    expect(page.indexState.state).not.toBe('ready');
+  });
 
   it('reports indexState building before the first full sync and ready after', async () => {
     const s1 = summary('s1', 'state', T1);