cloudron-box/src/janitor.js

'use strict';

const assert = require('assert'),
    async = require('async'),
    BoxError = require('./boxerror.js'),
    debug = require('debug')('box:janitor'),
    Docker = require('dockerode'),
    safe = require('safetydance'),
    tokens = require('./tokens.js');

exports = module.exports = {
    cleanupTokens,
    cleanupDockerVolumes
};

const NOOP_CALLBACK = function () { };

const gConnection = new Docker({ socketPath: '/var/run/docker.sock' });

async function cleanupTokens() {
    debug('Cleaning up expired tokens');

    const [error, result] = await safe(tokens.delExpired());
    if (error) return debug('cleanupTokens: error removing expired tokens', error);

    debug(`Cleaned up ${result} expired tokens`,);
}

function cleanupTmpVolume(containerInfo, callback) {
    assert.strictEqual(typeof containerInfo, 'object');
    assert.strictEqual(typeof callback, 'function');

    var cmd = 'find /tmp -type f -mtime +10 -exec rm -rf {} +'.split(' '); // 10 day old files

    debug('cleanupTmpVolume %j', containerInfo.Names);

    gConnection.getContainer(containerInfo.Id).exec({ Cmd: cmd, AttachStdout: true, AttachStderr: true, Tty: false }, function (error, execContainer) {
        if (error) return callback(new BoxError(BoxError.DOCKER_ERROR, `Failed to exec container: ${error.message}`));

        execContainer.start({ hijack: true }, function (error, stream) {
            if (error) return callback(new BoxError(BoxError.DOCKER_ERROR, `Failed to start exec container: ${error.message}`));

            stream.on('error', callback);
            stream.on('end', callback);

            gConnection.modem.demuxStream(stream, process.stdout, process.stderr);
        });
    });
}

function cleanupDockerVolumes(callback) {
    assert(!callback || typeof callback === 'function'); // callback is null when called from cronjob

    callback = callback || NOOP_CALLBACK;

    debug('Cleaning up docker volumes');

    gConnection.listContainers({ all: 0 }, function (error, containers) {
        if (error) return callback(error);

        async.eachSeries(containers, function (container, iteratorDone) {
            cleanupTmpVolume(container, function (error) {
                if (error) debug('Error cleaning tmp: %s', error);

                iteratorDone(); // intentionally ignore error
            });
        }, callback);
    });
}