feat: task runner

package.json

@@ -20,21 +20,21 @@
   "license": "MIT",
   "private": true,
   "devDependencies": {
-    "@commitlint/cli": "^17.6.3",
-    "@commitlint/config-conventional": "^17.6.3",
-    "@types/jest": "^29.2.5",
-    "@types/node": "^20.2.5",
-    "@typescript-eslint/eslint-plugin": "^5.59.8",
-    "@typescript-eslint/parser": "^5.59.8",
+    "@commitlint/cli": "^17.6.5",
+    "@commitlint/config-conventional": "^17.6.5",
+    "@types/jest": "^29.5.2",
+    "@types/node": "^20.3.1",
+    "@typescript-eslint/eslint-plugin": "^5.59.11",
+    "@typescript-eslint/parser": "^5.59.11",
     "cross-env": "^7.0.3",
-    "eslint": "^8.41.0",
-    "eslint-plugin-import": "^2.26.0",
+    "eslint": "^8.42.0",
+    "eslint-plugin-import": "^2.27.5",
     "eslint-plugin-unused-imports": "^2.0.0",
-    "jest": "^29.3.1",
+    "jest": "^29.5.0",
     "lerna": "^6.6.2",
     "rimraf": "^5.0.1",
-    "ts-jest": "^29.0.3",
-    "typescript": "^5.0.4"
+    "ts-jest": "^29.1.0",
+    "typescript": "^5.1.3"
   },
   "packageManager": "yarn@3.5.1"
 }

packages/app/package.json

@@ -33,7 +33,10 @@
         "access": "public"
     },
     "dependencies": {
+        "@bunt/assert": "^0.1.0",
+        "@bunt/async": "^0.26.3",
         "@bunt/input": "^0.26.3",
+        "@bunt/is": "^0.1.0",
         "@bunt/unit": "^0.26.3",
         "@bunt/util": "^0.26.3",
         "@types/busboy": "^1.5.0",

packages/app/src/Application.ts

@@ -8,7 +8,9 @@ import {
     Unit,
     unit,
 } from "@bunt/unit";
-import {assert, isDefined, logger, Logger} from "@bunt/util";
+import {logger, Logger} from "@bunt/util";
+import {assert} from "@bunt/assert";
+import {isDefined} from "@bunt/is";
 import {ActionResponse, IRequest} from "./interfaces.js";
 import {IRoute, RouteNotFound} from "./Route/index.js";
 

packages/app/src/Payload/Resolver.ts

@@ -1,5 +1,5 @@
 import {ActionAny, ActionState} from "@bunt/unit";
-import {isFunction, isObject} from "@bunt/util";
+import {isFunction, isObject} from "@bunt/is";
 import {IRouteContext} from "../Route/index.js";
 import {ResolverResolvers} from "./interfaces.js";
 

packages/app/src/Request/HeadersAbstract.ts

@@ -1,4 +1,6 @@
-import {assert, ILogable, isBoolean, isFunction} from "@bunt/util";
+import {isBoolean, isFunction} from "@bunt/is";
+import {ILogable} from "@bunt/type";
+import {assert} from "@bunt/assert";
 import {HeaderAssertValue, IHeaders} from "../interfaces.js";
 import {StrictKeyValueMap} from "./StrictKeyValueMap.js";
 

packages/app/src/Request/RequestAbstract.ts

@@ -1,4 +1,5 @@
-import {ILogable, isFunction, Promisify} from "@bunt/util";
+import {ILogable, Promisify} from "@bunt/type";
+import {isFunction} from "@bunt/is";
 import {Application} from "../Application.js";
 import {IHeaders, IKeyValueMap, IRequest, IRequestTransform, RequestTransformType} from "../interfaces.js";
 import {

packages/app/src/Route/Route.ts

@@ -1,5 +1,6 @@
 import {ActionAny, ActionFactory} from "@bunt/unit";
-import {ILogable, isFunction, isString} from "@bunt/util";
+import {isFunction, isString} from "@bunt/is";
+import {ILogable} from "@bunt/type";
 import {
     IRoute,
     IRouteMatcher,

packages/app/src/Route/RouteNotFound.ts

@@ -1,4 +1,4 @@
-import {NotFound} from "@bunt/util";
+import {NotFound} from "@bunt/assert";
 
 export class RouteNotFound extends NotFound {
     constructor(route: string) {

packages/app/src/TransformRequest/MultipartFormDataTransform.ts

@@ -2,8 +2,9 @@ import {randomBytes} from "crypto";
 import {tmpdir} from "os";
 import {join} from "path";
 import {createWriteStream} from "fs";
-import {Defer, QueryString} from "@bunt/util";
+import {QueryString} from "@bunt/util";
 import * as busboy from "busboy";
+import {Defer} from "@bunt/async";
 import {IRequest} from "../interfaces.js";
 
 export const MultipartFormDataTransform = async <T = unknown>(request: IRequest): Promise<T> => {

packages/app/src/interfaces.ts

@@ -1,4 +1,4 @@
-import {Promisify} from "@bunt/util";
+import {Promisify} from "@bunt/type";
 import {Application} from "./Application.js";
 
 export type ActionResponse = Error

packages/assert/LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2020 Artur Bier
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

packages/assert/package.json

@@ -0,0 +1,40 @@
+{
+    "name": "@bunt/assert",
+    "version": "0.1.0",
+    "keywords": [
+        "typescript"
+    ],
+    "author": {
+        "name": "Artur Bier",
+        "email": "izatop@gmail.com"
+    },
+    "main": "dist/cjs/index.js",
+    "module": "dist/esm/index.js",
+    "types": "dist/cjs/index.d.ts",
+    "exports": {
+        ".": {
+            "import": {
+                "types": "./dist/esm/index.d.ts",
+                "default": "./dist/esm/index.js"
+            },
+            "require": {
+                "types": "./dist/cjs/index.d.ts",
+                "default": "./dist/cjs/index.js"
+            }
+        }
+    },
+    "files": [
+        "dist/",
+        "LICENSE"
+    ],
+    "description": "Utils",
+    "repository": "git@github.com:izatop/bunt.git",
+    "publishConfig": {
+        "access": "public"
+    },
+    "license": "MIT",
+    "dependencies": {
+        "@bunt/is": "^0.1.0",
+        "@bunt/type": "^0.1.0"
+    }
+}

packages/assert/src/Exception/AssertionError.ts

@@ -0,0 +1,19 @@
+import {isFunction} from "@bunt/is";
+import {ILogable} from "@bunt/type";
+import {ValidationError} from "./ValidationError.js";
+
+export class AssertionError extends ValidationError implements ILogable<Record<any, any>> {
+    public readonly details?: any;
+
+    constructor(message?: string, details?: unknown | (() => unknown)) {
+        super(message || "Assertion fails");
+
+        this.details = isFunction(details)
+            ? details()
+            : details;
+    }
+
+    public getLogValue(): Record<any, any> {
+        return this.details;
+    }
+}

packages/assert/src/Exception/NotFound.ts

@@ -0,0 +1 @@
+export class NotFound extends Error {}

packages/assert/src/Exception/PermissionError.ts

@@ -0,0 +1 @@
+export class PermissionError extends Error {}

packages/assert/src/Exception/ValidationError.ts

@@ -0,0 +1 @@
+export class ValidationError extends Error {}

packages/assert/src/Exception/functions.ts

@@ -0,0 +1,5 @@
+import {IReadableError} from "./interfaces.js";
+
+export const isReadableError = (error: Error): error is IReadableError & Error => {
+    return "toSafeJSON" in error && "toSafeString" in error;
+};

packages/assert/src/Exception/index.ts

@@ -0,0 +1,6 @@
+export * from "./interfaces.js";
+export * from "./PermissionError.js";
+export * from "./ValidationError.js";
+export * from "./AssertionError.js";
+export * from "./NotFound.js";
+export * from "./functions.js";

packages/assert/src/Exception/interfaces.ts

@@ -0,0 +1,5 @@
+export interface IReadableError {
+    toSafeString(): string;
+
+    toSafeJSON(): Record<any, any>;
+}

packages/assert/src/assert.ts

@@ -0,0 +1,56 @@
+import {isFunction, isInstanceOf, isString} from "@bunt/is";
+import {AssertionError} from "./Exception/index.js";
+
+export type AssertionDetailsAllowType = string | Record<any, any> | null | number;
+export type AssertionDetails = (() => AssertionDetailsAllowType) | AssertionDetailsAllowType;
+export type AssertionMessage = string | (() => string) | (() => Error);
+
+function createAssertionError(message?: AssertionMessage, details?: AssertionDetails): Error | AssertionError {
+    const description = isFunction(message) ? message() : message;
+
+    return isInstanceOf(description, Error)
+        ? description
+        : new AssertionError(description, details);
+}
+
+export function assert(expr: unknown, message?: AssertionMessage, details?: AssertionDetails): asserts expr {
+    if (!expr) {
+        throw createAssertionError(message, details);
+    }
+}
+
+export function validateTrue(result: true | string, details?: AssertionDetails): void {
+    if (isString(result)) {
+        throw createAssertionError(result, details);
+    }
+}
+
+export function fails(expr: unknown, message?: AssertionMessage, details?: AssertionDetails): void {
+    if (expr) {
+        throw createAssertionError(message, details);
+    }
+}
+
+export function pass<T>(value: unknown, transform: (v: any) => T, validator: (v: any) => boolean, label?: string): T {
+    assert(value, `${label || "Value"} should be defined`);
+
+    const nextValue = transform(value);
+    assert(
+        validator(nextValue),
+        `This ${label || "value"} "${nextValue}" should pass the validation stage: ${validator.toString()}`,
+    );
+
+    return nextValue;
+}
+
+export function toError(error: unknown, alt: Error | string = "Unexpected error"): Error {
+    if (error instanceof Error) {
+        return error;
+    }
+
+    if (typeof alt === "string") {
+        return new Error(alt);
+    }
+
+    return alt;
+}

packages/assert/src/index.ts

@@ -0,0 +1,2 @@
+export * from "./Exception/index.js";
+export * from "./assert";

packages/assert/test/jest.config.js

@@ -0,0 +1,8 @@
+module.exports = {
+    transform: {"src/.+\\.[jt]s?$": ["ts-jest", {}]},
+    moduleNameMapper: {
+        "^([\\.]+\\/.+)\\/index\\.js": "$1",
+        "^([\\.]+\\/.+)\\.js": "$1",
+    },
+    rootDir: "src",
+};

packages/assert/test/src/assert.test.ts

@@ -0,0 +1,6 @@
+import {assert} from "../../src";
+
+test("assert", () => {
+    expect(() => assert(false)).toThrow();
+    expect(() => assert(true)).not.toThrow();
+});

packages/assert/test/tsconfig.json

@@ -0,0 +1,7 @@
+{
+    "extends": "../../../tsconfig.test.json",
+    "include": [
+        "src",
+        "../src"
+    ]
+}

packages/assert/tsconfig.esm.json

@@ -0,0 +1,20 @@
+{
+    "extends": "../../tsconfig.lib.json",
+    "compilerOptions": {
+        "module": "esnext",
+        "moduleResolution": "nodenext",
+        "rootDir": "src",
+        "outDir": "dist/esm"
+    },
+    "references": [
+        {
+            "path": "../type"
+        },
+        {
+            "path": "../is"
+        }
+    ],
+    "include": [
+        "src"
+    ]
+}

packages/assert/tsconfig.json

@@ -0,0 +1,18 @@
+{
+    "extends": "../../tsconfig.lib.json",
+    "compilerOptions": {
+        "rootDir": "src",
+        "outDir": "dist/cjs"
+    },
+    "references": [
+        {
+            "path": "../type"
+        },
+        {
+            "path": "../is"
+        }
+    ],
+    "include": [
+        "src"
+    ]
+}

packages/async/package.json

@@ -31,6 +31,8 @@
     "description": "Async utils",
     "repository": "git@github.com:izatop/bunt.git",
     "dependencies": {
+        "@bunt/assert": "^0.1.0",
+        "@bunt/is": "^0.1.0",
         "@bunt/util": "^0.26.3"
     },
     "publishConfig": {

packages/async/src/AsyncIteratorFactory.ts

@@ -1,4 +1,4 @@
-import {isUndefined} from "@bunt/util";
+import {isUndefined} from "@bunt/is";
 import {AsyncPool} from "./AsyncPool.js";
 
 export type AsyncIteratorFactoryControl<T> = {

packages/async/src/AsyncPool.ts

@@ -1,4 +1,4 @@
-import {assert} from "@bunt/util";
+import {assert} from "@bunt/assert";
 import {Defer} from "./Defer.js";
 
 export interface IAsyncPushPullOptions {

packages/async/src/AsyncState.ts

@@ -1,4 +1,4 @@
-import {isDefined} from "@bunt/util";
+import {isDefined} from "@bunt/is";
 
 export interface IAsyncStateMap<T> {
     resolve: (value: T | PromiseLike<T>) => void;

packages/cli/package.json

@@ -34,6 +34,7 @@
     },
     "dependencies": {
         "@bunt/app": "^0.26.3",
+        "@bunt/assert": "^0.1.0",
         "@bunt/util": "^0.26.3",
         "path-to-regexp": "^6.2.1"
     },

packages/cli/src/Request/RequestCommand.ts

@@ -1,5 +1,6 @@
 import {KeyValueMap, RequestAbstract} from "@bunt/app";
-import {Argv, assert} from "@bunt/util";
+import {Argv} from "@bunt/util";
+import {assert} from "@bunt/assert";
 import {Headers} from "./Headers.js";
 
 export class RequestCommand extends RequestAbstract {