ReaderController.js 2.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566
  1. const BaseController = require('./BaseController');
  2. const ReaderWorker = require('../core/ReaderWorker');
  3. const readerStorage = require('../core/readerStorage');
  4. const WorkerState = require('../core/WorkerState');//singleton
  5. class ReaderController extends BaseController {
  6. constructor(config) {
  7. super(config);
  8. this.readerWorker = new ReaderWorker(config);
  9. this.workerState = new WorkerState();
  10. }
  11. async loadBook(req, res) {
  12. const request = req.body;
  13. let error = '';
  14. try {
  15. if (!request.url)
  16. throw new Error(`key 'url' is empty`);
  17. const workerId = this.readerWorker.loadBookUrl({
  18. url: request.url,
  19. enableSitesFilter: (request.hasOwnProperty('enableSitesFilter') ? request.enableSitesFilter : true)
  20. });
  21. const state = this.workerState.getState(workerId);
  22. return (state ? state : {});
  23. } catch (e) {
  24. error = e.message;
  25. }
  26. //bad request
  27. res.status(400).send({error});
  28. return false;
  29. }
  30. async storage(req, res) {
  31. const request = req.body;
  32. let error = '';
  33. try {
  34. if (!request.action)
  35. throw new Error(`key 'action' is empty`);
  36. if (!request.items || Array.isArray(request.data))
  37. throw new Error(`key 'items' is empty`);
  38. return await readerStorage.doAction(request);
  39. } catch (e) {
  40. error = e.message;
  41. }
  42. //error
  43. res.status(500).send({error});
  44. return false;
  45. }
  46. async uploadFile(req, res) {
  47. const file = req.file;
  48. let error = '';
  49. try {
  50. const url = await this.readerWorker.saveFile(file);
  51. return {url};
  52. } catch (e) {
  53. error = e.message;
  54. }
  55. //bad request
  56. res.status(400).send({error});
  57. return false;
  58. }
  59. }
  60. module.exports = ReaderController;