From 9c7ed38d45ec2740d8beb0d5630ecb525243a66b Mon Sep 17 00:00:00 2001
From: Adam Soltys <asoltys@gmail.com>
Date: Tue, 20 Dec 2022 12:25:20 -0800
Subject: nostr feed

---
 src/lib/socket.js | 23 ++++++++++++++++++++++-
 1 file changed, 22 insertions(+), 1 deletion(-)

(limited to 'src/lib/socket.js')

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);
 	},
-- 
cgit v1.2.3