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
125
126
127
128
129
|
import config from "$config";
import { db, g } from "$lib/db";
import ln from "$lib/ln";
import { err, l, warn } from "$lib/logging";
import { mail, templates } from "$lib/mail";
import mqtt from "$lib/mqtt";
import { publish, serverSecret } from "$lib/nostr";
import { emit } from "$lib/sockets";
import { f, fiat, fmt, getUser, link, nada, t } from "$lib/utils";
import { hexToBytes } from "@noble/hashes/utils";
import { finalizeEvent, nip04 } from "nostr-tools";
import webpush from "web-push";
if (config.vapid) {
webpush.setVapidDetails(
`mailto:${config.support}`,
config.vapid.pk,
config.vapid.sk,
);
}
export const notify = async (p, user, withdrawal) => {
emit(user.id, "payment", p);
let { username } = user;
const { paymentReceived } = t(user);
username = username.replace(/\s/g, "");
try {
if (user.verified && user.notify) {
mail(user, paymentReceived, templates.paymentReceived, {
...t(user),
username,
payment: {
amount: fmt(p.amount),
link: link(p.id),
tip: p.tip ? fmt(p.tip) : undefined,
fiat: f(fiat(p.amount, p.rate), p.currency),
fiatTip: p.tip ? f(fiat(p.tip, p.rate), p.currency) : undefined,
memo: p.memo,
items: p.items?.map((i) => {
return {
quantity: i.quantity,
name: i.name,
total: i.quantity * i.price,
totalFiat: f(i.quantity * i.price, p.currency),
};
}),
},
withdrawal,
});
}
} catch (e) {
err("problem emailing", e.message);
}
const subscriptions = await db.sMembers(`${user.id}:subscriptions`);
const payload = {
title: paymentReceived,
body: `${fmt(p.amount)} ${f(fiat(p.amount, p.rate), p.currency)}`,
url: `/payment/${p.id}`,
};
for (const s of subscriptions) {
webpush
.sendNotification(JSON.parse(s), JSON.stringify(payload))
.catch((e) => {
warn("sub failed", e.message);
db.sRem(`${user.id}:subscriptions`, s);
});
}
if (config.mqtt) {
if (!mqtt.connected) await mqtt.reconnect();
mqtt.publish(
username,
`pay:${p.amount}:${p.tip}:${p.rate}:${p.created}:${p.id}:${p.memo}:${p.items}`,
);
}
};
export const nwcNotify = async (p) => {
try {
const user = await getUser(p.uid);
const pubkeys = await db.sMembers(`${user.id}:apps`);
if (pubkeys.length) {
let payment_hash = "";
if (p.type === "lightning") ({ payment_hash } = await ln.decode(p.hash));
for (const pubkey of pubkeys) {
const { notify } = await g(`app:${pubkey}`);
if (!notify) continue;
l("notifying", pubkey, p.type, p.amount);
const notification = {
type: p.amount > 0 ? "incoming" : "outgoing",
invoice: p.hash,
description: p.memo,
preimage: p.ref,
payment_hash: payment_hash,
amount: Math.abs(p.amount) * 1000,
fees_paid: (parseInt(p.fee) || 0) * 1000,
created_at: Math.round(p.created / 1000),
settled_at: Math.round(p.created / 1000),
};
const payload = JSON.stringify({
notification_type: p.amount > 0 ? "payment_received" : "payment_sent",
notification,
});
const content = await nip04.encrypt(serverSecret, pubkey, payload);
const unsigned = {
content,
tags: [["p", pubkey]],
kind: 23196,
created_at: Math.floor(Date.now() / 1000),
};
const event = finalizeEvent(unsigned, hexToBytes(serverSecret));
publish(event).catch(nada);
}
}
} catch (e) {
console.log(e);
warn("nwc notification failed", e.message);
}
};
|
