ranxianglei/billion-context

Largest clones in the code

• 64 lines in 2 placestypescript534 tokens
  src/server/prepare-google.ts:205–268·src/server/prepare-openai.ts:322–392

  205const turn = core.processTurn({ messages: renderMsgs, state: session.state, config: loopConfig, tokenCount, tokenCountSource, renderTags: renderStrategy, conte…
  206session.state = turn.state;
  207adoptContentStore(session, turn.contentStore);
  208// #4528: split the kernel pass from its post-processing scan passes so
  209// each is a bounded synchronous stretch rather than one long block.
  210await yieldToEventLoop();
  211// The fold from last turn's compress has now materialized in state —
  212// future usage reports are post-fold reality, drop the credit.
  213session.stats.compressCreditTokens = 0;
  214if (foldCoveredBefore !== null && !isTitleGen && msgs.length >= REWRITE_MIN_INCOMING_TOTAL) {
  

  First 10 of 64 lines.

• 58 lines in 2 placestypescript483 tokens
  src/server/prepare-anthropic.ts:375–432·src/server/prepare-google.ts:214–268

  375if (foldCoveredBefore !== null && msgs.length >= REWRITE_MIN_INCOMING_TOTAL) {
  376    const gap = foldCoverage(foldCoveredBefore, msgs.map((m) => m.id));
  377    if (gap) log("warn", `[${sessionId}] [acp-drift] fold coverage mismatch: ${gap.matched}/${gap.expected} covered message id(s) present in resent history — $…
  378}
  379storeEffectiveAbsorb(session, loopConfig);
  380storeEffectiveRules(session, config);
  381turn.messages = applyAbsorbView(turn.messages, session.state, loopConfig, tokenCount);
  382turn.messages = attachSubagentSessions(turn.messages, session);
  383// Drop sub-viability fragments before any consumer sees them: a tiny
  384// range in the list makes batched compress attempts fail atomically
  

  214if (foldCoveredBefore !== null && !isTitleGen && msgs.length >= REWRITE_MIN_INCOMING_TOTAL) {
  215    const gap = foldCoverage(foldCoveredBefore, msgs.map((m) => m.id));
  216    if (gap) log("warn", `[${sessionId}] [acp-drift] fold coverage mismatch: ${gap.matched}/${gap.expected} covered message id(s) present in resent history — $…
  217}
  218storeEffectiveAbsorb(session, loopConfig);
  219storeEffectiveRules(session, config);
  220turn.messages = applyAbsorbView(turn.messages, session.state, loopConfig, tokenCount);
  221turn.messages = attachSubagentSessions(turn.messages, session);
  222// #3204: also drop DEAD-ref-bracketing spans at this single point so
  223// every downstream consumer (decision prompt + directive, prose nudge,
  

  First 10 of 58 lines, the second copy on the right.

• 9 lines in 5 placestypescript77 tokens
  src/server/admin.ts:811–819·src/server/admin.ts:846–854·src/server/admin.ts:859–867·src/server/admin.ts:870–878·src/server/admin.ts:883–897

  811        handlePluginRegister(body.toString("utf8"), res);
  812        return;
  813    } catch (err) {
  814        res.writeHead(err instanceof BodyTooLargeError ? 413 : 400, { "content-type": "application/json" });
  815        res.end(JSON.stringify({ ok: false, error: String(err) }));
  816        return;
  817    }
  818}
  819if (req.method === "POST" && req.url === "/__bili/agent-providers") {
  

  846        handlePluginRuntimeInfo(body.toString("utf8"), res);
  847        return;
  848    } catch (err) {
  849        res.writeHead(err instanceof BodyTooLargeError ? 413 : 400, { "content-type": "application/json" });
  850        res.end(JSON.stringify({ ok: false, error: String(err) }));
  851        return;
  852    }
  853}
  854if (req.method === "POST" && req.url === "/__bili/plugin/attribution") {