aboutsummaryrefslogtreecommitdiffstats
path: root/src/components/Invoice.svelte
blob: 5955bcc0fe65a3ac9abeede0fdc65ce887e0f88e (plain) (blame) 
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

<script>
	import { f, sat, sats } from '$lib/utils';
	import { fly } from 'svelte/transition';
	import { Avatar, Icon } from '$comp';
	import { invoice } from '$lib/store';
</script>

{#if $invoice}
	<div class="fixed bottom-0 border-t w-full p-4 bg-white z-50" in:fly>
		<div class="flex flex-wrap md:flex-nowrap max-w-xl mx-auto gap-2">
			<div class="my-auto mx-auto">
				<div class="flex">
					<Avatar user={$invoice.user.username} size={12} />
					<h1 class="my-auto">
						<b>{$invoice.user.username}</b> sent an invoice for
						<b>{f(($invoice.amount * $invoice.rate) / sats, $invoice.currency)}</b>
						{sat($invoice.amount)}
					</h1>
				</div>
			</div>
			<div class="mx-auto my-auto flex gap-2">
				<a href={`/invoice/${$invoice.uuid}/tip`}>
					<button class="text-lg rounded-full border py-3 px-7 font-bold hover:opacity-80 w-40">
						Pay
					</button>
				</a>
				<button
					class="text-lg rounded-full border py-3 px-7 font-bold hover:opacity-80 w-40"
					on:click={() => ($invoice = undefined)}
				>
					Dismiss
				</button>
			</div>
		</div>
	</div>
{/if}
generated by cgit v1.2.3 (git 2.51.0) at 2026-10-30 22:20:31 +0000
e.Class */ .highlight .vg { color: #D70 } /* Name.Variable.Global */ .highlight .vi { color: #33B } /* Name.Variable.Instance */ .highlight .vm { color: #369 } /* Name.Variable.Magic */ .highlight .il { color: #00D; font-weight: bold } /* Literal.Number.Integer.Long */
const bolt11 = require("bolt11");
const { Op } = require("sequelize");

send = async (amount, memo, hash, user) => {
  let payreq = bolt11.decode(hash);
  let routingInfo = payreq.tags.find(t => t.tagName === "routing_info");
  if (
    routingInfo &&
    routingInfo.data.find(d => d.fee_proportional_millionths > 100)
  )
    throw new Error("Fee rate too high");

  if (!amount || payreq.satoshis > amount) amount = payreq.satoshis;

  if (seen.includes(hash)) {
    l.warn("attempted to pay a paid invoice", user.username);
    throw new Error("Invoice has been paid, can't pay again");
  }

  let error, fee, total, preimage, payment;

  await db.transaction(async transaction => {
    let account = await db.Account.findOne({
      where: {
        user_id: user.id,
        asset: config.liquid.btcasset,
        pubkey: null,
        balance: {
          [Op.gte]: amount
        }
      },
      lock: transaction.LOCK.UPDATE,
      transaction
    });

    if (!account || account.balance < amount) {
      throw new Error("Insufficient funds");
    }

    await account.decrement({ balance: amount }, { transaction });
    await account.reload({ transaction });

    if (config.lna.clightning) {
      let m = await lna.pay(hash);
      let sent;
      ({
        msatoshi: total,
        msatoshi_sent: sent,
        payment_preimage: preimage
      } = m);

      fee = parseInt((sent - total) / 1000);
      total = parseInt(total / 1000);
    } else {
      let m = await lna.sendPaymentSync({
        amt: amount,
        payment_request: hash,
        max_parts: 10,
        fee_limit: { fixed: Math.min(10000, account.balance) },
      });

      if (m.payment_error) throw new Error(m.payment_error);

      ({
        payment_route: { total_fees: fee, total_amt: total },
        payment_preimage: preimage
      } = m);
    }

    preimage = preimage.toString("hex");

    if (seen.includes(preimage)) {
      l.warn("duplicate payment detected", preimage);
      throw new Error("Duplicate payment detected");
    }
  });

  await db.transaction(async transaction => {
    let account = await db.Account.findOne({
      where: {
        user_id: user.id,
        asset: config.liquid.btcasset,
        pubkey: null
      },
      lock: transaction.LOCK.UPDATE,
      transaction
    });

    total = parseInt(total);
    fee = parseInt(fee);

    await account.decrement({ balance: fee }, { transaction });
    await account.reload({ transaction });

    payment = await db.Payment.create(
      {
        amount: -(total - fee),
        account_id: account.id,
        user_id: user.id,
        hash,
        memo,
        preimage,
        rate: app.get("rates")[user.currency],
        currency: user.currency,
        confirmed: true,
        network: "lightning",
        fee
      },
      { transaction }
    );

    payment = payment.get({ plain: true });
    payment.account = account.get({ plain: true });

    emit(user.username, "account", payment.account);
    emit(user.username, "payment", payment);

    seen.push(preimage);
    seen.push(hash);

    l.info("sent lightning", user.username, total - fee, fee);
  });

  return payment;
};
generated by cgit v1.2.3 (git 2.51.0) at 2026-10-30 22:20:31 +0000