File Explorer

1"use strict";2var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {3    if (k2 === undefined) k2 = k;4    var desc = Object.getOwnPropertyDescriptor(m, k);5    if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {6      desc = { enumerable: true, get: function() { return m[k]; } };7    }8    Object.defineProperty(o, k2, desc);9}) : (function(o, m, k, k2) {10    if (k2 === undefined) k2 = k;11    o[k2] = m[k];12}));13var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {14    Object.defineProperty(o, "default", { enumerable: true, value: v });15}) : function(o, v) {16    o["default"] = v;17});18var __importStar = (this && this.__importStar) || (function () {19    var ownKeys = function(o) {20        ownKeys = Object.getOwnPropertyNames || function (o) {21            var ar = [];22            for (var k in o) if (Object.prototype.hasOwnProperty.call(o, k)) ar[ar.length] = k;23            return ar;24        };25        return ownKeys(o);26    };27    return function (mod) {28        if (mod && mod.__esModule) return mod;29        var result = {};30        if (mod != null) for (var k = ownKeys(mod), i = 0; i < k.length; i++) if (k[i] !== "default") __createBinding(result, mod, k[i]);31        __setModuleDefault(result, mod);32        return result;33    };34})();35var __importDefault = (this && this.__importDefault) || function (mod) {36    return (mod && mod.__esModule) ? mod : { "default": mod };37};38Object.defineProperty(exports, "__esModule", { value: true });39exports.list = exports.filesFilter = void 0;40// tar -t41const fsm = __importStar(require("@isaacs/fs-minipass"));42const node_fs_1 = __importDefault(require("node:fs"));43const path_1 = require("path");44const make_command_js_1 = require("./make-command.js");45const parse_js_1 = require("./parse.js");46const strip_trailing_slashes_js_1 = require("./strip-trailing-slashes.js");47const onReadEntryFunction = (opt) => {48    const onReadEntry = opt.onReadEntry;49    opt.onReadEntry =50        onReadEntry ?51            e => {52                onReadEntry(e);53                e.resume();54            }55            : e => e.resume();56};57// construct a filter that limits the file entries listed58// include child entries if a dir is included59const filesFilter = (opt, files) => {60    const map = new Map(files.map(f => [(0, strip_trailing_slashes_js_1.stripTrailingSlashes)(f), true]));61    const filter = opt.filter;62    const mapHas = (file, r = '') => {63        const root = r || (0, path_1.parse)(file).root || '.';64        let ret;65        if (file === root)66            ret = false;67        else {68            const m = map.get(file);69            if (m !== undefined) {70                ret = m;71            }72            else {73                ret = mapHas((0, path_1.dirname)(file), root);74            }75        }76        map.set(file, ret);77        return ret;78    };79    opt.filter =80        filter ?81            (file, entry) => filter(file, entry) && mapHas((0, strip_trailing_slashes_js_1.stripTrailingSlashes)(file))82            : file => mapHas((0, strip_trailing_slashes_js_1.stripTrailingSlashes)(file));83};84exports.filesFilter = filesFilter;85const listFileSync = (opt) => {86    const p = new parse_js_1.Parser(opt);87    const file = opt.file;88    let fd;89    try {90        fd = node_fs_1.default.openSync(file, 'r');91        const stat = node_fs_1.default.fstatSync(fd);92        const readSize = opt.maxReadSize || 16 * 1024 * 1024;93        if (stat.size < readSize) {94            const buf = Buffer.allocUnsafe(stat.size);95            const read = node_fs_1.default.readSync(fd, buf, 0, stat.size, 0);96            p.end(read === buf.byteLength ? buf : buf.subarray(0, read));97        }98        else {99            let pos = 0;100            const buf = Buffer.allocUnsafe(readSize);101            while (pos < stat.size) {102                const bytesRead = node_fs_1.default.readSync(fd, buf, 0, readSize, pos);103                if (bytesRead === 0)104                    break;105                pos += bytesRead;106                p.write(buf.subarray(0, bytesRead));107            }108            p.end();109        }110    }111    finally {112        if (typeof fd === 'number') {113            try {114                node_fs_1.default.closeSync(fd);115                /* c8 ignore next */116            }117            catch (er) { }118        }119    }120};121const listFile = (opt, _files) => {122    const parse = new parse_js_1.Parser(opt);123    const readSize = opt.maxReadSize || 16 * 1024 * 1024;124    const file = opt.file;125    const p = new Promise((resolve, reject) => {126        parse.on('error', reject);127        parse.on('end', resolve);128        node_fs_1.default.stat(file, (er, stat) => {129            if (er) {130                reject(er);131            }132            else {133                const stream = new fsm.ReadStream(file, {134                    readSize: readSize,135                    size: stat.size,136                });137                stream.on('error', reject);138                stream.pipe(parse);139            }140        });141    });142    return p;143};144exports.list = (0, make_command_js_1.makeCommand)(listFileSync, listFile, opt => new parse_js_1.Parser(opt), opt => new parse_js_1.Parser(opt), (opt, files) => {145    if (files?.length)146        (0, exports.filesFilter)(opt, files);147    if (!opt.noResume)148        onReadEntryFunction(opt);149});150//# sourceMappingURL=list.js.map