(payload)
| 468 | } |
| 469 | |
| 470 | function handleStreamEvent(payload) { |
| 471 | log('Handling stream event:', payload.type, payload); |
| 472 | |
| 473 | switch (payload.type) { |
| 474 | case 'stream-connection': |
| 475 | addConnection({ |
| 476 | id: payload.connectionId, |
| 477 | url: payload.url, |
| 478 | frameUrl: payload.frameUrl, |
| 479 | isIframe: payload.isIframe, |
| 480 | source: payload.source || 'unknown', |
| 481 | status: 'connecting', |
| 482 | createdAt: payload.timestamp, |
| 483 | messages: [] |
| 484 | }); |
| 485 | log('Created connection:', payload.connectionId, payload.url); |
| 486 | selectConnection(payload.connectionId); |
| 487 | break; |
| 488 | |
| 489 | case 'stream-open': |
| 490 | updateConnectionStatus(payload.connectionId, 'open'); |
| 491 | log('Connection opened:', payload.connectionId); |
| 492 | renderConnectionList(); |
| 493 | break; |
| 494 | |
| 495 | case 'stream-message': |
| 496 | addMessage(payload.connectionId, { |
| 497 | id: payload.messageId, |
| 498 | eventType: payload.eventType, |
| 499 | data: payload.data, |
| 500 | lastEventId: payload.lastEventId, |
| 501 | timestamp: payload.timestamp |
| 502 | }); |
| 503 | log('Added message #' + payload.messageId + ' to connection:', payload.connectionId); |
| 504 | renderConnectionList(); |
| 505 | if (state.selectedConnectionId === payload.connectionId && callbacks$6.renderMessageList) { |
| 506 | callbacks$6.renderMessageList(); |
| 507 | } |
| 508 | break; |
| 509 | |
| 510 | case 'stream-error': |
| 511 | updateConnectionStatus(payload.connectionId, 'error'); |
| 512 | renderConnectionList(); |
| 513 | break; |
| 514 | |
| 515 | case 'stream-close': |
| 516 | updateConnectionStatus(payload.connectionId, 'closed'); |
| 517 | renderConnectionList(); |
| 518 | break; |
| 519 | } |
| 520 | } |
| 521 | |
| 522 | // Re-export state functions for use in this module |
| 523 | function setSelectedConnection(connectionId) { |
no test coverage detected