@naturalcycles/nodejs-lib/src/index.ts

import Ajv from 'ajv'
import { HTTPError, TimeoutError } from 'got'
import type { AfterResponseHook, BeforeErrorHook, BeforeRequestHook, Got } from 'got'
import { AnySchema, ValidationErrorItem } from 'joi'
import { _chunkBuffer } from './buffer/buffer.util'
import { tableDiff, TableDiffOptions } from './diff/tableDiff'
import { getGot } from './got/getGot'
import { GetGotOptions } from './got/got.model'
import { memoryUsage, memoryUsageFull, processSharedUtil } from './infra/process.util'
import { Debug, DebugLogLevel, IDebug, IDebugger } from './log/debug'
import {
  base64ToBuffer,
  base64ToString,
  bufferToBase64,
  hash,
  md5,
  stringToBase64,
} from './security/hash.util'
import {
  ALPHABET_ALPHANUMERIC,
  ALPHABET_ALPHANUMERIC_LOWERCASE,
  ALPHABET_ALPHANUMERIC_UPPERCASE,
  ALPHABET_LOWERCASE,
  ALPHABET_NUMBER,
  ALPHABET_UPPERCASE,
  stringId,
  stringIdAsync,
  stringIdUnsafe,
} from './security/id.util'
import {
  getSecretMap,
  loadSecretsFromEnv,
  loadSecretsFromJsonFile,
  removeSecretsFromEnv,
  secret,
  secretOptional,
  setSecretMap,
} from './security/secret.util'
import { slackDefaultMessagePrefixHook, SlackService } from './slack/slack.service'
import {
  SlackApiBody,
  SlackMessage,
  SlackMessagePrefixHook,
  SlackMessageProps,
  SlackServiceCfg,
} from './slack/slack.service.model'
import { NDJsonStats } from './stream/ndjson/ndjson.model'
import { ndJsonFileRead } from './stream/ndjson/ndJsonFileRead'
import { ndJsonFileWrite } from './stream/ndjson/ndJsonFileWrite'
import {
  ndjsonStreamForEach,
  NDJSONStreamForEachOptions,
} from './stream/ndjson/ndjsonStreamForEach'
import {
  pipelineFromNDJsonFile,
  PipelineFromNDJsonFileOptions,
} from './stream/ndjson/pipelineFromNDJsonFile'
import {
  pipelineToNDJsonFile,
  PipelineToNDJsonFileOptions,
} from './stream/ndjson/pipelineToNDJsonFile'
import { streamToNDJsonFile } from './stream/ndjson/streamToNDJsonFile'
import {
  bufferReviver,
  transformJsonParse,
  TransformJsonParseOptions,
} from './stream/ndjson/transformJsonParse'
import { transformToNDJson, TransformToNDJsonOptions } from './stream/ndjson/transformToNDJson'
import { _pipeline } from './stream/pipeline/pipeline'
import { pipelineToArray } from './stream/pipeline/pipelineToArray'
import { readableCreate, readableFrom } from './stream/readable/readableCreate'
import { readableFromArray } from './stream/readable/readableFromArray'
import {
  ReadableTyped,
  StreamForEachOptions,
  TransformOpt,
  TransformTyped,
  WritableTyped,
} from './stream/stream.model'
import { streamForEach } from './stream/streamForEach'
import { streamJoinToString } from './stream/streamJoinToString'
import { streamMapToArray } from './stream/streamMapToArray'
import { transformBuffer } from './stream/transform/transformBuffer'
import { transformConcurrent } from './stream/transform/transformConcurrent'
import { transformFilter } from './stream/transform/transformFilter'
import { transformLimit } from './stream/transform/transformLimit'
import {
  transformLogProgress,
  TransformLogProgressOptions,
} from './stream/transform/transformLogProgress'
import { transformMap, TransformMapOptions } from './stream/transform/transformMap'
import { MultiMapper, transformMapMulti } from './stream/transform/transformMapMulti'
import { transformMapSync, TransformMapSyncOptions } from './stream/transform/transformMapSync'
import { transformSplit } from './stream/transform/transformSplit'
import { transformTap } from './stream/transform/transformTap'
import { transformThrough } from './stream/transform/transformThrough'
import { transformToArray } from './stream/transform/transformToArray'
import { transformToString } from './stream/transform/transformToString'
import { BaseWorkerClass, WorkerClassInterface } from './stream/transform/worker/baseWorkerClass'
import {
  transformMultiThreaded,
  TransformMultiThreadedOptions,
} from './stream/transform/worker/transformMultiThreaded'
import { WorkerInput, WorkerOutput } from './stream/transform/worker/transformMultiThreaded.model'
import { writableForEach } from './stream/writable/writableForEach'
import { writableFork } from './stream/writable/writableFork'
import { writablePushToArray } from './stream/writable/writablePushToArray'
import { writableVoid } from './stream/writable/writableVoid'
import { inspectAny, InspectAnyOptions } from './string/string.util'
import { requireEnvKeys, requireFileToExist } from './util/env.util'
import { LRUMemoCache } from './util/lruMemoCache'
import {
  gunzipBuffer,
  gunzipToString,
  gzipBuffer,
  gzipString,
  unzipBuffer,
  unzipToString,
  zipBuffer,
  zipString,
} from './util/zip.util'
import { readAjvSchemas, readJsonSchemas } from './validation/ajv/ajv.util'
import { AjvSchema, AjvSchemaCfg, AjvValidationOptions } from './validation/ajv/ajvSchema'
import { AjvValidationError, AjvValidationErrorData } from './validation/ajv/ajvValidationError'
import { getAjv } from './validation/ajv/getAjv'
import { ExtendedJoi, Joi } from './validation/joi/joi.extensions'
import {
  AnySchemaTyped,
  ArraySchemaTyped,
  BooleanSchemaTyped,
  NumberSchemaTyped,
  ObjectSchemaTyped,
  SchemaTyped,
  StringSchemaTyped,
} from './validation/joi/joi.model'
import {
  anyObjectSchema,
  anySchema,
  arraySchema,
  binarySchema,
  booleanDefaultToFalseSchema,
  booleanSchema,
  dateStringSchema,
  emailSchema,
  idSchema,
  integerSchema,
  ipAddressSchema,
  numberSchema,
  objectSchema,
  percentageSchema,
  semVerSchema,
  SEM_VER_PATTERN,
  slugSchema,
  stringSchema,
  unixTimestampSchema,
  urlSchema,
  userAgentSchema,
  utcOffsetSchema,
  verSchema,
} from './validation/joi/joi.shared.schemas'
import { JoiValidationError, JoiValidationErrorData } from './validation/joi/joi.validation.error'
import {
  convert,
  getValidationResult,
  isValid,
  JoiValidationResult,
  undefinedIfInvalid,
  validate,
} from './validation/joi/joi.validation.util'

export type {
  JoiValidationErrorData,
  JoiValidationResult,
  ValidationErrorItem,
  ExtendedJoi,
  SchemaTyped,
  AnySchema,
  AnySchemaTyped,
  ArraySchemaTyped,
  BooleanSchemaTyped,
  NumberSchemaTyped,
  ObjectSchemaTyped,
  StringSchemaTyped,
  IDebug,
  IDebugger,
  SlackServiceCfg,
  SlackMessage,
  SlackMessageProps,
  SlackApiBody,
  SlackMessagePrefixHook,
  ReadableTyped,
  WritableTyped,
  TransformTyped,
  PipelineFromNDJsonFileOptions,
  PipelineToNDJsonFileOptions,
  TransformJsonParseOptions,
  TransformToNDJsonOptions,
  TransformMapOptions,
  TransformMapSyncOptions,
  MultiMapper,
  NDJSONStreamForEachOptions,
  TransformOpt,
  TransformLogProgressOptions,
  StreamForEachOptions,
  TransformMultiThreadedOptions,
  WorkerClassInterface,
  WorkerInput,
  WorkerOutput,
  TableDiffOptions,
  InspectAnyOptions,
  Got,
  GetGotOptions,
  AfterResponseHook,
  BeforeErrorHook,
  BeforeRequestHook,
  AjvValidationOptions,
  AjvSchemaCfg,
  AjvValidationErrorData,
}

export {
  JoiValidationError,
  validate,
  getValidationResult,
  isValid,
  undefinedIfInvalid,
  convert,
  Joi,
  booleanSchema,
  booleanDefaultToFalseSchema,
  stringSchema,
  numberSchema,
  integerSchema,
  percentageSchema,
  dateStringSchema,
  arraySchema,
  binarySchema,
  objectSchema,
  anySchema,
  anyObjectSchema,
  idSchema,
  unixTimestampSchema,
  verSchema,
  emailSchema,
  SEM_VER_PATTERN,
  semVerSchema,
  userAgentSchema,
  utcOffsetSchema,
  ipAddressSchema,
  slugSchema,
  urlSchema,
  processSharedUtil,
  zipBuffer,
  gzipBuffer,
  unzipBuffer,
  gunzipBuffer,
  zipString,
  gzipString,
  unzipToString,
  gunzipToString,
  requireEnvKeys,
  requireFileToExist,
  LRUMemoCache,
  stringId,
  stringIdAsync,
  stringIdUnsafe,
  ALPHABET_NUMBER,
  ALPHABET_LOWERCASE,
  ALPHABET_UPPERCASE,
  ALPHABET_ALPHANUMERIC_LOWERCASE,
  ALPHABET_ALPHANUMERIC_UPPERCASE,
  ALPHABET_ALPHANUMERIC,
  md5,
  hash,
  stringToBase64,
  base64ToString,
  bufferToBase64,
  base64ToBuffer,
  Debug,
  DebugLogLevel,
  getSecretMap,
  setSecretMap,
  loadSecretsFromEnv,
  loadSecretsFromJsonFile,
  removeSecretsFromEnv,
  secret,
  secretOptional,
  memoryUsage,
  memoryUsageFull,
  SlackService,
  slackDefaultMessagePrefixHook,
  readableCreate,
  readableFrom,
  readableFromArray,
  _pipeline,
  streamJoinToString,
  transformBuffer,
  ndJsonFileRead,
  ndJsonFileWrite,
  ndjsonStreamForEach,
  pipelineFromNDJsonFile,
  pipelineToNDJsonFile,
  NDJsonStats,
  streamToNDJsonFile,
  transformJsonParse,
  bufferReviver,
  transformToNDJson,
  transformThrough,
  pipelineToArray,
  transformConcurrent,
  transformFilter,
  transformMap,
  transformMapSync,
  writableForEach,
  transformMapMulti,
  writablePushToArray,
  transformSplit,
  transformToString,
  transformToArray,
  transformTap,
  transformLogProgress,
  transformLimit,
  streamForEach,
  streamMapToArray,
  writableVoid,
  writableFork,
  transformMultiThreaded,
  BaseWorkerClass,
  tableDiff,
  inspectAny,
  getGot,
  HTTPError,
  TimeoutError,
  _chunkBuffer,
  Ajv,
  getAjv,
  AjvSchema,
  AjvValidationError,
  readJsonSchemas,
  readAjvSchemas,
}