{"version":3,"file":"context.d.ts","sourceRoot":"","sources":["../../../src/harness/session/context.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EAAE,YAAY,EAAE,MAAM,gBAAgB,CAAC;AACnD,OAAO,KAAK,EAAE,OAAO,EAAE,MAAM,eAAe,CAAC;AAE7C,OAAO,KAAK,EAAmB,KAAK,EAAE,cAAc,EAAE,MAAM,YAAY,CAAC;AAEzE,MAAM,WAAW,0BAA0B;IAC1C,eAAe,CAAC,EAAE,QAAQ,CAAC,MAAM,CAAC,MAAM,EAAE,cAAc,CAAC,CAAC,CAAC;CAC3D;AAED,wBAAgB,mBAAmB,CAAC,WAAW,EAAE,SAAS,KAAK,EAAE,GAAG,KAAK,EAAE,CAY1E;AASD,wBAAgB,6BAA6B,CAAC,KAAK,EAAE,KAAK,GAAG,YAAY,EAAE,CAc1E;AAED,wBAAsB,mBAAmB,CACxC,WAAW,EAAE,SAAS,KAAK,EAAE,EAC7B,OAAO,EAAE,0BAA0B,GAAG,SAAS,EAC/C,OAAO,EAAE,OAAO,GACd,OAAO,CAAC,YAAY,EAAE,CAAC,CAazB","sourcesContent":["import type { AgentMessage } from \"../../types.ts\";\nimport type { Context } from \"../context.ts\";\nimport { createBranchSummaryMessage, createCompactionSummaryMessage } from \"../messages.ts\";\nimport type { CompactionEntry, Entry, EntryProjector } from \"./types.ts\";\n\nexport interface SessionContextBuildOptions {\n\tentryProjectors?: Readonly<Record<string, EntryProjector>>;\n}\n\nexport function buildContextEntries(pathEntries: readonly Entry[]): Entry[] {\n\tlet compaction: CompactionEntry | undefined;\n\tlet compactionIndex = -1;\n\tfor (let index = pathEntries.length - 1; index >= 0; index--) {\n\t\tconst entry = pathEntries[index];\n\t\tif (entry?.type === \"compaction\") {\n\t\t\tcompaction = entry;\n\t\t\tcompactionIndex = index;\n\t\t\tbreak;\n\t\t}\n\t}\n\treturn compaction === undefined ? [...pathEntries] : [compaction, ...pathEntries.slice(compactionIndex + 1)];\n}\n\nfunction isContextMessage(message: AgentMessage): boolean {\n\treturn (\n\t\tmessage.role !== \"assistant\" ||\n\t\t(message.stopReason !== \"error\" && message.stopReason !== \"aborted\" && message.stopReason !== \"deferred\")\n\t);\n}\n\nexport function sessionEntryToContextMessages(entry: Entry): AgentMessage[] {\n\tswitch (entry.type) {\n\t\tcase \"message\":\n\t\t\treturn isContextMessage(entry.message) ? [entry.message] : [];\n\t\tcase \"compaction\":\n\t\t\treturn [\n\t\t\t\tcreateCompactionSummaryMessage(entry.summary, entry.tokensBefore, entry.timestamp),\n\t\t\t\t...entry.retainedTail.filter(isContextMessage),\n\t\t\t];\n\t\tcase \"branch_summary\":\n\t\t\treturn entry.summary ? [createBranchSummaryMessage(entry.summary, entry.fromId, entry.timestamp)] : [];\n\t\tcase \"custom\":\n\t\t\treturn [];\n\t}\n}\n\nexport async function buildSessionContext(\n\tpathEntries: readonly Entry[],\n\toptions: SessionContextBuildOptions | undefined,\n\tcontext: Context,\n): Promise<AgentMessage[]> {\n\toptions ??= {};\n\tconst entries = buildContextEntries(pathEntries);\n\tconst messages: AgentMessage[] = [];\n\tfor (const entry of entries) {\n\t\tif (entry.type !== \"custom\") {\n\t\t\tmessages.push(...sessionEntryToContextMessages(entry));\n\t\t\tcontinue;\n\t\t}\n\t\tconst projector = options.entryProjectors?.[entry.customType];\n\t\tif (projector !== undefined) messages.push(...((await projector(entry, context)) ?? []));\n\t}\n\treturn messages;\n}\n"]}