🧷 chore: Expose Retain Recent Summarization Config (#14134)

packages/api/src/agents/__tests__/run-summarization.test.ts

@@ -398,6 +398,7 @@ describe('summarizationConfig field passthrough', () => {
         updatePrompt: 'Update the existing summary with new messages',
         reserveRatio: 0.1,
         maxSummaryTokens: 4096,
+        retainRecent: { turns: 5, tokens: 40000 },
       },
     });
     const config = agents[0].summarizationConfig as Record<string, unknown>;
@@ -413,6 +414,7 @@ describe('summarizationConfig field passthrough', () => {
     expect(config.updatePrompt).toBe('Update the existing summary with new messages');
     expect(config.reserveRatio).toBe(0.1);
     expect(config.maxSummaryTokens).toBe(4096);
+    expect(config.retainRecent).toEqual({ turns: 5, tokens: 40000 });
   });
 
   it('uses self-summarize default when no config provided', async () => {

packages/api/src/agents/run.ts

@@ -633,6 +633,7 @@ function shapeSummarizationConfig(
       updatePrompt: config?.updatePrompt,
       reserveRatio: config?.reserveRatio,
       maxSummaryTokens: config?.maxSummaryTokens,
+      retainRecent: config?.retainRecent,
     } satisfies AgentSummarizationConfig,
     contextPruning: config?.contextPruning as ContextPruningConfig | undefined,
     reserveRatio: config?.reserveRatio,

packages/data-provider/specs/config-schemas.spec.ts

@@ -11,6 +11,7 @@ import {
   SKILL_SYNC_MAX_INTERVAL_MINUTES,
   summarizationTriggerSchema,
   summarizationConfigSchema,
+  retainRecentConfigSchema,
   MAX_SUBAGENTS,
 } from '../src/config';
 import {
@@ -1113,6 +1114,35 @@ describe('summarizationTriggerSchema', () => {
   });
 });
 
+describe('retainRecentConfigSchema', () => {
+  it('accepts turn and token retention limits', () => {
+    const result = retainRecentConfigSchema.safeParse({
+      turns: 5,
+      tokens: 40000,
+    });
+
+    expect(result.success).toBe(true);
+  });
+
+  it('rejects invalid turn and token retention limits', () => {
+    expect(retainRecentConfigSchema.safeParse({ turns: -1 }).success).toBe(false);
+    expect(retainRecentConfigSchema.safeParse({ turns: 21 }).success).toBe(false);
+    expect(retainRecentConfigSchema.safeParse({ tokens: 0 }).success).toBe(false);
+  });
+
+  it('parses inside the full summarization config', () => {
+    const result = summarizationConfigSchema.safeParse({
+      enabled: true,
+      retainRecent: { turns: 5, tokens: 40000 },
+    });
+
+    expect(result.success).toBe(true);
+    if (result.success) {
+      expect(result.data.retainRecent).toEqual({ turns: 5, tokens: 40000 });
+    }
+  });
+});
+
 describe('specsConfigSchema', () => {
   it('accepts an empty list (defaults applied)', () => {
     const result = specsConfigSchema.safeParse({ list: [] });

packages/data-provider/src/config.ts

@@ -1781,6 +1781,11 @@ export const contextPruningSchema = z.object({
   minPrunableToolChars: z.number().min(0).optional(),
 });
 
+export const retainRecentConfigSchema = z.object({
+  turns: z.number().min(0).max(20).optional(),
+  tokens: z.number().positive().optional(),
+});
+
 export const summarizationConfigSchema = z.object({
   enabled: z.boolean().optional(),
   provider: z.string().optional(),
@@ -1792,6 +1797,7 @@ export const summarizationConfigSchema = z.object({
   reserveRatio: z.number().min(0).max(1).optional(),
   maxSummaryTokens: z.number().positive().optional(),
   contextPruning: contextPruningSchema.optional(),
+  retainRecent: retainRecentConfigSchema.optional(),
 });
 
 export type SummarizationConfig = z.infer<typeof summarizationConfigSchema>;