summaryrefslogtreecommitdiff
path: root/examples/ssr/server/api.mjs
blob: 9bb0be72ab47f18a8729005834059efe8c7757cd (plain) (blame)
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
import fs from 'fs';
import lightcookie from 'lightcookie';

const dbJSON = fs.readFileSync(new URL('./db.json', import.meta.url));
const db = JSON.parse(dbJSON);
const products = db.products;
const productMap = new Map(products.map((product) => [product.id, product]));

// Normally this would be in a database.
const userCartItems = new Map();

const routes = [
	{
		match: /\/api\/products\/([0-9])+/,
		async handle(_req, res, [, idStr]) {
			const id = Number(idStr);
			if (productMap.has(id)) {
				const product = productMap.get(id);
				res.writeHead(200, {
					'Content-Type': 'application/json',
				});
				res.end(JSON.stringify(product));
			} else {
				res.writeHead(404, {
					'Content-Type': 'text/plain',
				});
				res.end('Not found');
			}
		},
	},
	{
		match: /\/api\/products/,
		async handle(_req, res) {
			res.writeHead(200, {
				'Content-Type': 'application/json',
			});
			res.end(JSON.stringify(products));
		},
	},
	{
		match: /\/api\/cart/,
		async handle(req, res) {
			res.writeHead(200, {
				'Content-Type': 'application/json'
			});
			let cookie = req.headers.cookie;
			let userId = cookie ? lightcookie.parse(cookie)['user-id'] : '1'; // default for testing
			if(!userId || !userCartItems.has(userId)) {
				res.end(JSON.stringify({ items: [] }));
				return;
			}
			let items = userCartItems.get(userId);
			let array = Array.from(items.values());
			res.end(JSON.stringify({ items: array }));
		}
	},
	{
		match: /\/api\/add-to-cart/,
		async handle(req, res) {
			let body = '';
			req.on('data', chunk => body += chunk);
			return new Promise(resolve => {
				req.on('end', () => {
					let cookie = req.headers.cookie;
					let userId = lightcookie.parse(cookie)['user-id'];
					let msg = JSON.parse(body);

					if(!userCartItems.has(userId)) {
						userCartItems.set(userId, new Map());
					}

					let cart = userCartItems.get(userId);
					if(cart.has(msg.id)) {
						cart.get(msg.id).count++;
					} else {
						cart.set(msg.id, { id: msg.id, name: msg.name, count: 1 });
					}

					res.writeHead(200, {
						'Content-Type': 'application/json',
					});
					res.end(JSON.stringify({ ok: true }));
				});
			});
		}
	}
];

export async function apiHandler(req, res) {
	for (const route of routes) {
		const match = route.match.exec(req.url);
		if (match) {
			return route.handle(req, res, match);
		}
	}
	res.writeHead(404, {
		'Content-Type': 'text/plain',
	});
	res.end('Not found');
}