cloudron-box/src/routes/filemanager.js

'use strict';

exports = module.exports = {
    proxyAppData,
    proxyVolumeData
};

const assert = require('assert'),
    BoxError = require('../boxerror.js'),
    middleware = require('../middleware/index.js'),
    HttpError = require('connect-lastmile').HttpError,
    safe = require('safetydance'),
    services = require('../services.js'),
    url = require('url');

async function proxy(id, req, res, next) {
    assert.strictEqual(typeof id, 'string');

    req.clearTimeout();

    const [error, result] = await safe(services.getContainerDetails('sftp', 'CLOUDRON_SFTP_TOKEN'));
    if (error) return next(BoxError.toHttpError(error));

    let parsedUrl = url.parse(req.url, true /* parseQueryString */);
    parsedUrl.query['access_token'] = result.token;

    req.url = url.format({ pathname: `/files/${id}/${encodeURIComponent(req.params[0])}`, query: parsedUrl.query }); // params[0] already contains leading '/'

    const proxyOptions = url.parse(`https://${result.ip}:3000`);
    proxyOptions.rejectUnauthorized = false;
    const fileManagerProxy = middleware.proxy(proxyOptions);

    fileManagerProxy(req, res, function (error) {
        if (!error) return next();

        if (error.code === 'ECONNREFUSED') return next(new HttpError(424, 'Unable to connect to filemanager server'));
        if (error.code === 'ECONNRESET') return next(new HttpError(424, 'Unable to query filemanager server'));

        next(new HttpError(500, error));
    });
}

function proxyAppData(req, res, next) {
    proxy(`app-${req.params.id}`, req, res, next);
}

function proxyVolumeData(req, res, next) {
    proxy(`volume-${req.params.id}`, req, res, next);
}