sora/OTM
1
0
Fork 0
Code Issues 1 Pull Requests Projects Releases Wiki Activity

Update src/server/api.ts
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
sora 2025-05-17 08:43:07 +02:00
parent 619a06629b
commit c6a3cb322f
1 changed files with 6 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/server/api.ts
View File

@ -60,22 +60,19 @@ export default function (server, opts, done) {
if (req.params.id == undefined) if (req.params.id == undefined)
return reply.code(400).send({ error: "No ID query parameter" }); return reply.code(400).send({ error: "No ID query parameter" });
server.level.db.get(req.params.id, (err, val) => { return server.level.db.get(req.params.id)
if (err) { .then(r=> reply.send(JSON.parse(r)))
.catch(err=>{
console.warn(err); console.warn(err);
reply.code(500).send(); return reply.code(500).send({error: "Error with DB"});
} else { })
reply.send(JSON.parse(val));
}
});
return reply;
}); });
server.post("/:id", async (req, reply) => { server.post("/:id", async (req, reply) => {
if (req.params.id == undefined) if (req.params.id == undefined)
return reply.code(400).send({ error: "No ID query parameter" }); return reply.code(400).send({ error: "No ID query parameter" });
return server.level.db.get(req.params.id).then(r=>r.version||-1).catch(_=>-1).then(db_version=>{ return server.level.db.get(req.params.id).then(r=>JSON.parse(r)).then(r=>r.version||-1).catch(_=>-1).then(db_version=>{
if(db_version+1 == req.body.version || db_version == -1) if(db_version+1 == req.body.version || db_version == -1)
return server.level.db.put(req.params.id, req.body) return server.level.db.put(req.params.id, req.body)
.then(_=>reply.send({ content: "ok" })) .then(_=>reply.send({ content: "ok" }))