aboutsummaryrefslogtreecommitdiffstats
path: root/routes/requests.js
diff options
context:
space:
mode:
authorAdam Soltys <[email protected]>2023-01-16 23:40:25 -0800
committerAdam Soltys <[email protected]>2023-01-16 23:40:25 -0800
commit91e847126c832efa25ab0bf8d6f3b7e537378fa7 (patch)
tree4a42b6e3bec6eb0f640ed44533b54e6d3d6a5e0e /routes/requests.js
parent6bafea9bffe24d2227d269812a73a9a513d92ddf (diff)
downloadcoinos-server-91e847126c832efa25ab0bf8d6f3b7e537378fa7.tar.gz
coinos-server-91e847126c832efa25ab0bf8d6f3b7e537378fa7.zip
shuffle things around
Diffstat (limited to 'routes/requests.js')
-rw-r--r--routes/requests.js62
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();
}
-);
+};