Sharing #1

Merged
artem merged 3 commits from dev into main 2023-02-17 00:05:50 +01:00
4 changed files with 49 additions and 6 deletions

View File

@ -12,5 +12,6 @@ exports.systemRouter = require("./system")
exports.statusRouter = require("./status"); exports.statusRouter = require("./status");
exports.settingsRouter = require("./settings"); exports.settingsRouter = require("./settings");
exports.searchRouter = require("./search"); exports.searchRouter = require("./search");
exports.shareRouter = require("./share");
// exports.activitypubRouter = require("./activitypub"); // exports.activitypubRouter = require("./activitypub");
// exports.wellknownRouter = require("./well-known"); // exports.wellknownRouter = require("./well-known");

12
router/share.js Normal file
View File

@ -0,0 +1,12 @@
console.log("router/share INIT");
var express = require("express");
var router = new express.Router();
const database = require("../services/database");
router.route("/:id").get((req, res) => {
database.share.byId(req.params.id, (result) => {
res.json(result).status(200).end();
});
});
module.exports = router;

View File

@ -135,6 +135,7 @@ app.use("/api/search", router.searchRouter);
app.use("/api/settings", router.settingsRouter); app.use("/api/settings", router.settingsRouter);
app.use("/api/status", router.statusRouter); app.use("/api/status", router.statusRouter);
app.use("/api/system", router.systemRouter); app.use("/api/system", router.systemRouter);
app.use("/api/shares", router.shareRouter);
app.use("/api/tracks", router.trackRouter); app.use("/api/tracks", router.trackRouter);
app.use("/api/user", router.loginRouter); app.use("/api/user", router.loginRouter);
app.use("/api/user", router.userRouter); app.use("/api/user", router.userRouter);

View File

@ -2,16 +2,43 @@ const redis = require("../redis")
const { ObjectId } = require('mongodb'); const { ObjectId } = require('mongodb');
const connector = require("./CONNECTOR"); const connector = require("./CONNECTOR");
const database = require("./index");
var dbo; var dbo;
connector.connect().then((ret) => { connector.connect().then((ret) => {
dbo = ret; dbo = ret;
}); });
exports.byId = function (id, callback) { exports.byId = function (id, callback) {
let _id;
try {
_id = ObjectId(id);
} catch {
cb(callback);
return;
}
dbo.collection("shares") dbo.collection("shares")
.findOne({ _id: ObjectId(id) }) .findOne({ _id: _id })
.then((result) => { .then((result) => {
callback(result); if (result) {
switch (result.type) {
case "album":
database.albums.byId(result.object_id, undefined, (album) => {
result.object = album;
cb(callback, result);
});
break;
case "box":
database.boxes.byId(result.object_id, undefined, (box) => {
result.object = box;
cb(callback, result);
});
break;
default:
cb(callback, result);
}
} else {
cb(callback);
}
}); });
} }
@ -51,10 +78,12 @@ exports.delete = function (item, callback) {
dbo.collection("shares") dbo.collection("shares")
.deleteMany({ object_id: ObjectId(item.object_id) }, (err) => { .deleteMany({ object_id: ObjectId(item.object_id) }, (err) => {
if (err) throw err; if (err) throw err;
if (callback) { cb(callback);
callback();
}
}); });
}
function cb(callback, value) {
if (callback) {
callback(value);
}
} }