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
|
import app from "$app";
import db from "$db";
import redis from "$lib/redis";
import { coinos, pool, q } from "$lib/nostr";
import store from "$lib/store";
import { nada, wait } from "$lib/utils";
app.get("/event/:id", async (req, res) => {
try {
let event = JSON.parse(await redis.get(`ev:${req.params.id}`));
let { pubkey } = event;
event.user = JSON.parse(await redis.get(`user:${pubkey}`)) || {
username: pubkey.substr(0, 6),
pubkey,
anon: true,
follows: [],
followers: []
};
res.send(event);
} catch (e) {
res.code(500).send("Problem fetching event");
}
});
app.get("/nostr/:pubkey", async (req, res) => {
try {
let { pubkey } = req.params;
let user = JSON.parse(await redis.get(`user:${pubkey}`));
if (!user) {
user = await db.User.findOne({
where: { pubkey }
});
}
if (!user)
user = {
username: pubkey.substr(0, 6),
pubkey,
anon: true,
follows: [],
followers: []
};
q(
`${pubkey}:notes`,
{
kinds: [1],
authors: [pubkey]
},
{ since: 0 }
).catch(nada);
await redis.set(`user:${pubkey}`, JSON.stringify(user));
let ids = await redis.sMembers(pubkey);
let events = ids.length
? (await redis.mGet(ids.map(k => "ev:" + k))).map(JSON.parse)
: [];
res.send(events.map(e => ({ ...e, user })));
} catch (e) {
console.log(e);
res.code(500).send("problem fetching user events");
}
});
app.post("/nostr/send", async (req, res) => {
let { event } = req.body;
pool.send(["EVENT", event]);
res.send(event);
});
|
