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
|
import db from "../db.js";
import { Router } from "express";
import { getUser } from "./users.js";
import { type Event, type Id, type Rsvps, type User } from "../types.js";
const router = Router();
const joinHost = (event: Event) => {
const host = getUser(event.host_id) as User;
return { ...event, host };
};
const joinRSVPs = (event: Event) => {
const { id } = event;
const getRSVPs = db.prepare("SELECT * FROM rsvps WHERE event_id = @id");
const rsvps = getRSVPs.all({ id }) as Rsvps[];
return { ...event, rsvps };
};
const getEvent = (eventId: Id) => {
const byId = db.prepare("SELECT * FROM events WHERE id = @eventId");
const event = byId.get({ eventId }) as Event;
return joinHost(event);
};
router.get("/", (_req, res) => {
const listEvents = db.prepare(`SELECT * FROM events`);
const events = listEvents.all() as Event[];
res.json(events.map(joinHost).map(joinRSVPs));
});
const insertEvent = db.prepare(
`INSERT INTO events VALUES (@id, @title, @description, @image_url, @date, @host_id)`,
);
router.post("/new", (req, res) => {
const data = req.body;
const { lastInsertRowid } = insertEvent.run(data);
const id = lastInsertRowid as number;
const event = getEvent(id);
res.status(201).json(event);
});
router.get("/:id", (req, res) => {
const id = parseInt(req.params.id);
const event = getEvent(id);
if (!event) {
return res.status(404).json({ error: "Event not found" });
}
res.json(event);
});
router.patch("/:id", (req, res) => {
const eventId = parseInt(req.params.id);
const patch = req.body;
const updateCol = db.prepare(`
UPDATE events SET @col = @val WHERE id = @eventId
`);
const updateEvent = db.transaction((patch) => {
for (const [col, val] of Object.entries(patch)) {
updateCol.run({ col, val, eventId });
}
});
updateEvent(Object.entries(patch));
const updated = getEvent(eventId);
res.json(updated);
});
router.delete("/:id", (req, res) => {
const deleteEvent = db.prepare(`DELETE FROM events WHERE id = @eventId`);
const eventId = parseInt(req.params.id);
const event = getEvent(eventId);
if (!event) {
return res.status(404).json({ error: "Event not found" });
}
deleteEvent.run({ eventId });
res.json(event);
});
router.post("/:id/rsvp", (req, res) => {
const eventId = parseInt(req.params.id);
const { name, email } = req.body;
const getRSVP = db.prepare(
`SELECT * FROM rsvps WHERE (event_id = ${eventId} AND email = '${email}')`,
);
const insertRSVP = db.prepare(
`INSERT INTO rsvps VALUES (@eventId, @name, @email)`,
);
let [rsvp] = getRSVP.all({ eventId, email });
if (rsvp) {
// This email has already RSVPed
res.status(200).json({ rsvp });
} else {
// New RSVP
insertRSVP.run({ name, email, eventId });
rsvp = getRSVP.run({ eventId, email });
res.status(201).json({ rsvp });
}
});
export default router;
|
