api.js 3.9 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788
  1. const mime = require("mime-types");
  2. const fs = require('fs');
  3. const Path = require('path');
  4. const Security = require('../src/security.js');
  5. const MediaService = require('../model/mediaService.js');
  6. module.exports = { register: app => {
  7. app.router.get("/api/access/list", (req, res) => {
  8. app.routerUtils.onApiRequest(req, res);
  9. app.routerUtils.jsonResponse(res, req.accessList);
  10. });
  11. app.router.post("/api/access/link", async (req, res) => { // /api/access/link, post: { linkId: string }
  12. app.routerUtils.onApiRequest(req, res);
  13. if (!req.post?.linkId?.length)
  14. return app.routerUtils.httpResponse(res, 400, "Missing argument");
  15. let access = Security.addLinkToSession(req, req.post.linkId);
  16. app.routerUtils.jsonResponse(res, access);
  17. });
  18. app.router.del("/api/access/:id", (req, res) => {
  19. app.routerUtils.onApiRequest(req, res);
  20. Security.removeFromSession(req, req.params.id);
  21. let access = Security.getAccessList(req.cookies);
  22. app.routerUtils.jsonResponse(res, access);
  23. });
  24. app.router.get("/api/media/list", async (req, res) => {
  25. app.routerUtils.onApiRequest(req, res);
  26. let first = undefined,
  27. last = undefined;
  28. if (req.body?.chronology !== undefined) {
  29. let range = await MediaService.getMediaRange(app);
  30. first = range[0];
  31. last = range[1];
  32. }
  33. let fromDate = parseInt(req.body?.from);
  34. let count = parseInt(req.body?.count);
  35. app.routerUtils.jsonResponse(res, {
  36. data: await MediaService.fetchMediasWithAccess(
  37. app,
  38. isNaN(fromDate) ? 0 : fromDate,
  39. isNaN(count) ? 25 : Math.min(75, count),
  40. req.accessList),
  41. first: first,
  42. last: last
  43. });
  44. });
  45. app.router.get("/api/media/:md5sum", async (req, res) => {
  46. app.routerUtils.onApiRequest(req, res);
  47. let data = await MediaService.fetchOne(app, req.params.md5sum, req.accessList);
  48. if (!data)
  49. return app.routerUtils.onPageNotFound(res);
  50. app.routerUtils.jsonResponse(res, data);
  51. });
  52. app.router.get("/api/media/thumbnail/:md5sum.jpg", async (req, res) => {
  53. app.routerUtils.onApiRequest(req, res);
  54. let data = await MediaService.fetchOne(app, req.params.md5sum, req.accessList);
  55. if (!data)
  56. return app.routerUtils.onPageNotFound(res);
  57. try {
  58. let thumbnail = await (await app.libraryManager.findMedia(data.path))?.createThumbnail(req.body?.w || 0, req.body?.h || 0, req.body?.q || 6);
  59. if (!thumbnail)
  60. return app.routerUtils.onPageNotFound(res);
  61. res.setHeader("Content-Type", "image/jpeg");
  62. res.setHeader("Content-Length", fs.statSync(thumbnail.name)?.size || undefined);
  63. res.setHeader("Cache-Control", "private, max-age=2630000"); // 1 month cache
  64. let rd = fs.createReadStream(thumbnail.name);
  65. rd.once('end', () => thumbnail.removeCallback());
  66. rd.pipe(res);
  67. }
  68. catch (err) {
  69. console.error(err);
  70. app.routerUtils.onPageNotFound(res);
  71. }
  72. });
  73. app.router.get("/api/media/original/:md5sum", async (req, res) => {
  74. app.routerUtils.onApiRequest(req, res);
  75. let data = await MediaService.fetchOne(app, req.params.md5sum, req.accessList);
  76. if (!data)
  77. return app.routerUtils.onPageNotFound(res);
  78. const fileName = Path.basename(data.path);
  79. res.setHeader("Content-Type", mime.lookup(data.path));
  80. res.setHeader("Content-Length", fs.statSync(data.path)?.size || undefined);
  81. res.setHeader("Content-Disposition", `attachment; filename="${fileName}"`);
  82. res.setHeader("Cache-Control", "private, max-age=2630000"); // 1 month cache
  83. fs.createReadStream(data.path).pipe(res);
  84. });
  85. }};