aboutsummaryrefslogtreecommitdiffstats
path: root/src/lib/socket.js
diff options
context:
space:
mode:
authorAdam Soltys <[email protected]>2022-12-20 12:25:20 -0800
committerAdam Soltys <[email protected]>2022-12-20 12:25:23 -0800
commit9c7ed38d45ec2740d8beb0d5630ecb525243a66b (patch)
treec021950414623453cb56439dcb707ddfbfd65960 /src/lib/socket.js
parent64853b801688edf7a8858b7c1135502e5882823c (diff)
downloadcoinos-ui-9c7ed38d45ec2740d8beb0d5630ecb525243a66b.tar.gz
coinos-ui-9c7ed38d45ec2740d8beb0d5630ecb525243a66b.zip
nostr feed
Diffstat (limited to 'src/lib/socket.js')
-rw-r--r--src/lib/socket.js23
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);
},