@@ -1398,6 +1398,29 @@ test("restores queued compaction from durable pending input", async () => {
13981398 { type : "compaction-queued" , inputID : "message-compaction-later" } ,
13991399 ] )
14001400
1401+ emitEvent ( events , {
1402+ id : "evt_step_started" ,
1403+ created : 2 ,
1404+ type : "session.step.started" ,
1405+ durable : durable ( sessionID , 3 ) ,
1406+ data : {
1407+ sessionID,
1408+ assistantMessageID : "message-assistant" ,
1409+ agent : "build" ,
1410+ model : { id : "model" , providerID : "provider" } ,
1411+ } ,
1412+ } )
1413+ emitEvent ( events , {
1414+ id : "evt_text_started" ,
1415+ created : 2 ,
1416+ type : "session.text.started" ,
1417+ durable : durable ( sessionID , 4 ) ,
1418+ data : {
1419+ sessionID,
1420+ assistantMessageID : "message-assistant" ,
1421+ ordinal : 0 ,
1422+ } ,
1423+ } )
14011424 emitEvent ( events , {
14021425 id : "evt_text_ended" ,
14031426 created : 2 ,
@@ -1417,7 +1440,7 @@ test("restores queued compaction from durable pending input", async () => {
14171440 id : "evt_compaction_started" ,
14181441 created : 2 ,
14191442 type : "session.compaction.started" ,
1420- durable : durable ( sessionID , 4 ) ,
1443+ durable : durable ( sessionID , 6 ) ,
14211444 data : {
14221445 sessionID,
14231446 reason : "manual" ,
@@ -1432,7 +1455,7 @@ test("restores queued compaction from durable pending input", async () => {
14321455 id : "evt_compaction_ended" ,
14331456 created : 3 ,
14341457 type : "session.compaction.ended" ,
1435- durable : durable ( sessionID , 5 ) ,
1458+ durable : durable ( sessionID , 7 ) ,
14361459 data : { sessionID, reason : "manual" , text : "Summary" , recent : "" } ,
14371460 } )
14381461 expect ( data . session . pending . list ( sessionID ) . map ( ( item ) => item . id ) ) . toEqual ( [ "message-compaction-later" ] )
0 commit comments