const app = require('vn-loopback/server/server');
const ParameterizedSQL = require('loopback-connector').ParameterizedSQL;

describe('worker workerTimeControl_check()', () => {
    it(`should throw an error if the worker can't sign on that tablet`, async() => {
        let stmts = [];
        let stmt;
        const workerId = 110;
        const tabletId = 2;
        let err;
        stmts.push('START TRANSACTION');
        try {
            stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
                workerId,
                tabletId
            ]);
            stmts.push(stmt);

            stmts.push('ROLLBACK');

            let sql = ParameterizedSQL.join(stmts, ';');
            await app.models.Worker.rawStmt(sql);
        } catch (e) {
            err = e;
        }

        expect(err.sqlMessage).toEqual('No perteneces a este departamento.');
    });

    it('should check that the worker can sign on that tablet', async() => {
        let stmts = [];
        let stmt;
        const workerId = 110;
        const tabletId = 1;
        let err;
        stmts.push('START TRANSACTION');
        try {
            stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
                workerId,
                tabletId
            ]);
            stmts.push(stmt);

            stmts.push('ROLLBACK');

            let sql = ParameterizedSQL.join(stmts, ';');
            await app.models.Worker.rawStmt(sql);
        } catch (e) {
            err = e;
        }

        expect(err).not.toBeDefined();
    });

    it('should throw an error if the worker with a special category has not finished the 9h break', async() => {
        // dayBreak to 9h in postgresql.professional_category
        const workerId = 110;
        const tabletId = 1;
        let stmts = [];
        let stmt;
        let sql;
        let error;

        stmts.push('START TRANSACTION');
        stmt = new ParameterizedSQL(`INSERT INTO vn.workerTimeControl(userFk,timed,manual,direction)
            VALUES
                (?,TIMESTAMPADD(HOUR,-17,NOW()),0,"in"),
                (?,TIMESTAMPADD(SECOND,-32399,NOW()),0,"out")`, [
            workerId,
            workerId
        ]);
        stmts.push(stmt);

        stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
            workerId,
            tabletId
        ]);
        stmts.push(stmt);
        stmts.push('ROLLBACK');
        sql = ParameterizedSQL.join(stmts, ';');

        try {
            await app.models.Worker.rawStmt(sql);
        } catch (e) {
            await app.models.Worker.rawSql('ROLLBACK');
            error = e;
        }

        expect(error.sqlMessage).toEqual('Descansos 9 h');
    });

    it('should check f the worker with a special category has finished the 9h break', async() => {
        // dayBreak to 9h in postgresql.professional_category
        const workerId = 110;
        const tabletId = 1;
        let stmts = [];
        let stmt;
        let err;
        stmts.push('START TRANSACTION');
        stmt = new ParameterizedSQL(`INSERT INTO vn.workerTimeControl(userFk,timed,manual,direction)
            VALUES
                (?,TIMESTAMPADD(HOUR,-17,NOW()),0,"in"),
                (?,TIMESTAMPADD(SECOND,-32401,NOW()),0,"out")`, [
            workerId,
            workerId
        ]);
        stmts.push(stmt);

        stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
            workerId,
            tabletId
        ]);
        stmts.push(stmt);
        stmts.push('ROLLBACK');

        let sql = ParameterizedSQL.join(stmts, ';');

        try {
            await app.models.Worker.rawStmt(sql);
        } catch (e) {
            await app.models.Worker.rawSql('ROLLBACK');
            err = e;
        }

        expect(err).not.toBeDefined();
    });

    it('should throw an error if the worker has not finished the 12h break', async() => {
        const workerId = 109;
        const tabletId = 1;
        let stmts = [];
        let stmt;
        let sql;
        let error;

        stmts.push('START TRANSACTION');
        stmt = new ParameterizedSQL(`INSERT INTO vn.workerTimeControl(userFk,timed,manual,direction)
            VALUES
                (?,TIMESTAMPADD(HOUR,-20,NOW()),0,"in"),
                (?,TIMESTAMPADD(SECOND,-43199,NOW()),0,"out")`, [
            workerId,
            workerId
        ]);
        stmts.push(stmt);

        stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
            workerId,
            tabletId
        ]);
        stmts.push(stmt);
        stmts.push('ROLLBACK');
        sql = ParameterizedSQL.join(stmts, ';');

        try {
            await app.models.Worker.rawStmt(sql);
        } catch (e) {
            await app.models.Worker.rawSql('ROLLBACK');
            error = e;
        }

        expect(error.sqlMessage).toEqual('Descansos 12 h');
    });

    it('should throw an error if the worker has finished the 12h break', async() => {
        const workerId = 109;
        const tabletId = 1;
        let stmts = [];
        let stmt;
        let err;
        stmts.push('START TRANSACTION');
        stmt = new ParameterizedSQL(`INSERT INTO vn.workerTimeControl(userFk,timed,manual,direction)
            VALUES
                (?,TIMESTAMPADD(HOUR,-20,NOW()),0,"in"),
                (?,TIMESTAMPADD(SECOND,-43201,NOW()),0,"out")`, [
            workerId,
            workerId
        ]);
        stmts.push(stmt);

        stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
            workerId,
            tabletId
        ]);
        stmts.push(stmt);
        stmts.push('ROLLBACK');

        let sql = ParameterizedSQL.join(stmts, ';');

        try {
            await app.models.Worker.rawStmt(sql);
        } catch (e) {
            await app.models.Worker.rawSql('ROLLBACK');
            err = e;
        }

        expect(err).not.toBeDefined();
    });

    it('should throw an error if the worker has odd entry records', async() => {
        const workerId = 109;
        const tabletId = 1;
        let stmts = [];
        let stmt;
        let err;
        stmts.push('START TRANSACTION');
        stmt = new ParameterizedSQL(`INSERT INTO vn.workerTimeControl(userFk,timed,manual,direction)
            VALUES
                (?,TIMESTAMPADD(HOUR,-24,NOW()),0,"in")`, [
            workerId
        ]);
        stmts.push(stmt);

        stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
            workerId,
            tabletId
        ]);
        stmts.push(stmt);
        stmts.push('ROLLBACK');

        let sql = ParameterizedSQL.join(stmts, ';');

        try {
            await app.models.Worker.rawStmt(sql);
        } catch (e) {
            await app.models.Worker.rawSql('ROLLBACK');
            err = e;
        }

        expect(err.sqlMessage).toEqual('Dias con fichadas impares');
    });

    it('should throw an error if the worker try to sign on a holiday day', async() => {
        const workerId = 109;
        const tabletId = 1;
        let stmts = [];
        let stmt;
        let err;

        stmts.push('START TRANSACTION');

        stmt = new ParameterizedSQL(`INSERT INTO postgresql.calendar_employee(business_id,calendar_state_id,date)
            VALUES
                (?,1,CURDATE())`, [
            workerId
        ]);
        stmts.push(stmt);
        stmt = new ParameterizedSQL(`INSERT INTO vn.workerTimeControl(userFk,timed,manual,direction)
            VALUES
                (?,TIMESTAMPADD(HOUR,-24,NOW()),0,"in"),
                (?,TIMESTAMPADD(HOUR,-20,NOW()),0,"out")`, [
            workerId,
            workerId
        ]);
        stmts.push(stmt);

        stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
            workerId,
            tabletId
        ]);
        stmts.push(stmt);
        stmts.push('ROLLBACK');

        let sql = ParameterizedSQL.join(stmts, ';');

        try {
            await app.models.Worker.rawStmt(sql);
        } catch (e) {
            await app.models.Worker.rawSql('ROLLBACK');
            err = e;
        }

        expect(err.sqlMessage).toEqual('Holidays');
    });

    it('should throw an error if the worker try to sign with your contract ended', async() => {
        const workerId = 109;
        const tabletId = 1;
        let stmts = [];
        let stmt;
        let err;

        stmts.push('START TRANSACTION');

        stmt = new ParameterizedSQL(`UPDATE postgresql.business SET date_end=DATE_ADD(CURDATE(), INTERVAL -1 DAY) WHERE business_id=?`, [
            workerId
        ]);
        stmts.push(stmt);

        stmt = new ParameterizedSQL(`INSERT INTO vn.workerTimeControl(userFk,timed,manual,direction)
            VALUES
                (?,TIMESTAMPADD(HOUR,-24,NOW()),0,"in"),
                (?,TIMESTAMPADD(HOUR,-20,NOW()),0,"out")`, [
            workerId,
            workerId
        ]);
        stmts.push(stmt);

        stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
            workerId,
            tabletId
        ]);
        stmts.push(stmt);
        stmts.push('ROLLBACK');

        let sql = ParameterizedSQL.join(stmts, ';');

        try {
            await app.models.Worker.rawStmt(sql);
        } catch (e) {
            await app.models.Worker.rawSql('ROLLBACK');
            err = e;
        }

        expect(err.sqlMessage).toEqual('No hay un contrato en vigor');
    });

    it('should throw an error if the worker has not finished the 36h weekly break', async() => {
        const workerId = 109;
        const tabletId = 1;
        let stmts = [];
        let stmt;

        stmts.push('SET @warn := NULL');

        stmts.push('START TRANSACTION');

        stmt = new ParameterizedSQL(`INSERT INTO vn.workerTimeControl(userFk,timed,manual,direction)
            VALUES
                (?,TIMESTAMPADD(HOUR,-24,NOW()),0,"in"),
                (?,TIMESTAMPADD(HOUR,-16,NOW()),0,"out"),
                (?,TIMESTAMPADD(HOUR,-48,NOW()),0,"in"),
                (?,TIMESTAMPADD(HOUR,-40,NOW()),0,"out"),
                (?,TIMESTAMPADD(HOUR,-72,NOW()),0,"in"),
                (?,TIMESTAMPADD(HOUR,-64,NOW()),0,"out"),
                (?,TIMESTAMPADD(HOUR,-96,NOW()),0,"in"),
                (?,TIMESTAMPADD(HOUR,-88,NOW()),0,"out"),
                (?,TIMESTAMPADD(HOUR,-120,NOW()),0,"in"),
                (?,TIMESTAMPADD(HOUR,-112,NOW()),0,"out"),
                (?,TIMESTAMPADD(HOUR,-144,NOW()),0,"in"),
                (?,TIMESTAMPADD(HOUR,-136,NOW()),0,"out"),
                (?,TIMESTAMPADD(HOUR,-168,NOW()),0,"in"),
                (?,TIMESTAMPADD(HOUR,-160,NOW()),0,"out"),
                (?,TIMESTAMPADD(HOUR,-192,NOW()),0,"in"),
                (?,TIMESTAMPADD(HOUR,-184,NOW()),0,"out")`, [
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId
        ]);
        stmts.push(stmt);

        stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
            workerId,
            tabletId
        ]);
        stmts.push(stmt);

        let warningMessageIndex = stmts.push('SELECT @warn AS warning') - 1;
        stmts.push('ROLLBACK');
        let sql = ParameterizedSQL.join(stmts, ';');
        let result = await app.models.Worker.rawStmt(sql);

        expect(result[warningMessageIndex][0].warning).toEqual('Descansos 36 h');
    });

    it('should check if the worker has finished the 36h weekly break', async() => {
        const workerId = 109;
        const tabletId = 1;
        let stmts = [];
        let stmt;

        stmts.push('SET @warn := NULL');

        stmts.push('START TRANSACTION');

        stmt = new ParameterizedSQL(`INSERT INTO vn.workerTimeControl(userFk,timed,manual,direction)
            VALUES
            (?,TIMESTAMPADD(HOUR,-24,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-16,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-48,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-40,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-72,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-64,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-96,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-88,NOW()),0,"out")`, [
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId
        ]);
        stmts.push(stmt);

        stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
            workerId,
            tabletId
        ]);
        stmts.push(stmt);
        stmts.push('ROLLBACK');

        let warningMessageIndex = stmts.push('SELECT @warn AS warning') - 1;

        let sql = ParameterizedSQL.join(stmts, ';');
        let result = await app.models.Worker.rawStmt(sql);

        expect(result[warningMessageIndex][0].warning).toBe(null);
    });

    it('should throw an error if the worker has not finished the 72h biweekly break', async() => {
        const workerId = 109;
        const tabletId = 1;
        let stmts = [];
        let stmt;
        let err;
        stmts.push('START TRANSACTION');

        stmt = new ParameterizedSQL(`INSERT INTO vn.workerTimeControl(userFk,timed,manual,direction)
            VALUES
            (?,TIMESTAMPADD(HOUR,-24,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-16,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-48,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-40,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-72,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-64,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-96,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-88,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-120,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-112,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-144,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-136,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-168,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-160,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-192,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-184,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-216,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-208,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-240,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-232,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-264,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-256,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-289,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-280,NOW()),0,"out")`, [
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId
        ]);
        stmts.push(stmt);

        stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
            workerId,
            tabletId
        ]);
        stmts.push(stmt);
        stmts.push('ROLLBACK');

        stmts.push('SELECT @warn AS warning') - 1;

        let sql = ParameterizedSQL.join(stmts, ';');

        try {
            await app.models.Worker.rawStmt(sql);
        } catch (e) {
            await app.models.Worker.rawSql('ROLLBACK');
            err = e;
        }

        expect(err.sqlMessage).toEqual('Descansos 72 h');
    });

    it('should check if the worker has finished the 72h biweekly break', async() => {
        const workerId = 109;
        const tabletId = 1;
        let stmts = [];
        let stmt;
        let err;
        stmts.push('START TRANSACTION');

        stmt = new ParameterizedSQL(`INSERT INTO vn.workerTimeControl(userFk,timed,manual,direction)
            VALUES
            (?,TIMESTAMPADD(HOUR,-24,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-16,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-48,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-40,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-72,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-64,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-96,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-88,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-120,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-112,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-144,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-136,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-168,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-160,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-192,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-184,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-216,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-208,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-240,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-232,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-264,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-256,NOW()),0,"out"),
            (?,TIMESTAMPADD(HOUR,-288,NOW()),0,"in"),
            (?,TIMESTAMPADD(HOUR,-280,NOW()),0,"out")`, [
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId,
            workerId
        ]);
        stmts.push(stmt);

        stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
            workerId,
            tabletId
        ]);
        stmts.push(stmt);
        stmts.push('ROLLBACK');

        stmts.push('SELECT @warn AS warning') - 1;

        let sql = ParameterizedSQL.join(stmts, ';');

        try {
            await app.models.Worker.rawStmt(sql);
        } catch (e) {
            await app.models.Worker.rawSql('ROLLBACK');
            err = e;
        }

        expect(err).not.toBeDefined();
    });
});