|
999 | 999 | <script type="module"> |
1000 | 1000 | import { |
1001 | 1001 | createLightNode, |
1002 | | - ReliableChannelEvent, |
1003 | 1002 | ReliableChannel, |
1004 | 1003 | HealthStatus, |
1005 | | - WakuEvent |
1006 | | - } from 'https://unpkg.com/@waku/[email protected]/bundle/index.js'; |
| 1004 | + } from 'https://unpkg.com/@waku/[email protected]/bundle/index.js'; |
1007 | 1005 |
|
1008 | 1006 | // Define protobuf schema |
1009 | 1007 | const protoSchema = ` |
|
1813 | 1811 | this.updateStatus('Waiting for peers...', 'connecting'); |
1814 | 1812 |
|
1815 | 1813 | // Subscribe to messages |
1816 | | - this.reliableChannel.addEventListener(ReliableChannelEvent.InMessageReceived, (event) => { |
| 1814 | + this.reliableChannel.addEventListener("message-received", (event) => { |
1817 | 1815 | this.handleIncomingMessage(event.detail); |
1818 | 1816 | }) |
1819 | 1817 |
|
1820 | 1818 | // Subscribe to sent events |
1821 | | - this.reliableChannel.addEventListener(ReliableChannelEvent.OutMessageSent, (event) => { |
| 1819 | + this.reliableChannel.addEventListener("message-sent", (event) => { |
1822 | 1820 | this.addSystemMessage(`Message sent: ${event.detail.toString().substring(0, 12)}...`); |
1823 | 1821 | }) |
1824 | 1822 |
|
|
1849 | 1847 | if (!this.node || !this.node.events) return; |
1850 | 1848 |
|
1851 | 1849 | // Listen for health status changes |
1852 | | - this.node.events.addEventListener(WakuEvent.Health, (event) => { |
| 1850 | + this.node.events.addEventListener("waku:health", (event) => { |
1853 | 1851 | this.handleHealthChange(event.detail); |
1854 | 1852 | }); |
1855 | 1853 | } |
|
1975 | 1973 | // Track this message as locally sent |
1976 | 1974 | this.localSentMessages.set(messageId, chatMessageId); |
1977 | 1975 |
|
1978 | | - this.reliableChannel.addEventListener(ReliableChannelEvent.OutMessageIrrecoverableError, (event) => { |
| 1976 | + this.reliableChannel.addEventListener("sending-message-irrecoverable-error", (event) => { |
1979 | 1977 | if (messageId === event.detail.messageId) { |
1980 | 1978 | console.error('Failed to send message:', event.detail.error); |
1981 | 1979 | this.addSystemMessage(`Failed to send message: ${event.detail.error}`); |
1982 | 1980 | } |
1983 | 1981 | }) |
1984 | 1982 |
|
1985 | | - this.reliableChannel.addEventListener(ReliableChannelEvent.OutMessageSent, (event) => { |
| 1983 | + this.reliableChannel.addEventListener("message-sent", (event) => { |
1986 | 1984 | if (messageId === event.detail) { |
1987 | 1985 | this.updateMessageStatus(chatMessageId, 'sent'); |
1988 | 1986 | // Clear reply after successful send |
|
1992 | 1990 | } |
1993 | 1991 | }) |
1994 | 1992 |
|
1995 | | - this.reliableChannel.addEventListener(ReliableChannelEvent.OutMessageAcknowledged, (event) => { |
| 1993 | + this.reliableChannel.addEventListener("message-acknowledged", (event) => { |
1996 | 1994 | console.log("received ack", event.detail) |
1997 | 1995 | if (messageId === event.detail) { |
1998 | 1996 | this.updateMessageStatus(chatMessageId, 'acknowledged'); |
|
0 commit comments