diff options
| author | Adam Soltys <[email protected]> | 2023-01-16 23:40:25 -0800 |
|---|---|---|
| committer | Adam Soltys <[email protected]> | 2023-01-16 23:40:25 -0800 |
| commit | 91e847126c832efa25ab0bf8d6f3b7e537378fa7 (patch) | |
| tree | 4a42b6e3bec6eb0f640ed44533b54e6d3d6a5e0e /routes/requests.js | |
| parent | 6bafea9bffe24d2227d269812a73a9a513d92ddf (diff) | |
| download | coinos-server-91e847126c832efa25ab0bf8d6f3b7e537378fa7.tar.gz coinos-server-91e847126c832efa25ab0bf8d6f3b7e537378fa7.zip | |
shuffle things around
Diffstat (limited to 'routes/requests.js')
| -rw-r--r-- | routes/requests.js | 62 |
1 files changed, 27 insertions, 35 deletions
diff --git a/routes/requests.js b/routes/requests.js index bea8f7fd..f62c3131 100644 --- a/routes/requests.js +++ b/routes/requests.js @@ -1,38 +1,34 @@ -import app from "$app"; -import { auth } from "$lib/passport"; import { emit } from "$lib/sockets"; -import { g, rd } from "$lib/redis"; +import { g, db } from "$lib/db"; -app.get("/request/:id", auth, async ({ params: { id } }, res) => { - try { - res.send({ request: await g(id) }); - } catch (e) { - console.log(e); - res.code(500).send(e.message); - } -}); +export default { + async get({ params: { id } }, res) { + try { + res.send({ request: await g(id) }); + } catch (e) { + console.log(e); + res.code(500).send(e.message); + } + }, -app.get("/requests", auth, async ({ user: { uuid } }, res) => { - try { - const day = new Date(new Date().setDate(new Date().getDate() - 1)); + async list({ user: { uuid } }, res) { + try { + const day = new Date(new Date().setDate(new Date().getDate() - 1)); - let invoices = await rd.lRange(`${uuid}:invoices`, 0, -1); - let requests = await rd.lRange(`${uuid}:requests`, 0, -1); + let invoices = await db.lRange(`${uuid}:invoices`, 0, -1); + let requests = await db.lRange(`${uuid}:requests`, 0, -1); - res.send({ invoices, requests }); - } catch (e) { - console.log(e); - res.code(500).send(e.message); - } -}); + res.send({ invoices, requests }); + } catch (e) { + console.log(e); + res.code(500).send(e.message); + } + }, -app.post( - "/requests", - auth, - async ( + async create( { body: { recipient, ...params }, user: { username, profile } }, res - ) => { + ) { let { id: recipient_id } = await g(`user:${recipient}`); let request = { recipient_id, ...params }; @@ -44,14 +40,10 @@ app.post( emit(recipient, "request", request); res.send(request); - } -); + }, -app.post( - "/requests/delete", - auth, - async ({ body: { request_id }, user: { id } }, res) => { - await rd.lrem(`user:${id}:requests`, request_id); + async destroy({ body: { request_id }, user: { id } }, res) { + await db.lrem(`user:${id}:requests`, request_id); res.send(); } -); +}; |
