sample notify script

1 files changed, 9 insertions, 11 deletions

diff --git a/lib/upload.js b/lib/upload.js
index fbf9ce20..5f5aebed 100644
--- a/lib/upload.js
+++ b/lib/upload.js
@@ -5,12 +5,16 @@ import fs from "fs";
 import path from "path";
 import sharp from "sharp";
 import { pipeline } from "stream";
-import { g, s } from "$lib/db";
+import { g, s, db } from "$lib/db";
 
-export default async ({ params: { type }, file, user }, res) => {
+export default async (req, res) => {
+  let {
+    params: { type },
+    user
+  } = req;
   if (!["banner", "profile"].includes(type)) throw new Error("invalid upload");
 
-  let data = await file();
+  let data = await req.file();
   let s1 = new Clone(data.file);
   let s2 = new Clone(data.file);
 
@@ -30,14 +34,8 @@ export default async ({ params: { type }, file, user }, res) => {
 
   await new Promise(r => pipeline(s2, t, fs.createWriteStream(path), r));
 
-  let r = async () => {
-    await db.watch(`user:${user.id}`);
-    user = await g(`user:${user.id}`);
-    user[type] = true;
-    let m = await db.multi();
-    await s(`user:${user.id}`, user);
-  };
-  await r();
+  user[type] = true;
+  await s(`user:${user.id}`, user);
 
   res.send(name);
 };