Forráskód Böngészése

Sync up with frontend

AXCWG 2 hónapja
szülő
commit
145f7f4ab7
2 módosított fájl, 61 hozzáadás és 20 törlés
  1. 37 10
      UserInteractions.js
  2. 24 10
      main.js

+ 37 - 10
UserInteractions.js

@@ -59,12 +59,12 @@ export default function UserInteractions(opts) {
         })
     })
     app.get("/userapi", (req, res) => {
-        if(req.query.getname){
+        if (req.query.getname) {
             db.execute("SELECT username from user where uuid = ?", [req.query.uuid], (err, result) => {
                 res.set(cwh).end(result[0].username);
 
             })
-        }else{
+        } else {
             if (!req.session.uuid) {
                 res.set(cwh).status(500).json({code: 500, R: "IO"})
                 return
@@ -131,37 +131,64 @@ export default function UserInteractions(opts) {
                 res.set(cwh).status(500).json({code: 500, R: "AD"})
                 return;
             }
-            if(result.length === 0) {
+            if (result.length === 0) {
                 res.set(cwh).status(404).json({code: 404, R: "DNF"})
                 return;
             }
+
             res.set(cwh).json(result[0]);
 
         })
     })
+    app.post("/remove-playlist", async function (req, res) {
+        if (!req.session.uuid) {
+            res.set(cwh).status(500).json({code: 500, R: "AD"})
+            return;
+        }
+        if (req.body.playlistuuid) {
+            db.execute("SELECT owner FROM playlist WHERE uuid = ?", [req.body.playlistuuid], function (err, result) {
+                if(result.length === 0) {
+                    res.set(cwh).status(200).json({code: 301, R: "DNM"})
+
+                }
+                if (result[0].owner === req.session.uuid) {
+                    db.execute("DELETE FROM  playlist  WHERE uuid = ?", [req.body.playlistuuid], (err, result) => {
+                        if (err) {
+                            console.log(err);
+                            res.set(cwh).status(500).json({code: 500, R: "Err"})
+                            return
+                        }
+                        res.set(cwh).status(200).json({code: 200, R: "SS"})
 
+                    })
+                } else {
+                    res.set(cwh).status(403).json({code: 403, R: "Forbidden"})
+                }
+            })
+        }
+    })
     app.post("/upload-playlist", async function (req, res) {
         if (!req.session.uuid) {
             res.set(cwh).status(500).json({code: 500, R: "AD"})
             return;
         }
-        if(req.body.playlistuuid){
+        if (req.body.playlistuuid) {
             db.execute("SELECT owner FROM playlist WHERE uuid = ?", [req.body.playlistuuid], function (err, result) {
-                if(result[0].owner === req.session.uuid){
-                    db.execute("UPDATE playlist SET content = ?, private = ?, tmb = ?, title = ? WHERE uuid = ?", [req.body.content, req.body.private, req.body.tmb, req.body.title, req.body.playlistuuid], (err, result) => {
+                if (result[0].owner === req.session.uuid) {
+                    db.execute("UPDATE playlist SET content = ?, private = ?, tmb = ?, title = ? WHERE uuid = ?", [req.body.content, req.body.private, Buffer.from( Object.values(req.body.tmb.data)), req.body.title, req.body.playlistuuid], (err, result) => {
                         if (err) {
                             console.log(err);
                             res.set(cwh).status(500).json({code: 500, R: "Err"})
 
                         }
                     })
-                }else{
+                } else {
                     res.set(cwh).status(403).json({code: 403, R: "Forbidden"})
                 }
             })
-        }else{
+        } else {
             let key = crypto.randomUUID();
-            db.execute("INSERT INTO playlist(owner, uuid, content, private, tmb, title) values (?,?,?,?,?,?)", [req.session.uuid,key , req.body.content, req.body.private, req.body.tmb, req.body.title], function (err, result) {
+            db.execute("INSERT INTO playlist(owner, uuid, content, private, tmb, title) values (?,?,?,?,?,?)", [req.session.uuid, key, req.body.content, req.body.private, req.body.tmb, req.body.title], function (err, result) {
                 if (err) {
                     console.log(err);
                     res.set(cwh).status(500).json({code: 500, R: "AD"})
@@ -169,7 +196,7 @@ export default function UserInteractions(opts) {
                 }
 
                 res.set(cwh).json({
-                    code: 200, R: "SS", UUID:key
+                    code: 200, R: "SS", UUID: key
                 });
 
             })

+ 24 - 10
main.js

@@ -15,16 +15,16 @@ try {
 } catch (e) {
 }
 
-let original = console.log;
-console.log = (str) => {
-    if (!fs.existsSync("log")) {
-        fs.mkdirSync("log")
-
-    }
-    fs.appendFileSync("log/latest.log", "[" + new Date().toISOString() + "] " + str.toString() + "\n");
-    original(str);
-
-}
+// let original = console.log;
+// console.log = (str) => {
+//     if (!fs.existsSync("log")) {
+//         fs.mkdirSync("log")
+//
+//     }
+//     fs.appendFileSync("log/latest.log", "[" + new Date().toISOString() + "] " + str.toString() + "\n");
+//     original(str);
+//
+// }
 import cwh from "./Singletons.js";
 import webp from 'webp-converter'
 
@@ -638,6 +638,20 @@ app.get("/avatar", async (req, res) => {
         res.set(cwh).end(result[0].avatar);
     })
 })
+app.post("/avatar", async (req, res) => {
+    if (!req.session.uuid) {
+        res.set(cwh).status(500).json({code: 500, R: "IO"})
+        return
+    }
+    db.execute("UPDATE user set avatar = ? where uuid = ?", [Buffer.from(Object.values(req.body.avatar)) , req.session.uuid], (err, result) => {
+        if(err){
+            console.log(err)
+            res.set(cwh).status(500).json({code: 500, R: "UE"})
+            return
+        }
+        res.set(cwh).status(200).json({code: 200, R: "SS"})
+    })
+})
 // Fetch
 app.get('/:uuid', async function (req, res) {