import test from 'ava';
import getToFile from '../src/getToFileMapFunc';
import { GpgKey, FilePartIndex, RelativeFilePath, Operation, RemotePendingCommitDownloaded, AbsoluteFilePath, Callback } from '../src/Types';

function getInput(path: RelativeFilePath, part: FilePartIndex, proceed = true): RemotePendingCommitDownloaded {
    let d = new Date('2017-07-22T17:02:48.000Z');
    return {
        gpgKey: 'commit-gpg-key',
        clientId: 'notme',
        createdAt: d,
        commitId: 'cid',
        record: [{
            gpgKey: 'gpg-key',
            sha256: 'sha',
            operation: Operation.Create,
            filePartByteCountThreshold: 1024,
            fileByteCount: 200,
            modifiedDate: d,
            path: path,
            part: part,
            local: null,
            stat: null,
            proceed
        }]
    };

}

test.cb('Can delete', (tst) => {

    let done = {
        rename: 0,
        decrypt: 0,
        mkdirp: 1,
        unlink: 0,
        utimes: 0
    };

    let e = () => { throw new Error("Should not be here"); };

    let deps = {
        utimes: e,
        copyFile: e,
        unlink: (path, n) => {
            done.unlink = done.unlink + 1;
            tst.is(path, '/store/Docs/a.txt');
            n(null);
        },
        decrypt: e,
        rename: (s, d, n) => {
            tst.is(s, '/store/.ebak/remote-pending-commit/c-cid-commit--gpg--key-notme.commit');
            tst.is(d, '/store/.ebak/remote-commit/c-cid-commit--gpg--key-notme.commit');
            done.rename = done.rename + 1;
            n(null);
        },
        mkdirp: (p, n) => {
            tst.is(p, '/store/.ebak/remote-commit');
            n(null);
        }
    };

    let mf = getToFile(deps, '/store/.ebak', '/store');

    let input = getInput('Docs/a.txt', [2, 2], true);
    input.record[0] = {...input.record[0], operation: Operation.Delete};
    mf(input, (e, r) => {
        tst.is(done.utimes, 0);
        tst.is(done.decrypt, 0);
        tst.is(done.mkdirp, 1);
        tst.is(done.rename, 1);
        tst.is(done.unlink, 1);
        tst.is(null, e);
        tst.deepEqual(r, input);
        tst.end();
    });

});

test.cb('Will skip if not proceed', (tst) => {

    let done = {
        rename: 0,
        decrypt: 0,
        mkdirp: 1,
        unlink: 0,
        utimes: 0
    };

    let e = () => { throw new Error("Should not be here"); };

    let deps = {
        utimes: e,
        copyFile: e,
        unlink: e,
        decrypt: e,
        rename: (s, d, n) => {
            tst.is(s, '/store/.ebak/remote-pending-commit/c-cid-commit--gpg--key-notme.commit');
            tst.is(d, '/store/.ebak/remote-commit/c-cid-commit--gpg--key-notme.commit');
            done.rename = done.rename + 1;
            n(null);
        },
        mkdirp: (p, n) => {
            tst.is(p, '/store/.ebak/remote-commit');
            n(null);
        }
    };

    let mf = getToFile(deps, '/store/.ebak', '/store');

    mf(getInput('Docs/a.txt', [2, 2], false), (e, r) => {
        tst.is(done.utimes, 0);
        tst.is(done.decrypt, 0);
        tst.is(done.mkdirp, 1);
        tst.is(done.rename, 1);
        tst.is(done.unlink, 0);
        tst.is(null, e);
        tst.deepEqual(r, getInput('Docs/a.txt', [2, 2], false));
        tst.end();
    });

});


test.cb('Can unencrypt local FilePart', (tst) => {

    let done = {
        rename: 0,
        copyFile: 0,
        decrypt: 0,
        mkdirp: 0,
        unlink: 0,
        utimes: 0
    };

    let deps = {
        utimes: (f: AbsoluteFilePath, atime: number, mtime: number, next: Callback<void>) => {
            done.utimes = done.utimes + 1;
            tst.is(f, '/store/Docs/a.txt');
            tst.is(atime, 1500742968);
            tst.is(mtime, 1500742968);
            next(null);
        },
        copyFile: (oldFn: AbsoluteFilePath, newFn: AbsoluteFilePath, next: Callback<void>) => {
            let expected = {
                oldFn: '/store/.ebak/tmp/sha.ebak.dec',
                newFn: '/store/Docs/a.txt',
            };
            done.copyFile = done.copyFile + 1;
            tst.is(oldFn, expected.oldFn);
            tst.is(newFn, expected.newFn);
            next(null);
        },
        rename: (oldFn: AbsoluteFilePath, newFn: AbsoluteFilePath, next: Callback<void>) => {
            let expected = {
                oldFn: '/store/.ebak/remote-pending-commit/c-cid-commit--gpg--key-notme.commit',
                newFn: '/store/.ebak/remote-commit/c-cid-commit--gpg--key-notme.commit'
            };
            done.rename = done.rename + 1;
            tst.is(oldFn, expected.oldFn);
            tst.is(newFn, expected.newFn);
            next(null);
        },
        mkdirp: (p, n) => {
            let expected = [
                '/store/Docs',
                '/store/.ebak/remote-commit'
            ];
            tst.is(p, expected[done.mkdirp]);
            done.mkdirp = done.mkdirp + 1;
            n(null);
        },
        unlink: (path: AbsoluteFilePath, next: Callback<void>) => {
            let expected = [
                '/store/.ebak/remote-encrypted-filepart/c-cid-f-sha-1-1KB-gpg--key.ebak',
                '/store/.ebak/remote-encrypted-filepart/c-cid-f-sha-2-1KB-gpg--key.ebak',
                '/store/.ebak/tmp/sha.ebak.dec'
            ];
            tst.deepEqual(path, expected[done.unlink]);
            done.unlink = done.unlink + 1;
            next(null);
        },
        decrypt: (gpgKey: GpgKey, src: AbsoluteFilePath[], dst: AbsoluteFilePath, info: string, next: Callback<void>) => {
            tst.is(gpgKey, 'gpg-key');
            tst.is(dst, '/store/.ebak/tmp/sha.ebak.dec');
            tst.deepEqual(src, [
                '/store/.ebak/remote-encrypted-filepart/c-cid-f-sha-1-1KB-gpg--key.ebak',
                '/store/.ebak/remote-encrypted-filepart/c-cid-f-sha-2-1KB-gpg--key.ebak'
            ]);
            done['decrypt'] = done['decrypt'] + 1;
            next(null);
        }
    };

    let mf = getToFile(deps, '/store/.ebak', '/store');

    mf(getInput('Docs/a.txt', [2, 2]), (e, r) => {
        tst.is(done.utimes, 1);
        tst.is(done.decrypt, 1);
        tst.is(done.mkdirp, 2);
        tst.is(done.copyFile, 1);
        tst.is(done.unlink, 3);
        tst.is(null, e);
        tst.deepEqual(r, getInput('Docs/a.txt', [2, 2]));
        tst.end();
    });

});