@@ -17,47 +17,47 @@ import { ILogger } from '@theia/core';
1717import { MockLogger } from '@theia/core/lib/common/test/mock-logger' ;
1818import { DefaultCommunicationRecordingService } from './communication-recording-service' ;
1919import { expect } from 'chai' ;
20- import { LanguageModelRequestMessage } from '@theia/ai-core' ;
20+ import { TextMessage } from '@theia/ai-core' ;
2121
2222describe ( 'DefaultCommunicationRecordingService' , ( ) => {
2323
2424 it ( 'records history' , ( ) => {
2525 const service = new DefaultCommunicationRecordingService ( ) ;
2626 ( service as unknown as { logger : ILogger } ) . logger = new MockLogger ( ) ;
27- service . recordRequest ( { agentId : 'agent' , requestId : '1' , sessionId : '1' , timestamp : 100 , request : [ { type : 'text' , actor : 'user' , query : 'dummy request' } ] } ) ;
27+ service . recordRequest ( { agentId : 'agent' , requestId : '1' , sessionId : '1' , timestamp : 100 , request : [ { type : 'text' , actor : 'user' , text : 'dummy request' } ] } ) ;
2828
2929 const history1 = service . getHistory ( 'agent' ) ;
30- expect ( ( history1 [ 0 ] . request ?. [ 0 ] as LanguageModelRequestMessage ) . query ) . to . eq ( 'dummy request' ) ;
30+ expect ( ( history1 [ 0 ] . request ?. [ 0 ] as TextMessage ) . text ) . to . eq ( 'dummy request' ) ;
3131
32- service . recordResponse ( { agentId : 'agent' , requestId : '1' , sessionId : '1' , timestamp : 200 , response : [ { type : 'text' , actor : 'ai' , query : 'dummy response' } ] } ) ;
32+ service . recordResponse ( { agentId : 'agent' , requestId : '1' , sessionId : '1' , timestamp : 200 , response : [ { type : 'text' , actor : 'ai' , text : 'dummy response' } ] } ) ;
3333 const history2 = service . getHistory ( 'agent' ) ;
34- expect ( ( history2 [ 0 ] . request ?. [ 0 ] as LanguageModelRequestMessage ) . query ) . to . eq ( 'dummy request' ) ;
35- expect ( ( history2 [ 0 ] . response ?. [ 0 ] as LanguageModelRequestMessage ) . query ) . to . eq ( 'dummy response' ) ;
34+ expect ( ( history2 [ 0 ] . request ?. [ 0 ] as TextMessage ) . text ) . to . eq ( 'dummy request' ) ;
35+ expect ( ( history2 [ 0 ] . response ?. [ 0 ] as TextMessage ) . text ) . to . eq ( 'dummy response' ) ;
3636 } ) ;
3737
3838 it ( 'returns session history' , ( ) => {
3939 const service = new DefaultCommunicationRecordingService ( ) ;
4040 ( service as unknown as { logger : ILogger } ) . logger = new MockLogger ( ) ;
4141 // some requests and responses for session 1
42- service . recordRequest ( { agentId : 'agent' , requestId : '1' , sessionId : '1' , timestamp : 100 , request : [ { type : 'text' , actor : 'user' , query : 'session 1 request 1' } ] } ) ;
43- service . recordResponse ( { agentId : 'agent' , requestId : '1' , sessionId : '1' , timestamp : 200 , response : [ { type : 'text' , actor : 'ai' , query : 'session 1 response 1' } ] } ) ;
44- service . recordRequest ( { agentId : 'agent2' , requestId : '2' , sessionId : '1' , timestamp : 100 , request : [ { type : 'text' , actor : 'user' , query : 'session 1 request 2' } ] } ) ;
45- service . recordResponse ( { agentId : 'agent2' , requestId : '2' , sessionId : '1' , timestamp : 200 , response : [ { type : 'text' , actor : 'ai' , query : 'session 1 response 2' } ] } ) ;
42+ service . recordRequest ( { agentId : 'agent' , requestId : '1' , sessionId : '1' , timestamp : 100 , request : [ { type : 'text' , actor : 'user' , text : 'session 1 request 1' } ] } ) ;
43+ service . recordResponse ( { agentId : 'agent' , requestId : '1' , sessionId : '1' , timestamp : 200 , response : [ { type : 'text' , actor : 'ai' , text : 'session 1 response 1' } ] } ) ;
44+ service . recordRequest ( { agentId : 'agent2' , requestId : '2' , sessionId : '1' , timestamp : 100 , request : [ { type : 'text' , actor : 'user' , text : 'session 1 request 2' } ] } ) ;
45+ service . recordResponse ( { agentId : 'agent2' , requestId : '2' , sessionId : '1' , timestamp : 200 , response : [ { type : 'text' , actor : 'ai' , text : 'session 1 response 2' } ] } ) ;
4646 // some requests and responses for session 2
47- service . recordRequest ( { agentId : 'agent' , requestId : '3' , sessionId : '2' , timestamp : 100 , request : [ { type : 'text' , actor : 'user' , query : 'different session request' } ] } ) ;
48- service . recordResponse ( { agentId : 'agent' , requestId : '3' , sessionId : '2' , timestamp : 200 , response : [ { type : 'text' , actor : 'ai' , query : 'different session request' } ] } ) ;
47+ service . recordRequest ( { agentId : 'agent' , requestId : '3' , sessionId : '2' , timestamp : 100 , request : [ { type : 'text' , actor : 'user' , text : 'different session request' } ] } ) ;
48+ service . recordResponse ( { agentId : 'agent' , requestId : '3' , sessionId : '2' , timestamp : 200 , response : [ { type : 'text' , actor : 'ai' , text : 'different session request' } ] } ) ;
4949
5050 const history1 = service . getSessionHistory ( '1' ) ;
5151 expect ( history1 . length ) . to . eq ( 2 ) ;
52- expect ( ( history1 [ 0 ] . request ?. [ 0 ] as LanguageModelRequestMessage ) . query ) . to . eq ( 'session 1 request 1' ) ;
53- expect ( ( history1 [ 0 ] . response ?. [ 0 ] as LanguageModelRequestMessage ) . query ) . to . eq ( 'session 1 response 1' ) ;
54- expect ( ( history1 [ 1 ] . request ?. [ 0 ] as LanguageModelRequestMessage ) . query ) . to . eq ( 'session 1 request 2' ) ;
55- expect ( ( history1 [ 1 ] . response ?. [ 0 ] as LanguageModelRequestMessage ) . query ) . to . eq ( 'session 1 response 2' ) ;
52+ expect ( ( history1 [ 0 ] . request ?. [ 0 ] as TextMessage ) . text ) . to . eq ( 'session 1 request 1' ) ;
53+ expect ( ( history1 [ 0 ] . response ?. [ 0 ] as TextMessage ) . text ) . to . eq ( 'session 1 response 1' ) ;
54+ expect ( ( history1 [ 1 ] . request ?. [ 0 ] as TextMessage ) . text ) . to . eq ( 'session 1 request 2' ) ;
55+ expect ( ( history1 [ 1 ] . response ?. [ 0 ] as TextMessage ) . text ) . to . eq ( 'session 1 response 2' ) ;
5656
5757 const history2 = service . getSessionHistory ( '2' ) ;
5858 expect ( history2 . length ) . to . eq ( 1 ) ;
59- expect ( ( history2 [ 0 ] . request ?. [ 0 ] as LanguageModelRequestMessage ) . query ) . to . eq ( 'different session request' ) ;
60- expect ( ( history2 [ 0 ] . response ?. [ 0 ] as LanguageModelRequestMessage ) . query ) . to . eq ( 'different session request' ) ;
59+ expect ( ( history2 [ 0 ] . request ?. [ 0 ] as TextMessage ) . text ) . to . eq ( 'different session request' ) ;
60+ expect ( ( history2 [ 0 ] . response ?. [ 0 ] as TextMessage ) . text ) . to . eq ( 'different session request' ) ;
6161 } ) ;
6262
6363} ) ;
0 commit comments