1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
|
import { get } from 'svelte/store';
import {
events as $events,
invoice,
request,
newPayment,
last,
rate,
payments,
user
} from '$lib/store';
import { success, sat } from '$lib/utils';
import { PUBLIC_SOCKET } from '$env/static/public';
import { invalidate } from '$app/navigation';
import { browser } from '$app/environment';
let socket, token;
let le = browser && localStorage.getItem('events');
let events = le && le !== 'undefined' ? JSON.parse(le) : {};
let q = Object.keys(events);
export const auth = () => token && send('login', token) && send('heartbeat');
export const send = (type, data) => {
socket?.readyState === 1 && socket.send(JSON.stringify({ type, data }));
return true;
};
export const messages = (data) => ({
id() {
last.set(Date.now());
},
invoice() {
invoice.set(data);
},
event() {
data.seen = Math.round(Date.now() / 1000);
events[data.id] = data;
q.push(data.id);
$events.set(events);
while (q.length > 10000) delete events[q.shift()];
localStorage.setItem(
'events',
JSON.stringify(q.slice(-100).reduce((a, b) => (a = { ...a, [b]: events[b] }), {}))
);
},
rate() {
rate.set(data);
},
request() {
request.set(data);
invalidate('app:invoice');
},
async payment() {
let { amount, invoice } = data;
invalidate('app:invoice');
let p = get(payments);
let i = p.findIndex((p) => p.id === data.id);
if (~i) {
p[i] = data;
payments.set(p);
} else newPayment.set(true);
invalidate((url) => url.pathname === '/payments');
if (amount > 0) {
success(`${data.confirmed ? 'Received' : 'Detected'} ${sat(amount)}!`);
} else {
success(`Sent ${sat(amount)}!`);
}
},
connected: auth
});
const initialReconnectDelay = 1000;
const maxReconnectDelay = 16000;
let currentReconnectDelay = initialReconnectDelay;
export function connect(t) {
token = t;
if (socket) return auth();
socket = new WebSocket(PUBLIC_SOCKET);
socket.addEventListener('open', onWebsocketOpen);
socket.addEventListener('close', onWebsocketClose);
socket.addEventListener('message', onWebsocketMessage);
}
export function close() {
if (socket) socket.close();
}
function onWebsocketMessage(msg) {
let { type, data } = JSON.parse(msg.data);
messages(data)[type] && messages(data)[type]();
}
function onWebsocketOpen() {
currentReconnectDelay = initialReconnectDelay;
}
function onWebsocketClose() {
socket = null;
setTimeout(() => {
reconnectToWebsocket();
}, currentReconnectDelay + Math.floor(Math.random() * 3000));
}
function reconnectToWebsocket() {
if (currentReconnectDelay < maxReconnectDelay) {
currentReconnectDelay *= 2;
}
connect(token);
}
|
