aboutsummaryrefslogtreecommitdiffstats
path: root/postcss.config.cjs
diff options
context:
space:
mode:
Diffstat (limited to 'postcss.config.cjs')
0 files changed, 0 insertions, 0 deletions
generated by cgit v1.2.3 (git 2.51.0) at 2026-11-06 13:54:19 +0000
46'>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 
import { navigating } from "$app/stores";
import { get } from "svelte/store";
import { event, invoice, request, last } from "$lib/store";
import { success, sat, sleep } from "$lib/utils";
import { PUBLIC_SOCKET } from "$env/static/public";
import { invalidate } from "$app/navigation";

let socket, token;

export const auth = () => token && send("login", token);

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() {
    event.set(data);
  },

  request() {
    request.set(data);
    invalidate("app:invoice");
  },

  async payment() {
    let { amount, confirmed } = data;

    invalidate("app:user");
    invalidate("app:invoice");
    invalidate("app:payments");

    if (amount > 0) {
      success(`${confirmed ? "Received" : "Detected"} ${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();
}

async function onWebsocketMessage(msg) {
  let { type, data } = JSON.parse(msg.data);
  if (get(navigating)) await sleep(2000);

  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);
}