@naturalcycles/nodejs-lib/dist/index.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.runScript = exports.readAjvSchemas = exports.readJsonSchemas = exports.AjvValidationError = exports.AjvSchema = exports.Ajv = exports._chunkBuffer = exports.TimeoutError = exports.RequestError = exports.inspectAnyStringifyFn = exports.inspectAny = exports.tableDiff = exports.BaseWorkerClass = exports.transformMultiThreaded = exports.transformMapSync = exports.transformMap = exports.transformToNDJson = exports.bufferReviver = exports.transformJsonParse = exports.streamToNDJsonFile = exports.NDJsonStats = exports.pipelineToNDJsonFile = exports.pipelineFromNDJsonFile = exports.ndjsonStreamForEach = exports.slackDefaultMessagePrefixHook = exports.SlackService = exports.Debug = exports.Joi = exports.convert = exports.undefinedIfInvalid = exports.isValid = exports.getValidationResult = exports.validate = exports.JoiValidationError = exports.fastGlob = exports.globby = void 0;
const tslib_1 = require("tslib");
const ajv_1 = require("ajv");
exports.Ajv = ajv_1.default;
const fastGlob = require("fast-glob");
exports.fastGlob = fastGlob;
const globby = require("globby");
exports.globby = globby;
const got_1 = require("got");
Object.defineProperty(exports, "RequestError", { enumerable: true, get: function () { return got_1.RequestError; } });
Object.defineProperty(exports, "TimeoutError", { enumerable: true, get: function () { return got_1.TimeoutError; } });
const buffer_util_1 = require("./buffer/buffer.util");
Object.defineProperty(exports, "_chunkBuffer", { enumerable: true, get: function () { return buffer_util_1._chunkBuffer; } });
const tableDiff_1 = require("./diff/tableDiff");
Object.defineProperty(exports, "tableDiff", { enumerable: true, get: function () { return tableDiff_1.tableDiff; } });
tslib_1.__exportStar(require("./got/getGot"), exports);
tslib_1.__exportStar(require("./infra/process.util"), exports);
const debug_1 = require("./log/debug");
Object.defineProperty(exports, "Debug", { enumerable: true, get: function () { return debug_1.Debug; } });
tslib_1.__exportStar(require("./security/hash.util"), exports);
tslib_1.__exportStar(require("./security/crypto.util"), exports);
tslib_1.__exportStar(require("./security/id.util"), exports);
tslib_1.__exportStar(require("./security/secret.util"), exports);
tslib_1.__exportStar(require("./colors/colors"), exports);
tslib_1.__exportStar(require("./log/log.util"), exports);
const slack_service_1 = require("./slack/slack.service");
Object.defineProperty(exports, "slackDefaultMessagePrefixHook", { enumerable: true, get: function () { return slack_service_1.slackDefaultMessagePrefixHook; } });
Object.defineProperty(exports, "SlackService", { enumerable: true, get: function () { return slack_service_1.SlackService; } });
const ndjson_model_1 = require("./stream/ndjson/ndjson.model");
Object.defineProperty(exports, "NDJsonStats", { enumerable: true, get: function () { return ndjson_model_1.NDJsonStats; } });
tslib_1.__exportStar(require("./stream/ndjson/ndJsonFileRead"), exports);
tslib_1.__exportStar(require("./stream/ndjson/ndJsonFileWrite"), exports);
tslib_1.__exportStar(require("./stream/ndjson/ndjsonMap"), exports);
const ndjsonStreamForEach_1 = require("./stream/ndjson/ndjsonStreamForEach");
Object.defineProperty(exports, "ndjsonStreamForEach", { enumerable: true, get: function () { return ndjsonStreamForEach_1.ndjsonStreamForEach; } });
const pipelineFromNDJsonFile_1 = require("./stream/ndjson/pipelineFromNDJsonFile");
Object.defineProperty(exports, "pipelineFromNDJsonFile", { enumerable: true, get: function () { return pipelineFromNDJsonFile_1.pipelineFromNDJsonFile; } });
const pipelineToNDJsonFile_1 = require("./stream/ndjson/pipelineToNDJsonFile");
Object.defineProperty(exports, "pipelineToNDJsonFile", { enumerable: true, get: function () { return pipelineToNDJsonFile_1.pipelineToNDJsonFile; } });
const streamToNDJsonFile_1 = require("./stream/ndjson/streamToNDJsonFile");
Object.defineProperty(exports, "streamToNDJsonFile", { enumerable: true, get: function () { return streamToNDJsonFile_1.streamToNDJsonFile; } });
const transformJsonParse_1 = require("./stream/ndjson/transformJsonParse");
Object.defineProperty(exports, "bufferReviver", { enumerable: true, get: function () { return transformJsonParse_1.bufferReviver; } });
Object.defineProperty(exports, "transformJsonParse", { enumerable: true, get: function () { return transformJsonParse_1.transformJsonParse; } });
const transformToNDJson_1 = require("./stream/ndjson/transformToNDJson");
Object.defineProperty(exports, "transformToNDJson", { enumerable: true, get: function () { return transformToNDJson_1.transformToNDJson; } });
tslib_1.__exportStar(require("./stream/pipeline/pipeline"), exports);
tslib_1.__exportStar(require("./stream/readable/readableCreate"), exports);
tslib_1.__exportStar(require("./stream/readable/readableForEach"), exports);
tslib_1.__exportStar(require("./stream/readable/readableFromArray"), exports);
tslib_1.__exportStar(require("./stream/readable/readableMap"), exports);
tslib_1.__exportStar(require("./stream/readable/readableMapToArray"), exports);
tslib_1.__exportStar(require("./stream/readable/readableToArray"), exports);
tslib_1.__exportStar(require("./stream/transform/transformBuffer"), exports);
tslib_1.__exportStar(require("./stream/transform/transformFilter"), exports);
tslib_1.__exportStar(require("./stream/transform/transformLimit"), exports);
tslib_1.__exportStar(require("./stream/transform/transformLogProgress"), exports);
const transformMap_1 = require("./stream/transform/transformMap");
Object.defineProperty(exports, "transformMap", { enumerable: true, get: function () { return transformMap_1.transformMap; } });
tslib_1.__exportStar(require("./stream/transform/transformMapSimple"), exports);
tslib_1.__exportStar(require("./stream/transform/transformNoOp"), exports);
const transformMapSync_1 = require("./stream/transform/transformMapSync");
Object.defineProperty(exports, "transformMapSync", { enumerable: true, get: function () { return transformMapSync_1.transformMapSync; } });
tslib_1.__exportStar(require("./stream/transform/transformSplit"), exports);
tslib_1.__exportStar(require("./stream/transform/transformTap"), exports);
tslib_1.__exportStar(require("./stream/transform/transformToArray"), exports);
tslib_1.__exportStar(require("./stream/transform/transformToString"), exports);
const baseWorkerClass_1 = require("./stream/transform/worker/baseWorkerClass");
Object.defineProperty(exports, "BaseWorkerClass", { enumerable: true, get: function () { return baseWorkerClass_1.BaseWorkerClass; } });
const transformMultiThreaded_1 = require("./stream/transform/worker/transformMultiThreaded");
Object.defineProperty(exports, "transformMultiThreaded", { enumerable: true, get: function () { return transformMultiThreaded_1.transformMultiThreaded; } });
tslib_1.__exportStar(require("./stream/writable/writableForEach"), exports);
tslib_1.__exportStar(require("./stream/writable/writableFork"), exports);
tslib_1.__exportStar(require("./stream/writable/writablePushToArray"), exports);
tslib_1.__exportStar(require("./stream/writable/writableVoid"), exports);
const inspectAny_1 = require("./string/inspectAny");
Object.defineProperty(exports, "inspectAny", { enumerable: true, get: function () { return inspectAny_1.inspectAny; } });
Object.defineProperty(exports, "inspectAnyStringifyFn", { enumerable: true, get: function () { return inspectAny_1.inspectAnyStringifyFn; } });
tslib_1.__exportStar(require("./util/env.util"), exports);
tslib_1.__exportStar(require("./util/lruMemoCache"), exports);
tslib_1.__exportStar(require("./util/zip.util"), exports);
const ajv_util_1 = require("./validation/ajv/ajv.util");
Object.defineProperty(exports, "readAjvSchemas", { enumerable: true, get: function () { return ajv_util_1.readAjvSchemas; } });
Object.defineProperty(exports, "readJsonSchemas", { enumerable: true, get: function () { return ajv_util_1.readJsonSchemas; } });
const ajvSchema_1 = require("./validation/ajv/ajvSchema");
Object.defineProperty(exports, "AjvSchema", { enumerable: true, get: function () { return ajvSchema_1.AjvSchema; } });
const ajvValidationError_1 = require("./validation/ajv/ajvValidationError");
Object.defineProperty(exports, "AjvValidationError", { enumerable: true, get: function () { return ajvValidationError_1.AjvValidationError; } });
tslib_1.__exportStar(require("./validation/ajv/getAjv"), exports);
const joi_extensions_1 = require("./validation/joi/joi.extensions");
Object.defineProperty(exports, "Joi", { enumerable: true, get: function () { return joi_extensions_1.Joi; } });
tslib_1.__exportStar(require("./validation/joi/joi.shared.schemas"), exports);
const joi_validation_error_1 = require("./validation/joi/joi.validation.error");
Object.defineProperty(exports, "JoiValidationError", { enumerable: true, get: function () { return joi_validation_error_1.JoiValidationError; } });
const joi_validation_util_1 = require("./validation/joi/joi.validation.util");
Object.defineProperty(exports, "convert", { enumerable: true, get: function () { return joi_validation_util_1.convert; } });
Object.defineProperty(exports, "getValidationResult", { enumerable: true, get: function () { return joi_validation_util_1.getValidationResult; } });
Object.defineProperty(exports, "isValid", { enumerable: true, get: function () { return joi_validation_util_1.isValid; } });
Object.defineProperty(exports, "undefinedIfInvalid", { enumerable: true, get: function () { return joi_validation_util_1.undefinedIfInvalid; } });
Object.defineProperty(exports, "validate", { enumerable: true, get: function () { return joi_validation_util_1.validate; } });
const script_1 = require("./script");
Object.defineProperty(exports, "runScript", { enumerable: true, get: function () { return script_1.runScript; } });