codekingpro/portable-devtools

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 -t
41const 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 listed
58// include child entries if a dir is included
59const 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            ret = m !== undefined ? m : mapHas((0, path_1.dirname)(file), root);
70        }
71        map.set(file, ret);
72        return ret;
73    };
74    opt.filter =
75        filter ?
76            (file, entry) => filter(file, entry) && mapHas((0, strip_trailing_slashes_js_1.stripTrailingSlashes)(file))
77            : file => mapHas((0, strip_trailing_slashes_js_1.stripTrailingSlashes)(file));
78};
79exports.filesFilter = filesFilter;
80const listFileSync = (opt) => {
81    const p = new parse_js_1.Parser(opt);
82    const file = opt.file;
83    let fd;
84    try {
85        fd = node_fs_1.default.openSync(file, 'r');
86        const stat = node_fs_1.default.fstatSync(fd);
87        const readSize = opt.maxReadSize || 16 * 1024 * 1024;
88        if (stat.size < readSize) {
89            const buf = Buffer.allocUnsafe(stat.size);
90            const read = node_fs_1.default.readSync(fd, buf, 0, stat.size, 0);
91            p.end(read === buf.byteLength ? buf : buf.subarray(0, read));
92        }
93        else {
94            let pos = 0;
95            const buf = Buffer.allocUnsafe(readSize);
96            while (pos < stat.size) {
97                const bytesRead = node_fs_1.default.readSync(fd, buf, 0, readSize, pos);
98                if (bytesRead === 0)
99                    break;
100                pos += bytesRead;
101                p.write(buf.subarray(0, bytesRead));
102            }
103            p.end();
104        }
105    }
106    finally {
107        if (typeof fd === 'number') {
108            try {
109                node_fs_1.default.closeSync(fd);
110                /* c8 ignore next */
111            }
112            catch { }
113        }
114    }
115};
116const listFile = (opt, _files) => {
117    const parse = new parse_js_1.Parser(opt);
118    const readSize = opt.maxReadSize || 16 * 1024 * 1024;
119    const file = opt.file;
120    const p = new Promise((resolve, reject) => {
121        parse.on('error', reject);
122        parse.on('end', resolve);
123        node_fs_1.default.stat(file, (er, stat) => {
124            if (er) {
125                reject(er);
126            }
127            else {
128                const stream = new fsm.ReadStream(file, {
129                    readSize: readSize,
130                    size: stat.size,
131                });
132                stream.on('error', reject);
133                stream.pipe(parse);
134            }
135        });
136    });
137    return p;
138};
139exports.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) => {
140    if (files?.length)
141        (0, exports.filesFilter)(opt, files);
142    if (!opt.noResume)
143        onReadEntryFunction(opt);
144});
145//# sourceMappingURL=list.js.map