(ev)
| 1135 | } |
| 1136 | }, |
| 1137 | async onmessage(ev) { |
| 1138 | const payload = JSON.parse(ev.data) |
| 1139 | switch (payload.event) { |
| 1140 | case 'start': |
| 1141 | setMessages((prevMessages) => [...prevMessages, { message: '', type: 'apiMessage' }]) |
| 1142 | break |
| 1143 | case 'token': |
| 1144 | updateLastMessage(payload.data) |
| 1145 | break |
| 1146 | case 'sourceDocuments': |
| 1147 | updateLastMessageSourceDocuments(payload.data) |
| 1148 | break |
| 1149 | case 'usedTools': |
| 1150 | updateLastMessageUsedTools(payload.data) |
| 1151 | break |
| 1152 | case 'calledTools': |
| 1153 | updateLastMessageCalledTools(payload.data) |
| 1154 | break |
| 1155 | case 'fileAnnotations': |
| 1156 | updateLastMessageFileAnnotations(payload.data) |
| 1157 | break |
| 1158 | case 'agentReasoning': |
| 1159 | updateLastMessageAgentReasoning(payload.data) |
| 1160 | break |
| 1161 | case 'thinking': |
| 1162 | handleThinkingEvent(payload.data, payload.duration) |
| 1163 | break |
| 1164 | case 'agentFlowEvent': |
| 1165 | updateAgentFlowEvent(payload.data) |
| 1166 | break |
| 1167 | case 'agentFlowExecutedData': |
| 1168 | updateAgentFlowExecutedData(payload.data) |
| 1169 | break |
| 1170 | case 'artifacts': |
| 1171 | updateLastMessageArtifacts(payload.data) |
| 1172 | break |
| 1173 | case 'action': |
| 1174 | updateLastMessageAction(payload.data) |
| 1175 | break |
| 1176 | case 'nextAgent': |
| 1177 | updateLastMessageNextAgent(payload.data) |
| 1178 | break |
| 1179 | case 'nextAgentFlow': |
| 1180 | updateLastMessageNextAgentFlow(payload.data) |
| 1181 | break |
| 1182 | case 'metadata': |
| 1183 | updateMetadata(payload.data, input) |
| 1184 | break |
| 1185 | case 'error': |
| 1186 | updateErrorMessage(payload.data) |
| 1187 | break |
| 1188 | case 'abort': |
| 1189 | abortMessage(payload.data) |
| 1190 | closeResponse() |
| 1191 | break |
| 1192 | case 'tts_start': |
| 1193 | handleTTSStart(payload.data) |
| 1194 | break |
nothing calls this directly
no test coverage detected