"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const fs = require("fs-extra");
const path = require("path");
const util_1 = require("./util");
const debug = require('debug')('oclif-update');
async function extract(stream, basename, output, sha) {
    const getTmp = () => `${output}.partial.${Math.random().toString().split('.')[1].slice(0, 5)}`;
    let tmp = getTmp();
    if (fs.pathExistsSync(tmp))
        tmp = getTmp();
    debug(`extracting to ${tmp}`);
    try {
        await new Promise((resolve, reject) => {
            const zlib = require('zlib');
            const tar = require('tar-fs');
            const crypto = require('crypto');
            let shaValidated = false;
            let extracted = false;
            const check = () => shaValidated && extracted && resolve();
            if (sha) {
                let hasher = crypto.createHash('sha256');
                stream.on('error', reject);
                stream.on('data', d => hasher.update(d));
                stream.on('end', () => {
                    let shasum = hasher.digest('hex');
                    if (sha === shasum) {
                        shaValidated = true;
                        check();
                    }
                    else {
                        reject(new Error(`SHA mismatch: expected ${shasum} to be ${sha}`));
                    }
                });
            }
            else
                shaValidated = true;
            let ignore = (_, header) => {
                switch (header.type) {
                    case 'directory':
                    case 'file':
                        if (process.env.OCLIF_DEBUG_UPDATE_FILES)
                            debug(header.name);
                        return false;
                    case 'symlink':
                        return true;
                    default:
                        throw new Error(header.type);
                }
            };
            let extract = tar.extract(tmp, { ignore });
            extract.on('error', reject);
            extract.on('finish', () => {
                extracted = true;
                check();
            });
            let gunzip = zlib.createGunzip();
            gunzip.on('error', reject);
            stream.pipe(gunzip).pipe(extract);
        });
        if (await fs.pathExists(output)) {
            try {
                const tmp = getTmp();
                await fs.move(output, tmp);
                await fs.remove(tmp).catch(debug);
            }
            catch (err) {
                debug(err);
                await fs.remove(output);
            }
        }
        const from = path.join(tmp, basename);
        debug('moving %s to %s', from, output);
        await fs.rename(from, output);
        await fs.remove(tmp).catch(debug);
        await util_1.touch(output);
        debug('done extracting');
    }
    catch (err) {
        await fs.remove(tmp).catch(process.emitWarning);
        throw err;
    }
}
exports.extract = extract;