// MIT License
//
// Copyright (c) 2021 Kai Zhu
//
// 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.

/*
sh one-liner:
sh jslint_ci.sh shCiBuildWasm
sh jslint_ci.sh shSqlmathUpdate
*/

/*jslint beta, bitwise, name, node*/
/*global FinalizationRegistry*/
"use strict";

// init debugInline
const debugInline = (function () {
    let consoleError = Object;
    function debug(...argList) {

// This function will print <argList> to stderr and then return <argList>[0].

        consoleError("\n\ndebugInline");
        consoleError(...argList);
        consoleError("\n");
        if (consoleError === Object) {
            consoleError = console.error;
        }
        return argList[0];
    }
    return debug;
}());
debugInline(); // coverage-hack

const JSBATON_ARGC = 8; //jslint-ignore-line
const JSBATON_OFFSET_ALL = 256;
const JSBATON_OFFSET_ARGV = 128;
const JSBATON_OFFSET_BUFV = 192;
// const JSBATON_OFFSET_ERRMSG = 48;
const JSBATON_OFFSET_FUNCNAME = 8;
const JS_MAX_SAFE_INTEGER = 0x1f_ffff_ffff_ffff;
const JS_MIN_SAFE_INTEGER = -0x1f_ffff_ffff_ffff;
const SIZEOF_BLOB_MAX = 1_000_000_000;
// const SIZEOF_ERRMSG = 80;
const SIZEOF_FUNCNAME = 16;
const SQLITE_DATATYPE_BLOB = 0x04;
const SQLITE_DATATYPE_EXTERNALBUFFER = 0x71;
const SQLITE_DATATYPE_FLOAT = 0x02;
const SQLITE_DATATYPE_INTEGER = 0x01;
const SQLITE_DATATYPE_INTEGER_0 = 0x00;
const SQLITE_DATATYPE_INTEGER_1 = 0x21;
const SQLITE_DATATYPE_NULL = 0x05;
const SQLITE_DATATYPE_TEXT = 0x03;
const SQLITE_DATATYPE_TEXT_0 = 0x13;
const SQLITE_RESPONSETYPE_LASTBLOB = 1;
const SQLITE_RESPONSETYPE_LASTVALUE = 2;

const FILENAME_DBTMP = "/tmp/__dbtmp1"; //jslint-ignore-line

const LGBM_DTYPE_FLOAT32 = 0;           /* float32 (single precision float)*/
const LGBM_DTYPE_FLOAT64 = 1;           /* float64 (double precision float)*/
const LGBM_DTYPE_INT32 = 2;             /* int32*/
const LGBM_DTYPE_INT64 = 3;             /* int64*/
const LGBM_FEATURE_IMPORTANCE_GAIN = 1; /* Gain type of feature importance*/
const LGBM_FEATURE_IMPORTANCE_SPLIT = 0;/* Split type of feature importance*/
const LGBM_MATRIX_TYPE_CSC = 1;         /* CSC sparse matrix type*/
const LGBM_MATRIX_TYPE_CSR = 0;         /* CSR sparse matrix type*/
const LGBM_PREDICT_CONTRIB = 3; /* Predict feature contributions (SHAP values)*/
const LGBM_PREDICT_LEAF_INDEX = 2;      /* Predict leaf index*/
const LGBM_PREDICT_NORMAL = 0;  /* Normal prediction w/ transform (if needed)*/
const LGBM_PREDICT_RAW_SCORE = 1;       /* Predict raw score*/
const SQLITE_OPEN_AUTOPROXY = 0x00000020;       /* VFS only */
const SQLITE_OPEN_CREATE = 0x00000004;          /* Ok for sqlite3_open_v2() */
const SQLITE_OPEN_DELETEONCLOSE = 0x00000008;   /* VFS only */
const SQLITE_OPEN_EXCLUSIVE = 0x00000010;       /* VFS only */
const SQLITE_OPEN_FULLMUTEX = 0x00010000;       /* Ok for sqlite3_open_v2() */
const SQLITE_OPEN_MAIN_DB = 0x00000100;         /* VFS only */
const SQLITE_OPEN_MAIN_JOURNAL = 0x00000800;    /* VFS only */
const SQLITE_OPEN_MEMORY = 0x00000080;          /* Ok for sqlite3_open_v2() */
const SQLITE_OPEN_NOFOLLOW = 0x01000000;        /* Ok for sqlite3_open_v2() */
const SQLITE_OPEN_NOMUTEX = 0x00008000;         /* Ok for sqlite3_open_v2() */
const SQLITE_OPEN_PRIVATECACHE = 0x00040000;    /* Ok for sqlite3_open_v2() */
const SQLITE_OPEN_READONLY = 0x00000001;        /* Ok for sqlite3_open_v2() */
const SQLITE_OPEN_READWRITE = 0x00000002;       /* Ok for sqlite3_open_v2() */
const SQLITE_OPEN_SHAREDCACHE = 0x00020000;     /* Ok for sqlite3_open_v2() */
const SQLITE_OPEN_SUBJOURNAL = 0x00002000;      /* VFS only */
const SQLITE_OPEN_SUPER_JOURNAL = 0x00004000;   /* VFS only */
const SQLITE_OPEN_TEMP_DB = 0x00000200;         /* VFS only */
const SQLITE_OPEN_TEMP_JOURNAL = 0x00001000;    /* VFS only */
const SQLITE_OPEN_TRANSIENT_DB = 0x00000400;    /* VFS only */
const SQLITE_OPEN_URI = 0x00000040;             /* Ok for sqlite3_open_v2() */
const SQLITE_OPEN_WAL = 0x00080000;             /* VFS only */

const DB_EXEC_PROFILE_DICT = {}; //jslint-ignore-line
const DB_STATE = {};
const version = "v2026.7.30";
let DB_EXEC_PROFILE_MODE;
let DB_EXEC_PROFILE_SQL_LENGTH;
let IS_BROWSER;
let SQLMATH_EXE;
let SQLMATH_NODE;
let cModule;
let cModulePath;
let consoleError = console.error;
let dbFinalizationRegistry;
let moduleChildProcess;
let moduleChildProcessSpawn;
let moduleCrypto;
let moduleFs;
let moduleFsInitResolveList;
let modulePath;
let moduleUrl;
let {
    npm_config_mode_debug,
    npm_config_mode_setup,
    npm_config_mode_test
} = typeof process === "object" && process?.env;
let sqlMessageDict = {}; // dict of web-worker-callbacks
let sqlMessageId = 0;
let sqlWorker;

async function assertErrorThrownAsync(asyncFunc, regexp) {

// This function will assert calling <asyncFunc> throws an error.

    let err;
    try {
        await asyncFunc();
    } catch (errCaught) {
        err = errCaught;
    }
    assertOrThrow(err, "No error thrown.");
    assertOrThrow(
        !regexp || new RegExp(regexp).test(err.message),
        err
    );
}

function assertInt64(val) {
    // This function will assert <val> is within range of c99-signed-long-long.
    val = BigInt(val);
    if (!(
        -9_223_372_036_854_775_808n <= val && val <= 9_223_372_036_854_775_807n
    )) {
        throw new Error(
            `integer ${val} outside signed-64-bit inclusive-range`
            + " -9,223,372,036,854,775,808 to 9,223,372,036,854,775,807"
        );
    }
}

function assertJsonEqual(aa, bb, message) {

// This function will assert JSON.stringify(<aa>) === JSON.stringify(<bb>).

    aa = JSON.stringify(objectDeepCopyWithKeysSorted(aa), undefined, 1);
    bb = JSON.stringify(objectDeepCopyWithKeysSorted(bb), undefined, 1);
    if (aa !== bb) {
        throw new Error(
            "\n" + aa + "\n!==\n" + bb
            + (
                typeof message === "string"
                ? " - " + message
                : message
                ? " - " + JSON.stringify(message)
                : ""
            )
        );
    }
}

function assertNumericalEqual(aa, bb, message) {

// This function will assert aa - bb <= Number.EPSILON.

    assertOrThrow(aa, "value cannot be 0 or falsy");
    if (!(Math.abs((aa - bb) / Math.max(aa, bb)) <= 256 * Number.EPSILON)) {
        throw new Error(
            JSON.stringify(aa) + " != " + JSON.stringify(bb) + (
                message
                ? " - " + message
                : ""
            )
        );
    }
}

function assertOrThrow(condition, message) {

// This function will throw <message> if <condition> is falsy.

    if (!condition) {
        throw (
            (!message || typeof message === "string")
            ? new Error(String(message).slice(0, 2048))
            : message
        );
    }
}

async function childProcessSpawn2(command, args, option) {

// This function will run child_process.spawn as a promise.

    return await new Promise(function (resolve, reject) {
        let bufList = [[], [], []];
        let child;
        let {
            modeCapture,
            modeDebug,
            stdio = []
        } = option;
        if (modeDebug) {
            consoleError(
                `childProcessSpawn2 - ${command} ${JSON.stringify(args)}`
            );
        }
        child = moduleChildProcessSpawn(
            command,
            args,
            Object.assign({}, option, {
                stdio: [
                    "ignore",
                    (
                        modeCapture
                        ? "pipe"
                        : stdio[1]
                    ),
                    (
                        modeCapture
                        ? "pipe"
                        : stdio[2]
                    )
                ]
            })
        );
        if (modeCapture) {
            [
                child.stdin, child.stdout, child.stderr
            ].forEach(function (pipe, ii) {
                if (ii === 0) {
                    return;
                }
                pipe.on("data", function (chunk) {
                    bufList[ii].push(chunk);
                    if (stdio[ii] !== "ignore") {
                        switch (ii) {
                        case 1:
                            process.stdout.write(chunk);
                            break;
                        case 2:
                            process.stderr.write(chunk);
                            break;
                        }
                    }
                });
            });
        }
        child.on("exit", function (exitCode) {
            let resolve0 = resolve;
            let stderr;
            let stdout;
            // coverage-hack
            if (exitCode || npm_config_mode_test) {
                resolve = reject;
            }
            // coverage-hack
            if (npm_config_mode_test) {
                resolve = resolve0;
            }
            [
                stdout, stderr
            ] = bufList.slice(1).map(function (buf) {
                return (
                    typeof modeCapture === "string"
                    ? Buffer.concat(buf).toString(modeCapture)
                    : Buffer.concat(buf)
                );
            });
            resolve([
                exitCode, stdout, stderr
            ]);
        });
    });
}

async function ciBuildExt({
    process
}) {

// This function will build sqlmath from c.

    let binNodegyp;
    let exitCode;
    binNodegyp = modulePath.resolve(
        modulePath.dirname(process.execPath || ""),
        "node_modules/npm/node_modules/node-gyp/bin/node-gyp.js"
    ).replace("/bin/node_modules/", "/lib/node_modules/");
    if (!noop(
        await fsExistsUnlessTest(cModulePath)
    )) {
        await ciBuildExt1NodejsConfigure({
            binNodegyp,
            process
        });
    }
    consoleError(
        `ciBuildExt2Nodejs - linking lib ${modulePath.resolve(cModulePath)}`
    );
    [
        exitCode
    ] = await childProcessSpawn2(
        "sh",
        [
            "-c",
            (`
(set -e
    # rebuild binding
    node "${binNodegyp}" build --release
    # node "${binNodegyp}" build --release --loglevel=verbose
    mv build/Release/binding.node "${cModulePath}"
    mv build/Release/shell "${SQLMATH_EXE}"
    # ugly-hack - win32-sqlite-shell doesn't like nodejs-builtin-zlib,
    #             so link with external-zlib.
    if (uname | grep -q "MING\\|MSYS")
    then
        rm -f ${SQLMATH_EXE}
        python setup.py exe_link \
            ./build/Release/SRC_SQLITE_BASE.lib \
            ./build/Release/SRC_SQLMATH_BASE.lib \
            ./build/Release/obj/shell/sqlmath_external_sqlite.obj \
            ./zlib.v1.3.1.vcpkg.x64-windows-static.lib \
            \
            -ltcg \
            -nologo \
            -out:${SQLMATH_EXE} \
            -subsystem:console
    fi
)
            `)
        ],
        {modeDebug: npm_config_mode_debug, stdio: ["ignore", 1, 2]}
    );
    assertOrThrow(!exitCode, `ciBuildExt - exitCode=${exitCode}`);
}

async function ciBuildExt1NodejsConfigure({
    binNodegyp
    // process
}) {

// This function will setup posix/win32 env for building c-extension.

    let cflagWallList = [];
    let cflagWnoList = [];
    String(
        await fsReadFileUnlessTest(".ci.sh", "utf8", (`
SQLMATH_CFLAG_WALL_LIST=" \\
"
SQLMATH_CFLAG_WNO_LIST=" \\
"
        `))
    ).replace((
        /(SQLMATH_CFLAG_WALL_LIST|SQLMATH_CFLAG_WNO_LIST)=" \\([\S\s]*?)"/g
    ), function (ignore, cflagType, cflagList) {
        cflagList = cflagList.split(/[\s\\]/).filter(noop);
        switch (cflagType) {
        case "SQLMATH_CFLAG_WALL_LIST":
            cflagWallList = cflagList;
            break;
        case "SQLMATH_CFLAG_WNO_LIST":
            cflagWnoList = cflagList;
            break;
        }
        return "";
    });
    consoleError(`ciBuildExt1Nodejs - configure binding.gyp`);
    await fsWriteFileUnlessTest("binding.gyp", JSON.stringify({
        "target_defaults": {
            "cflags": cflagWallList,
// https://github.com/nodejs/node-gyp/blob/v10.3.1/gyp/pylib/gyp/MSVSSettings.py
            "msvs_settings": {
                "VCCLCompilerTool": {
                    "WarnAsError": 1,
                    "WarningLevel": 4
                }
            },
            "xcode_settings": {
                "OTHER_CFLAGS": cflagWallList
            }
        },
        "targets": [
            {
                "cflags": cflagWnoList,
                "defines": [
                    "SRC_SQLITE_BASE_C2"
                ],
                "msvs_settings": {
                    "VCCLCompilerTool": {
                        "WarnAsError": 1,
                        "WarningLevel": 2
                    }
                },
                "sources": [
                    "sqlmath_external_sqlite.c"
                ],
                "target_name": "SRC_SQLITE_BASE",
                "type": "static_library",
                "xcode_settings": {
                    "OTHER_CFLAGS": cflagWnoList
                }
            },
            {
                "defines": [
                    "SRC_SQLMATH_BASE_C2"
                ],
                "dependencies": [
                    "SRC_SQLITE_BASE"
                ],
                "sources": [
                    "sqlmath_base.c"
                ],
                "target_name": "SRC_SQLMATH_BASE",
                "type": "static_library"
            },
            {
                "defines": [
                    "SRC_SQLMATH_NODEJS_C2"
                ],
                "dependencies": [
                    "SRC_SQLMATH_BASE"
                ],
                "sources": [
                    "sqlmath_base.c"
                ],
                "target_name": "binding"
            },
            {
                "conditions": [
                    [
                        "OS==\"win\"",
                        {},
                        {
                            "libraries": [
                                "-lz"
                            ]
                        }
                    ]
                ],
                "defines": [
                    "SRC_SQLITE_SHELL_C2"
                ],
                "dependencies": [
                    "SRC_SQLMATH_BASE"
                ],
                "sources": [
                    "sqlmath_external_sqlite.c"
                ],
                "target_name": "shell",
                "type": "executable"
            }
        ]
    }, undefined, 4) + "\n");
    await childProcessSpawn2(
        "sh",
        [
            "-c",
            (`
(set -e
    # node "${binNodegyp}" clean
    node "${binNodegyp}" configure
)
            `)
        ],
        {modeDebug: npm_config_mode_debug, stdio: ["ignore", 1, 2]}
    );
}

function csvFromListofList({
    colList,
    rowList
}) {
// this function will convert json <rowList> to csv with given <colList>
    let data = JSON.stringify([[colList], rowList].flat(), undefined, 1);
    // convert data to csv
    data = data.replace((
        /\n  /g
    ), "");
    data = data.replace((
        /\n \[/g
    ), "");
    data = data.replace((
        /\n \],?/g
    ), "\r\n");
    data = data.slice(1, -2);
    // sqlite-strings are c-strings which should never contain null-char
    data = data.replace((
        /\u0000/g
    ), "");
    // hide double-backslash `\\\\` as null-char
    data = data.replace((
        /\\\\/g
    ), "\u0000");
    // escape double-quote `\\"` to `""`
    data = data.replace((
        /\\"/g
    ), "\"\"");
    // replace newline with space
    data = data.replace((
        /\\r\\n|\\r|\\n/g
    ), " ");
    // restore double-backslash `\\\\` from null-char
    data = data.replace((
        /\u0000/g
    ), "\\\\");
    return data;
}

function csvToListofList({
    csv
}) {
// This function will convert <csv>-text to json list-of-list.
//
// https://tools.ietf.org/html/rfc4180#section-2
// Definition of the CSV Format
// While there are various specifications and implementations for the
// CSV format (for ex. [4], [5], [6] and [7]), there is no formal
// specification in existence, which allows for a wide variety of
// interpretations of CSV files.  This section documents the format that
// seems to be followed by most implementations:
//
// 1.  Each record is located on a separate line, delimited by a line
//     break (CRLF).  For example:
//     aaa,bbb,ccc CRLF
//     zzz,yyy,xxx CRLF
//
// 2.  The last record in the file may or may not have an ending line
//     break.  For example:
//     aaa,bbb,ccc CRLF
//     zzz,yyy,xxx
//
// 3.  There maybe an optional header line appearing as the first line
//     of the file with the same format as normal record lines.  This
//     header will contain names corresponding to the fields in the file
//     and should contain the same number of fields as the records in
//     the rest of the file (the presence or absence of the header line
//     should be indicated via the optional "header" parameter of this
//     MIME type).  For example:
//     field_name,field_name,field_name CRLF
//     aaa,bbb,ccc CRLF
//     zzz,yyy,xxx CRLF
//
// 4.  Within the header and each record, there may be one or more
//     fields, separated by commas.  Each line should contain the same
//     number of fields throughout the file.  Spaces are considered part
//     of a field and should not be ignored.  The last field in the
//     record must not be followed by a comma.  For example:
//     aaa,bbb,ccc
//
// 5.  Each field may or may not be enclosed in double quotes (however
//     some programs, such as Microsoft Excel, do not use double quotes
//     at all).  If fields are not enclosed with double quotes, then
//     double quotes may not appear inside the fields.  For example:
//     "aaa","bbb","ccc" CRLF
//     zzz,yyy,xxx
//
// 6.  Fields containing line breaks (CRLF), double quotes, and commas
//     should be enclosed in double-quotes.  For example:
//     "aaa","b CRLF
//     bb","ccc" CRLF
//     zzz,yyy,xxx
//
// 7.  If double-quotes are used to enclose fields, then a double-quote
//     appearing inside a field must be escaped by preceding it with
//     another double quote.  For example:
//     "aaa","b""bb","ccc"
    let match;
    let quote;
    let rgx;
    let row;
    let rowList;
    let val;
    // normalize "\r\n" to "\n"
    csv = csv.trimEnd().replace((
        /\r\n?/gu
    ), "\n") + "\n";
    rgx = (
        /(.*?)(""|"|,|\n)/gu
    );
    rowList = [];
    // reset row
    row = [];
    val = "";
    while (true) {
        match = rgx.exec(csv);
        if (!match) {
// 2.  The last record in the file may or may not have an ending line
//     break.  For example:
//     aaa,bbb,ccc CRLF
//     zzz,yyy,xxx
            if (!row.length) {
                break;
            }
            // // if eof missing crlf, then mock it
            // rgx.lastIndex = csv.length;
            // match = [
            //     "\n", "", "\n"
            // ];
        }
        // build val
        val += match[1];
        if (match[2] === "\"") {
// 5.  Each field may or may not be enclosed in double quotes (however
//     some programs, such as Microsoft Excel, do not use double quotes
//     at all).  If fields are not enclosed with double quotes, then
//     double quotes may not appear inside the fields.  For example:
//     "aaa","bbb","ccc" CRLF
//     zzz,yyy,xxx
            quote = !quote;
        } else if (quote) {
// 7.  If double-quotes are used to enclose fields, then a double-quote
//     appearing inside a field must be escaped by preceding it with
//     another double quote.  For example:
//     "aaa","b""bb","ccc"
            if (match[2] === "\"\"") {
                val += "\"";
// 6.  Fields containing line breaks (CRLF), double quotes, and commas
//     should be enclosed in double-quotes.  For example:
//     "aaa","b CRLF
//     bb","ccc" CRLF
//     zzz,yyy,xxx
            } else {
                val += match[2];
            }
        } else if (match[2] === ",") {
// 4.  Within the header and each record, there may be one or more
//     fields, separated by commas.  Each line should contain the same
//     number of fields throughout the file.  Spaces are considered part
//     of a field and should not be ignored.  The last field in the
//     record must not be followed by a comma.  For example:
//     aaa,bbb,ccc
            // delimit val
            row.push(val);
            val = "";
        } else if (match[2] === "\n") {
// 1.  Each record is located on a separate line, delimited by a line
//     break (CRLF).  For example:
//     aaa,bbb,ccc CRLF
//     zzz,yyy,xxx CRLF
            // delimit val
            row.push(val);
            val = "";
            // append row
            rowList.push(row);
            // reset row
            row = [];
        }
    }
    // // append val
    // if (val) {
    //     row.push(val);
    // }
    // // append row
    // if (row.length) {
    //     rowList.push(row);
    // }
    return rowList;
}

async function dbCallAsync(baton, argList, mode, db) {

// This function will call c-function dbXxx() with given <funcname>
// and return [<baton>, ...argList].

    let errStack;
    let funcname;
    let id;
    let profileObj;
    let profileStart;
    let result;
    let sql;
    let timeElapsed;
    // If argList contains <db>, then mark it as busy.
    if (mode === "modeDbExec" || mode === "modeDbFile") {
        // init db
        db = argList[0];
        assertOrThrow(
            db.busy >= 0,
            `dbCallAsync - invalid db.busy = ${db.busy}`
        );
        db.ii = (db.ii + 1) % db.connPool.length;
        db.ptr = db.connPool[db.ii][0];
        // increment db.busy
        db.busy += 1;
        // init profileObj
        if (DB_EXEC_PROFILE_MODE && mode === "modeDbExec") {
            profileStart = Date.now();
            sql = String(argList[1]);
            // sql-hash - remove comment
            sql = sql.replace((/\s*?--.*?$/gm), "");
            // sql-hash - remove vowel
            sql = sql.replace((/[aeiou]\b/gi), "\u0000$&");
            sql = sql.replace((/([bcdfghjklmnpqrstvwxyz])[aeiou]+/gi), "$1");
            sql = sql.replace((/\u0000([aeiou])\b/gi), "$1");
            // sql-hash - remove underscore
            sql = sql.replace((/_+/g), "");
            // sql-hash - truncate long text
            sql = sql.replace((/(\S{16})\S+/g), "$1");
            // sql-hash - remove whitespace
            sql = sql.replace((/\s+/g), " ");
            sql = sql.trim().slice(0, DB_EXEC_PROFILE_SQL_LENGTH);
            DB_EXEC_PROFILE_DICT[sql] = DB_EXEC_PROFILE_DICT[sql] || {
                busy: 0,
                count: 0,
                sql,
                timeElapsed: 0
            };
            profileObj = DB_EXEC_PROFILE_DICT[sql];
            // increment profileObj.busy
            profileObj.busy += 1;
            profileObj.count += 1;
        }
        try {
            return await dbCallAsync(
                baton,
                [
                    db.ptr,
                    ...argList.slice(1)
                ],
                undefined,
                db
            );
        } finally {
            // decrement db.busy
            db.busy -= 1;
            assertOrThrow(
                db.busy >= 0,
                `dbCallAsync - invalid db.busy = ${db.busy}`
            );
            // update profileObj
            if (profileObj) {
                // decrement profileObj.busy
                profileObj.busy -= 1;
                assertOrThrow(
                    profileObj.busy >= 0,
                    `dbCallAsync - invalid profileObj.busy = ${profileObj.busy}`
                );
                if (profileObj.busy === 0) {
                    profileObj.timeElapsed += Date.now() - profileStart;
                }
            }
        }
    }
    // copy argList to avoid side-effect
    argList = [...argList];
    assertOrThrow(
        argList.length <= JSBATON_ARGC,
        `dbCallAsync - argList.length must be less than than ${JSBATON_ARGC}`
    );
    // pad argList to length JSBATON_ARGC
    while (argList.length < JSBATON_ARGC) {
        argList.push(0n);
    }
    // serialize js-value to c-value
    argList = argList.map(function (val, argi) {
        if (val === null || val === undefined) {
            val = 0;
        }
        switch (typeof val) {
        case "bigint":
        case "boolean":
        case "number":
            // check for min/max safe-integer
            assertOrThrow(
                (
                    (JS_MIN_SAFE_INTEGER <= val && val <= JS_MAX_SAFE_INTEGER)
                    || typeof val === "bigint"
                ),
                (
                    "dbCallAsync - "
                    + "non-bigint-integer must be within inclusive-range"
                    + ` ${JS_MIN_SAFE_INTEGER} to ${JS_MAX_SAFE_INTEGER}`
                )
            );
            val = BigInt(val);
            assertInt64(val);
            baton.setBigInt64(JSBATON_OFFSET_ARGV + argi * 8, val, true);
            return val;
        // case "object":
        //     break;
        case "string":
            baton = jsbatonSetValue(baton, argi, (
                val.endsWith("\u0000")
                ? val
                // append null-terminator to string
                : val + "\u0000"
            ));
            return;
        }
        assertOrThrow(
            !ArrayBuffer.isView(val) || val.byteOffset === 0,
            (
                "dbCallAsync - argList cannot contain arraybuffer-views"
                + " with non-zero byteOffset"
            )
        );
        if (isExternalBuffer(val)) {
            return val;
        }
        throw new Error(`dbCallAsync - invalid arg-type "${typeof val}"`);
    });
    // assert byteOffset === 0
    [baton, ...argList].forEach(function (arg) {
        assertOrThrow(!ArrayBuffer.isView(arg) || arg.byteOffset === 0, arg);
    });
    // extract funcname
    funcname = new TextDecoder().decode(
        new DataView(baton.buffer, JSBATON_OFFSET_FUNCNAME, SIZEOF_FUNCNAME)
    ).replace((/\u0000/g), "");
    // preserve stack-trace
    errStack = new Error().stack.replace((/.*$/m), "");
    try {

// Dispatch to nodejs-napi.

        if (!IS_BROWSER) {
            await cModule._jspromiseCreate(baton.buffer, argList, funcname);
            // prepend baton to argList
            return [baton, ...argList];
        }

// Dispatch to web-worker.

        // increment sqlMessageId
        sqlMessageId += 1;
        id = sqlMessageId;
        // postMessage to web-worker
        sqlWorker.postMessage(
            {
                FILENAME_DBTMP,
                JSBATON_OFFSET_ALL,
                JSBATON_OFFSET_BUFV,
                argList,
                baton,
                funcname,
                id
            },
            // transfer arraybuffer without copying
            [baton.buffer, ...argList.filter(isExternalBuffer)]
        );
        // init timeElapsed
        timeElapsed = Date.now();
        // await result from web-worker
        result = await new Promise(function (resolve) {
            sqlMessageDict[id] = resolve;
        });
        // cleanup sqlMessageDict
        delete sqlMessageDict[id];
        // debug slow postMessage
        timeElapsed = Date.now() - timeElapsed;
        if (timeElapsed > 500 || funcname === "testTimeElapsed") {
            consoleError(
                "sqlMessagePost - "
                + JSON.stringify({funcname, timeElapsed})
                + errStack
            );
        }
        assertOrThrow(!result.errmsg, result.errmsg);
        // prepend baton to argList
        return [result.baton, ...result.argList];
    } catch (err) {
        // debug db.filename
        if (db?.filename2 || db?.filename) {
            err.message += ` (from ${db?.filename2 || db?.filename})`;
        }
        err.stack += errStack;
        assertOrThrow(undefined, err);
    }
}

async function dbCloseAsync(db) {

// This function will close sqlite-database-connection <db>.

    // prevent segfault - do not close db if actions are pending
    assertOrThrow(
        db.busy === 0,
        `dbCloseAsync - cannot close db with ${db.busy} actions pending`
    );
    // cleanup connPool
    await Promise.all(db.connPool.map(async function (ptr) {
        let val = ptr[0];
        ptr[0] = 0n;
        await dbCallAsync(
            jsbatonCreate("_dbClose"),
            [
                val,
                db.filename
            ]
        );
    }));
}

function dbExecAndReturnLastBlob(option) {

// This function will exec <sql> in <db>,
// and return last-value retrieved from execution as raw blob/buffer.

    return dbExecAsync(Object.assign({
        responseType: "lastblob"
    }, option));
}

async function dbExecAndReturnLastRow(option) {

// This function will exec <sql> in <db>,
// and return last-row or empty-object.

    let result = await dbExecAsync(option);
    result = result[result.length - 1] || [];
    result = result[result.length - 1] || {};
    return result;
}

async function dbExecAndReturnLastTable(option) {

// This function will exec <sql> in <db>,
// and return last-table or empty-list.

    let result = await dbExecAsync(option);
    result = result[result.length - 1] || [];
    return result;
}

function dbExecAndReturnLastValue(option) {

// This function will exec <sql> in <db>,
// and return last-json-value.

    return dbExecAsync(Object.assign({
        responseType: "lastvalue"
    }, option));
}

async function dbExecAsync({
    bindList = [],
    db,
    modeNoop,
    responseType,
    sql
}) {

// This function will exec <sql> in <db> and return <result>.

    let baton = jsbatonCreate("_dbExec");
    let bindByKey = !Array.isArray(bindList);
    let bufi = [0];
    let referenceList = [];
    let result;
    if (modeNoop) {
        return;
    }
    if (bindByKey) {
        Object.entries(bindList).forEach(function ([key, val]) {
            baton = jsbatonSetValue(baton, undefined, `:${key}\u0000`);
            baton = jsbatonSetValue(
                baton,
                undefined,
                val,
                bufi,
                referenceList
            );
        });
    } else {
        bindList.forEach(function (val) {
            baton = jsbatonSetValue(
                baton,
                undefined,
                val,
                bufi,
                referenceList
            );
        });
    }
    [
        baton, ...result
    ] = await dbCallAsync(
        baton,
        [
            // 0. db
            db,
            // 1. sql
            String(sql) + "\n;\nPRAGMA noop",
            // 2. bindList.length
            (
                bindByKey
                ? Object.keys(bindList).length
                : bindList.length
            ),
            // 3. bindByKey
            bindByKey,
            // 4. responseType
            (
                responseType === "lastblob"
                ? SQLITE_RESPONSETYPE_LASTBLOB
                : responseType === "lastvalue"
                ? SQLITE_RESPONSETYPE_LASTVALUE
                : 0
            )
        ],
        "modeDbExec"
    );
    result = result[0];
    if (!IS_BROWSER) {
        result = cModule._jsbatonStealCbuffer(
            baton.buffer,
            0,
            Number(
                responseType !== "arraybuffer" && responseType !== "lastblob"
            )
        );
    }
    switch (responseType) {
    case "arraybuffer":
    case "lastblob":
        break;
    case "lastvalue":
    case "list":
        result = jsonParseArraybuffer(result);
        break;
    default:
        result = jsonParseArraybuffer(result).map(function (table) {
            let colList = table.shift();
            return table.map(function (row) {
                let dict = {};
                colList.forEach(function (key, ii) {
                    dict[key] = row[ii];
                });
                return dict;
            });
        });
    }
    return result;
}

function dbExecProfile({
    limit = 20,
    lineLength = 80,
    modeInit,
    sqlLength = 256
}) {

// This function will profile dbExecAsync.

    let result;
    if (modeInit && !DB_EXEC_PROFILE_MODE) {
        DB_EXEC_PROFILE_MODE = Date.now();
        DB_EXEC_PROFILE_SQL_LENGTH = sqlLength;
        process.on("exit", function () {
            console.error(dbExecProfile({
                limit,
                lineLength
            }));
        });
        return;
    }
    result = Object.values(DB_EXEC_PROFILE_DICT);
    result.sort(function (aa, bb) {
        return ((bb.timeElapsed - aa.timeElapsed) || (bb.count - aa.count));
    });
    result = result.slice(0, limit).map(function ({
        count,
        sql,
        timeElapsed
    }, ii) {
        return String(
            `${Number(ii + 1).toFixed(0).padStart(2, " ")}.`
            + ` ${timeElapsed.toFixed(0).padStart(4)}`
            + ` ${count.toFixed(0).padStart(3)}`
            + " " + JSON.stringify(sql)
        ).slice(0, lineLength);
    }).join("\n");
    result = (
        `\ndbExecProfile:\n`
        + ` #  time cnt sql\n`
        + `${result}\n`
    );
    return result;
}

async function dbFileLoadAsync({
    db,
    dbData,
    filename,
    modeNoop,
    modeSave = 0
}) {

// This function will load <filename> to <db>.

    let filename2;
    async function _dbFileLoad() {
        dbData = await dbCallAsync(
            jsbatonCreate("_dbFileLoad"),
            [
                // 0. sqlite3 * pInMemory
                db,
                // 1. char *zFilename
                filename,
                // 2. const int isSave
                modeSave,
                // 3. undefined
                undefined,
                // 4. dbData - same position as dbOpenAsync
                dbData
            ],
            "modeDbFile"
        );
    }
    if (modeNoop) {
        return;
    }
    if (IS_BROWSER) {
        filename = FILENAME_DBTMP;
    }
    assertOrThrow(
        typeof filename === "string" && filename,
        `invalid filename ${filename}`
    );
    db.filename2 = filename;
    // Save to tmpfile and then atomically-rename to actual-filename.
    if (moduleFs && modeSave) {
        filename2 = filename;
        filename = modulePath.join(
            modulePath.dirname(filename),
            `.dbFileSaveAsync.${moduleCrypto.randomUUID()}`
        );
        try {
            await _dbFileLoad();
            await moduleFs.promises.rename(filename, filename2);
        } finally {
            await moduleFs.promises.unlink(filename).catch(noop);
        }
    } else {
        await _dbFileLoad();
    }
    return dbData[1 + 0];
}

async function dbFileSaveAsync({
    db,
    dbData,
    filename,
    modeNoop
}) {

// This function will save <db> to <filename>.

    return await dbFileLoadAsync({
        db,
        dbData,
        filename,
        modeNoop,
        modeSave: 1
    });
}

async function dbNoopAsync(...argList) {

// This function will do nothing except return <argList>.

    return await dbCallAsync(
        jsbatonCreate("_dbNoop"),
        argList
    );
}

async function dbOpenAsync({
    afterFinalization,
    dbData,
    filename = ":memory:",
    flags,
    threadCount = 1,
    timeoutBusy = 5000
}) {

// This function will open and return sqlite-database-connection <db>.

// int sqlite3_open_v2(
//   const char *filename,   /* Database filename (UTF-8) */
//   sqlite3 **ppDb,         /* OUT: SQLite db handle */
//   int flags,              /* Flags */
//   const char *zVfs        /* Name of VFS module to use */
// );
    let connPool;
    let db = {busy: 0, filename, ii: 0};
    assertOrThrow(typeof filename === "string", `invalid filename ${filename}`);
    assertOrThrow(
        !dbData || isExternalBuffer(dbData),
        "dbData must be ArrayBuffer"
    );
    connPool = await Promise.all(Array.from(new Array(
        threadCount
    ), async function () {
        let [ptr] = await dbCallAsync(
            jsbatonCreate("_dbOpen"),
            [
                // 0. const char *filename,   Database filename (UTF-8)
                filename,
                // 1. sqlite3 **ppDb,         OUT: SQLite db handle
                undefined,
                // 2. int flags,              Flags
                flags ?? (
                    SQLITE_OPEN_CREATE | SQLITE_OPEN_READWRITE | SQLITE_OPEN_URI
                ),
                // 3. const char *zVfs        Name of VFS module to use
                undefined,
                // 4. wasm-only - arraybuffer of raw sqlite-database
                dbData
            ]
        );
        ptr = [ptr.getBigInt64(JSBATON_OFFSET_ARGV + 0, true)];
        dbFinalizationRegistry.register(db, {afterFinalization, ptr});
        return ptr;
    }));
    db.connPool = connPool;
    if (!IS_BROWSER && !DB_STATE.init) {
        DB_STATE.init = true;
        await Promise.all([
            // PRAGMA busy_timeout
            dbExecAsync({
                db,
                sql: (`
PRAGMA busy_timeout = ${timeoutBusy};
                `)
            }),
            // LGBM_DLOPEN
            (async function () {
                let libLgbm = `lib_lightgbm_${libPlatformArchExt()}`;
                libLgbm = `${import.meta.dirname}/sqlmath/${libLgbm}`;
                await moduleFs.promises.access(
                    libLgbm
                ).then(async function () {
                    await dbExecAsync({
                        db,
                        sql: (`
SELECT LGBM_DLOPEN('${libLgbm}');
                        `)
                    });
                    DB_STATE.lgbm = true;
                }).catch(noop);
            }())
        ]);
    }
    return db;
}

async function dbTableImportAsync({
    db,
    filename,
    headerMissing,
    mode,
    tableName,
    textData
}) {
// This function will create table from imported csv/json <textData>.
    let colList;
    let rowList;
    let rowidList;
    let tmp;
    if (filename) {
        textData = await moduleFs.promises.readFile(filename, "utf8");
    }
    switch (mode) {
    case "csv":
        rowList = csvToListofList({
            csv: textData
        });
        break;
    case "tsv":
        rowList = [];
        textData.trimEnd().replace((/.+/g), function (line) {
            rowList.push(line.split("\t"));
        });
        break;
    // case "json":
    default:
        rowList = JSON.parse(textData);
    }
    if (!(typeof rowList === "object" && rowList)) {
        rowList = [];
    }
    // normalize rowList to list
    if (!Array.isArray(rowList)) {
        rowidList = [];
        rowList = Object.entries(rowList).map(function ([
            key, val
        ]) {
            rowidList.push(key);
            return val;
        });
    }
    // headerMissing
    if (headerMissing && (rowList.length > 0 && Array.isArray(rowList[0]))) {
        rowList.unshift(Array.from(rowList[0]).map(function (ignore, ii) {
            return String(ii + 1);
        }));
    }
    // normalize rowList[ii] to list
    if (rowList.length === 0) {
        rowList.push([
            "undefined"
        ]);
    }
    if (!Array.isArray(rowList[0])) {
        colList = Array.from(
            new Set(
                rowList.map(function (obj) {
                    return Object.keys(obj);
                }).flat()
            )
        );
        rowList = rowList.map(function (obj) {
            return colList.map(function (key) {
                return obj[key];
            });
        });
        rowList.unshift(colList);
    }
    // init colList
    colList = rowList.shift();
    // preserve rowid
    if (rowidList) {
        colList.unshift("rowid");
        rowList.forEach(function (row, ii) {
            row.unshift(rowidList[ii]);
        });
    }
    // normalize colList
    tmp = new Set();
    colList = colList.map(function (colName) {
        let colName2;
        let duplicate = 0;
        colName = colName.trim();
        colName = colName.replace((/\W/g), "_");
        colName = colName.replace((/^[^A-Z_a-z]|^$/gm), "_$&");
        while (true) {
            duplicate += 1;
            colName2 = (
                duplicate === 1
                ? colName
                : colName + "_" + duplicate
            );
            if (!tmp.has(colName2)) {
                tmp.add(colName2);
                return colName2;
            }
        }
    });
    // create dbtable from rowList
    await dbExecAsync({
        bindList: {
            rowList: JSON.stringify(rowList)
        },
        db,
        sql: (
            rowList.length === 0
            ? `CREATE TABLE ${tableName} (${colList.join(",")});`
            : (
                `CREATE TABLE ${tableName} AS SELECT `
                + colList.map(function (colName, ii) {
                    return "value->>" + ii + " AS " + colName;
                }).join(",")
                + " FROM JSON_EACH($rowList);"
            )
        )
    });
}

async function fsCopyFileUnlessTest(file1, file2, mode) {

// This function will copy <file1> to <file2> unless <npm_config_mode_test> = 1.

    if (npm_config_mode_test && mode !== "force") {
        return;
    }
    await moduleFs.promises.copyFile(file1, file2, mode | 0);
}

async function fsExistsUnlessTest(file, mode) {

// This function will test if <file> exists unless <npm_config_mode_test> = 1.

    if (npm_config_mode_test && mode !== "force") {
        return false;
    }
    try {
        await moduleFs.promises.access(file, moduleFs.promises.constants.F_OK);
        return true;
    } catch (ignore) {
        return false;
    }
}

async function fsReadFileUnlessTest(file, mode, defaultData) {

// This function will read <data> from <file> unless <npm_config_mode_test> = 1.

    if (npm_config_mode_test && mode !== "force") {
        return defaultData;
    }
    return await moduleFs.promises.readFile(
        file,
        mode && mode.replace("force", "utf8")
    );
}

async function fsWriteFileUnlessTest(file, data, mode) {

// This function will write <data> to <file> unless <npm_config_mode_test> = 1.

    if (npm_config_mode_test && mode !== "force") {
        return;
    }
    await moduleFs.promises.writeFile(file, data);
}

function isExternalBuffer(buf) {

// This function will check if <buf> is ArrayBuffer.

    return buf && buf.constructor === ArrayBuffer;
}

function jsbatonCreate(funcname) {

// This function will create buffer <baton>.

    let baton = new DataView(new ArrayBuffer(JSBATON_OFFSET_ALL));
    // init nallc, nused
    baton.setInt32(4, JSBATON_OFFSET_ALL, true);
    // copy funcname into baton
    new Uint8Array(
        baton.buffer,
        baton.byteOffset + JSBATON_OFFSET_FUNCNAME,
        SIZEOF_FUNCNAME - 1
    ).set(new TextEncoder().encode(funcname));
    return baton;
}

function jsbatonGetInt64(baton, argi) {

// This function will return int64-value from <baton> at <argi>.

    return baton.getBigInt64(JSBATON_OFFSET_ARGV + argi * 8, true);
}

function jsbatonGetString(baton, argi) {

// This function will return string-value from <baton> at <argi>.

    let offset = baton.getInt32(JSBATON_OFFSET_ARGV + argi * 8, true);
    return new TextDecoder().decode(new Uint8Array(
        baton.buffer,
        baton.byteOffset + offset + 1 + 4,
        // remove null-terminator from string
        baton.getInt32(offset + 1, true) - 1
    ));
}

function jsbatonSetValue(baton, argi, val, bufi, referenceList) {

// This function will set <val> to buffer <baton>.

    let nn;
    let nused;
    let tmp;
    let vsize;
    let vtype;
/*
#define SQLITE_DATATYPE_BLOB            0x04
#define SQLITE_DATATYPE_EXTERNALBUFFER          0x71
#define SQLITE_DATATYPE_FLOAT           0x02
#define SQLITE_DATATYPE_INTEGER         0x01
#define SQLITE_DATATYPE_INTEGER_0       0x00
#define SQLITE_DATATYPE_INTEGER_1       0x21
#define SQLITE_DATATYPE_NULL            0x05
#define SQLITE_DATATYPE_TEXT            0x03
#define SQLITE_DATATYPE_TEXT_0          0x13
    //  1. 0.bigint
    //  2. 0.boolean
    //  3. 0.function
    //  4. 0.number
    //  5. 0.object
    //  6. 0.string
    //  7. 0.symbol
    //  8. 0.undefined
    //  9. 1.bigint
    // 10. 1.boolean
    // 11. 1.function
    // 12. 1.number
    // 13. 1.object
    // 14. 1.string
    // 15. 1.symbol
    // 16. 1.undefined
    // 17. 1.buffer
    // 18. 1.externalbuffer
*/
    // 10. 1.boolean
    if (val === 1 || val === 1n) {
        val = true;
    }
    switch (
        val
        ? "1." + typeof(val)
        : "0." + typeof(val)
    ) {
    //  1. 0.bigint
    case "0.bigint":
    //  2. 0.boolean
    case "0.boolean":
    //  4. 0.number
    case "0.number":
        if (Number.isNaN(val)) {
            vtype = SQLITE_DATATYPE_NULL;
            vsize = 0;
            break;
        }
        vtype = SQLITE_DATATYPE_INTEGER_0;
        vsize = 0;
        break;
    //  3. 0.function
    // case "0.function":
    //  5. 0.object
    case "0.object":
    //  7. 0.symbol
    case "0.symbol":
    //  8. 0.undefined
    case "0.undefined":
    // 11. 1.function
    case "1.function":
    // 15. 1.symbol
    case "1.symbol":
    // 16. 1.undefined
    // case "1.undefined":
        vtype = SQLITE_DATATYPE_NULL;
        vsize = 0;
        break;
    //  6. 0.string
    case "0.string":
        vtype = SQLITE_DATATYPE_TEXT_0;
        vsize = 0;
        break;
    //  9. 1.bigint
    case "1.bigint":
        vtype = SQLITE_DATATYPE_INTEGER;
        vsize = 8;
        break;
    // 10. 1.boolean
    case "1.boolean":
        vtype = SQLITE_DATATYPE_INTEGER_1;
        vsize = 0;
        break;
    // 12. 1.number
    case "1.number":
        vtype = SQLITE_DATATYPE_FLOAT;
        vsize = 8;
        break;
    // 14. 1.string
    case "1.string":
        val = new TextEncoder().encode(val);
        vtype = SQLITE_DATATYPE_TEXT;
        vsize = 4 + val.byteLength;
        break;
    // 13. 1.object
    default:
        // 18. 1.externalbuffer
        if (val.constructor === ArrayBuffer) {
            assertOrThrow(
                !IS_BROWSER,
                "external ArrayBuffer cannot be passed directly to wasm"
            );
            vtype = SQLITE_DATATYPE_EXTERNALBUFFER;
            vsize = 4;
            break;
        }
        // 17. 1.buffer
        if (ArrayBuffer.isView(val)) {
            if (val.byteLength === 0) {
                vtype = SQLITE_DATATYPE_NULL;
                vsize = 0;
                break;
            }
            vtype = SQLITE_DATATYPE_BLOB;
            vsize = 4 + val.byteLength;
            break;
        }
        // 13. 1.object
        val = new TextEncoder().encode(
            typeof val.toJSON === "function"
            ? val.toJSON()
            : JSON.stringify(val)
        );
        vtype = SQLITE_DATATYPE_TEXT;
        vsize = 4 + val.byteLength;
    }
    nused = baton.getInt32(4, true);
    nn = nused + 1 + vsize;
    assertOrThrow(
        nn <= 0xffff_ffff,
        "jsbaton cannot exceed 0x7fff_ffff / 2,147,483,647 bytes"
    );
    // exponentially grow baton as needed
    if (baton.byteLength < nn) {
        tmp = baton;
        baton = new DataView(new ArrayBuffer(
            Math.min(2 ** Math.ceil(Math.log2(nn)), 0x7fff_ffff)
        ));
        // update nallc
        baton.setInt32(0, baton.byteLength, true);
        // copy old-baton into new-baton
        new Uint8Array(baton.buffer, baton.byteOffset, nused).set(
            new Uint8Array(tmp.buffer, tmp.byteOffset, nused)
        );
    }
    // push vtype - 1-byte
    baton.setUint8(nused, vtype);
    // update nused
    baton.setInt32(4, nused + 1 + vsize, true);
    // handle blob-value
    switch (vtype) {
    case SQLITE_DATATYPE_BLOB:
    case SQLITE_DATATYPE_TEXT:
        // set argv[ii] to blob/text location
        if (argi !== undefined) {
            baton.setInt32(JSBATON_OFFSET_ARGV + argi * 8, nused, true);
        }
        vsize -= 4;
        assertOrThrow(
            0 <= vsize && vsize <= SIZEOF_BLOB_MAX,
            (
                "sqlite-blob byte-length must be within inclusive-range"
                + ` 0 to ${SIZEOF_BLOB_MAX}`
            )
        );
        // push vsize - 4-byte
        baton.setInt32(nused + 1, vsize, true);
        // push SQLITE-BLOB/TEXT - vsize-byte
        new Uint8Array(
            baton.buffer,
            baton.byteOffset + nused + 1 + 4,
            vsize
        ).set(new Uint8Array(val.buffer, val.byteOffset, vsize));
        break;
    case SQLITE_DATATYPE_EXTERNALBUFFER:
        vsize = val.byteLength;
        assertOrThrow(
            0 <= vsize && vsize <= SIZEOF_BLOB_MAX,
            (
                "sqlite-blob byte-length must be within inclusive-range"
                + ` 0 to ${SIZEOF_BLOB_MAX}`
            )
        );
        assertOrThrow(
            bufi[0] < JSBATON_ARGC,
            `cannot pass more than ${JSBATON_ARGC} arraybuffers`
        );
        // push externalbuffer - 4-byte
        baton.setInt32(nused + 1, bufi[0], true);
        // set buffer
        cModule._jsbatonSetArraybuffer(baton.buffer, bufi[0], val);
        // increment bufi
        bufi[0] += 1;
        // add buffer to reference_list to prevent gc during db_call.
        referenceList.push(val);
        break;
    case SQLITE_DATATYPE_FLOAT:
        // push SQLITE-REAL - 8-byte
        baton.setFloat64(nused + 1, val, true);
        break;
    case SQLITE_DATATYPE_INTEGER:
        assertInt64(val);
        // push SQLITE-INTEGER - 8-byte
        baton.setBigInt64(nused + 1, val, true);
        break;
    }
    return baton;
}

function jsonParseArraybuffer(buf) {

// This function will JSON.parse arraybuffer <buf>.

    return JSON.parse(
        (
            IS_BROWSER
            ? new TextDecoder().decode(buf)
            : buf
        )
        || "null"
    );
}

function libPlatformArchExt() {
    let libArch = process.arch;
    let libExt = process.platform;
    let libPlatform = process.platform;
    libExt = libExt.replace("darwin", "dylib");
    libExt = libExt.replace("win32", "dll");
    libExt = libExt.replace(libPlatform, "so");
    return `${libPlatform}_${libArch}.${libExt}`;
}

function listOrEmptyList(list) {

// This function will return <list> or empty-list if falsy.

    return list || [];
}

async function moduleFsInit() {

// This function will import nodejs builtin-modules if they have not yet been
// imported.

// State 3 - Modules already imported.

    if (moduleFs !== undefined) {
        return;
    }

// State 2 - Wait while modules are importing.

    if (moduleFsInitResolveList !== undefined) {
        return new Promise(function (resolve) {
            moduleFsInitResolveList.push(resolve);
        });
    }

// State 1 - Start importing modules.

    moduleFsInitResolveList = [];
    [
        moduleChildProcess,
        moduleCrypto,
        moduleFs,
        modulePath,
        moduleUrl
    ] = await Promise.all([
        import("child_process"),
        import("crypto"),
        import("fs"),
        import("path"),
        import("url")
    ]);
    while (moduleFsInitResolveList.length > 0) {
        moduleFsInitResolveList.shift()();
    }
    SQLMATH_NODE = `_sqlmath.napi6_${process.platform}_${process.arch}.node`;
    SQLMATH_EXE = (
        `_sqlmath.shell_${process.platform}_${process.arch}`
        + process.platform.replace(
            "win32",
            ".exe"
        ).replace(
            process.platform,
            ""
        )
    );
}

function noop(value) {

// This function will do nothing except return <value>.

    return value;
}

function objectDeepCopyWithKeysSorted(obj) {

// This function will recursively deep-copy <obj> with keys sorted.

    let sorted;
    if (typeof obj !== "object" || !obj) {
        return obj;
    }

// Recursively deep-copy list with child-keys sorted.

    if (Array.isArray(obj)) {
        return obj.map(objectDeepCopyWithKeysSorted);
    }

// Recursively deep-copy obj with keys sorted.

    sorted = Object.create(null);
    Object.keys(obj).sort().forEach(function (key) {
        sorted[key] = objectDeepCopyWithKeysSorted(obj[key]);
    });
    return sorted;
}

async function sqlmathInit() {

// This function will init sqlmath.

    let moduleModule;
    dbFinalizationRegistry = (
        dbFinalizationRegistry
    ) || new FinalizationRegistry(function ({afterFinalization, ptr}) {

// This function will auto-close any open sqlite3-db-pointer,
// after its js-wrapper has been garbage-collected.

        dbCallAsync(
            jsbatonCreate("_dbClose"),
            [
                ptr[0]
            ]
        );
        if (afterFinalization) {
            afterFinalization();
        }
    });

// Feature-detect nodejs.

    if (
        typeof process !== "object"
        || typeof process?.versions?.node !== "string"
        || cModule
    ) {
        return;
    }

// Init moduleFs.

    await moduleFsInit();
    moduleFsInit(); // coverage-hack
    moduleChildProcessSpawn = moduleChildProcess.spawn;

// Init moduleFs.

    await moduleFsInit();
    moduleFsInit(); // coverage-hack
    moduleChildProcessSpawn = moduleChildProcess.spawn;
    cModulePath = moduleUrl.fileURLToPath(import.meta.url).replace(
        (/\bsqlmath\.mjs$/),
        SQLMATH_NODE
    );

// Import napi c-addon.

    if (!npm_config_mode_setup) {
        moduleModule = await import("module");
        if (!cModule) {
            cModule = moduleModule.createRequire(cModulePath);
            cModule = cModule(cModulePath);
        }
    }
    if (npm_config_mode_test) {

// Mock consoleError.

        consoleError = noop;

// Mock moduleChildProcessSpawn.

        moduleChildProcessSpawn = function () {
            let child = {
                end: noop,
                on: function (onType, resolve) {
                    switch (onType) {
                    case "data":
                        resolve(Buffer.alloc(0));
                        return;
                    default:
                        resolve(0);
                    }
                },
                setEncoding: noop,
                write: noop
            };
            child.stderr = child;
            child.stdin = child;
            child.stdout = child;
            return child;
        };
    }
}

function sqlmathWebworkerInit({
    db,
    modeTest
}) {

// This function will init sqlmath web-worker.

// Feature-detect browser.

    let Worker = globalThis.Worker;
    IS_BROWSER = true;
    if (modeTest) {
        Worker = function () {
            return;
        };
    }
    sqlWorker = new Worker("sqlmath_wasm.js");
    sqlWorker.onmessage = function ({
        data
    }) {
        sqlMessageDict[data.id](data);
    };
    if (modeTest) {
        sqlWorker.postMessage = function (data) {
            setTimeout(function () {
                sqlWorker.onmessage({data});
            });
        };
        // test dbCallAsync handling-behavior
        dbCallAsync(
            jsbatonCreate("testTimeElapsed"),
            [
                true
            ]
        );
        // test dbFileLoadAsync handling-behavior
        dbFileLoadAsync({db, filename: "aa", modeTest});
        // test jsonParseArraybuffer handling-behavior
        jsonParseArraybuffer(new TextEncoder().encode("0"));
        // revert IS_BROWSER
        IS_BROWSER = undefined;
    }
}

async function uvthreadpoolsizeGet() {

// This function will guess how many logical-processors on current-host.

    let uvthreadpoolsize;
    await new Promise(function (resolve) {
        let child;
        child = moduleChildProcess.spawn(
            "sh",
            ["-c", (`
    case "$(uname)" in
    Darwin)
        sysctl -n hw.logicalcpu
        ;;
    Linux)
        nproc
        ;;
    *NT*)
        wmic cpu get NumberOfLogicalProcessors | \
            grep -v "NumberOfLogicalProcessors"
        ;;
    esac
            `)],
            {stdio: ["ignore", "pipe", "ignore"]}
        );
        child.stdout.setEncoding("utf8");
        child.stdout.on("data", function (chunk) {
            uvthreadpoolsize = Number(chunk);
        });
        child.on("exit", resolve);
    });
    if (npm_config_mode_test) {
        uvthreadpoolsize = undefined;
    }
    return uvthreadpoolsize || 4;
}

function waitAsync(timeout) {

// This function will wait <timeout> ms.

    return new Promise(function (resolve) {
        let ms = Number(timeout);
        if (!Number.isFinite(ms)) {
            ms = 0;
        }
        setTimeout(resolve, ms * !npm_config_mode_test);
    });
}

sqlmathInit(); // coverage-hack
await sqlmathInit();
sqlmathInit(); // coverage-hack

export {
    DB_EXEC_PROFILE_DICT,
    DB_STATE,
    LGBM_DTYPE_FLOAT32,
    LGBM_DTYPE_FLOAT64,
    LGBM_DTYPE_INT32,
    LGBM_DTYPE_INT64,
    LGBM_FEATURE_IMPORTANCE_GAIN,
    LGBM_FEATURE_IMPORTANCE_SPLIT,
    LGBM_MATRIX_TYPE_CSC,
    LGBM_MATRIX_TYPE_CSR,
    LGBM_PREDICT_CONTRIB,
    LGBM_PREDICT_LEAF_INDEX,
    LGBM_PREDICT_NORMAL,
    LGBM_PREDICT_RAW_SCORE,
    SQLITE_OPEN_AUTOPROXY,
    SQLITE_OPEN_CREATE,
    SQLITE_OPEN_DELETEONCLOSE,
    SQLITE_OPEN_EXCLUSIVE,
    SQLITE_OPEN_FULLMUTEX,
    SQLITE_OPEN_MAIN_DB,
    SQLITE_OPEN_MAIN_JOURNAL,
    SQLITE_OPEN_MEMORY,
    SQLITE_OPEN_NOFOLLOW,
    SQLITE_OPEN_NOMUTEX,
    SQLITE_OPEN_PRIVATECACHE,
    SQLITE_OPEN_READONLY,
    SQLITE_OPEN_READWRITE,
    SQLITE_OPEN_SHAREDCACHE,
    SQLITE_OPEN_SUBJOURNAL,
    SQLITE_OPEN_SUPER_JOURNAL,
    SQLITE_OPEN_TEMP_DB,
    SQLITE_OPEN_TEMP_JOURNAL,
    SQLITE_OPEN_TRANSIENT_DB,
    SQLITE_OPEN_URI,
    SQLITE_OPEN_WAL,
    SQLMATH_EXE,
    SQLMATH_NODE,
    assertErrorThrownAsync,
    assertInt64,
    assertJsonEqual,
    assertNumericalEqual,
    assertOrThrow,
    childProcessSpawn2,
    ciBuildExt,
    csvFromListofList,
    csvToListofList,
    dbCloseAsync,
    dbExecAndReturnLastBlob,
    dbExecAndReturnLastRow,
    dbExecAndReturnLastTable,
    dbExecAndReturnLastValue,
    dbExecAsync,
    dbExecProfile,
    dbFileLoadAsync,
    dbFileSaveAsync,
    dbNoopAsync,
    dbOpenAsync,
    dbTableImportAsync,
    debugInline,
    fsCopyFileUnlessTest,
    fsExistsUnlessTest,
    fsReadFileUnlessTest,
    fsWriteFileUnlessTest,
    jsbatonGetInt64,
    jsbatonGetString,
    libPlatformArchExt,
    listOrEmptyList,
    noop,
    objectDeepCopyWithKeysSorted,
    sqlmathWebworkerInit,
    uvthreadpoolsizeGet,
    version,
    waitAsync
};