@@ -33,7 +33,7 @@ const LATSAgent = () => {
3333 goal : 'search running shoes, click on the first result' ,
3434 maxDepth : 3 ,
3535 num_simulations : 1 ,
36- iterations : 1
36+ iterations : 2
3737 } ) ;
3838
3939 const [ sessionId , setSessionId ] = useState < string | null > ( null ) ;
@@ -87,10 +87,17 @@ const LATSAgent = () => {
8787 wsRef . current = new WebSocket ( wsUrl ) ;
8888
8989 wsRef . current . onopen = ( ) => {
90- logMessage ( 'Connected to LATS WebSocket server' ) ;
90+ const connectionMessage = {
91+ type : "server_connection" ,
92+ info : 'Connecting to LATS WebSocket server'
93+ } ;
94+
95+ wsRef . current ?. send ( JSON . stringify ( connectionMessage ) ) ;
96+ logMessage ( connectionMessage , 'incoming' ) ;
97+ // logMessage('Connected to LATS WebSocket server');
9198 setConnected ( true ) ;
9299
93- const request = {
100+ const searchRequest = {
94101 type : "start_search" ,
95102 agent_type : "LATSAgent" ,
96103 starting_url : searchParams . startingUrl ,
@@ -101,8 +108,8 @@ const LATSAgent = () => {
101108 iterations : searchParams . iterations
102109 } ;
103110
104- wsRef . current ?. send ( JSON . stringify ( request ) ) ;
105- logMessage ( request , 'outgoing' ) ;
111+ wsRef . current ?. send ( JSON . stringify ( searchRequest ) ) ;
112+ logMessage ( searchRequest , 'outgoing' ) ;
106113 } ;
107114
108115 wsRef . current . onmessage = ( event ) => {
@@ -119,19 +126,31 @@ const LATSAgent = () => {
119126 } ;
120127
121128 wsRef . current . onclose = ( ) => {
122- logMessage ( 'Disconnected from WebSocket server' ) ;
129+ const closeMessage = {
130+ type : "server_connection" ,
131+ info : 'Disconnected from WebSocket server'
132+ } ;
133+ logMessage ( closeMessage , 'incoming' ) ;
123134 setConnected ( false ) ;
124135 setIsSearching ( false ) ;
125136 wsRef . current = null ;
126137 } ;
127138
128139 wsRef . current . onerror = ( error ) => {
129- logMessage ( `WebSocket error: ${ error instanceof Error ? error . message : String ( error ) } ` ) ;
140+ const errorMessage = {
141+ type : "server_connection" ,
142+ info : `WebSocket error: ${ error instanceof Error ? error . message : String ( error ) } `
143+ } ;
144+ logMessage ( errorMessage , 'incoming' ) ;
130145 setConnected ( false ) ;
131146 setIsSearching ( false ) ;
132147 } ;
133148 } catch ( error ) {
134- logMessage ( `Failed to connect: ${ error instanceof Error ? error . message : String ( error ) } ` ) ;
149+ const errorMessage = {
150+ type : "server_connection" ,
151+ info : `Failed to connect: ${ error instanceof Error ? error . message : String ( error ) } `
152+ } ;
153+ logMessage ( errorMessage , 'incoming' ) ;
135154 setConnected ( false ) ;
136155 setIsSearching ( false ) ;
137156 }
@@ -164,9 +183,17 @@ const LATSAgent = () => {
164183 if ( ! response . ok ) {
165184 throw new Error ( `Failed to terminate session: ${ response . statusText } ` ) ;
166185 }
167- logMessage ( `Session ${ sessionId } terminated successfully` ) ;
186+ const terminateMessage = {
187+ type : "server_connection" ,
188+ info : `Session ${ sessionId } terminated successfully`
189+ } ;
190+ logMessage ( terminateMessage , 'incoming' ) ;
168191 } catch ( error ) {
169- logMessage ( `Failed to terminate session: ${ error instanceof Error ? error . message : String ( error ) } ` ) ;
192+ const errorMessage = {
193+ type : "server_connection" ,
194+ info : `Failed to terminate session: ${ error instanceof Error ? error . message : String ( error ) } `
195+ } ;
196+ logMessage ( errorMessage , 'incoming' ) ;
170197 }
171198 }
172199
0 commit comments