123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566 |
- const BaseController = require('./BaseController');
- const ReaderWorker = require('../core/ReaderWorker');
- const readerStorage = require('../core/readerStorage');
- const WorkerState = require('../core/WorkerState');//singleton
- class ReaderController extends BaseController {
- constructor(config) {
- super(config);
- this.readerWorker = new ReaderWorker(config);
- this.workerState = new WorkerState();
- }
- async loadBook(req, res) {
- const request = req.body;
- let error = '';
- try {
- if (!request.url)
- throw new Error(`key 'url' is empty`);
- const workerId = this.readerWorker.loadBookUrl({
- url: request.url,
- enableSitesFilter: (request.hasOwnProperty('enableSitesFilter') ? request.enableSitesFilter : true)
- });
- const state = this.workerState.getState(workerId);
- return (state ? state : {});
- } catch (e) {
- error = e.message;
- }
- //bad request
- res.status(400).send({error});
- return false;
- }
- async storage(req, res) {
- const request = req.body;
- let error = '';
- try {
- if (!request.action)
- throw new Error(`key 'action' is empty`);
- if (!request.items || Array.isArray(request.data))
- throw new Error(`key 'items' is empty`);
- return await readerStorage.doAction(request);
- } catch (e) {
- error = e.message;
- }
- //error
- res.status(500).send({error});
- return false;
- }
- async uploadFile(req, res) {
- const file = req.file;
- let error = '';
- try {
- const url = await this.readerWorker.saveFile(file);
- return {url};
- } catch (e) {
- error = e.message;
- }
- //bad request
- res.status(400).send({error});
- return false;
- }
- }
- module.exports = ReaderController;
|