mirror of
https://github.com/paperclipai/paperclip.git
synced 2026-11-10 12:37:55 +01:00
chore(runner): drop added code comments per CONTRIBUTING
Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
This commit is contained in:
1 parent
294f200437
commit
36b7e3846f
3 files changed
+1
-15
No files matched your search
@@ -223,8 +223,7 @@ async function pumpEvents(opened: HarnessSession): Promise<void> {
|
||||
// The inner OpenCode driver publishes session-scoped model metadata as
|
||||
// an item before any turn exists. The outer Codex protocol facade emits
|
||||
// its own model item, so forwarding this unbound duplicate would quite
|
||||
// correctly trip the facade's strict turn-binding validator. Token
|
||||
// deltas runnerd does not consume stay here; see the predicate.
|
||||
// correctly trip the facade's strict turn-binding validator.
|
||||
if (
|
||||
!shouldForwardOpenCodeProxyItem({
|
||||
eventType: event.eventType,
|
||||
|
||||
@@ -23,9 +23,6 @@ describe("OpenCode runnerd proxy event boundary", () => {
|
||||
});
|
||||
|
||||
it("keeps per-token deltas runnerd discards from queueing ahead of a tool call", () => {
|
||||
// One provider step: streamed reasoning and tool output, a completed
|
||||
// reasoning item, then the tool call request. runnerd pays a durable state
|
||||
// save for every frame it reads, in order, before it reaches the request.
|
||||
const framesBeforeToolCall = (tokens: number) => {
|
||||
vi.useFakeTimers();
|
||||
try {
|
||||
|
||||
@@ -19,16 +19,6 @@ export function openCodeProxyToolNotification(input: {
|
||||
} };
|
||||
}
|
||||
|
||||
/**
|
||||
* runnerd reads this proxy's frames in order, only after its controller
|
||||
* acknowledges earlier events, and saves its whole durable provider state
|
||||
* (including every tool result retained in the turn) for each frame it reads.
|
||||
* Its Codex facade turns only assistant text deltas into events; it discards
|
||||
* every other `item/delta`. OpenCode reports reasoning and tool output one
|
||||
* token at a time, so forwarding those deltas queued each tool call behind
|
||||
* hundreds of discarded frames, and the wait grew with every result the turn
|
||||
* retained. Completed reasoning and tool items still arrive as item/completed.
|
||||
*/
|
||||
export function shouldForwardOpenCodeProxyItem(input: {
|
||||
eventType?: string;
|
||||
turnId?: string;
|
||||
|
||||
Reference in new issue
Block a user