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
|
import app from "$app";
import db from "$db";
import redis from "$lib/redis";
import { coinos, q } 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;
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: []
};
await q(pubkey, {
kinds: [1],
authors: [pubkey]
});
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);
} catch (e) {
console.log(e);
res.code(500).send("problem fetching user events");
}
});
app.post("/nostr/send", async (req, res) => {
let { event } = req.body;
coinos.send(["EVENT", event]);
res.send(event);
});
|
