cloudron-box/src/test/notifications-test.js

/* jslint node:true */
/* global it:false */
/* global describe:false */
/* global before:false */
/* global after:false */

'use strict';

const async = require('async'),
    BoxError = require('../boxerror.js'),
    database = require('../database.js'),
    expect = require('expect.js'),
    notifications = require('../notifications.js'),
    safe = require('safetydance');

const EVENT_0 = {
    id: 'event_0',
    action: 'action',
    source: {},
    data: {}
};

function setup(done) {
    async.series([
        database.initialize,
        database._clear,
    ], done);
}

function cleanup(done) {
    async.series([
        database._clear,
        database.uninitialize
    ], done);
}

describe('Notifications', function () {
    before(setup);
    after(cleanup);

    let notificationIds = [];

    it('can add notifications', async function () {
        for (let i = 0; i < 3; i++) {
            const [error, id] = await safe(notifications._add(EVENT_0.id, `title ${i}`, `message ${i}`));
            expect(error).to.equal(null);
            expect(id).to.be.a('string');
            notificationIds.push(id);
        }
    });

    it('can get by id', async function () {
        const [error, result] = await safe(notifications.get(notificationIds[0]));
        expect(error).to.be(null);
        expect(result.title).to.be('title 0');
        expect(result.message).to.be('message 0');
        expect(result.acknowledged).to.be(false);
    });

    it('cannot get non-existent id', async function () {
        const result = await notifications.get('random');
        expect(result).to.be(null);
    });

    it('can list notifications', async function () {
        const result = await notifications.list({}, 1, 10);
        expect(result.length).to.be(3);
        expect(result[0].title).to.be('title 0');
        expect(result[1].title).to.be('title 1');
        expect(result[2].title).to.be('title 2');
    });

    it('can update notification', async function () {
        await notifications.update({ id: notificationIds[0] }, { title: 'updated title 0', message: 'updated message 0', acknowledged: true });

        const result = await notifications.get(notificationIds[0]);
        expect(result.title).to.be('updated title 0');
        expect(result.message).to.be('updated message 0');
        expect(result.acknowledged).to.be(true);
    });

    it('cannot update non-existent notification', async function () {
        const [error] = await safe(notifications.update({ id: 'random' }, { title: 'updated title 0', message: 'updated message 0', acknowledged: true }));
        expect(error.reason).to.be(BoxError.NOT_FOUND);

    });

    it('can delete', async function () {
        await notifications.del(notificationIds[0]);
    });

    it('cannot delete non-existent notification', async function () {
        const [error] = await safe(notifications.del('random'));
        expect(error.reason).to.be(BoxError.NOT_FOUND);
    });
});