UNPKG

8.84 kBPlain TextView Raw
1import Ajv from 'ajv'
2import { HTTPError, TimeoutError } from 'got'
3import type { AfterResponseHook, BeforeErrorHook, BeforeRequestHook, Got } from 'got'
4import { AnySchema, ValidationErrorItem } from 'joi'
5import { _chunkBuffer } from './buffer/buffer.util'
6import { tableDiff, TableDiffOptions } from './diff/tableDiff'
7import { getGot } from './got/getGot'
8import { GetGotOptions } from './got/got.model'
9import { memoryUsage, memoryUsageFull, processSharedUtil } from './infra/process.util'
10import { Debug, DebugLogLevel, IDebug, IDebugger } from './log/debug'
11import {
12 base64ToBuffer,
13 base64ToString,
14 bufferToBase64,
15 hash,
16 md5,
17 stringToBase64,
18} from './security/hash.util'
19import {
20 ALPHABET_ALPHANUMERIC,
21 ALPHABET_ALPHANUMERIC_LOWERCASE,
22 ALPHABET_ALPHANUMERIC_UPPERCASE,
23 ALPHABET_LOWERCASE,
24 ALPHABET_NUMBER,
25 ALPHABET_UPPERCASE,
26 stringId,
27 stringIdAsync,
28 stringIdUnsafe,
29} from './security/id.util'
30import {
31 getSecretMap,
32 loadSecretsFromEnv,
33 loadSecretsFromJsonFile,
34 removeSecretsFromEnv,
35 secret,
36 secretOptional,
37 setSecretMap,
38} from './security/secret.util'
39import { slackDefaultMessagePrefixHook, SlackService } from './slack/slack.service'
40import {
41 SlackApiBody,
42 SlackMessage,
43 SlackMessagePrefixHook,
44 SlackMessageProps,
45 SlackServiceCfg,
46} from './slack/slack.service.model'
47import { NDJsonStats } from './stream/ndjson/ndjson.model'
48import { ndJsonFileRead } from './stream/ndjson/ndJsonFileRead'
49import { ndJsonFileWrite } from './stream/ndjson/ndJsonFileWrite'
50import {
51 ndjsonStreamForEach,
52 NDJSONStreamForEachOptions,
53} from './stream/ndjson/ndjsonStreamForEach'
54import {
55 pipelineFromNDJsonFile,
56 PipelineFromNDJsonFileOptions,
57} from './stream/ndjson/pipelineFromNDJsonFile'
58import {
59 pipelineToNDJsonFile,
60 PipelineToNDJsonFileOptions,
61} from './stream/ndjson/pipelineToNDJsonFile'
62import { streamToNDJsonFile } from './stream/ndjson/streamToNDJsonFile'
63import {
64 bufferReviver,
65 transformJsonParse,
66 TransformJsonParseOptions,
67} from './stream/ndjson/transformJsonParse'
68import { transformToNDJson, TransformToNDJsonOptions } from './stream/ndjson/transformToNDJson'
69import { _pipeline } from './stream/pipeline/pipeline'
70import { readableCreate, readableFrom } from './stream/readable/readableCreate'
71import { readableForEach, readableForEachSync } from './stream/readable/readableForEach'
72import { readableFromArray } from './stream/readable/readableFromArray'
73import { readableMap } from './stream/readable/readableMap'
74import { readableToArray } from './stream/readable/readableToArray'
75import {
76 ReadableTyped,
77 TransformOptions,
78 TransformTyped,
79 WritableTyped,
80} from './stream/stream.model'
81import { transformBuffer } from './stream/transform/transformBuffer'
82import { transformFilter, transformFilterSync } from './stream/transform/transformFilter'
83import { transformLimit } from './stream/transform/transformLimit'
84import {
85 transformLogProgress,
86 TransformLogProgressOptions,
87} from './stream/transform/transformLogProgress'
88import { transformMap, TransformMapOptions } from './stream/transform/transformMap'
89import { transformMapSimple } from './stream/transform/transformMapSimple'
90import { transformMapSync, TransformMapSyncOptions } from './stream/transform/transformMapSync'
91import { transformSplit } from './stream/transform/transformSplit'
92import { transformTap } from './stream/transform/transformTap'
93import { transformToArray } from './stream/transform/transformToArray'
94import { transformToString } from './stream/transform/transformToString'
95import { BaseWorkerClass, WorkerClassInterface } from './stream/transform/worker/baseWorkerClass'
96import {
97 transformMultiThreaded,
98 TransformMultiThreadedOptions,
99} from './stream/transform/worker/transformMultiThreaded'
100import { WorkerInput, WorkerOutput } from './stream/transform/worker/transformMultiThreaded.model'
101import { writableForEach } from './stream/writable/writableForEach'
102import { writableFork } from './stream/writable/writableFork'
103import { writablePushToArray } from './stream/writable/writablePushToArray'
104import { writableVoid } from './stream/writable/writableVoid'
105import { inspectAny, InspectAnyOptions } from './string/string.util'
106import { requireEnvKeys, requireFileToExist } from './util/env.util'
107import { LRUMemoCache } from './util/lruMemoCache'
108import {
109 gunzipBuffer,
110 gunzipToString,
111 gzipBuffer,
112 gzipString,
113 unzipBuffer,
114 unzipToString,
115 zipBuffer,
116 zipString,
117} from './util/zip.util'
118import { readAjvSchemas, readJsonSchemas } from './validation/ajv/ajv.util'
119import { AjvSchema, AjvSchemaCfg, AjvValidationOptions } from './validation/ajv/ajvSchema'
120import { AjvValidationError, AjvValidationErrorData } from './validation/ajv/ajvValidationError'
121import { getAjv } from './validation/ajv/getAjv'
122import { ExtendedJoi, Joi } from './validation/joi/joi.extensions'
123import {
124 AnySchemaTyped,
125 ArraySchemaTyped,
126 BooleanSchemaTyped,
127 NumberSchemaTyped,
128 ObjectSchemaTyped,
129 SchemaTyped,
130 StringSchemaTyped,
131} from './validation/joi/joi.model'
132import {
133 anyObjectSchema,
134 anySchema,
135 arraySchema,
136 binarySchema,
137 booleanDefaultToFalseSchema,
138 booleanSchema,
139 dateStringSchema,
140 emailSchema,
141 idSchema,
142 integerSchema,
143 ipAddressSchema,
144 numberSchema,
145 objectSchema,
146 percentageSchema,
147 semVerSchema,
148 SEM_VER_PATTERN,
149 slugSchema,
150 stringSchema,
151 unixTimestampSchema,
152 urlSchema,
153 userAgentSchema,
154 utcOffsetSchema,
155 verSchema,
156} from './validation/joi/joi.shared.schemas'
157import { JoiValidationError, JoiValidationErrorData } from './validation/joi/joi.validation.error'
158import {
159 convert,
160 getValidationResult,
161 isValid,
162 JoiValidationResult,
163 undefinedIfInvalid,
164 validate,
165} from './validation/joi/joi.validation.util'
166
167export type {
168 JoiValidationErrorData,
169 JoiValidationResult,
170 ValidationErrorItem,
171 ExtendedJoi,
172 SchemaTyped,
173 AnySchema,
174 AnySchemaTyped,
175 ArraySchemaTyped,
176 BooleanSchemaTyped,
177 NumberSchemaTyped,
178 ObjectSchemaTyped,
179 StringSchemaTyped,
180 IDebug,
181 IDebugger,
182 SlackServiceCfg,
183 SlackMessage,
184 SlackMessageProps,
185 SlackApiBody,
186 SlackMessagePrefixHook,
187 ReadableTyped,
188 WritableTyped,
189 TransformTyped,
190 PipelineFromNDJsonFileOptions,
191 PipelineToNDJsonFileOptions,
192 TransformJsonParseOptions,
193 TransformToNDJsonOptions,
194 TransformMapOptions,
195 TransformMapSyncOptions,
196 NDJSONStreamForEachOptions,
197 TransformOptions,
198 TransformLogProgressOptions,
199 TransformMultiThreadedOptions,
200 WorkerClassInterface,
201 WorkerInput,
202 WorkerOutput,
203 TableDiffOptions,
204 InspectAnyOptions,
205 Got,
206 GetGotOptions,
207 AfterResponseHook,
208 BeforeErrorHook,
209 BeforeRequestHook,
210 AjvValidationOptions,
211 AjvSchemaCfg,
212 AjvValidationErrorData,
213}
214
215export {
216 JoiValidationError,
217 validate,
218 getValidationResult,
219 isValid,
220 undefinedIfInvalid,
221 convert,
222 Joi,
223 booleanSchema,
224 booleanDefaultToFalseSchema,
225 stringSchema,
226 numberSchema,
227 integerSchema,
228 percentageSchema,
229 dateStringSchema,
230 arraySchema,
231 binarySchema,
232 objectSchema,
233 anySchema,
234 anyObjectSchema,
235 idSchema,
236 unixTimestampSchema,
237 verSchema,
238 emailSchema,
239 SEM_VER_PATTERN,
240 semVerSchema,
241 userAgentSchema,
242 utcOffsetSchema,
243 ipAddressSchema,
244 slugSchema,
245 urlSchema,
246 processSharedUtil,
247 zipBuffer,
248 gzipBuffer,
249 unzipBuffer,
250 gunzipBuffer,
251 zipString,
252 gzipString,
253 unzipToString,
254 gunzipToString,
255 requireEnvKeys,
256 requireFileToExist,
257 LRUMemoCache,
258 stringId,
259 stringIdAsync,
260 stringIdUnsafe,
261 ALPHABET_NUMBER,
262 ALPHABET_LOWERCASE,
263 ALPHABET_UPPERCASE,
264 ALPHABET_ALPHANUMERIC_LOWERCASE,
265 ALPHABET_ALPHANUMERIC_UPPERCASE,
266 ALPHABET_ALPHANUMERIC,
267 md5,
268 hash,
269 stringToBase64,
270 base64ToString,
271 bufferToBase64,
272 base64ToBuffer,
273 Debug,
274 DebugLogLevel,
275 getSecretMap,
276 setSecretMap,
277 loadSecretsFromEnv,
278 loadSecretsFromJsonFile,
279 removeSecretsFromEnv,
280 secret,
281 secretOptional,
282 memoryUsage,
283 memoryUsageFull,
284 SlackService,
285 slackDefaultMessagePrefixHook,
286 readableCreate,
287 readableFrom,
288 readableFromArray,
289 readableToArray,
290 readableForEach,
291 readableForEachSync,
292 readableMap,
293 _pipeline,
294 transformBuffer,
295 ndJsonFileRead,
296 ndJsonFileWrite,
297 ndjsonStreamForEach,
298 pipelineFromNDJsonFile,
299 pipelineToNDJsonFile,
300 NDJsonStats,
301 streamToNDJsonFile,
302 transformJsonParse,
303 bufferReviver,
304 transformToNDJson,
305 transformFilter,
306 transformFilterSync,
307 transformMap,
308 transformMapSync,
309 transformMapSimple,
310 writableForEach,
311 writablePushToArray,
312 transformSplit,
313 transformToString,
314 transformToArray,
315 transformTap,
316 transformLogProgress,
317 transformLimit,
318 writableVoid,
319 writableFork,
320 transformMultiThreaded,
321 BaseWorkerClass,
322 tableDiff,
323 inspectAny,
324 getGot,
325 HTTPError,
326 TimeoutError,
327 _chunkBuffer,
328 Ajv,
329 getAjv,
330 AjvSchema,
331 AjvValidationError,
332 readJsonSchemas,
333 readAjvSchemas,
334}