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
|
import app from "$app";
import db from "$db";
import redis from "$lib/redis";
import { pool } from "$lib/nostr";
import store from "$lib/store";
import { wait } from "$lib/utils";
app.get("/nostr/:pubkey", async (req, res) => {
try {
let { pubkey } = req.params;
store.fetching[pubkey] = true;
store.timeouts[pubkey] = setTimeout(
() => (store.fetching[pubkey] = false),
500
);
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 };
let { since } = user;
pool.subscribe(pubkey, {
since,
kinds: [1],
authors: [pubkey]
});
user.since = Math.round(Date.now() / 1000);
await redis.set(`user:${pubkey}`, JSON.stringify(user));
await wait(() => !store.fetching[pubkey], 100, 100);
let ids = await redis.sMembers(pubkey);
let events = ids.length ? (
await redis.mGet((ids).map(k => "ev:" + k))
).map(JSON.parse) : [];
res.send(events);
} 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);
});
|
