Overleaf/services/docstore/app/coffee/HttpController.js

/*
 * decaffeinate suggestions:
 * DS101: Remove unnecessary use of Array.from
 * DS102: Remove unnecessary code created because of implicit returns
 * DS207: Consider shorter variations of null checks
 * Full docs: https://github.com/decaffeinate/decaffeinate/blob/master/docs/suggestions.md
 */
let HttpController;
const DocManager = require("./DocManager");
const logger = require("logger-sharelatex");
const DocArchive = require("./DocArchiveManager");
const HealthChecker = require("./HealthChecker");
const Settings   = require("settings-sharelatex");


module.exports = (HttpController = {
	getDoc(req, res, next) {
		if (next == null) { next = function(error) {}; }
		const {
            project_id
        } = req.params;
		const {
            doc_id
        } = req.params;
		const include_deleted = (req.query != null ? req.query.include_deleted : undefined) === "true";
		logger.log({project_id, doc_id}, "getting doc");
		return DocManager.getFullDoc(project_id, doc_id, function(error, doc) {
			if (error != null) { return next(error); }
			logger.log({doc_id, project_id}, "got doc");
			if ((doc == null)) {
				return res.send(404);
			} else if (doc.deleted && !include_deleted) {
				return res.send(404);
			} else {
				return res.json(HttpController._buildDocView(doc));
			}
		});
	},

	getRawDoc(req, res, next){
		if (next == null) { next = function(error){}; }
		const {
            project_id
        } = req.params;
		const {
            doc_id
        } = req.params;
		logger.log({project_id, doc_id}, "getting raw doc");
		return DocManager.getDocLines(project_id, doc_id, function(error, doc) {
			if (error != null) { return next(error); }
			if ((doc == null)) {
				return res.send(404);
			} else {
				res.setHeader('content-type', 'text/plain');
				return res.send(HttpController._buildRawDocView(doc));
			}
		});
	},

	getAllDocs(req, res, next) {
		if (next == null) { next = function(error) {}; }
		const {
            project_id
        } = req.params;
		logger.log({project_id}, "getting all docs");
		return DocManager.getAllNonDeletedDocs(project_id, {lines: true, rev: true}, function(error, docs) {
			if (docs == null) { docs = []; }
			if (error != null) { return next(error); }
			return res.json(HttpController._buildDocsArrayView(project_id, docs));
		});
	},
	
	getAllRanges(req, res, next) {
		if (next == null) { next = function(error) {}; }
		const {
            project_id
        } = req.params;
		logger.log({project_id}, "getting all ranges");
		return DocManager.getAllNonDeletedDocs(project_id, {ranges: true}, function(error, docs) {
			if (docs == null) { docs = []; }
			if (error != null) { return next(error); }
			return res.json(HttpController._buildDocsArrayView(project_id, docs));
		});
	},

	updateDoc(req, res, next) {
		if (next == null) { next = function(error) {}; }
		const {
            project_id
        } = req.params;
		const {
            doc_id
        } = req.params;
		const lines      = req.body != null ? req.body.lines : undefined;
		const version    = req.body != null ? req.body.version : undefined;
		const ranges     = req.body != null ? req.body.ranges : undefined;

		if ((lines == null) || !(lines instanceof Array)) {
			logger.error({project_id, doc_id}, "no doc lines provided");
			res.send(400); // Bad Request
			return;
		}
		
		if ((version == null) || (typeof version === !"number")) {
			logger.error({project_id, doc_id}, "no doc version provided");
			res.send(400); // Bad Request
			return;
		}
		
		if ((ranges == null)) {
			logger.error({project_id, doc_id}, "no doc ranges provided");
			res.send(400); // Bad Request
			return;
		}

		const bodyLength = lines.reduce(
			(len, line) => line.length + len,
			0
		);
		if (bodyLength > Settings.max_doc_length) {
			logger.error({project_id, doc_id, bodyLength}, "document body too large");
			res.status(413).send("document body too large");
			return;
		}

		logger.log({project_id, doc_id}, "got http request to update doc");
		return DocManager.updateDoc(project_id, doc_id, lines, version, ranges, function(error, modified, rev) {
			if (error != null) { return next(error); }
			return res.json({
				modified,
				rev
			});
	});
	},

	deleteDoc(req, res, next) {
		if (next == null) { next = function(error) {}; }
		const {
            project_id
        } = req.params;
		const {
            doc_id
        } = req.params;
		logger.log({project_id, doc_id}, "deleting doc");
		return DocManager.deleteDoc(project_id, doc_id, function(error) {
			if (error != null) { return next(error); }
			return res.send(204);
		});
	},

	_buildDocView(doc) { 
		const doc_view = { _id: (doc._id != null ? doc._id.toString() : undefined) };
		for (let attribute of ["lines", "rev", "version", "ranges", "deleted"]) {
			if (doc[attribute] != null) {
				doc_view[attribute] = doc[attribute];
			}
		}
		return doc_view;
	},

	_buildRawDocView(doc){
		return ((doc != null ? doc.lines : undefined) || []).join("\n");
	},
	
	_buildDocsArrayView(project_id, docs) {
		const docViews = [];
		for (let doc of Array.from(docs)) {
			if (doc != null) { // There can end up being null docs for some reason :( (probably a race condition)
				docViews.push(HttpController._buildDocView(doc));
			} else {
				logger.error({err: new Error("null doc"), project_id}, "encountered null doc");
			}
		}
		return docViews;
	},

	archiveAllDocs(req, res, next) {
		if (next == null) { next = function(error) {}; }
		const {
            project_id
        } = req.params;
		logger.log({project_id}, "archiving all docs");
		return DocArchive.archiveAllDocs(project_id, function(error) {
			if (error != null) { return next(error); }
			return res.send(204);
		});
	},

	unArchiveAllDocs(req, res, next) {
		if (next == null) { next = function(error) {}; }
		const {
            project_id
        } = req.params;
		logger.log({project_id}, "unarchiving all docs");
		return DocArchive.unArchiveAllDocs(project_id, function(error) {
			if (error != null) { return next(error); }
			return res.send(200);
		});
	},

	destroyAllDocs(req, res, next) {
		if (next == null) { next = function(error) {}; }
		const {
            project_id
        } = req.params;
		logger.log({project_id}, "destroying all docs");
		return DocArchive.destroyAllDocs(project_id, function(error) {
			if (error != null) { return next(error); }
			return res.send(204);
		});
	},

	healthCheck(req, res){
		return HealthChecker.check(function(err){
			if (err != null) {
				logger.err({err}, "error performing health check");
				return res.send(500);
			} else {
				return res.send(200);
			}
		});
	}
});