import { emit } from "$lib/sockets";
import { handleZap } from "$lib/nostr";
import config from "$config";
import { notify } from "$lib/notifications";
import { callWebhook } from "$lib/webhooks";
import ln from "$lib/ln";
import { l, err, warn } from "$lib/logging";
import { g, s, t, db } from "$lib/db";
import { credit, types } from "$lib/payments";

export async function listenForLightning() {
  let inv = await ln.waitanyinvoice((await g("pay_index")) || 0);
  let {
    bolt11,
    description,
    pay_index,
    status,
    amount_received_msat,
    payment_preimage: preimage,
  } = inv;

  await s("pay_index", pay_index);
  setTimeout(listenForLightning);

  let received = Math.round(amount_received_msat / 1000);

  try {
    if (!preimage) return;

    let id = await g(`invoice:${bolt11}`);
    let invoice = await g(`invoice:${id}`);
    if (!invoice) return warn("received lightning with no invoice", bolt11);

    if (invoice && invoice.memo) {
      try {
        if (JSON.parse(description).kind === 9734) await handleZap(inv);
      } catch (e) {
        warn("failed to handle zap", e.message);
      }
    }

    let p = await g(`payment:${bolt11}`);
    if (typeof p === "string") p = await g(`payment:${p}`);

    if (p) return warn("already processed", bolt11);

    await credit(bolt11, received, invoice.memo, preimage, types.lightning);
  } catch (e) {
    console.log(e);
    err("problem receiving lightning payment", e.message);
  }
}