diff options
| author | Adam Soltys <[email protected]> | 2022-12-20 12:25:20 -0800 |
|---|---|---|
| committer | Adam Soltys <[email protected]> | 2022-12-20 12:25:23 -0800 |
| commit | 9c7ed38d45ec2740d8beb0d5630ecb525243a66b (patch) | |
| tree | c021950414623453cb56439dcb707ddfbfd65960 /src/lib/socket.js | |
| parent | 64853b801688edf7a8858b7c1135502e5882823c (diff) | |
| download | coinos-ui-9c7ed38d45ec2740d8beb0d5630ecb525243a66b.tar.gz coinos-ui-9c7ed38d45ec2740d8beb0d5630ecb525243a66b.zip | |
nostr feed
Diffstat (limited to 'src/lib/socket.js')
| -rw-r--r-- | src/lib/socket.js | 23 |
1 files changed, 22 insertions, 1 deletions
diff --git a/src/lib/socket.js b/src/lib/socket.js index 95b4a512..43f6c386 100644 --- a/src/lib/socket.js +++ b/src/lib/socket.js @@ -1,10 +1,23 @@ import { get } from 'svelte/store'; -import { invoices, invoice, request, newPayment, last, rate, txns, user } from '$lib/store'; +import { + events as $events, + invoices, + invoice, + request, + newPayment, + last, + rate, + txns, + user +} from '$lib/store'; import { success, sat } from '$lib/utils'; import { PUBLIC_SOCKET } from '$env/static/public'; import { invalidate } from '$app/navigation'; let socket, token; +let events = get($events); +delete events.q; +events.q = Object.keys(events); export const auth = () => token && send('login', token) && send('heartbeat'); @@ -22,6 +35,14 @@ export const messages = (data) => ({ invoice.set(data); }, + event() { + data.seen = Math.round(Date.now() / 1000); + events[data.id] = data; + events.q.push(data.id); + $events.set(events); + if (events.q.length > 1000) events.delete[events.q.shift()]; + }, + rate() { rate.set(data); }, |
