@potygen/cli - npm Package Compare versions

Comparing version 0.8.2 to 0.9.0

dist/emitter.d.ts

+import { LoadContext } from '@potygen/potygen';
+/**
+ * Handle both "last updated" checks on files as well as actually checking file contents.
+ */
+export declare class CacheStore {
+    /**
+     * Path to the cache file
+     */
+    fileName: string;
+    /**
+     * If enabled is false, do not perform any caching
+     */
+    enabled: boolean;
+    /**
+     * If true, initialize the cache with empty values so that after save everything is overwritten
+     */
+    cacheClear: boolean;
+    /**
+     * Current version of the cache, if version mismatch, clear the cache
+     */
+    cacheVersion: string;
+    contents: Map<string, {
+        path: string;
+        content: string;
+    } | undefined>;
+    updates: Map<string, number>;
+    constructor(
+    /**
+     * Path to the cache file
+     */
+    fileName: string, 
+    /**
+     * If enabled is false, do not perform any caching
+     */
+    enabled?: boolean, 
+    /**
+     * If true, initialize the cache with empty values so that after save everything is overwritten
+     */
+    cacheClear?: boolean, 
+    /**
+     * Current version of the cache, if version mismatch, clear the cache
+     */
+    cacheVersion?: string);
+    /**
+     * Check the file's last modified time (mtime).
+     * If its after the time stored in cache, consider the file stale.
+     */
+    isStale(path: string): Promise<boolean>;
+    /**
+     * For a given path and file content, check if content is present in the cache.
+     * If it is not, run the process function and store the results in the cache,
+     * keyed by md5 of the initial content
+     */
+    cachedOrProcessed(path: string, content: string, process: (path: string, content: string) => Promise<{
+        path: string;
+        content: string;
+    } | undefined>): Promise<{
+        path: string;
+        content: string;
+        isCached?: boolean;
+    } | undefined>;
+    /**
+     * Load the cache from file
+     */
+    load(): Promise<void>;
+    /**
+     * Save current state in the cache file
+     */
+    save(): Promise<void>;
+}
+export declare const toEmitter: (ctx: LoadContext, cacheStore: CacheStore, options: {
+    root: string;
+    template: string;
+    typePrefix?: string;
+}) => Promise<(path: string) => Promise<{
+    path: string;
+} | undefined>>;

dist/emitter.js

+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.toEmitter = exports.CacheStore = void 0;
+const fs_1 = require("fs");
+const typescript_1 = require("typescript");
+const path_1 = require("path");
+const potygen_1 = require("@potygen/potygen");
+const typescript_printer_1 = require("./typescript-printer");
+const promises_1 = require("fs/promises");
+const crypto_1 = require("crypto");
+/**
+ * Handle both "last updated" checks on files as well as actually checking file contents.
+ */
+class CacheStore {
+    constructor(
+    /**
+     * Path to the cache file
+     */
+    fileName, 
+    /**
+     * If enabled is false, do not perform any caching
+     */
+    enabled = false, 
+    /**
+     * If true, initialize the cache with empty values so that after save everything is overwritten
+     */
+    cacheClear = false, 
+    /**
+     * Current version of the cache, if version mismatch, clear the cache
+     */
+    cacheVersion = '1.0') {
+        this.fileName = fileName;
+        this.enabled = enabled;
+        this.cacheClear = cacheClear;
+        this.cacheVersion = cacheVersion;
+        this.contents = new Map();
+        this.updates = new Map();
+    }
+    /**
+     * Check the file's last modified time (mtime).
+     * If its after the time stored in cache, consider the file stale.
+     */
+    async isStale(path) {
+        if (!this.enabled) {
+            return true;
+        }
+        const mtime = (await (0, promises_1.stat)(path)).mtime.getTime();
+        const currentMtime = this.updates.get(path);
+        return !(currentMtime && mtime === currentMtime);
+    }
+    /**
+     * For a given path and file content, check if content is present in the cache.
+     * If it is not, run the process function and store the results in the cache,
+     * keyed by md5 of the initial content
+     */
+    async cachedOrProcessed(path, content, process) {
+        if (!this.enabled) {
+            return await process(path, content);
+        }
+        const key = (0, crypto_1.createHash)('md5').update(content).digest('hex');
+        const cached = this.contents.get(key);
+        if (cached) {
+            return { ...cached, isCached: true };
+        }
+        else {
+            const processed = await process(path, content);
+            const mtime = (await (0, promises_1.stat)(path)).mtime.getTime();
+            this.contents.set(key, processed);
+            this.updates.set(path, mtime);
+            return processed;
+        }
+    }
+    /**
+     * Load the cache from file
+     */
+    async load() {
+        if (!this.cacheClear && (0, fs_1.existsSync)(this.fileName)) {
+            const cache = JSON.parse(await (0, promises_1.readFile)(this.fileName, 'utf-8'));
+            if (typeof cache === 'object' && cache !== null && 'version' in cache && cache.version === this.cacheVersion) {
+                this.updates = new Map(Object.entries(cache.updates));
+                this.contents = new Map(Object.entries(cache.contents));
+            }
+        }
+    }
+    /**
+     * Save current state in the cache file
+     */
+    async save() {
+        await (0, promises_1.mkdir)((0, path_1.dirname)(this.fileName), { recursive: true });
+        await (0, promises_1.writeFile)(this.fileName, JSON.stringify({
+            updates: Object.fromEntries(this.updates),
+            contents: Object.fromEntries(this.contents),
+            version: this.cacheVersion,
+        }), 'utf-8');
+    }
+}
+exports.CacheStore = CacheStore;
+const toTemplateParent = (node) => (0, typescript_1.isCallExpression)(node.parent) ? toTemplateParent(node.parent) : node.parent;
+/**
+ * Extract the sql tagged template literals from a typescript ast
+ */
+const getTemplateTagQueries = (ast) => {
+    const queries = [];
+    let tagPropertyName = 'sql';
+    const visitor = (node) => {
+        if ((0, typescript_1.isImportDeclaration)(node) &&
+            (0, typescript_1.isStringLiteral)(node.moduleSpecifier) &&
+            node.importClause?.namedBindings &&
+            (0, typescript_1.isNamedImports)(node.importClause.namedBindings) &&
+            node.moduleSpecifier.text === '@potygen/potygen') {
+            tagPropertyName =
+                node.importClause?.namedBindings.elements.find(({ propertyName, name }) => (propertyName ?? name).text === 'sql')?.name.text ?? tagPropertyName;
+        }
+        else if ((0, typescript_1.isTaggedTemplateExpression)(node) &&
+            (0, typescript_1.isNoSubstitutionTemplateLiteral)(node.template) &&
+            (0, typescript_1.isIdentifier)(node.tag) &&
+            node.tag.text === tagPropertyName) {
+            const tag = {
+                name: toTemplateParent(node).getChildAt(0).getText(),
+                pos: node.template.pos + 1,
+                template: node.template.text,
+            };
+            try {
+                queries.push({ ...tag, queryInterface: (0, potygen_1.toQueryInterface)((0, potygen_1.parser)(node.template.text).ast) });
+            }
+            catch (error) {
+                throw new potygen_1.ParseError(tag, `Error parsing sql: ${String(error)}`);
+            }
+        }
+        else {
+            node.forEachChild(visitor);
+        }
+    };
+    visitor(ast);
+    return queries;
+};
+const parseFile = (path, content) => {
+    if (path.endsWith('.ts')) {
+        const source = (0, typescript_1.createSourceFile)((0, path_1.basename)(path), content, typescript_1.ScriptTarget.ES2021, true);
+        const file = { type: 'ts', source, path, queries: getTemplateTagQueries(source) };
+        return file.queries.length > 0 ? file : undefined;
+    }
+    else {
+        return { type: 'sql', path, content, queryInterface: (0, potygen_1.toQueryInterface)((0, potygen_1.parser)(content).ast) };
+    }
+};
+const isError = (error) => error instanceof potygen_1.LoadError || error instanceof potygen_1.ParseError;
+const toLoadFile = (data) => (file) => {
+    if (file.type === 'sql') {
+        try {
+            return { ...file, loadedQuery: (0, potygen_1.toLoadedQueryInterface)(data)(file.queryInterface) };
+        }
+        catch (error) {
+            throw isError(error) ? new potygen_1.ParsedSqlFileLoadError(file, error) : error;
+        }
+    }
+    else {
+        return {
+            ...file,
+            queries: file.queries.map((template) => {
+                try {
+                    return { ...template, loadedQuery: (0, potygen_1.toLoadedQueryInterface)(data)(template.queryInterface) };
+                }
+                catch (error) {
+                    throw isError(error) ? new potygen_1.ParsedTypescriptFileLoadError(file, template, error) : error;
+                }
+            }),
+        };
+    }
+};
+const toEmitter = async (ctx, cacheStore, options) => {
+    const data = await (0, potygen_1.loadAllData)(ctx, []);
+    const loadFile = toLoadFile(data);
+    const typeScriptPrinter = (0, typescript_printer_1.toTypeScriptPrinter)(options.root, options.template, options.typePrefix);
+    return async (path) => {
+        const start = process.hrtime();
+        const relPath = (0, path_1.relative)(options.root ?? '.', path);
+        try {
+            if (await cacheStore.isStale(path)) {
+                const content = await (0, promises_1.readFile)(path, 'utf-8');
+                const output = await cacheStore.cachedOrProcessed(path, content, async (path, content) => {
+                    const file = parseFile(path, content);
+                    return file ? await typeScriptPrinter(loadFile(file)) : undefined;
+                });
+                if (output) {
+                    await (0, promises_1.mkdir)((0, path_1.dirname)(output.path), { recursive: true });
+                    await (0, promises_1.writeFile)(output.path, output.content, 'utf-8');
+                    const elapsed = (0, potygen_1.toMilliseconds)(process.hrtime(start));
+                    ctx.logger.info(`[${output.isCached ? 'Cached' : 'Generated'}]: ${relPath} (${elapsed}ms)`);
+                }
+            }
+            else {
+                ctx.logger.info(`[Not modified]: ${relPath}`);
+            }
+            return { path };
+        }
+        catch (error) {
+            const elapsed = (0, potygen_1.toMilliseconds)(process.hrtime(start));
+            ctx.logger.error(`[Error]: ${relPath} (${elapsed})ms`);
+            throw error;
+        }
+    };
+};
+exports.toEmitter = toEmitter;
+//# sourceMappingURL=emitter.js.map

dist/emitter.js.map

+{"version":3,"file":"emitter.js","sourceRoot":"","sources":["../src/emitter.ts"],"names":[],"mappings":";;;AAAA,2BAAgC;AAChC,2CAYoB;AACpB,+BAAmD;AACnD,8CAe0B;AAC1B,6DAA2D;AAC3D,0CAA+D;AAC/D,mCAAoC;AAEpC;;GAEG;AACH,MAAa,UAAU;IAIrB;IACE;;OAEG;IACI,QAAgB;IACvB;;OAEG;IACI,UAAmB,KAAK;IAC/B;;OAEG;IACI,aAAsB,KAAK;IAClC;;OAEG;IACI,eAAe,KAAK;QAZpB,aAAQ,GAAR,QAAQ,CAAQ;QAIhB,YAAO,GAAP,OAAO,CAAiB;QAIxB,eAAU,GAAV,UAAU,CAAiB;QAI3B,iBAAY,GAAZ,YAAY,CAAQ;QAnBtB,aAAQ,GAAG,IAAI,GAAG,EAAyD,CAAC;QAC5E,YAAO,GAAG,IAAI,GAAG,EAAkB,CAAC;IAmBxC,CAAC;IAEJ;;;OAGG;IACI,KAAK,CAAC,OAAO,CAAC,IAAY;QAC/B,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE;YACjB,OAAO,IAAI,CAAC;SACb;QACD,MAAM,KAAK,GAAG,CAAC,MAAM,IAAA,eAAI,EAAC,IAAI,CAAC,CAAC,CAAC,KAAK,CAAC,OAAO,EAAE,CAAC;QACjD,MAAM,YAAY,GAAG,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;QAC5C,OAAO,CAAC,CAAC,YAAY,IAAI,KAAK,KAAK,YAAY,CAAC,CAAC;IACnD,CAAC;IAED;;;;OAIG;IACI,KAAK,CAAC,iBAAiB,CAC5B,IAAY,EACZ,OAAe,EACf,OAAkG;QAElG,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE;YACjB,OAAO,MAAM,OAAO,CAAC,IAAI,EAAE,OAAO,CAAC,CAAC;SACrC;QACD,MAAM,GAAG,GAAG,IAAA,mBAAU,EAAC,KAAK,CAAC,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC;QAC5D,MAAM,MAAM,GAAG,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC;QACtC,IAAI,MAAM,EAAE;YACV,OAAO,EAAE,GAAG,MAAM,EAAE,QAAQ,EAAE,IAAI,EAAE,CAAC;SACtC;aAAM;YACL,MAAM,SAAS,GAAG,MAAM,OAAO,CAAC,IAAI,EAAE,OAAO,CAAC,CAAC;YAC/C,MAAM,KAAK,GAAG,CAAC,MAAM,IAAA,eAAI,EAAC,IAAI,CAAC,CAAC,CAAC,KAAK,CAAC,OAAO,EAAE,CAAC;YACjD,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,GAAG,EAAE,SAAS,CAAC,CAAC;YAClC,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,IAAI,EAAE,KAAK,CAAC,CAAC;YAC9B,OAAO,SAAS,CAAC;SAClB;IACH,CAAC;IAED;;OAEG;IACI,KAAK,CAAC,IAAI;QACf,IAAI,CAAC,IAAI,CAAC,UAAU,IAAI,IAAA,eAAU,EAAC,IAAI,CAAC,QAAQ,CAAC,EAAE;YACjD,MAAM,KAAK,GAAG,IAAI,CAAC,KAAK,CAAC,MAAM,IAAA,mBAAQ,EAAC,IAAI,CAAC,QAAQ,EAAE,OAAO,CAAC,CAAC,CAAC;YACjE,IAAI,OAAO,KAAK,KAAK,QAAQ,IAAI,KAAK,KAAK,IAAI,IAAI,SAAS,IAAI,KAAK,IAAI,KAAK,CAAC,OAAO,KAAK,IAAI,CAAC,YAAY,EAAE;gBAC5G,IAAI,CAAC,OAAO,GAAG,IAAI,GAAG,CAAC,MAAM,CAAC,OAAO,CAAC,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC;gBACtD,IAAI,CAAC,QAAQ,GAAG,IAAI,GAAG,CAAC,MAAM,CAAC,OAAO,CAAC,KAAK,CAAC,QAAQ,CAAC,CAAC,CAAC;aACzD;SACF;IACH,CAAC;IAED;;OAEG;IACI,KAAK,CAAC,IAAI;QACf,MAAM,IAAA,gBAAK,EAAC,IAAA,cAAO,EAAC,IAAI,CAAC,QAAQ,CAAC,EAAE,EAAE,SAAS,EAAE,IAAI,EAAE,CAAC,CAAC;QACzD,MAAM,IAAA,oBAAS,EACb,IAAI,CAAC,QAAQ,EACb,IAAI,CAAC,SAAS,CAAC;YACb,OAAO,EAAE,MAAM,CAAC,WAAW,CAAC,IAAI,CAAC,OAAO,CAAC;YACzC,QAAQ,EAAE,MAAM,CAAC,WAAW,CAAC,IAAI,CAAC,QAAQ,CAAC;YAC3C,OAAO,EAAE,IAAI,CAAC,YAAY;SAC3B,CAAC,EACF,OAAO,CACR,CAAC;IACJ,CAAC;CACF;AA1FD,gCA0FC;AAED,MAAM,gBAAgB,GAAG,CAAC,IAAU,EAAQ,EAAE,CAC5C,IAAA,6BAAgB,EAAC,IAAI,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,gBAAgB,CAAC,IAAI,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,MAAM,CAAC;AAE9E;;GAEG;AACH,MAAM,qBAAqB,GAAG,CAAC,GAAe,EAAsB,EAAE;IACpE,MAAM,OAAO,GAAuB,EAAE,CAAC;IACvC,IAAI,eAAe,GAAG,KAAK,CAAC;IAE5B,MAAM,OAAO,GAAG,CAAC,IAAU,EAAQ,EAAE;QACnC,IACE,IAAA,gCAAmB,EAAC,IAAI,CAAC;YACzB,IAAA,4BAAe,EAAC,IAAI,CAAC,eAAe,CAAC;YACrC,IAAI,CAAC,YAAY,EAAE,aAAa;YAChC,IAAA,2BAAc,EAAC,IAAI,CAAC,YAAY,CAAC,aAAa,CAAC;YAC/C,IAAI,CAAC,eAAe,CAAC,IAAI,KAAK,kBAAkB,EAChD;YACA,eAAe;gBACb,IAAI,CAAC,YAAY,EAAE,aAAa,CAAC,QAAQ,CAAC,IAAI,CAC5C,CAAC,EAAE,YAAY,EAAE,IAAI,EAAE,EAAE,EAAE,CAAC,CAAC,YAAY,IAAI,IAAI,CAAC,CAAC,IAAI,KAAK,KAAK,CAClE,EAAE,IAAI,CAAC,IAAI,IAAI,eAAe,CAAC;SACnC;aAAM,IACL,IAAA,uCAA0B,EAAC,IAAI,CAAC;YAChC,IAAA,4CAA+B,EAAC,IAAI,CAAC,QAAQ,CAAC;YAC9C,IAAA,yBAAY,EAAC,IAAI,CAAC,GAAG,CAAC;YACtB,IAAI,CAAC,GAAG,CAAC,IAAI,KAAK,eAAe,EACjC;YACA,MAAM,GAAG,GAAG;gBACV,IAAI,EAAE,gBAAgB,CAAC,IAAI,CAAC,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC,OAAO,EAAE;gBACpD,GAAG,EAAE,IAAI,CAAC,QAAQ,CAAC,GAAG,GAAG,CAAC;gBAC1B,QAAQ,EAAE,IAAI,CAAC,QAAQ,CAAC,IAAI;aAC7B,CAAC;YACF,IAAI;gBACF,OAAO,CAAC,IAAI,CAAC,EAAE,GAAG,GAAG,EAAE,cAAc,EAAE,IAAA,0BAAgB,EAAC,IAAA,gBAAM,EAAC,IAAI,CAAC,QAAQ,CAAC,IAAI,CAAC,CAAC,GAAG,CAAC,EAAE,CAAC,CAAC;aAC5F;YAAC,OAAO,KAAK,EAAE;gBACd,MAAM,IAAI,oBAAU,CAAC,GAAG,EAAE,sBAAsB,MAAM,CAAC,KAAK,CAAC,EAAE,CAAC,CAAC;aAClE;SACF;aAAM;YACL,IAAI,CAAC,YAAY,CAAC,OAAO,CAAC,CAAC;SAC5B;IACH,CAAC,CAAC;IAEF,OAAO,CAAC,GAAG,CAAC,CAAC;IACb,OAAO,OAAO,CAAC;AACjB,CAAC,CAAC;AAEF,MAAM,SAAS,GAAG,CAAC,IAAY,EAAE,OAAe,EAA0B,EAAE;IAC1E,IAAI,IAAI,CAAC,QAAQ,CAAC,KAAK,CAAC,EAAE;QACxB,MAAM,MAAM,GAAG,IAAA,6BAAgB,EAAC,IAAA,eAAQ,EAAC,IAAI,CAAC,EAAE,OAAO,EAAE,yBAAY,CAAC,MAAM,EAAE,IAAI,CAAC,CAAC;QACpF,MAAM,IAAI,GAAe,EAAE,IAAI,EAAE,IAAI,EAAE,MAAM,EAAE,IAAI,EAAE,OAAO,EAAE,qBAAqB,CAAC,MAAM,CAAC,EAAE,CAAC;QAC9F,OAAO,IAAI,CAAC,OAAO,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,SAAS,CAAC;KACnD;SAAM;QACL,OAAO,EAAE,IAAI,EAAE,KAAK,EAAE,IAAI,EAAE,OAAO,EAAE,cAAc,EAAE,IAAA,0BAAgB,EAAC,IAAA,gBAAM,EAAC,OAAO,CAAC,CAAC,GAAG,CAAC,EAAE,CAAC;KAC9F;AACH,CAAC,CAAC;AAEF,MAAM,OAAO,GAAG,CAAC,KAAc,EAAmC,EAAE,CAClE,KAAK,YAAY,mBAAS,IAAI,KAAK,YAAY,oBAAU,CAAC;AAE5D,MAAM,UAAU,GACd,CAAC,IAAkB,EAAE,EAAE,CACvB,CAAC,IAAgB,EAAc,EAAE;IAC/B,IAAI,IAAI,CAAC,IAAI,KAAK,KAAK,EAAE;QACvB,IAAI;YACF,OAAO,EAAE,GAAG,IAAI,EAAE,WAAW,EAAE,IAAA,gCAAsB,EAAC,IAAI,CAAC,CAAC,IAAI,CAAC,cAAc,CAAC,EAAE,CAAC;SACpF;QAAC,OAAO,KAAK,EAAE;YACd,MAAM,OAAO,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,IAAI,gCAAsB,CAAC,IAAI,EAAE,KAAK,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC;SACxE;KACF;SAAM;QACL,OAAO;YACL,GAAG,IAAI;YACP,OAAO,EAAE,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,QAAQ,EAAE,EAAE;gBACrC,IAAI;oBACF,OAAO,EAAE,GAAG,QAAQ,EAAE,WAAW,EAAE,IAAA,gCAAsB,EAAC,IAAI,CAAC,CAAC,QAAQ,CAAC,cAAc,CAAC,EAAE,CAAC;iBAC5F;gBAAC,OAAO,KAAK,EAAE;oBACd,MAAM,OAAO,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,IAAI,uCAA6B,CAAC,IAAI,EAAE,QAAQ,EAAE,KAAK,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC;iBACzF;YACH,CAAC,CAAC;SACH,CAAC;KACH;AACH,CAAC,CAAC;AAEG,MAAM,SAAS,GAAG,KAAK,EAC5B,GAAgB,EAChB,UAAsB,EACtB,OAAgE,EAChE,EAAE;IACF,MAAM,IAAI,GAAG,MAAM,IAAA,qBAAW,EAAC,GAAG,EAAE,EAAE,CAAC,CAAC;IACxC,MAAM,QAAQ,GAAG,UAAU,CAAC,IAAI,CAAC,CAAC;IAClC,MAAM,iBAAiB,GAAG,IAAA,wCAAmB,EAAC,OAAO,CAAC,IAAI,EAAE,OAAO,CAAC,QAAQ,EAAE,OAAO,CAAC,UAAU,CAAC,CAAC;IAElG,OAAO,KAAK,EAAE,IAAY,EAAyC,EAAE;QACnE,MAAM,KAAK,GAAG,OAAO,CAAC,MAAM,EAAE,CAAC;QAC/B,MAAM,OAAO,GAAG,IAAA,eAAQ,EAAC,OAAO,CAAC,IAAI,IAAI,GAAG,EAAE,IAAI,CAAC,CAAC;QACpD,IAAI;YACF,IAAI,MAAM,UAAU,CAAC,OAAO,CAAC,IAAI,CAAC,EAAE;gBAClC,MAAM,OAAO,GAAG,MAAM,IAAA,mBAAQ,EAAC,IAAI,EAAE,OAAO,CAAC,CAAC;gBAC9C,MAAM,MAAM,GAAG,MAAM,UAAU,CAAC,iBAAiB,CAAC,IAAI,EAAE,OAAO,EAAE,KAAK,EAAE,IAAI,EAAE,OAAO,EAAE,EAAE;oBACvF,MAAM,IAAI,GAAG,SAAS,CAAC,IAAI,EAAE,OAAO,CAAC,CAAC;oBACtC,OAAO,IAAI,CAAC,CAAC,CAAC,MAAM,iBAAiB,CAAC,QAAQ,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,CAAC,SAAS,CAAC;gBACpE,CAAC,CAAC,CAAC;gBACH,IAAI,MAAM,EAAE;oBACV,MAAM,IAAA,gBAAK,EAAC,IAAA,cAAO,EAAC,MAAM,CAAC,IAAI,CAAC,EAAE,EAAE,SAAS,EAAE,IAAI,EAAE,CAAC,CAAC;oBACvD,MAAM,IAAA,oBAAS,EAAC,MAAM,CAAC,IAAI,EAAE,MAAM,CAAC,OAAO,EAAE,OAAO,CAAC,CAAC;oBACtD,MAAM,OAAO,GAAG,IAAA,wBAAc,EAAC,OAAO,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC;oBACtD,GAAG,CAAC,MAAM,CAAC,IAAI,CAAC,IAAI,MAAM,CAAC,QAAQ,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC,CAAC,WAAW,MAAM,OAAO,KAAK,OAAO,KAAK,CAAC,CAAC;iBAC7F;aACF;iBAAM;gBACL,GAAG,CAAC,MAAM,CAAC,IAAI,CAAC,mBAAmB,OAAO,EAAE,CAAC,CAAC;aAC/C;YACD,OAAO,EAAE,IAAI,EAAE,CAAC;SACjB;QAAC,OAAO,KAAK,EAAE;YACd,MAAM,OAAO,GAAG,IAAA,wBAAc,EAAC,OAAO,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC;YACtD,GAAG,CAAC,MAAM,CAAC,KAAK,CAAC,YAAY,OAAO,KAAK,OAAO,KAAK,CAAC,CAAC;YACvD,MAAM,KAAK,CAAC;SACb;IACH,CAAC,CAAC;AACJ,CAAC,CAAC;AAnCW,QAAA,SAAS,aAmCpB"}

dist/typescript-printer.d.ts

+import { SourceFile } from 'typescript';
+import { LoadedFile, Type } from '@potygen/potygen';
+export declare const compactTypes: (types: Type[]) => Type[];
+/**
+ * Convert a potygen {@link LoadedFile} into a typescript {@link SourceFile}.
+ *
+ * @param file
+ * @param typePrefix prefix all class names with this string
+ * @returns
+ */
+export declare const toTypeSource: (file: LoadedFile, typePrefix?: string) => SourceFile;
+export declare const toTypeScriptPrinter: (root: string, template: string, typePrefix?: string) => (file: LoadedFile) => Promise<{
+    path: string;
+    content: string;
+}>;

dist/typescript-printer.js

+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.toTypeScriptPrinter = exports.toTypeSource = exports.compactTypes = void 0;
+const path_1 = require("path");
+const typescript_1 = require("typescript");
+const potygen_1 = require("@potygen/potygen");
+const isIdentifierRegExp = /^[$A-Z_][0-9A-Z_$]*$/i;
+const parseTemplate = (root, template, path) => Object.entries({ ...(0, path_1.parse)((0, path_1.relative)(root, path)), root }).reduce((acc, [name, value]) => acc.replace(`{{${name}}}`, value), template);
+const jsDoc = (doc) => `*\n${doc
+    .split('\n')
+    .map((line) => ` * ${line}`)
+    .join('\n')}\n `;
+const withJSDoc = (doc, node) => doc === undefined ? node : (0, typescript_1.addSyntheticLeadingComment)(node, typescript_1.SyntaxKind.MultiLineCommentTrivia, jsDoc(doc), true);
+const compactTypes = (types) => types
+    .map((type) => ((0, potygen_1.isTypeOptional)(type) ? { ...type.value, nullable: type.nullable } : type))
+    .filter((item, index, all) => (0, potygen_1.isTypeLiteral)(item) && item.literal !== undefined
+    ? !all.some((other, otherIndex) => index !== otherIndex && other.type === item.type && other.literal === undefined)
+    : true)
+    .filter((0, potygen_1.isUniqueBy)(potygen_1.isTypeEqual));
+exports.compactTypes = compactTypes;
+const toPropertyType = (context) => (type) => {
+    if ((0, potygen_1.isTypeComposite)(type)) {
+        return { ...context, type: typescript_1.factory.createToken(typescript_1.SyntaxKind.StringKeyword) };
+    }
+    else if ((0, potygen_1.isTypeObjectLiteral)(type)) {
+        return type.items.reduce((acc, item) => {
+            const itemType = toPropertyType({ ...acc, name: context.name + toClassCase(item.name) })(item.type);
+            const memeber = typescript_1.factory.createPropertySignature(undefined, item.name.includes(' ')
+                ? typescript_1.factory.createComputedPropertyName(typescript_1.factory.createStringLiteral(item.name))
+                : item.name, 'nullable' in item.type && item.type.nullable ? typescript_1.factory.createToken(typescript_1.SyntaxKind.QuestionToken) : undefined, itemType.type);
+            return { ...itemType, type: typescript_1.factory.createTypeLiteralNode(acc.type.members.concat(memeber)) };
+        }, { ...context, type: typescript_1.factory.createTypeLiteralNode([]) });
+    }
+    else if ((0, potygen_1.isTypeArray)(type)) {
+        const itemsType = toPropertyType(context)(type.items);
+        return { ...itemsType, type: typescript_1.factory.createArrayTypeNode(itemsType.type) };
+    }
+    else if ((0, potygen_1.isTypeUnion)(type)) {
+        const unionTypes = (0, exports.compactTypes)(type.items);
+        return (0, potygen_1.isEmpty)(unionTypes)
+            ? { ...context, type: typescript_1.factory.createToken(typescript_1.SyntaxKind.UnknownKeyword) }
+            : unionTypes.reduce((acc, item, index) => {
+                const itemType = toPropertyType({ ...acc, name: context.name + index })(item);
+                return { ...itemType, type: typescript_1.factory.createUnionTypeNode(acc.type.types.concat(itemType.type)) };
+            }, { ...context, type: typescript_1.factory.createUnionTypeNode([]) });
+    }
+    else if ((0, potygen_1.isTypeOptional)(type)) {
+        return type.value
+            ? toPropertyType(context)(type.value)
+            : { ...context, type: typescript_1.factory.createToken(typescript_1.SyntaxKind.UnknownKeyword) };
+    }
+    else {
+        switch (type.type) {
+            case 6 /* TypeName.Date */:
+                return { ...context, type: typescript_1.factory.createTypeReferenceNode('Date') };
+            case 0 /* TypeName.Buffer */:
+                return { ...context, type: typescript_1.factory.createTypeReferenceNode('Buffer') };
+            case 5 /* TypeName.Boolean */:
+                return {
+                    ...context,
+                    type: type.literal !== undefined
+                        ? typescript_1.factory.createLiteralTypeNode(type.literal ? typescript_1.factory.createTrue() : typescript_1.factory.createFalse())
+                        : typescript_1.factory.createToken(typescript_1.SyntaxKind.BooleanKeyword),
+                };
+            case 8 /* TypeName.Json */:
+                return {
+                    ...context,
+                    refs: context.refs.concat(context.name),
+                    type: context.toJson
+                        ? typescript_1.factory.createTypeReferenceNode('Json', [typescript_1.factory.createTypeReferenceNode(context.name)])
+                        : typescript_1.factory.createTypeReferenceNode(context.name),
+                };
+            case 7 /* TypeName.Null */:
+                return { ...context, type: typescript_1.factory.createToken(typescript_1.SyntaxKind.UndefinedKeyword) };
+            case 3 /* TypeName.Number */:
+            case 4 /* TypeName.BigInt */:
+                return {
+                    ...context,
+                    type: type.literal !== undefined
+                        ? typescript_1.factory.createLiteralTypeNode(typescript_1.factory.createStringLiteral(String(type.literal)))
+                        : typescript_1.factory.createToken(typescript_1.SyntaxKind.NumberKeyword),
+                };
+            case 2 /* TypeName.String */:
+                return {
+                    ...context,
+                    type: type.literal !== undefined
+                        ? typescript_1.factory.createLiteralTypeNode(typescript_1.factory.createStringLiteral(type.literal))
+                        : typescript_1.factory.createToken(typescript_1.SyntaxKind.StringKeyword),
+                };
+            case 9 /* TypeName.Unknown */:
+                return { ...context, type: typescript_1.factory.createToken(typescript_1.SyntaxKind.UnknownKeyword) };
+            case 1 /* TypeName.Any */:
+                return { ...context, type: typescript_1.factory.createToken(typescript_1.SyntaxKind.AnyKeyword) };
+        }
+    }
+};
+const toClassCase = (identifier) => identifier[0].toUpperCase() + identifier.slice(1);
+const toAstImports = (names) => typescript_1.factory.createImportDeclaration(undefined, typescript_1.factory.createImportClause(false, undefined, typescript_1.factory.createNamedImports(names.map((name) => typescript_1.factory.createImportSpecifier(false, undefined, typescript_1.factory.createIdentifier(name))))), typescript_1.factory.createStringLiteral('@potygen/potygen'));
+const toLoadedQueryTypeNodes = (refs, name, loadedQuery) => {
+    const params = loadedQuery.params.reduce((acc, item) => {
+        const itemType = toPropertyType({ toJson: false, name: 'TParam' + toClassCase(item.name), refs: acc.refs })(item.type);
+        const prop = typescript_1.factory.createPropertySignature(undefined, item.name, 'nullable' in item.type && item.type.nullable ? typescript_1.factory.createToken(typescript_1.SyntaxKind.QuestionToken) : undefined, itemType.type);
+        return { ...itemType, props: acc.props.concat(prop) };
+    }, { refs, props: [] });
+    const results = loadedQuery.results.reduce((acc, item) => {
+        const itemType = toPropertyType({ toJson: true, name: 'T' + toClassCase(item.name), refs: acc.refs })(item.type);
+        const prop = withJSDoc(item.type.comment ?? undefined, typescript_1.factory.createPropertySignature(undefined, isIdentifierRegExp.test(item.name) ? item.name : typescript_1.factory.createStringLiteral(item.name), 'nullable' in item.type && item.type.nullable ? typescript_1.factory.createToken(typescript_1.SyntaxKind.QuestionToken) : undefined, itemType.type));
+        return { ...itemType, props: acc.props.concat(prop) };
+    }, { refs: [], props: [] });
+    return {
+        resultRefs: results.refs,
+        statements: [
+            typescript_1.factory.createInterfaceDeclaration([typescript_1.factory.createModifier(typescript_1.SyntaxKind.ExportKeyword)], `${name}Params`, params.refs.map((ref) => typescript_1.factory.createTypeParameterDeclaration([], ref, undefined, typescript_1.factory.createToken(typescript_1.SyntaxKind.UnknownKeyword))), undefined, params.props),
+            typescript_1.factory.createInterfaceDeclaration([typescript_1.factory.createModifier(typescript_1.SyntaxKind.ExportKeyword)], `${name}Result`, results.refs.map((ref) => typescript_1.factory.createTypeParameterDeclaration([], ref, undefined, typescript_1.factory.createToken(typescript_1.SyntaxKind.UnknownKeyword))), undefined, results.props),
+            typescript_1.factory.createInterfaceDeclaration([typescript_1.factory.createModifier(typescript_1.SyntaxKind.ExportKeyword)], `${name}Query`, [...params.refs, ...results.refs].map((ref) => typescript_1.factory.createTypeParameterDeclaration([], ref, undefined, typescript_1.factory.createToken(typescript_1.SyntaxKind.UnknownKeyword))), undefined, [
+                typescript_1.factory.createPropertySignature(undefined, 'params', undefined, typescript_1.factory.createTypeReferenceNode(`${name}Params`, params.refs.map((ref) => typescript_1.factory.createTypeReferenceNode(ref)))),
+                typescript_1.factory.createPropertySignature(undefined, 'result', undefined, typescript_1.factory.createArrayTypeNode(typescript_1.factory.createTypeReferenceNode(`${name}Result`, results.refs.map((ref) => typescript_1.factory.createTypeReferenceNode(ref))))),
+            ]),
+        ],
+    };
+};
+/**
+ * Convert a potygen {@link LoadedFile} into a typescript {@link SourceFile}.
+ *
+ * @param file
+ * @param typePrefix prefix all class names with this string
+ * @returns
+ */
+const toTypeSource = (file, typePrefix = '') => {
+    const content = file.type === 'ts'
+        ? file.queries.reduce((acc, query) => {
+            const { statements, resultRefs } = toLoadedQueryTypeNodes(acc.resultRefs, typePrefix + toClassCase(query.name), query.loadedQuery);
+            return { resultRefs, statements: acc.statements.concat(statements) };
+        }, { resultRefs: [], statements: [] })
+        : toLoadedQueryTypeNodes([], typePrefix, file.loadedQuery);
+    return typescript_1.factory.updateSourceFile((0, typescript_1.createSourceFile)(file.path, '', typescript_1.ScriptTarget.ES2021, true), content.resultRefs.length > 0 ? [toAstImports(['Json']), ...content.statements] : content.statements);
+};
+exports.toTypeSource = toTypeSource;
+const toTypeScriptPrinter = (root, template, typePrefix) => {
+    const printer = (0, typescript_1.createPrinter)({ newLine: typescript_1.NewLineKind.LineFeed });
+    return async (file) => {
+        const path = parseTemplate(root, template, file.path);
+        return { path, content: printer.printFile((0, exports.toTypeSource)(file, typePrefix)) };
+    };
+};
+exports.toTypeScriptPrinter = toTypeScriptPrinter;
+//# sourceMappingURL=typescript-printer.js.map

dist/typescript-printer.js.map

+{"version":3,"file":"typescript-printer.js","sourceRoot":"","sources":["../src/typescript-printer.ts"],"names":[],"mappings":";;;AAAA,+BAAuC;AACvC,2CAeoB;AACpB,8CAc0B;AAE1B,MAAM,kBAAkB,GAAG,uBAAuB,CAAC;AAEnD,MAAM,aAAa,GAAG,CAAC,IAAY,EAAE,QAAgB,EAAE,IAAY,EAAU,EAAE,CAC7E,MAAM,CAAC,OAAO,CAAC,EAAE,GAAG,IAAA,YAAK,EAAC,IAAA,eAAQ,EAAC,IAAI,EAAE,IAAI,CAAC,CAAC,EAAE,IAAI,EAAE,CAAC,CAAC,MAAM,CAC7D,CAAC,GAAG,EAAE,CAAC,IAAI,EAAE,KAAK,CAAC,EAAE,EAAE,CAAC,GAAG,CAAC,OAAO,CAAC,KAAK,IAAI,IAAI,EAAE,KAAK,CAAC,EACzD,QAAQ,CACT,CAAC;AAUJ,MAAM,KAAK,GAAG,CAAC,GAAW,EAAU,EAAE,CACpC,MAAM,GAAG;KACN,KAAK,CAAC,IAAI,CAAC;KACX,GAAG,CAAC,CAAC,IAAI,EAAE,EAAE,CAAC,MAAM,IAAI,EAAE,CAAC;KAC3B,IAAI,CAAC,IAAI,CAAC,KAAK,CAAC;AAErB,MAAM,SAAS,GAAG,CAAiB,GAAuB,EAAE,IAAO,EAAK,EAAE,CACxE,GAAG,KAAK,SAAS,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,IAAA,uCAA0B,EAAC,IAAI,EAAE,uBAAU,CAAC,sBAAsB,EAAE,KAAK,CAAC,GAAG,CAAC,EAAE,IAAI,CAAC,CAAC;AAE5G,MAAM,YAAY,GAAG,CAAC,KAAa,EAAU,EAAE,CACpD,KAAK;KACF,GAAG,CAAC,CAAC,IAAI,EAAE,EAAE,CAAC,CAAC,IAAA,wBAAc,EAAC,IAAI,CAAC,CAAC,CAAC,CAAC,EAAE,GAAG,IAAI,CAAC,KAAK,EAAE,QAAQ,EAAE,IAAI,CAAC,QAAQ,EAAE,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC;KACzF,MAAM,CAAC,CAAC,IAAI,EAAE,KAAK,EAAE,GAAG,EAAE,EAAE,CAC3B,IAAA,uBAAa,EAAC,IAAI,CAAC,IAAI,IAAI,CAAC,OAAO,KAAK,SAAS;IAC/C,CAAC,CAAC,CAAC,GAAG,CAAC,IAAI,CACP,CAAC,KAAK,EAAE,UAAU,EAAE,EAAE,CAAC,KAAK,KAAK,UAAU,IAAI,KAAK,CAAC,IAAI,KAAK,IAAI,CAAC,IAAI,IAAI,KAAK,CAAC,OAAO,KAAK,SAAS,CACvG;IACH,CAAC,CAAC,IAAI,CACT;KACA,MAAM,CAAC,IAAA,oBAAU,EAAC,qBAAW,CAAC,CAAC,CAAC;AAVxB,QAAA,YAAY,gBAUY;AAErC,MAAM,cAAc,GAClB,CAAC,OAAoB,EAAE,EAAE,CACzB,CAAC,IAAU,EAAoC,EAAE;IAC/C,IAAI,IAAA,yBAAe,EAAC,IAAI,CAAC,EAAE;QACzB,OAAO,EAAE,GAAG,OAAO,EAAE,IAAI,EAAE,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,aAAa,CAAC,EAAE,CAAC;KAC5E;SAAM,IAAI,IAAA,6BAAmB,EAAC,IAAI,CAAC,EAAE;QACpC,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,CACtB,CAAC,GAAG,EAAE,IAAI,EAAE,EAAE;YACZ,MAAM,QAAQ,GAAG,cAAc,CAAC,EAAE,GAAG,GAAG,EAAE,IAAI,EAAE,OAAO,CAAC,IAAI,GAAG,WAAW,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;YACpG,MAAM,OAAO,GAAG,oBAAO,CAAC,uBAAuB,CAC7C,SAAS,EACT,IAAI,CAAC,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC;gBACrB,CAAC,CAAC,oBAAO,CAAC,0BAA0B,CAAC,oBAAO,CAAC,mBAAmB,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;gBAC5E,CAAC,CAAC,IAAI,CAAC,IAAI,EACb,UAAU,IAAI,IAAI,CAAC,IAAI,IAAI,IAAI,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC,CAAC,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,aAAa,CAAC,CAAC,CAAC,CAAC,SAAS,EACzG,QAAQ,CAAC,IAAI,CACd,CAAC;YACF,OAAO,EAAE,GAAG,QAAQ,EAAE,IAAI,EAAE,oBAAO,CAAC,qBAAqB,CAAC,GAAG,CAAC,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC,EAAE,CAAC;QAChG,CAAC,EACD,EAAE,GAAG,OAAO,EAAE,IAAI,EAAE,oBAAO,CAAC,qBAAqB,CAAC,EAAE,CAAC,EAAE,CACxD,CAAC;KACH;SAAM,IAAI,IAAA,qBAAW,EAAC,IAAI,CAAC,EAAE;QAC5B,MAAM,SAAS,GAAG,cAAc,CAAC,OAAO,CAAC,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC;QACtD,OAAO,EAAE,GAAG,SAAS,EAAE,IAAI,EAAE,oBAAO,CAAC,mBAAmB,CAAC,SAAS,CAAC,IAAI,CAAC,EAAE,CAAC;KAC5E;SAAM,IAAI,IAAA,qBAAW,EAAC,IAAI,CAAC,EAAE;QAC5B,MAAM,UAAU,GAAG,IAAA,oBAAY,EAAC,IAAI,CAAC,KAAK,CAAC,CAAC;QAC5C,OAAO,IAAA,iBAAO,EAAC,UAAU,CAAC;YACxB,CAAC,CAAC,EAAE,GAAG,OAAO,EAAE,IAAI,EAAE,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,cAAc,CAAC,EAAE;YACtE,CAAC,CAAC,UAAU,CAAC,MAAM,CACf,CAAC,GAAG,EAAE,IAAI,EAAE,KAAK,EAAE,EAAE;gBACnB,MAAM,QAAQ,GAAG,cAAc,CAAC,EAAE,GAAG,GAAG,EAAE,IAAI,EAAE,OAAO,CAAC,IAAI,GAAG,KAAK,EAAE,CAAC,CAAC,IAAI,CAAC,CAAC;gBAC9E,OAAO,EAAE,GAAG,QAAQ,EAAE,IAAI,EAAE,oBAAO,CAAC,mBAAmB,CAAC,GAAG,CAAC,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,QAAQ,CAAC,IAAI,CAAC,CAAC,EAAE,CAAC;YAClG,CAAC,EACD,EAAE,GAAG,OAAO,EAAE,IAAI,EAAE,oBAAO,CAAC,mBAAmB,CAAC,EAAE,CAAC,EAAE,CACtD,CAAC;KACP;SAAM,IAAI,IAAA,wBAAc,EAAC,IAAI,CAAC,EAAE;QAC/B,OAAO,IAAI,CAAC,KAAK;YACf,CAAC,CAAC,cAAc,CAAC,OAAO,CAAC,CAAC,IAAI,CAAC,KAAK,CAAC;YACrC,CAAC,CAAC,EAAE,GAAG,OAAO,EAAE,IAAI,EAAE,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,cAAc,CAAC,EAAE,CAAC;KAC1E;SAAM;QACL,QAAQ,IAAI,CAAC,IAAI,EAAE;YACjB;gBACE,OAAO,EAAE,GAAG,OAAO,EAAE,IAAI,EAAE,oBAAO,CAAC,uBAAuB,CAAC,MAAM,CAAC,EAAE,CAAC;YACvE;gBACE,OAAO,EAAE,GAAG,OAAO,EAAE,IAAI,EAAE,oBAAO,CAAC,uBAAuB,CAAC,QAAQ,CAAC,EAAE,CAAC;YACzE;gBACE,OAAO;oBACL,GAAG,OAAO;oBACV,IAAI,EACF,IAAI,CAAC,OAAO,KAAK,SAAS;wBACxB,CAAC,CAAC,oBAAO,CAAC,qBAAqB,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC,CAAC,oBAAO,CAAC,UAAU,EAAE,CAAC,CAAC,CAAC,oBAAO,CAAC,WAAW,EAAE,CAAC;wBAC5F,CAAC,CAAC,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,cAAc,CAAC;iBACrD,CAAC;YACJ;gBACE,OAAO;oBACL,GAAG,OAAO;oBACV,IAAI,EAAE,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,IAAI,CAAC;oBACvC,IAAI,EAAE,OAAO,CAAC,MAAM;wBAClB,CAAC,CAAC,oBAAO,CAAC,uBAAuB,CAAC,MAAM,EAAE,CAAC,oBAAO,CAAC,uBAAuB,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC;wBAC1F,CAAC,CAAC,oBAAO,CAAC,uBAAuB,CAAC,OAAO,CAAC,IAAI,CAAC;iBAClD,CAAC;YACJ;gBACE,OAAO,EAAE,GAAG,OAAO,EAAE,IAAI,EAAE,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,gBAAgB,CAAC,EAAE,CAAC;YAChF,6BAAqB;YACrB;gBACE,OAAO;oBACL,GAAG,OAAO;oBACV,IAAI,EACF,IAAI,CAAC,OAAO,KAAK,SAAS;wBACxB,CAAC,CAAC,oBAAO,CAAC,qBAAqB,CAAC,oBAAO,CAAC,mBAAmB,CAAC,MAAM,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC,CAAC;wBAClF,CAAC,CAAC,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,aAAa,CAAC;iBACpD,CAAC;YACJ;gBACE,OAAO;oBACL,GAAG,OAAO;oBACV,IAAI,EACF,IAAI,CAAC,OAAO,KAAK,SAAS;wBACxB,CAAC,CAAC,oBAAO,CAAC,qBAAqB,CAAC,oBAAO,CAAC,mBAAmB,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;wBAC1E,CAAC,CAAC,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,aAAa,CAAC;iBACpD,CAAC;YACJ;gBACE,OAAO,EAAE,GAAG,OAAO,EAAE,IAAI,EAAE,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,cAAc,CAAC,EAAE,CAAC;YAC9E;gBACE,OAAO,EAAE,GAAG,OAAO,EAAE,IAAI,EAAE,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,UAAU,CAAC,EAAE,CAAC;SAC3E;KACF;AACH,CAAC,CAAC;AAEJ,MAAM,WAAW,GAAG,CAAC,UAAkB,EAAE,EAAE,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC,WAAW,EAAE,GAAG,UAAU,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;AAE9F,MAAM,YAAY,GAAG,CAAC,KAAe,EAAa,EAAE,CAClD,oBAAO,CAAC,uBAAuB,CAC7B,SAAS,EACT,oBAAO,CAAC,kBAAkB,CACxB,KAAK,EACL,SAAS,EACT,oBAAO,CAAC,kBAAkB,CACxB,KAAK,CAAC,GAAG,CAAC,CAAC,IAAI,EAAE,EAAE,CAAC,oBAAO,CAAC,qBAAqB,CAAC,KAAK,EAAE,SAAS,EAAE,oBAAO,CAAC,gBAAgB,CAAC,IAAI,CAAC,CAAC,CAAC,CACrG,CACF,EACD,oBAAO,CAAC,mBAAmB,CAAC,kBAAkB,CAAC,CAChD,CAAC;AAEJ,MAAM,sBAAsB,GAAG,CAC7B,IAAU,EACV,IAAY,EACZ,WAAiC,EACc,EAAE;IACjD,MAAM,MAAM,GAAG,WAAW,CAAC,MAAM,CAAC,MAAM,CACtC,CAAC,GAAG,EAAE,IAAI,EAAE,EAAE;QACZ,MAAM,QAAQ,GAAG,cAAc,CAAC,EAAE,MAAM,EAAE,KAAK,EAAE,IAAI,EAAE,QAAQ,GAAG,WAAW,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,IAAI,EAAE,CAAC,CACzG,IAAI,CAAC,IAAI,CACV,CAAC;QACF,MAAM,IAAI,GAAG,oBAAO,CAAC,uBAAuB,CAC1C,SAAS,EACT,IAAI,CAAC,IAAI,EACT,UAAU,IAAI,IAAI,CAAC,IAAI,IAAI,IAAI,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC,CAAC,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,aAAa,CAAC,CAAC,CAAC,CAAC,SAAS,EACzG,QAAQ,CAAC,IAAI,CACd,CAAC;QACF,OAAO,EAAE,GAAG,QAAQ,EAAE,KAAK,EAAE,GAAG,CAAC,KAAK,CAAC,MAAM,CAAC,IAAI,CAAC,EAAE,CAAC;IACxD,CAAC,EACD,EAAE,IAAI,EAAE,KAAK,EAAE,EAAE,EAAE,CACpB,CAAC;IAEF,MAAM,OAAO,GAAG,WAAW,CAAC,OAAO,CAAC,MAAM,CACxC,CAAC,GAAG,EAAE,IAAI,EAAE,EAAE;QACZ,MAAM,QAAQ,GAAG,cAAc,CAAC,EAAE,MAAM,EAAE,IAAI,EAAE,IAAI,EAAE,GAAG,GAAG,WAAW,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,IAAI,EAAE,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;QACjH,MAAM,IAAI,GAAG,SAAS,CACpB,IAAI,CAAC,IAAI,CAAC,OAAO,IAAI,SAAS,EAC9B,oBAAO,CAAC,uBAAuB,CAC7B,SAAS,EACT,kBAAkB,CAAC,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC,CAAC,oBAAO,CAAC,mBAAmB,CAAC,IAAI,CAAC,IAAI,CAAC,EACvF,UAAU,IAAI,IAAI,CAAC,IAAI,IAAI,IAAI,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC,CAAC,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,aAAa,CAAC,CAAC,CAAC,CAAC,SAAS,EACzG,QAAQ,CAAC,IAAI,CACd,CACF,CAAC;QACF,OAAO,EAAE,GAAG,QAAQ,EAAE,KAAK,EAAE,GAAG,CAAC,KAAK,CAAC,MAAM,CAAC,IAAI,CAAC,EAAE,CAAC;IACxD,CAAC,EACD,EAAE,IAAI,EAAE,EAAE,EAAE,KAAK,EAAE,EAAE,EAAE,CACxB,CAAC;IAEF,OAAO;QACL,UAAU,EAAE,OAAO,CAAC,IAAI;QACxB,UAAU,EAAE;YACV,oBAAO,CAAC,0BAA0B,CAChC,CAAC,oBAAO,CAAC,cAAc,CAAC,uBAAU,CAAC,aAAa,CAAC,CAAC,EAClD,GAAG,IAAI,QAAQ,EACf,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CACtB,oBAAO,CAAC,8BAA8B,CAAC,EAAE,EAAE,GAAG,EAAE,SAAS,EAAE,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,cAAc,CAAC,CAAC,CAC3G,EACD,SAAS,EACT,MAAM,CAAC,KAAK,CACb;YACD,oBAAO,CAAC,0BAA0B,CAChC,CAAC,oBAAO,CAAC,cAAc,CAAC,uBAAU,CAAC,aAAa,CAAC,CAAC,EAClD,GAAG,IAAI,QAAQ,EACf,OAAO,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CACvB,oBAAO,CAAC,8BAA8B,CAAC,EAAE,EAAE,GAAG,EAAE,SAAS,EAAE,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,cAAc,CAAC,CAAC,CAC3G,EACD,SAAS,EACT,OAAO,CAAC,KAAK,CACd;YACD,oBAAO,CAAC,0BAA0B,CAChC,CAAC,oBAAO,CAAC,cAAc,CAAC,uBAAU,CAAC,aAAa,CAAC,CAAC,EAClD,GAAG,IAAI,OAAO,EACd,CAAC,GAAG,MAAM,CAAC,IAAI,EAAE,GAAG,OAAO,CAAC,IAAI,CAAC,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CAC5C,oBAAO,CAAC,8BAA8B,CAAC,EAAE,EAAE,GAAG,EAAE,SAAS,EAAE,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,cAAc,CAAC,CAAC,CAC3G,EACD,SAAS,EACT;gBACE,oBAAO,CAAC,uBAAuB,CAC7B,SAAS,EACT,QAAQ,EACR,SAAS,EACT,oBAAO,CAAC,uBAAuB,CAC7B,GAAG,IAAI,QAAQ,EACf,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,oBAAO,CAAC,uBAAuB,CAAC,GAAG,CAAC,CAAC,CAC/D,CACF;gBACD,oBAAO,CAAC,uBAAuB,CAC7B,SAAS,EACT,QAAQ,EACR,SAAS,EACT,oBAAO,CAAC,mBAAmB,CACzB,oBAAO,CAAC,uBAAuB,CAC7B,GAAG,IAAI,QAAQ,EACf,OAAO,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,oBAAO,CAAC,uBAAuB,CAAC,GAAG,CAAC,CAAC,CAChE,CACF,CACF;aACF,CACF;SACF;KACF,CAAC;AACJ,CAAC,CAAC;AAEF;;;;;;GAMG;AACI,MAAM,YAAY,GAAG,CAAC,IAAgB,EAAE,aAAqB,EAAE,EAAc,EAAE;IACpF,MAAM,OAAO,GACX,IAAI,CAAC,IAAI,KAAK,IAAI;QAChB,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,MAAM,CACjB,CAAC,GAAG,EAAE,KAAK,EAAE,EAAE;YACb,MAAM,EAAE,UAAU,EAAE,UAAU,EAAE,GAAG,sBAAsB,CACvD,GAAG,CAAC,UAAU,EACd,UAAU,GAAG,WAAW,CAAC,KAAK,CAAC,IAAI,CAAC,EACpC,KAAK,CAAC,WAAW,CAClB,CAAC;YACF,OAAO,EAAE,UAAU,EAAE,UAAU,EAAE,GAAG,CAAC,UAAU,CAAC,MAAM,CAAC,UAAU,CAAC,EAAE,CAAC;QACvE,CAAC,EACD,EAAE,UAAU,EAAE,EAAE,EAAE,UAAU,EAAE,EAAE,EAAE,CACnC;QACH,CAAC,CAAC,sBAAsB,CAAC,EAAE,EAAE,UAAU,EAAE,IAAI,CAAC,WAAW,CAAC,CAAC;IAE/D,OAAO,oBAAO,CAAC,gBAAgB,CAC7B,IAAA,6BAAgB,EAAC,IAAI,CAAC,IAAI,EAAE,EAAE,EAAE,yBAAY,CAAC,MAAM,EAAE,IAAI,CAAC,EAC1D,OAAO,CAAC,UAAU,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC,CAAC,CAAC,YAAY,CAAC,CAAC,MAAM,CAAC,CAAC,EAAE,GAAG,OAAO,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC,OAAO,CAAC,UAAU,CACrG,CAAC;AACJ,CAAC,CAAC;AApBW,QAAA,YAAY,gBAoBvB;AAEK,MAAM,mBAAmB,GAAG,CAAC,IAAY,EAAE,QAAgB,EAAE,UAAmB,EAAE,EAAE;IACzF,MAAM,OAAO,GAAG,IAAA,0BAAa,EAAC,EAAE,OAAO,EAAE,wBAAW,CAAC,QAAQ,EAAE,CAAC,CAAC;IACjE,OAAO,KAAK,EAAE,IAAgB,EAA8C,EAAE;QAC5E,MAAM,IAAI,GAAG,aAAa,CAAC,IAAI,EAAE,QAAQ,EAAE,IAAI,CAAC,IAAI,CAAC,CAAC;QACtD,OAAO,EAAE,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,SAAS,CAAC,IAAA,oBAAY,EAAC,IAAI,EAAE,UAAU,CAAC,CAAC,EAAE,CAAC;IAC9E,CAAC,CAAC;AACJ,CAAC,CAAC;AANW,QAAA,mBAAmB,uBAM9B"}

dist/config.d.ts

@@ -11,3 +11,2 @@ import { Record, Optional, Static, String, Boolean } from 'runtypes';
     typePrefix: Optional<String>;
-    preload: Optional<Boolean>;
     cache: Optional<Boolean>;
@@ -14,0 +13,0 @@ cacheFile: Optional<String>;

dist/config.js

@@ -14,3 +14,2 @@ "use strict";
     typePrefix: (0, runtypes_1.Optional)(runtypes_1.String),
-    preload: (0, runtypes_1.Optional)(runtypes_1.Boolean),
     cache: (0, runtypes_1.Optional)(runtypes_1.Boolean),
@@ -24,3 +23,2 @@ cacheFile: (0, runtypes_1.Optional)(runtypes_1.String),
     root: process.cwd(),
-    preload: false,
     template: '{{dir}}/{{name}}.queries.ts',
@@ -27,0 +25,0 @@ connection: 'postgres://localhost:5432/db',

dist/config.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"config.js","sourceRoot":"","sources":["../src/config.ts"],"names":[],"mappings":";;;AAAA,uCAAqE;AAExD,QAAA,MAAM,GAAG,IAAA,iBAAM,EAAC;IAC3B,KAAK,EAAE,IAAA,mBAAQ,EAAC,iBAAM,CAAC;IACvB,KAAK,EAAE,IAAA,mBAAQ,EAAC,kBAAO,CAAC;IACxB,IAAI,EAAE,IAAA,mBAAQ,EAAC,iBAAM,CAAC;IACtB,UAAU,EAAE,IAAA,mBAAQ,EAAC,iBAAM,CAAC;IAC5B,QAAQ,EAAE,IAAA,mBAAQ,EAAC,iBAAM,CAAC;IAC1B,OAAO,EAAE,IAAA,mBAAQ,EAAC,kBAAO,CAAC;IAC1B,MAAM,EAAE,IAAA,mBAAQ,EAAC,kBAAO,CAAC;IACzB,UAAU,EAAE,IAAA,mBAAQ,EAAC,iBAAM,CAAC;IAC5B,OAAO,EAAE,IAAA,mBAAQ,EAAC,kBAAO,CAAC;IAC1B,KAAK,EAAE,IAAA,mBAAQ,EAAC,kBAAO,CAAC;IACxB,SAAS,EAAE,IAAA,mBAAQ,EAAC,iBAAM,CAAC;IAC3B,UAAU,EAAE,IAAA,mBAAQ,EAAC,kBAAO,CAAC;CAC9B,CAAC,CAAC;AAKI,MAAM,QAAQ,GAAG,CAAC,MAAe,EAAkB,EAAE,CAAC,CAAC;IAC5D,KAAK,EAAE,UAAU;IACjB,SAAS,EAAE,sBAAsB;IACjC,IAAI,EAAE,OAAO,CAAC,GAAG,EAAE;IACnB,OAAO,EAAE,KAAK;IACd,QAAQ,EAAE,6BAA6B;IACvC,UAAU,EAAE,8BAA8B;IAC1C,KAAK,EAAE,KAAK;IACZ,OAAO,EAAE,KAAK;IACd,MAAM,EAAE,KAAK;IACb,KAAK,EAAE,KAAK;IACZ,UAAU,EAAE,KAAK;IACjB,UAAU,EAAE,EAAE;IACd,GAAG,cAAM,CAAC,KAAK,CAAC,MAAM,CAAC;CACxB,CAAC,CAAC;AAdU,QAAA,QAAQ,YAclB"}
+{"version":3,"file":"config.js","sourceRoot":"","sources":["../src/config.ts"],"names":[],"mappings":";;;AAAA,uCAAqE;AAExD,QAAA,MAAM,GAAG,IAAA,iBAAM,EAAC;IAC3B,KAAK,EAAE,IAAA,mBAAQ,EAAC,iBAAM,CAAC;IACvB,KAAK,EAAE,IAAA,mBAAQ,EAAC,kBAAO,CAAC;IACxB,IAAI,EAAE,IAAA,mBAAQ,EAAC,iBAAM,CAAC;IACtB,UAAU,EAAE,IAAA,mBAAQ,EAAC,iBAAM,CAAC;IAC5B,QAAQ,EAAE,IAAA,mBAAQ,EAAC,iBAAM,CAAC;IAC1B,OAAO,EAAE,IAAA,mBAAQ,EAAC,kBAAO,CAAC;IAC1B,MAAM,EAAE,IAAA,mBAAQ,EAAC,kBAAO,CAAC;IACzB,UAAU,EAAE,IAAA,mBAAQ,EAAC,iBAAM,CAAC;IAC5B,KAAK,EAAE,IAAA,mBAAQ,EAAC,kBAAO,CAAC;IACxB,SAAS,EAAE,IAAA,mBAAQ,EAAC,iBAAM,CAAC;IAC3B,UAAU,EAAE,IAAA,mBAAQ,EAAC,kBAAO,CAAC;CAC9B,CAAC,CAAC;AAKI,MAAM,QAAQ,GAAG,CAAC,MAAe,EAAkB,EAAE,CAAC,CAAC;IAC5D,KAAK,EAAE,UAAU;IACjB,SAAS,EAAE,sBAAsB;IACjC,IAAI,EAAE,OAAO,CAAC,GAAG,EAAE;IACnB,QAAQ,EAAE,6BAA6B;IACvC,UAAU,EAAE,8BAA8B;IAC1C,KAAK,EAAE,KAAK;IACZ,OAAO,EAAE,KAAK;IACd,MAAM,EAAE,KAAK;IACb,KAAK,EAAE,KAAK;IACZ,UAAU,EAAE,KAAK;IACjB,UAAU,EAAE,EAAE;IACd,GAAG,cAAM,CAAC,KAAK,CAAC,MAAM,CAAC;CACxB,CAAC,CAAC;AAbU,QAAA,QAAQ,YAalB"}

dist/index.d.ts

@@ -1,4 +0,3 @@
-export { SqlRead, QueryLoader } from './traverse';
 export { Config, ConfigType, FullConfigType, toConfig } from './config';
-export { emitLoadedFile, toTypeSource, compactTypes } from './emit';
+export { toTypeScriptPrinter, toTypeSource, compactTypes } from './typescript-printer';
 export { glob } from './glob';

dist/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.glob = exports.compactTypes = exports.toTypeSource = exports.emitLoadedFile = exports.toConfig = exports.Config = exports.QueryLoader = exports.SqlRead = void 0;
-var traverse_1 = require("./traverse");
-Object.defineProperty(exports, "SqlRead", { enumerable: true, get: function () { return traverse_1.SqlRead; } });
-Object.defineProperty(exports, "QueryLoader", { enumerable: true, get: function () { return traverse_1.QueryLoader; } });
+exports.glob = exports.compactTypes = exports.toTypeSource = exports.toTypeScriptPrinter = exports.toConfig = exports.Config = void 0;
 var config_1 = require("./config");
 Object.defineProperty(exports, "Config", { enumerable: true, get: function () { return config_1.Config; } });
 Object.defineProperty(exports, "toConfig", { enumerable: true, get: function () { return config_1.toConfig; } });
-var emit_1 = require("./emit");
-Object.defineProperty(exports, "emitLoadedFile", { enumerable: true, get: function () { return emit_1.emitLoadedFile; } });
-Object.defineProperty(exports, "toTypeSource", { enumerable: true, get: function () { return emit_1.toTypeSource; } });
-Object.defineProperty(exports, "compactTypes", { enumerable: true, get: function () { return emit_1.compactTypes; } });
+var typescript_printer_1 = require("./typescript-printer");
+Object.defineProperty(exports, "toTypeScriptPrinter", { enumerable: true, get: function () { return typescript_printer_1.toTypeScriptPrinter; } });
+Object.defineProperty(exports, "toTypeSource", { enumerable: true, get: function () { return typescript_printer_1.toTypeSource; } });
+Object.defineProperty(exports, "compactTypes", { enumerable: true, get: function () { return typescript_printer_1.compactTypes; } });
 var glob_1 = require("./glob");
 Object.defineProperty(exports, "glob", { enumerable: true, get: function () { return glob_1.glob; } });
 //# sourceMappingURL=index.js.map

dist/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";;;AAAA,uCAAkD;AAAzC,mGAAA,OAAO,OAAA;AAAE,uGAAA,WAAW,OAAA;AAC7B,mCAAwE;AAA/D,gGAAA,MAAM,OAAA;AAA8B,kGAAA,QAAQ,OAAA;AACrD,+BAAoE;AAA3D,sGAAA,cAAc,OAAA;AAAE,oGAAA,YAAY,OAAA;AAAE,oGAAA,YAAY,OAAA;AACnD,+BAA8B;AAArB,4FAAA,IAAI,OAAA"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";;;AAAA,mCAAwE;AAA/D,gGAAA,MAAM,OAAA;AAA8B,kGAAA,QAAQ,OAAA;AACrD,2DAAuF;AAA9E,yHAAA,mBAAmB,OAAA;AAAE,kHAAA,YAAY,OAAA;AAAE,kHAAA,YAAY,OAAA;AACxD,+BAA8B;AAArB,4FAAA,IAAI,OAAA"}

dist/potygen.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.potygen = void 0;
+const potygen_1 = require("@potygen/potygen");
+const promise_pool_1 = require("@supercharge/promise-pool");
 const fs_1 = require("fs");
 const util_1 = require("util");
 const pg_1 = require("pg");
-const stream_1 = require("stream");
 const commander_1 = require("commander");
-const traverse_1 = require("./traverse");
+const emitter_1 = require("./emitter");
 const config_1 = require("./config");
-const cache_1 = require("./cache");
-const asyncPipeline = (0, util_1.promisify)(stream_1.pipeline);
+const glob_1 = require("./glob");
 var LogLevel;
@@ -25,3 +25,3 @@ (function (LogLevel) {
         if (this.level >= LogLevel.error) {
-            console.info(...args);
+            console.error(...args);
         }
@@ -42,3 +42,3 @@ }
     .description('Convert postgres query files into typescript types')
-    .version('0.8.2')
+    .version('0.9.0')
     .option('-c, --config <config>', 'A configuration file to load', 'potygen.config.json')
@@ -52,4 +52,3 @@ .option('-f, --files <files>', 'A glob pattern to search files by (default: "**/*.sql")')
     .option('-s, --silent', 'Only show error logs')
-    .option('-p, --typePrefix <typePrefix>', 'Prefix generated types')
-    .option('-l, --preload', 'Load all data at once. Slower start but faster for a lot of files')
+    .option('-p, --type-prefix <typePrefix>', 'Prefix generated types')
     .option('-r, --root <root>', `Set the root directory (default: ${process.cwd()})`)
@@ -60,7 +59,6 @@ .option('-n, --connection <connection>', 'Connection to the postgres database. URI (default: "postgres://localhost:5432/db")')
     const { config, ...rest } = options;
-    const { root, connection, watch, files, template, verbose, silent, typePrefix, preload, cache, cacheFile, cacheClear, } = (0, config_1.toConfig)({
+    const { root, connection, watch, files, template, verbose, silent, typePrefix, cache, cacheFile, cacheClear } = (0, config_1.toConfig)({
         ...((0, fs_1.existsSync)(config) ? JSON.parse((0, fs_1.readFileSync)(config, 'utf-8')) : {}),
         ...rest,
     });
-    const cacheStore = new cache_1.CacheStore(cacheFile, cache, cacheClear);
     const logger = overwriteLogger ?? new LogLevelConsole(verbose ? LogLevel.debug : silent ? LogLevel.error : LogLevel.info);
@@ -71,18 +69,28 @@ logger.debug(`Potygen Config: ${(0, util_1.inspect)({ root, connection, watch, files, template })}`);
     try {
-        const sqls = new traverse_1.SqlRead({ path: files, root, watch, logger, cacheStore });
-        const sink = new traverse_1.QueryLoader({ db, root, template, logger, typePrefix, preload, cacheStore });
-        logger.info(`Potygen started processing ("${files}", watch: ${watch})`);
-        await asyncPipeline(sqls, sink);
-        cacheStore.save();
-    }
-    catch (error) {
-        if (process.env.POTYGEN_DEBUG && error instanceof Error) {
-            logger.error(error.stack);
+        const cacheStore = new emitter_1.CacheStore(cacheFile, cache, cacheClear);
+        await cacheStore.load();
+        const emit = await (0, emitter_1.toEmitter)({ db, logger }, cacheStore, { root, template, typePrefix });
+        const { results, errors } = await promise_pool_1.PromisePool.withConcurrency(20)
+            .for(Array.from((0, glob_1.glob)(files, root)))
+            .process(emit);
+        if (errors.length) {
+            logger.error('Errors:');
+            logger.error('------------------------------');
+            for (const error of errors) {
+                logger.error(`[${error.item}]`);
+                logger.error(process.env.POTYGEN_DEBUG ? error.stack : String(error.raw));
+                logger.error('\n');
+            }
         }
-        else {
-            logger.error(String(error));
+        if (watch) {
+            for (const { path } of results.filter(potygen_1.isNil)) {
+                (0, fs_1.watchFile)(path, () => emit(path));
+            }
         }
+        await cacheStore.save();
     }
     finally {
-        await db.end();
+        if (!watch) {
+            await db.end();
+        }
     }
@@ -89,0 +97,0 @@ });

dist/potygen.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"potygen.js","sourceRoot":"","sources":["../src/potygen.ts"],"names":[],"mappings":";;;AACA,2BAA8C;AAC9C,+BAA0C;AAC1C,2BAA4B;AAC5B,mCAAkC;AAClC,yCAAmD;AACnD,yCAAkD;AAClD,qCAAgD;AAChD,mCAAqC;AAErC,MAAM,aAAa,GAAG,IAAA,gBAAS,EAAC,iBAAQ,CAAC,CAAC;AAE1C,IAAK,QAIJ;AAJD,WAAK,QAAQ;IACX,yCAAK,CAAA;IACL,uCAAI,CAAA;IACJ,yCAAK,CAAA;AACP,CAAC,EAJI,QAAQ,KAAR,QAAQ,QAIZ;AAED,MAAM,eAAe;IACnB,YAAmB,KAAe;QAAf,UAAK,GAAL,KAAK,CAAU;IAAG,CAAC;IAEtC,KAAK,CAAC,GAAG,IAAW;QAClB,IAAI,IAAI,CAAC,KAAK,IAAI,QAAQ,CAAC,KAAK,EAAE;YAChC,OAAO,CAAC,IAAI,CAAC,GAAG,IAAI,CAAC,CAAC;SACvB;IACH,CAAC;IAED,IAAI,CAAC,GAAG,IAAW;QACjB,IAAI,IAAI,CAAC,KAAK,IAAI,QAAQ,CAAC,IAAI,EAAE;YAC/B,OAAO,CAAC,IAAI,CAAC,GAAG,IAAI,CAAC,CAAC;SACvB;IACH,CAAC;IAED,KAAK,CAAC,GAAG,IAAW;QAClB,IAAI,IAAI,CAAC,KAAK,IAAI,QAAQ,CAAC,KAAK,EAAE;YAChC,OAAO,CAAC,KAAK,CAAC,GAAG,IAAI,CAAC,CAAC;SACxB;IACH,CAAC;CACF;AAEM,MAAM,OAAO,GAAG,CAAC,eAAwB,EAAW,EAAE,CAC3D,IAAA,yBAAa,EAAC,SAAS,CAAC;KACrB,WAAW,CAAC,oDAAoD,CAAC;KACjE,OAAO,CAAC,OAAO,CAAC;KAChB,MAAM,CAAC,uBAAuB,EAAE,8BAA8B,EAAE,qBAAqB,CAAC;KACtF,MAAM,CAAC,qBAAqB,EAAE,yDAAyD,CAAC;KACxF,MAAM,CAAC,aAAa,EAAE,wCAAwC,CAAC;KAC/D,MAAM,CAAC,eAAe,EAAE,mBAAmB,CAAC;KAC5C,MAAM,CAAC,8BAA8B,EAAE,kCAAkC,EAAE,sBAAsB,CAAC;KAClG,MAAM,CAAC,mBAAmB,EAAE,iBAAiB,CAAC;KAC9C,MAAM,CAAC,aAAa,EAAE,sEAAsE,CAAC;KAC7F,MAAM,CAAC,cAAc,EAAE,sBAAsB,CAAC;KAC9C,MAAM,CAAC,+BAA+B,EAAE,wBAAwB,CAAC;KACjE,MAAM,CAAC,eAAe,EAAE,mEAAmE,CAAC;KAC5F,MAAM,CAAC,mBAAmB,EAAE,oCAAoC,OAAO,CAAC,GAAG,EAAE,GAAG,CAAC;KACjF,MAAM,CACL,+BAA+B,EAC/B,oFAAoF,CACrF;KACA,MAAM,CACL,2BAA2B,EAC3B,gLAAgL,CACjL;KACA,MAAM,CAAC,KAAK,EAAE,OAAwC,EAAE,EAAE;IACzD,MAAM,EAAE,MAAM,EAAE,GAAG,IAAI,EAAE,GAAG,OAAO,CAAC;IACpC,MAAM,EACJ,IAAI,EACJ,UAAU,EACV,KAAK,EACL,KAAK,EACL,QAAQ,EACR,OAAO,EACP,MAAM,EACN,UAAU,EACV,OAAO,EACP,KAAK,EACL,SAAS,EACT,UAAU,GACX,GAAG,IAAA,iBAAQ,EAAC;QACX,GAAG,CAAC,IAAA,eAAU,EAAC,MAAM,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,KAAK,CAAC,IAAA,iBAAY,EAAC,MAAM,EAAE,OAAO,CAAC,CAAC,CAAC,CAAC,CAAC,EAAE,CAAC;QACxE,GAAG,IAAI;KACR,CAAC,CAAC;IAEH,MAAM,UAAU,GAAG,IAAI,kBAAU,CAAC,SAAS,EAAE,KAAK,EAAE,UAAU,CAAC,CAAC;IAEhE,MAAM,MAAM,GACV,eAAe,IAAI,IAAI,eAAe,CAAC,OAAO,CAAC,CAAC,CAAC,QAAQ,CAAC,KAAK,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,CAAC,QAAQ,CAAC,KAAK,CAAC,CAAC,CAAC,QAAQ,CAAC,IAAI,CAAC,CAAC;IAE7G,MAAM,CAAC,KAAK,CAAC,mBAAmB,IAAA,cAAO,EAAC,EAAE,IAAI,EAAE,UAAU,EAAE,KAAK,EAAE,KAAK,EAAE,QAAQ,EAAE,CAAC,EAAE,CAAC,CAAC;IAEzF,MAAM,EAAE,GAAG,IAAI,WAAM,CAAC,UAAU,CAAC,CAAC;IAClC,MAAM,EAAE,CAAC,OAAO,EAAE,CAAC;IACnB,IAAI;QACF,MAAM,IAAI,GAAG,IAAI,kBAAO,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,IAAI,EAAE,KAAK,EAAE,MAAM,EAAE,UAAU,EAAE,CAAC,CAAC;QAC3E,MAAM,IAAI,GAAG,IAAI,sBAAW,CAAC,EAAE,EAAE,EAAE,IAAI,EAAE,QAAQ,EAAE,MAAM,EAAE,UAAU,EAAE,OAAO,EAAE,UAAU,EAAE,CAAC,CAAC;QAE9F,MAAM,CAAC,IAAI,CAAC,gCAAgC,KAAK,aAAa,KAAK,GAAG,CAAC,CAAC;QAExE,MAAM,aAAa,CAAC,IAAI,EAAE,IAAI,CAAC,CAAC;QAChC,UAAU,CAAC,IAAI,EAAE,CAAC;KACnB;IAAC,OAAO,KAAK,EAAE;QACd,IAAI,OAAO,CAAC,GAAG,CAAC,aAAa,IAAI,KAAK,YAAY,KAAK,EAAE;YACvD,MAAM,CAAC,KAAK,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC;SAC3B;aAAM;YACL,MAAM,CAAC,KAAK,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC;SAC7B;KACF;YAAS;QACR,MAAM,EAAE,CAAC,GAAG,EAAE,CAAC;KAChB;AACH,CAAC,CAAC,CAAC;AArEM,QAAA,OAAO,WAqEb"}
+{"version":3,"file":"potygen.js","sourceRoot":"","sources":["../src/potygen.ts"],"names":[],"mappings":";;;AAAA,8CAAiD;AACjD,4DAAwD;AACxD,2BAAyD;AACzD,+BAA+B;AAC/B,2BAA4B;AAC5B,yCAAmD;AACnD,uCAAkD;AAClD,qCAAgD;AAChD,iCAA8B;AAE9B,IAAK,QAIJ;AAJD,WAAK,QAAQ;IACX,yCAAK,CAAA;IACL,uCAAI,CAAA;IACJ,yCAAK,CAAA;AACP,CAAC,EAJI,QAAQ,KAAR,QAAQ,QAIZ;AAED,MAAM,eAAe;IACnB,YAAmB,KAAe;QAAf,UAAK,GAAL,KAAK,CAAU;IAAG,CAAC;IAEtC,KAAK,CAAC,GAAG,IAAW;QAClB,IAAI,IAAI,CAAC,KAAK,IAAI,QAAQ,CAAC,KAAK,EAAE;YAChC,OAAO,CAAC,KAAK,CAAC,GAAG,IAAI,CAAC,CAAC;SACxB;IACH,CAAC;IAED,IAAI,CAAC,GAAG,IAAW;QACjB,IAAI,IAAI,CAAC,KAAK,IAAI,QAAQ,CAAC,IAAI,EAAE;YAC/B,OAAO,CAAC,IAAI,CAAC,GAAG,IAAI,CAAC,CAAC;SACvB;IACH,CAAC;IAED,KAAK,CAAC,GAAG,IAAW;QAClB,IAAI,IAAI,CAAC,KAAK,IAAI,QAAQ,CAAC,KAAK,EAAE;YAChC,OAAO,CAAC,KAAK,CAAC,GAAG,IAAI,CAAC,CAAC;SACxB;IACH,CAAC;CACF;AAEM,MAAM,OAAO,GAAG,CAAC,eAAwB,EAAW,EAAE,CAC3D,IAAA,yBAAa,EAAC,SAAS,CAAC;KACrB,WAAW,CAAC,oDAAoD,CAAC;KACjE,OAAO,CAAC,OAAO,CAAC;KAChB,MAAM,CAAC,uBAAuB,EAAE,8BAA8B,EAAE,qBAAqB,CAAC;KACtF,MAAM,CAAC,qBAAqB,EAAE,yDAAyD,CAAC;KACxF,MAAM,CAAC,aAAa,EAAE,wCAAwC,CAAC;KAC/D,MAAM,CAAC,eAAe,EAAE,mBAAmB,CAAC;KAC5C,MAAM,CAAC,8BAA8B,EAAE,kCAAkC,EAAE,sBAAsB,CAAC;KAClG,MAAM,CAAC,mBAAmB,EAAE,iBAAiB,CAAC;KAC9C,MAAM,CAAC,aAAa,EAAE,sEAAsE,CAAC;KAC7F,MAAM,CAAC,cAAc,EAAE,sBAAsB,CAAC;KAC9C,MAAM,CAAC,gCAAgC,EAAE,wBAAwB,CAAC;KAClE,MAAM,CAAC,mBAAmB,EAAE,oCAAoC,OAAO,CAAC,GAAG,EAAE,GAAG,CAAC;KACjF,MAAM,CACL,+BAA+B,EAC/B,oFAAoF,CACrF;KACA,MAAM,CACL,2BAA2B,EAC3B,gLAAgL,CACjL;KACA,MAAM,CAAC,KAAK,EAAE,OAAwC,EAAE,EAAE;IACzD,MAAM,EAAE,MAAM,EAAE,GAAG,IAAI,EAAE,GAAG,OAAO,CAAC;IACpC,MAAM,EAAE,IAAI,EAAE,UAAU,EAAE,KAAK,EAAE,KAAK,EAAE,QAAQ,EAAE,OAAO,EAAE,MAAM,EAAE,UAAU,EAAE,KAAK,EAAE,SAAS,EAAE,UAAU,EAAE,GAC3G,IAAA,iBAAQ,EAAC;QACP,GAAG,CAAC,IAAA,eAAU,EAAC,MAAM,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,KAAK,CAAC,IAAA,iBAAY,EAAC,MAAM,EAAE,OAAO,CAAC,CAAC,CAAC,CAAC,CAAC,EAAE,CAAC;QACxE,GAAG,IAAI;KACR,CAAC,CAAC;IAEL,MAAM,MAAM,GACV,eAAe,IAAI,IAAI,eAAe,CAAC,OAAO,CAAC,CAAC,CAAC,QAAQ,CAAC,KAAK,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,CAAC,QAAQ,CAAC,KAAK,CAAC,CAAC,CAAC,QAAQ,CAAC,IAAI,CAAC,CAAC;IAE7G,MAAM,CAAC,KAAK,CAAC,mBAAmB,IAAA,cAAO,EAAC,EAAE,IAAI,EAAE,UAAU,EAAE,KAAK,EAAE,KAAK,EAAE,QAAQ,EAAE,CAAC,EAAE,CAAC,CAAC;IAEzF,MAAM,EAAE,GAAG,IAAI,WAAM,CAAC,UAAU,CAAC,CAAC;IAClC,MAAM,EAAE,CAAC,OAAO,EAAE,CAAC;IACnB,IAAI;QACF,MAAM,UAAU,GAAG,IAAI,oBAAU,CAAC,SAAS,EAAE,KAAK,EAAE,UAAU,CAAC,CAAC;QAChE,MAAM,UAAU,CAAC,IAAI,EAAE,CAAC;QACxB,MAAM,IAAI,GAAG,MAAM,IAAA,mBAAS,EAAC,EAAE,EAAE,EAAE,MAAM,EAAE,EAAE,UAAU,EAAE,EAAE,IAAI,EAAE,QAAQ,EAAE,UAAU,EAAE,CAAC,CAAC;QACzF,MAAM,EAAE,OAAO,EAAE,MAAM,EAAE,GAAG,MAAM,0BAAW,CAAC,eAAe,CAAC,EAAE,CAAC;aAC9D,GAAG,CAAC,KAAK,CAAC,IAAI,CAAC,IAAA,WAAI,EAAC,KAAK,EAAE,IAAI,CAAC,CAAC,CAAC;aAClC,OAAO,CAAC,IAAI,CAAC,CAAC;QAEjB,IAAI,MAAM,CAAC,MAAM,EAAE;YACjB,MAAM,CAAC,KAAK,CAAC,SAAS,CAAC,CAAC;YACxB,MAAM,CAAC,KAAK,CAAC,gCAAgC,CAAC,CAAC;YAC/C,KAAK,MAAM,KAAK,IAAI,MAAM,EAAE;gBAC1B,MAAM,CAAC,KAAK,CAAC,IAAI,KAAK,CAAC,IAAI,GAAG,CAAC,CAAC;gBAChC,MAAM,CAAC,KAAK,CAAC,OAAO,CAAC,GAAG,CAAC,aAAa,CAAC,CAAC,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC,CAAC,MAAM,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,CAAC;gBAC1E,MAAM,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;aACpB;SACF;QACD,IAAI,KAAK,EAAE;YACT,KAAK,MAAM,EAAE,IAAI,EAAE,IAAI,OAAO,CAAC,MAAM,CAAC,eAAK,CAAC,EAAE;gBAC5C,IAAA,cAAS,EAAC,IAAI,EAAE,GAAG,EAAE,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC,CAAC;aACnC;SACF;QACD,MAAM,UAAU,CAAC,IAAI,EAAE,CAAC;KACzB;YAAS;QACR,IAAI,CAAC,KAAK,EAAE;YACV,MAAM,EAAE,CAAC,GAAG,EAAE,CAAC;SAChB;KACF;AACH,CAAC,CAAC,CAAC;AAjEM,QAAA,OAAO,WAiEb"}

package.json

 {
   "name": "@potygen/cli",
-  "version": "0.8.2",
+  "version": "0.9.0",
   "homepage": "https://github.com/ivank/potygen/tree/main/packages/cli",
@@ -23,2 +23,3 @@ "description": "Command line interface for potygen (Postgres Typescript Generator)",
     "@potygen/potygen": "0.7.1",
+    "@supercharge/promise-pool": "^2.3.2",
     "@types/pg": "^8.6.0",
@@ -25,0 +26,0 @@ "commander": "^8.3.0",

dist/cache.d.ts

-export declare class CacheStore {
-    fileName: string;
-    enabled: boolean;
-    cacheClear: boolean;
-    store: Map<string, number>;
-    constructor(fileName: string, enabled?: boolean, cacheClear?: boolean);
-    shouldParseFile(path: string): boolean;
-    cacheFile(path: string): void;
-    save(): void;
-}

dist/cache.js

-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.CacheStore = void 0;
-const fs_1 = require("fs");
-const path_1 = require("path");
-class CacheStore {
-    constructor(fileName, enabled = false, cacheClear = false) {
-        this.fileName = fileName;
-        this.enabled = enabled;
-        this.cacheClear = cacheClear;
-        this.store = new Map();
-        if (this.enabled && !this.cacheClear) {
-            if ((0, fs_1.existsSync)(fileName)) {
-                this.store = new Map(Object.entries(JSON.parse((0, fs_1.readFileSync)(fileName, 'utf-8'))));
-            }
-        }
-    }
-    shouldParseFile(path) {
-        if (!this.enabled) {
-            return true;
-        }
-        else {
-            const mtime = (0, fs_1.statSync)(path).mtime.getTime();
-            const currentMtime = this.store.get(path);
-            if (currentMtime && mtime === currentMtime) {
-                return false;
-            }
-        }
-        return true;
-    }
-    cacheFile(path) {
-        const mtime = (0, fs_1.statSync)(path).mtime.getTime();
-        this.store.set(path, mtime);
-    }
-    save() {
-        if (this.enabled) {
-            (0, fs_1.mkdirSync)((0, path_1.dirname)(this.fileName), { recursive: true });
-            (0, fs_1.writeFileSync)(this.fileName, JSON.stringify(Object.fromEntries(this.store)), 'utf-8');
-        }
-    }
-}
-exports.CacheStore = CacheStore;
-//# sourceMappingURL=cache.js.map

dist/cache.js.map

-{"version":3,"file":"cache.js","sourceRoot":"","sources":["../src/cache.ts"],"names":[],"mappings":";;;AAAA,2BAAkF;AAClF,+BAA+B;AAE/B,MAAa,UAAU;IAGrB,YAAmB,QAAgB,EAAS,UAAmB,KAAK,EAAS,aAAsB,KAAK;QAArF,aAAQ,GAAR,QAAQ,CAAQ;QAAS,YAAO,GAAP,OAAO,CAAiB;QAAS,eAAU,GAAV,UAAU,CAAiB;QAFjG,UAAK,GAAG,IAAI,GAAG,EAAkB,CAAC;QAGvC,IAAI,IAAI,CAAC,OAAO,IAAI,CAAC,IAAI,CAAC,UAAU,EAAE;YACpC,IAAI,IAAA,eAAU,EAAC,QAAQ,CAAC,EAAE;gBACxB,IAAI,CAAC,KAAK,GAAG,IAAI,GAAG,CAAC,MAAM,CAAC,OAAO,CAAC,IAAI,CAAC,KAAK,CAAC,IAAA,iBAAY,EAAC,QAAQ,EAAE,OAAO,CAAC,CAAC,CAAC,CAAC,CAAC;aACnF;SACF;IACH,CAAC;IAEM,eAAe,CAAC,IAAY;QACjC,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE;YACjB,OAAO,IAAI,CAAC;SACb;aAAM;YACL,MAAM,KAAK,GAAG,IAAA,aAAQ,EAAC,IAAI,CAAC,CAAC,KAAK,CAAC,OAAO,EAAE,CAAC;YAC7C,MAAM,YAAY,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC;YAC1C,IAAI,YAAY,IAAI,KAAK,KAAK,YAAY,EAAE;gBAC1C,OAAO,KAAK,CAAC;aACd;SACF;QACD,OAAO,IAAI,CAAC;IACd,CAAC;IAEM,SAAS,CAAC,IAAY;QAC3B,MAAM,KAAK,GAAG,IAAA,aAAQ,EAAC,IAAI,CAAC,CAAC,KAAK,CAAC,OAAO,EAAE,CAAC;QAC7C,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,IAAI,EAAE,KAAK,CAAC,CAAC;IAC9B,CAAC;IAEM,IAAI;QACT,IAAI,IAAI,CAAC,OAAO,EAAE;YAChB,IAAA,cAAS,EAAC,IAAA,cAAO,EAAC,IAAI,CAAC,QAAQ,CAAC,EAAE,EAAE,SAAS,EAAE,IAAI,EAAE,CAAC,CAAC;YACvD,IAAA,kBAAa,EAAC,IAAI,CAAC,QAAQ,EAAE,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,WAAW,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC,EAAE,OAAO,CAAC,CAAC;SACvF;IACH,CAAC;CACF;AAnCD,gCAmCC"}

dist/emit.d.ts

-import { SourceFile } from 'typescript';
-import { LoadedFile, Type } from '@potygen/potygen';
-import { CacheStore } from './cache';
-export declare const compactTypes: (types: Type[]) => Type[];
-export declare const toTypeSource: (file: LoadedFile, typePrefix?: string) => SourceFile;
-export declare const emitLoadedFile: (root: string, template: string, cacheStore: CacheStore, typePrefix?: string) => (file: LoadedFile) => Promise<void>;

dist/emit.js

-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.emitLoadedFile = exports.toTypeSource = exports.compactTypes = void 0;
-const fs_1 = require("fs");
-const util_1 = require("util");
-const path_1 = require("path");
-const typescript_1 = require("typescript");
-const potygen_1 = require("@potygen/potygen");
-const mkdirAsync = (0, util_1.promisify)(fs_1.mkdir);
-const writeFileAsync = (0, util_1.promisify)(fs_1.writeFile);
-const isIdentifierRegExp = /^[$A-Z_][0-9A-Z_$]*$/i;
-const parseTemplate = (root, template, path) => Object.entries({ ...(0, path_1.parse)((0, path_1.relative)(root, path)), root }).reduce((acc, [name, value]) => acc.replace(`{{${name}}}`, value), template);
-const jsDoc = (doc) => `*\n${doc
-    .split('\n')
-    .map((line) => ` * ${line}`)
-    .join('\n')}\n `;
-const withJSDoc = (doc, node) => doc === undefined ? node : (0, typescript_1.addSyntheticLeadingComment)(node, typescript_1.SyntaxKind.MultiLineCommentTrivia, jsDoc(doc), true);
-const compactTypes = (types) => types
-    .map((type) => ((0, potygen_1.isTypeOptional)(type) ? { ...type.value, nullable: type.nullable } : type))
-    .filter((item, index, all) => (0, potygen_1.isTypeLiteral)(item) && item.literal !== undefined
-    ? !all.some((other, otherIndex) => index !== otherIndex && other.type === item.type && other.literal === undefined)
-    : true)
-    .filter((0, potygen_1.isUniqueBy)(potygen_1.isTypeEqual));
-exports.compactTypes = compactTypes;
-const toPropertyType = (context) => (type) => {
-    if ((0, potygen_1.isTypeComposite)(type)) {
-        return { ...context, type: typescript_1.factory.createToken(typescript_1.SyntaxKind.StringKeyword) };
-    }
-    else if ((0, potygen_1.isTypeObjectLiteral)(type)) {
-        return type.items.reduce((acc, item) => {
-            const itemType = toPropertyType({ ...acc, name: context.name + toClassCase(item.name) })(item.type);
-            const memeber = typescript_1.factory.createPropertySignature(undefined, item.name.includes(' ')
-                ? typescript_1.factory.createComputedPropertyName(typescript_1.factory.createStringLiteral(item.name))
-                : item.name, 'nullable' in item.type && item.type.nullable ? typescript_1.factory.createToken(typescript_1.SyntaxKind.QuestionToken) : undefined, itemType.type);
-            return { ...itemType, type: typescript_1.factory.createTypeLiteralNode(acc.type.members.concat(memeber)) };
-        }, { ...context, type: typescript_1.factory.createTypeLiteralNode([]) });
-    }
-    else if ((0, potygen_1.isTypeArray)(type)) {
-        const itemsType = toPropertyType(context)(type.items);
-        return { ...itemsType, type: typescript_1.factory.createArrayTypeNode(itemsType.type) };
-    }
-    else if ((0, potygen_1.isTypeUnion)(type)) {
-        const unionTypes = (0, exports.compactTypes)(type.items);
-        return (0, potygen_1.isEmpty)(unionTypes)
-            ? { ...context, type: typescript_1.factory.createToken(typescript_1.SyntaxKind.UnknownKeyword) }
-            : unionTypes.reduce((acc, item, index) => {
-                const itemType = toPropertyType({ ...acc, name: context.name + index })(item);
-                return { ...itemType, type: typescript_1.factory.createUnionTypeNode(acc.type.types.concat(itemType.type)) };
-            }, { ...context, type: typescript_1.factory.createUnionTypeNode([]) });
-    }
-    else if ((0, potygen_1.isTypeOptional)(type)) {
-        return type.value
-            ? toPropertyType(context)(type.value)
-            : { ...context, type: typescript_1.factory.createToken(typescript_1.SyntaxKind.UnknownKeyword) };
-    }
-    else {
-        switch (type.type) {
-            case 6 /* TypeName.Date */:
-                return { ...context, type: typescript_1.factory.createTypeReferenceNode('Date') };
-            case 0 /* TypeName.Buffer */:
-                return { ...context, type: typescript_1.factory.createTypeReferenceNode('Buffer') };
-            case 5 /* TypeName.Boolean */:
-                return {
-                    ...context,
-                    type: type.literal !== undefined
-                        ? typescript_1.factory.createLiteralTypeNode(type.literal ? typescript_1.factory.createTrue() : typescript_1.factory.createFalse())
-                        : typescript_1.factory.createToken(typescript_1.SyntaxKind.BooleanKeyword),
-                };
-            case 8 /* TypeName.Json */:
-                return {
-                    ...context,
-                    refs: context.refs.concat(context.name),
-                    type: context.toJson
-                        ? typescript_1.factory.createTypeReferenceNode('Json', [typescript_1.factory.createTypeReferenceNode(context.name)])
-                        : typescript_1.factory.createTypeReferenceNode(context.name),
-                };
-            case 7 /* TypeName.Null */:
-                return { ...context, type: typescript_1.factory.createToken(typescript_1.SyntaxKind.UndefinedKeyword) };
-            case 3 /* TypeName.Number */:
-            case 4 /* TypeName.BigInt */:
-                return {
-                    ...context,
-                    type: type.literal !== undefined
-                        ? typescript_1.factory.createLiteralTypeNode(typescript_1.factory.createStringLiteral(String(type.literal)))
-                        : typescript_1.factory.createToken(typescript_1.SyntaxKind.NumberKeyword),
-                };
-            case 2 /* TypeName.String */:
-                return {
-                    ...context,
-                    type: type.literal !== undefined
-                        ? typescript_1.factory.createLiteralTypeNode(typescript_1.factory.createStringLiteral(type.literal))
-                        : typescript_1.factory.createToken(typescript_1.SyntaxKind.StringKeyword),
-                };
-            case 9 /* TypeName.Unknown */:
-                return { ...context, type: typescript_1.factory.createToken(typescript_1.SyntaxKind.UnknownKeyword) };
-            case 1 /* TypeName.Any */:
-                return { ...context, type: typescript_1.factory.createToken(typescript_1.SyntaxKind.AnyKeyword) };
-        }
-    }
-};
-const toClassCase = (identifier) => identifier[0].toUpperCase() + identifier.slice(1);
-const toAstImports = (names) => typescript_1.factory.createImportDeclaration(undefined, undefined, typescript_1.factory.createImportClause(false, undefined, typescript_1.factory.createNamedImports(names.map((name) => typescript_1.factory.createImportSpecifier(false, undefined, typescript_1.factory.createIdentifier(name))))), typescript_1.factory.createStringLiteral('@potygen/potygen'));
-const toLoadedQueryTypeNodes = (refs, name, loadedQuery) => {
-    const params = loadedQuery.params.reduce((acc, item) => {
-        const itemType = toPropertyType({ toJson: false, name: 'TParam' + toClassCase(item.name), refs: acc.refs })(item.type);
-        const prop = typescript_1.factory.createPropertySignature(undefined, item.name, 'nullable' in item.type && item.type.nullable ? typescript_1.factory.createToken(typescript_1.SyntaxKind.QuestionToken) : undefined, itemType.type);
-        return { ...itemType, props: acc.props.concat(prop) };
-    }, { refs, props: [] });
-    const results = loadedQuery.results.reduce((acc, item) => {
-        const itemType = toPropertyType({ toJson: true, name: 'T' + toClassCase(item.name), refs: acc.refs })(item.type);
-        const prop = withJSDoc(item.type.comment ?? undefined, typescript_1.factory.createPropertySignature(undefined, isIdentifierRegExp.test(item.name) ? item.name : typescript_1.factory.createStringLiteral(item.name), 'nullable' in item.type && item.type.nullable ? typescript_1.factory.createToken(typescript_1.SyntaxKind.QuestionToken) : undefined, itemType.type));
-        return { ...itemType, props: acc.props.concat(prop) };
-    }, { refs: [], props: [] });
-    return {
-        resultRefs: results.refs,
-        statements: [
-            typescript_1.factory.createInterfaceDeclaration([typescript_1.factory.createModifier(typescript_1.SyntaxKind.ExportKeyword)], `${name}Params`, params.refs.map((ref) => typescript_1.factory.createTypeParameterDeclaration([], ref, undefined, typescript_1.factory.createToken(typescript_1.SyntaxKind.UnknownKeyword))), undefined, params.props),
-            typescript_1.factory.createInterfaceDeclaration([typescript_1.factory.createModifier(typescript_1.SyntaxKind.ExportKeyword)], `${name}Result`, results.refs.map((ref) => typescript_1.factory.createTypeParameterDeclaration([], ref, undefined, typescript_1.factory.createToken(typescript_1.SyntaxKind.UnknownKeyword))), undefined, results.props),
-            typescript_1.factory.createInterfaceDeclaration([typescript_1.factory.createModifier(typescript_1.SyntaxKind.ExportKeyword)], `${name}Query`, [...params.refs, ...results.refs].map((ref) => typescript_1.factory.createTypeParameterDeclaration([], ref, undefined, typescript_1.factory.createToken(typescript_1.SyntaxKind.UnknownKeyword))), undefined, [
-                typescript_1.factory.createPropertySignature(undefined, 'params', undefined, typescript_1.factory.createTypeReferenceNode(`${name}Params`, params.refs.map((ref) => typescript_1.factory.createTypeReferenceNode(ref)))),
-                typescript_1.factory.createPropertySignature(undefined, 'result', undefined, typescript_1.factory.createArrayTypeNode(typescript_1.factory.createTypeReferenceNode(`${name}Result`, results.refs.map((ref) => typescript_1.factory.createTypeReferenceNode(ref))))),
-            ]),
-        ],
-    };
-};
-const toTypeSource = (file, typePrefix = '') => {
-    const content = file.type === 'ts'
-        ? file.queries.reduce((acc, query) => {
-            const { statements, resultRefs } = toLoadedQueryTypeNodes(acc.resultRefs, typePrefix + toClassCase(query.name), query.loadedQuery);
-            return { resultRefs, statements: acc.statements.concat(statements) };
-        }, { resultRefs: [], statements: [] })
-        : toLoadedQueryTypeNodes([], typePrefix, file.loadedQuery);
-    return typescript_1.factory.updateSourceFile((0, typescript_1.createSourceFile)(file.path, '', typescript_1.ScriptTarget.ES2021, true), content.resultRefs.length > 0 ? [toAstImports(['Json']), ...content.statements] : content.statements);
-};
-exports.toTypeSource = toTypeSource;
-const emitLoadedFile = (root, template, cacheStore, typePrefix) => {
-    const printer = (0, typescript_1.createPrinter)({ newLine: typescript_1.NewLineKind.LineFeed });
-    return async (file) => {
-        const outputFile = parseTemplate(root, template, file.path);
-        const directory = (0, path_1.dirname)(outputFile);
-        await mkdirAsync(directory, { recursive: true });
-        await writeFileAsync(outputFile, printer.printFile((0, exports.toTypeSource)(file, typePrefix)));
-        cacheStore.cacheFile(file.path);
-    };
-};
-exports.emitLoadedFile = emitLoadedFile;
-//# sourceMappingURL=emit.js.map

dist/emit.js.map

-{"version":3,"file":"emit.js","sourceRoot":"","sources":["../src/emit.ts"],"names":[],"mappings":";;;AAAA,2BAAsC;AACtC,+BAAiC;AACjC,+BAAgD;AAChD,2CAeoB;AACpB,8CAc0B;AAG1B,MAAM,UAAU,GAAG,IAAA,gBAAS,EAAC,UAAK,CAAC,CAAC;AACpC,MAAM,cAAc,GAAG,IAAA,gBAAS,EAAC,cAAS,CAAC,CAAC;AAE5C,MAAM,kBAAkB,GAAG,uBAAuB,CAAC;AAEnD,MAAM,aAAa,GAAG,CAAC,IAAY,EAAE,QAAgB,EAAE,IAAY,EAAU,EAAE,CAC7E,MAAM,CAAC,OAAO,CAAC,EAAE,GAAG,IAAA,YAAK,EAAC,IAAA,eAAQ,EAAC,IAAI,EAAE,IAAI,CAAC,CAAC,EAAE,IAAI,EAAE,CAAC,CAAC,MAAM,CAC7D,CAAC,GAAG,EAAE,CAAC,IAAI,EAAE,KAAK,CAAC,EAAE,EAAE,CAAC,GAAG,CAAC,OAAO,CAAC,KAAK,IAAI,IAAI,EAAE,KAAK,CAAC,EACzD,QAAQ,CACT,CAAC;AAUJ,MAAM,KAAK,GAAG,CAAC,GAAW,EAAU,EAAE,CACpC,MAAM,GAAG;KACN,KAAK,CAAC,IAAI,CAAC;KACX,GAAG,CAAC,CAAC,IAAI,EAAE,EAAE,CAAC,MAAM,IAAI,EAAE,CAAC;KAC3B,IAAI,CAAC,IAAI,CAAC,KAAK,CAAC;AAErB,MAAM,SAAS,GAAG,CAAiB,GAAuB,EAAE,IAAO,EAAK,EAAE,CACxE,GAAG,KAAK,SAAS,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,IAAA,uCAA0B,EAAC,IAAI,EAAE,uBAAU,CAAC,sBAAsB,EAAE,KAAK,CAAC,GAAG,CAAC,EAAE,IAAI,CAAC,CAAC;AAE5G,MAAM,YAAY,GAAG,CAAC,KAAa,EAAU,EAAE,CACpD,KAAK;KACF,GAAG,CAAC,CAAC,IAAI,EAAE,EAAE,CAAC,CAAC,IAAA,wBAAc,EAAC,IAAI,CAAC,CAAC,CAAC,CAAC,EAAE,GAAG,IAAI,CAAC,KAAK,EAAE,QAAQ,EAAE,IAAI,CAAC,QAAQ,EAAE,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC;KACzF,MAAM,CAAC,CAAC,IAAI,EAAE,KAAK,EAAE,GAAG,EAAE,EAAE,CAC3B,IAAA,uBAAa,EAAC,IAAI,CAAC,IAAI,IAAI,CAAC,OAAO,KAAK,SAAS;IAC/C,CAAC,CAAC,CAAC,GAAG,CAAC,IAAI,CACP,CAAC,KAAK,EAAE,UAAU,EAAE,EAAE,CAAC,KAAK,KAAK,UAAU,IAAI,KAAK,CAAC,IAAI,KAAK,IAAI,CAAC,IAAI,IAAI,KAAK,CAAC,OAAO,KAAK,SAAS,CACvG;IACH,CAAC,CAAC,IAAI,CACT;KACA,MAAM,CAAC,IAAA,oBAAU,EAAC,qBAAW,CAAC,CAAC,CAAC;AAVxB,QAAA,YAAY,gBAUY;AAErC,MAAM,cAAc,GAClB,CAAC,OAAoB,EAAE,EAAE,CACzB,CAAC,IAAU,EAAoC,EAAE;IAC/C,IAAI,IAAA,yBAAe,EAAC,IAAI,CAAC,EAAE;QACzB,OAAO,EAAE,GAAG,OAAO,EAAE,IAAI,EAAE,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,aAAa,CAAC,EAAE,CAAC;KAC5E;SAAM,IAAI,IAAA,6BAAmB,EAAC,IAAI,CAAC,EAAE;QACpC,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,CACtB,CAAC,GAAG,EAAE,IAAI,EAAE,EAAE;YACZ,MAAM,QAAQ,GAAG,cAAc,CAAC,EAAE,GAAG,GAAG,EAAE,IAAI,EAAE,OAAO,CAAC,IAAI,GAAG,WAAW,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;YACpG,MAAM,OAAO,GAAG,oBAAO,CAAC,uBAAuB,CAC7C,SAAS,EACT,IAAI,CAAC,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC;gBACrB,CAAC,CAAC,oBAAO,CAAC,0BAA0B,CAAC,oBAAO,CAAC,mBAAmB,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;gBAC5E,CAAC,CAAC,IAAI,CAAC,IAAI,EACb,UAAU,IAAI,IAAI,CAAC,IAAI,IAAI,IAAI,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC,CAAC,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,aAAa,CAAC,CAAC,CAAC,CAAC,SAAS,EACzG,QAAQ,CAAC,IAAI,CACd,CAAC;YACF,OAAO,EAAE,GAAG,QAAQ,EAAE,IAAI,EAAE,oBAAO,CAAC,qBAAqB,CAAC,GAAG,CAAC,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC,EAAE,CAAC;QAChG,CAAC,EACD,EAAE,GAAG,OAAO,EAAE,IAAI,EAAE,oBAAO,CAAC,qBAAqB,CAAC,EAAE,CAAC,EAAE,CACxD,CAAC;KACH;SAAM,IAAI,IAAA,qBAAW,EAAC,IAAI,CAAC,EAAE;QAC5B,MAAM,SAAS,GAAG,cAAc,CAAC,OAAO,CAAC,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC;QACtD,OAAO,EAAE,GAAG,SAAS,EAAE,IAAI,EAAE,oBAAO,CAAC,mBAAmB,CAAC,SAAS,CAAC,IAAI,CAAC,EAAE,CAAC;KAC5E;SAAM,IAAI,IAAA,qBAAW,EAAC,IAAI,CAAC,EAAE;QAC5B,MAAM,UAAU,GAAG,IAAA,oBAAY,EAAC,IAAI,CAAC,KAAK,CAAC,CAAC;QAC5C,OAAO,IAAA,iBAAO,EAAC,UAAU,CAAC;YACxB,CAAC,CAAC,EAAE,GAAG,OAAO,EAAE,IAAI,EAAE,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,cAAc,CAAC,EAAE;YACtE,CAAC,CAAC,UAAU,CAAC,MAAM,CACf,CAAC,GAAG,EAAE,IAAI,EAAE,KAAK,EAAE,EAAE;gBACnB,MAAM,QAAQ,GAAG,cAAc,CAAC,EAAE,GAAG,GAAG,EAAE,IAAI,EAAE,OAAO,CAAC,IAAI,GAAG,KAAK,EAAE,CAAC,CAAC,IAAI,CAAC,CAAC;gBAC9E,OAAO,EAAE,GAAG,QAAQ,EAAE,IAAI,EAAE,oBAAO,CAAC,mBAAmB,CAAC,GAAG,CAAC,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,QAAQ,CAAC,IAAI,CAAC,CAAC,EAAE,CAAC;YAClG,CAAC,EACD,EAAE,GAAG,OAAO,EAAE,IAAI,EAAE,oBAAO,CAAC,mBAAmB,CAAC,EAAE,CAAC,EAAE,CACtD,CAAC;KACP;SAAM,IAAI,IAAA,wBAAc,EAAC,IAAI,CAAC,EAAE;QAC/B,OAAO,IAAI,CAAC,KAAK;YACf,CAAC,CAAC,cAAc,CAAC,OAAO,CAAC,CAAC,IAAI,CAAC,KAAK,CAAC;YACrC,CAAC,CAAC,EAAE,GAAG,OAAO,EAAE,IAAI,EAAE,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,cAAc,CAAC,EAAE,CAAC;KAC1E;SAAM;QACL,QAAQ,IAAI,CAAC,IAAI,EAAE;YACjB;gBACE,OAAO,EAAE,GAAG,OAAO,EAAE,IAAI,EAAE,oBAAO,CAAC,uBAAuB,CAAC,MAAM,CAAC,EAAE,CAAC;YACvE;gBACE,OAAO,EAAE,GAAG,OAAO,EAAE,IAAI,EAAE,oBAAO,CAAC,uBAAuB,CAAC,QAAQ,CAAC,EAAE,CAAC;YACzE;gBACE,OAAO;oBACL,GAAG,OAAO;oBACV,IAAI,EACF,IAAI,CAAC,OAAO,KAAK,SAAS;wBACxB,CAAC,CAAC,oBAAO,CAAC,qBAAqB,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC,CAAC,oBAAO,CAAC,UAAU,EAAE,CAAC,CAAC,CAAC,oBAAO,CAAC,WAAW,EAAE,CAAC;wBAC5F,CAAC,CAAC,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,cAAc,CAAC;iBACrD,CAAC;YACJ;gBACE,OAAO;oBACL,GAAG,OAAO;oBACV,IAAI,EAAE,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,IAAI,CAAC;oBACvC,IAAI,EAAE,OAAO,CAAC,MAAM;wBAClB,CAAC,CAAC,oBAAO,CAAC,uBAAuB,CAAC,MAAM,EAAE,CAAC,oBAAO,CAAC,uBAAuB,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC;wBAC1F,CAAC,CAAC,oBAAO,CAAC,uBAAuB,CAAC,OAAO,CAAC,IAAI,CAAC;iBAClD,CAAC;YACJ;gBACE,OAAO,EAAE,GAAG,OAAO,EAAE,IAAI,EAAE,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,gBAAgB,CAAC,EAAE,CAAC;YAChF,6BAAqB;YACrB;gBACE,OAAO;oBACL,GAAG,OAAO;oBACV,IAAI,EACF,IAAI,CAAC,OAAO,KAAK,SAAS;wBACxB,CAAC,CAAC,oBAAO,CAAC,qBAAqB,CAAC,oBAAO,CAAC,mBAAmB,CAAC,MAAM,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC,CAAC;wBAClF,CAAC,CAAC,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,aAAa,CAAC;iBACpD,CAAC;YACJ;gBACE,OAAO;oBACL,GAAG,OAAO;oBACV,IAAI,EACF,IAAI,CAAC,OAAO,KAAK,SAAS;wBACxB,CAAC,CAAC,oBAAO,CAAC,qBAAqB,CAAC,oBAAO,CAAC,mBAAmB,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;wBAC1E,CAAC,CAAC,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,aAAa,CAAC;iBACpD,CAAC;YACJ;gBACE,OAAO,EAAE,GAAG,OAAO,EAAE,IAAI,EAAE,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,cAAc,CAAC,EAAE,CAAC;YAC9E;gBACE,OAAO,EAAE,GAAG,OAAO,EAAE,IAAI,EAAE,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,UAAU,CAAC,EAAE,CAAC;SAC3E;KACF;AACH,CAAC,CAAC;AAEJ,MAAM,WAAW,GAAG,CAAC,UAAkB,EAAE,EAAE,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC,WAAW,EAAE,GAAG,UAAU,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;AAE9F,MAAM,YAAY,GAAG,CAAC,KAAe,EAAa,EAAE,CAClD,oBAAO,CAAC,uBAAuB,CAC7B,SAAS,EACT,SAAS,EACT,oBAAO,CAAC,kBAAkB,CACxB,KAAK,EACL,SAAS,EACT,oBAAO,CAAC,kBAAkB,CACxB,KAAK,CAAC,GAAG,CAAC,CAAC,IAAI,EAAE,EAAE,CAAC,oBAAO,CAAC,qBAAqB,CAAC,KAAK,EAAE,SAAS,EAAE,oBAAO,CAAC,gBAAgB,CAAC,IAAI,CAAC,CAAC,CAAC,CACrG,CACF,EACD,oBAAO,CAAC,mBAAmB,CAAC,kBAAkB,CAAC,CAChD,CAAC;AAEJ,MAAM,sBAAsB,GAAG,CAC7B,IAAU,EACV,IAAY,EACZ,WAAiC,EACc,EAAE;IACjD,MAAM,MAAM,GAAG,WAAW,CAAC,MAAM,CAAC,MAAM,CACtC,CAAC,GAAG,EAAE,IAAI,EAAE,EAAE;QACZ,MAAM,QAAQ,GAAG,cAAc,CAAC,EAAE,MAAM,EAAE,KAAK,EAAE,IAAI,EAAE,QAAQ,GAAG,WAAW,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,IAAI,EAAE,CAAC,CACzG,IAAI,CAAC,IAAI,CACV,CAAC;QACF,MAAM,IAAI,GAAG,oBAAO,CAAC,uBAAuB,CAC1C,SAAS,EACT,IAAI,CAAC,IAAI,EACT,UAAU,IAAI,IAAI,CAAC,IAAI,IAAI,IAAI,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC,CAAC,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,aAAa,CAAC,CAAC,CAAC,CAAC,SAAS,EACzG,QAAQ,CAAC,IAAI,CACd,CAAC;QACF,OAAO,EAAE,GAAG,QAAQ,EAAE,KAAK,EAAE,GAAG,CAAC,KAAK,CAAC,MAAM,CAAC,IAAI,CAAC,EAAE,CAAC;IACxD,CAAC,EACD,EAAE,IAAI,EAAE,KAAK,EAAE,EAAE,EAAE,CACpB,CAAC;IAEF,MAAM,OAAO,GAAG,WAAW,CAAC,OAAO,CAAC,MAAM,CACxC,CAAC,GAAG,EAAE,IAAI,EAAE,EAAE;QACZ,MAAM,QAAQ,GAAG,cAAc,CAAC,EAAE,MAAM,EAAE,IAAI,EAAE,IAAI,EAAE,GAAG,GAAG,WAAW,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,IAAI,EAAE,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;QACjH,MAAM,IAAI,GAAG,SAAS,CACpB,IAAI,CAAC,IAAI,CAAC,OAAO,IAAI,SAAS,EAC9B,oBAAO,CAAC,uBAAuB,CAC7B,SAAS,EACT,kBAAkB,CAAC,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC,CAAC,oBAAO,CAAC,mBAAmB,CAAC,IAAI,CAAC,IAAI,CAAC,EACvF,UAAU,IAAI,IAAI,CAAC,IAAI,IAAI,IAAI,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC,CAAC,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,aAAa,CAAC,CAAC,CAAC,CAAC,SAAS,EACzG,QAAQ,CAAC,IAAI,CACd,CACF,CAAC;QACF,OAAO,EAAE,GAAG,QAAQ,EAAE,KAAK,EAAE,GAAG,CAAC,KAAK,CAAC,MAAM,CAAC,IAAI,CAAC,EAAE,CAAC;IACxD,CAAC,EACD,EAAE,IAAI,EAAE,EAAE,EAAE,KAAK,EAAE,EAAE,EAAE,CACxB,CAAC;IAEF,OAAO;QACL,UAAU,EAAE,OAAO,CAAC,IAAI;QACxB,UAAU,EAAE;YACV,oBAAO,CAAC,0BAA0B,CAChC,CAAC,oBAAO,CAAC,cAAc,CAAC,uBAAU,CAAC,aAAa,CAAC,CAAC,EAClD,GAAG,IAAI,QAAQ,EACf,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CACtB,oBAAO,CAAC,8BAA8B,CAAC,EAAE,EAAE,GAAG,EAAE,SAAS,EAAE,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,cAAc,CAAC,CAAC,CAC3G,EACD,SAAS,EACT,MAAM,CAAC,KAAK,CACb;YACD,oBAAO,CAAC,0BAA0B,CAChC,CAAC,oBAAO,CAAC,cAAc,CAAC,uBAAU,CAAC,aAAa,CAAC,CAAC,EAClD,GAAG,IAAI,QAAQ,EACf,OAAO,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CACvB,oBAAO,CAAC,8BAA8B,CAAC,EAAE,EAAE,GAAG,EAAE,SAAS,EAAE,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,cAAc,CAAC,CAAC,CAC3G,EACD,SAAS,EACT,OAAO,CAAC,KAAK,CACd;YACD,oBAAO,CAAC,0BAA0B,CAChC,CAAC,oBAAO,CAAC,cAAc,CAAC,uBAAU,CAAC,aAAa,CAAC,CAAC,EAClD,GAAG,IAAI,OAAO,EACd,CAAC,GAAG,MAAM,CAAC,IAAI,EAAE,GAAG,OAAO,CAAC,IAAI,CAAC,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CAC5C,oBAAO,CAAC,8BAA8B,CAAC,EAAE,EAAE,GAAG,EAAE,SAAS,EAAE,oBAAO,CAAC,WAAW,CAAC,uBAAU,CAAC,cAAc,CAAC,CAAC,CAC3G,EACD,SAAS,EACT;gBACE,oBAAO,CAAC,uBAAuB,CAC7B,SAAS,EACT,QAAQ,EACR,SAAS,EACT,oBAAO,CAAC,uBAAuB,CAC7B,GAAG,IAAI,QAAQ,EACf,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,oBAAO,CAAC,uBAAuB,CAAC,GAAG,CAAC,CAAC,CAC/D,CACF;gBACD,oBAAO,CAAC,uBAAuB,CAC7B,SAAS,EACT,QAAQ,EACR,SAAS,EACT,oBAAO,CAAC,mBAAmB,CACzB,oBAAO,CAAC,uBAAuB,CAC7B,GAAG,IAAI,QAAQ,EACf,OAAO,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,oBAAO,CAAC,uBAAuB,CAAC,GAAG,CAAC,CAAC,CAChE,CACF,CACF;aACF,CACF;SACF;KACF,CAAC;AACJ,CAAC,CAAC;AAEK,MAAM,YAAY,GAAG,CAAC,IAAgB,EAAE,aAAqB,EAAE,EAAc,EAAE;IACpF,MAAM,OAAO,GACX,IAAI,CAAC,IAAI,KAAK,IAAI;QAChB,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,MAAM,CACjB,CAAC,GAAG,EAAE,KAAK,EAAE,EAAE;YACb,MAAM,EAAE,UAAU,EAAE,UAAU,EAAE,GAAG,sBAAsB,CACvD,GAAG,CAAC,UAAU,EACd,UAAU,GAAG,WAAW,CAAC,KAAK,CAAC,IAAI,CAAC,EACpC,KAAK,CAAC,WAAW,CAClB,CAAC;YACF,OAAO,EAAE,UAAU,EAAE,UAAU,EAAE,GAAG,CAAC,UAAU,CAAC,MAAM,CAAC,UAAU,CAAC,EAAE,CAAC;QACvE,CAAC,EACD,EAAE,UAAU,EAAE,EAAE,EAAE,UAAU,EAAE,EAAE,EAAE,CACnC;QACH,CAAC,CAAC,sBAAsB,CAAC,EAAE,EAAE,UAAU,EAAE,IAAI,CAAC,WAAW,CAAC,CAAC;IAE/D,OAAO,oBAAO,CAAC,gBAAgB,CAC7B,IAAA,6BAAgB,EAAC,IAAI,CAAC,IAAI,EAAE,EAAE,EAAE,yBAAY,CAAC,MAAM,EAAE,IAAI,CAAC,EAC1D,OAAO,CAAC,UAAU,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC,CAAC,CAAC,YAAY,CAAC,CAAC,MAAM,CAAC,CAAC,EAAE,GAAG,OAAO,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC,OAAO,CAAC,UAAU,CACrG,CAAC;AACJ,CAAC,CAAC;AApBW,QAAA,YAAY,gBAoBvB;AAEK,MAAM,cAAc,GAAG,CAAC,IAAY,EAAE,QAAgB,EAAE,UAAsB,EAAE,UAAmB,EAAE,EAAE;IAC5G,MAAM,OAAO,GAAG,IAAA,0BAAa,EAAC,EAAE,OAAO,EAAE,wBAAW,CAAC,QAAQ,EAAE,CAAC,CAAC;IACjE,OAAO,KAAK,EAAE,IAAgB,EAAiB,EAAE;QAC/C,MAAM,UAAU,GAAG,aAAa,CAAC,IAAI,EAAE,QAAQ,EAAE,IAAI,CAAC,IAAI,CAAC,CAAC;QAC5D,MAAM,SAAS,GAAG,IAAA,cAAO,EAAC,UAAU,CAAC,CAAC;QAEtC,MAAM,UAAU,CAAC,SAAS,EAAE,EAAE,SAAS,EAAE,IAAI,EAAE,CAAC,CAAC;QACjD,MAAM,cAAc,CAAC,UAAU,EAAE,OAAO,CAAC,SAAS,CAAC,IAAA,oBAAY,EAAC,IAAI,EAAE,UAAU,CAAC,CAAC,CAAC,CAAC;QACpF,UAAU,CAAC,SAAS,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;IAClC,CAAC,CAAC;AACJ,CAAC,CAAC;AAVW,QAAA,cAAc,kBAUzB"}

dist/traverse.d.ts

-/// <reference types="node" />
-/// <reference types="node" />
-import { Readable, Writable } from 'stream';
-import { LoadContext, LoadedData, Logger, ParsedFile, ParsedTypescriptFile } from '@potygen/potygen';
-import { ClientBase } from 'pg';
-import { CacheStore } from './cache';
-export declare class SqlRead extends Readable {
-    options: {
-        path: string;
-        root: string;
-        watch: boolean;
-        logger: Logger;
-        cacheStore: CacheStore;
-    };
-    source: Generator<string, void, unknown>;
-    watchedFiles: Set<string>;
-    constructor(options: {
-        path: string;
-        root: string;
-        watch: boolean;
-        logger: Logger;
-        cacheStore: CacheStore;
-    });
-    next(): ParsedFile | undefined;
-    watchFile(path: string): () => void;
-    _read(): void;
-}
-export declare class QueryLoader extends Writable {
-    options: {
-        db: ClientBase;
-        root: string;
-        template: string;
-        logger: Logger;
-        typePrefix?: string;
-        preload?: boolean;
-        cacheStore: CacheStore;
-    };
-    ctx: LoadContext;
-    data: LoadedData[];
-    constructor(options: {
-        db: ClientBase;
-        root: string;
-        template: string;
-        logger: Logger;
-        typePrefix?: string;
-        preload?: boolean;
-        cacheStore: CacheStore;
-    });
-    _writev(chunks: Array<{
-        chunk: ParsedFile;
-        encoding: BufferEncoding;
-    }>, callback: (error?: Error | null) => void): Promise<void>;
-    _write(file: ParsedTypescriptFile, encoding: BufferEncoding, callback: (error?: Error | null) => void): Promise<void>;
-}

dist/traverse.js

-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.QueryLoader = exports.SqlRead = void 0;
-const fs_1 = require("fs");
-const stream_1 = require("stream");
-const glob_1 = require("./glob");
-const typescript_1 = require("typescript");
-const path_1 = require("path");
-const potygen_1 = require("@potygen/potygen");
-const emit_1 = require("./emit");
-const util_1 = require("util");
-const toTemplateParent = (node) => (0, typescript_1.isCallExpression)(node.parent) ? toTemplateParent(node.parent) : node.parent;
-const getTemplateTagQueries = (ast) => {
-    const queries = [];
-    let tagPropertyName = 'sql';
-    const visitor = (node) => {
-        if ((0, typescript_1.isImportDeclaration)(node) &&
-            (0, typescript_1.isStringLiteral)(node.moduleSpecifier) &&
-            node.importClause?.namedBindings &&
-            (0, typescript_1.isNamedImports)(node.importClause.namedBindings) &&
-            node.moduleSpecifier.text === '@potygen/potygen') {
-            tagPropertyName =
-                node.importClause?.namedBindings.elements.find(({ propertyName, name }) => (propertyName ?? name).text === 'sql')?.name.text ?? tagPropertyName;
-        }
-        else if ((0, typescript_1.isTaggedTemplateExpression)(node) &&
-            (0, typescript_1.isNoSubstitutionTemplateLiteral)(node.template) &&
-            (0, typescript_1.isIdentifier)(node.tag) &&
-            node.tag.text === tagPropertyName) {
-            const tag = {
-                name: toTemplateParent(node).getChildAt(0).getText(),
-                pos: node.template.pos + 1,
-                template: node.template.text,
-            };
-            try {
-                queries.push({ ...tag, queryInterface: (0, potygen_1.toQueryInterface)((0, potygen_1.parser)(node.template.text).ast) });
-            }
-            catch (error) {
-                throw new potygen_1.ParseError(tag, `Error parsing sql: ${error instanceof Error ? error.message : String(error)}`);
-            }
-        }
-        else {
-            node.forEachChild(visitor);
-        }
-    };
-    visitor(ast);
-    return queries;
-};
-const toParsedTypescriptFile = (path) => {
-    const sourceText = (0, fs_1.readFileSync)(path, 'utf-8');
-    const source = (0, typescript_1.createSourceFile)((0, path_1.basename)(path), sourceText, typescript_1.ScriptTarget.ES2021, true);
-    return { type: 'ts', source, path, queries: getTemplateTagQueries(source) };
-};
-const toParsedSqlFile = (path) => {
-    const content = (0, fs_1.readFileSync)(path, 'utf-8');
-    return { type: 'sql', path, content, queryInterface: (0, potygen_1.toQueryInterface)((0, potygen_1.parser)(content).ast) };
-};
-const toQueryInterfaces = (files) => files.flatMap((file) => file.type === 'ts' ? file.queries.map((query) => query.queryInterface) : file.queryInterface);
-const loadDataFromParsedFiles = async (ctx, data, files) => (0, potygen_1.loadQueryInterfacesData)(ctx, toQueryInterfaces(files), data);
-const isError = (error) => error instanceof potygen_1.LoadError || error instanceof potygen_1.ParseError;
-const loadFile = (data) => (file) => {
-    if (file.type === 'sql') {
-        try {
-            return { ...file, loadedQuery: (0, potygen_1.toLoadedQueryInterface)(data)(file.queryInterface) };
-        }
-        catch (error) {
-            throw isError(error) ? new potygen_1.ParsedSqlFileLoadError(file, error) : error;
-        }
-    }
-    else {
-        return {
-            ...file,
-            queries: file.queries.map((template) => {
-                try {
-                    return { ...template, loadedQuery: (0, potygen_1.toLoadedQueryInterface)(data)(template.queryInterface) };
-                }
-                catch (error) {
-                    throw isError(error) ? new potygen_1.ParsedTypescriptFileLoadError(file, template, error) : error;
-                }
-            }),
-        };
-    }
-};
-const parseFile = (path) => {
-    if (path.endsWith('.ts')) {
-        const file = toParsedTypescriptFile(path);
-        return file.queries.length > 0 ? file : undefined;
-    }
-    else {
-        return toParsedSqlFile(path);
-    }
-};
-class SqlRead extends stream_1.Readable {
-    constructor(options) {
-        super({ objectMode: true });
-        this.options = options;
-        this.watchedFiles = new Set();
-        this.source = (0, glob_1.glob)(options.path, options.root);
-    }
-    next() {
-        let path;
-        while (!(path = this.source.next()).done) {
-            if (this.options.cacheStore.shouldParseFile(path.value)) {
-                const file = parseFile(path.value);
-                if (file) {
-                    return file;
-                }
-            }
-        }
-        return undefined;
-    }
-    watchFile(path) {
-        return () => {
-            const file = parseFile(path);
-            if (file) {
-                this.options.logger.info(`Processing ${(0, path_1.relative)(this.options.root ?? '.', path)}`);
-                this.push(file);
-            }
-        };
-    }
-    _read() {
-        const next = this.next();
-        if (next) {
-            if (this.options.watch && !this.watchedFiles.has(next.path)) {
-                this.watchedFiles.add(next.path);
-                (0, fs_1.watchFile)(next.path, this.watchFile(next.path));
-            }
-            this.options.logger.info(`Processing ${(0, path_1.relative)(this.options.root ?? '.', next.path)}`);
-            this.push(next);
-        }
-        else if (!this.options.watch) {
-            this.options.logger.info(`Done`);
-            this.push(null);
-        }
-    }
-}
-exports.SqlRead = SqlRead;
-class QueryLoader extends stream_1.Writable {
-    constructor(options) {
-        super({ objectMode: true });
-        this.options = options;
-        this.data = [];
-        this.ctx = { db: options.db, logger: options.logger ?? console };
-    }
-    async _writev(chunks, callback) {
-        try {
-            const parsedFiles = chunks.map((file) => file.chunk);
-            this.ctx.logger.debug(`Parse files: ${(0, util_1.inspect)(parsedFiles.map((file) => `${(0, path_1.relative)(this.options.root, file.path)} (${file.type})`))}`);
-            this.data = this.options.preload
-                ? this.data.length === 0
-                    ? await (0, potygen_1.loadAllData)(this.ctx, this.data)
-                    : this.data
-                : await loadDataFromParsedFiles(this.ctx, this.data, parsedFiles);
-            await Promise.all(parsedFiles
-                .map(loadFile(this.data))
-                .map((0, emit_1.emitLoadedFile)(this.options.root, this.options.template, this.options.cacheStore, this.options.typePrefix)));
-        }
-        catch (error) {
-            this.options.logger.error(error instanceof Error ? String(error) : new Error(String(error)));
-        }
-        callback();
-    }
-    async _write(file, encoding, callback) {
-        try {
-            this.ctx.logger.debug(`Parse file: ${(0, path_1.relative)(this.options.root, file.path)} (${file.type})`);
-            this.data = this.options.preload
-                ? this.data.length === 0
-                    ? await (0, potygen_1.loadAllData)(this.ctx, this.data)
-                    : this.data
-                : await loadDataFromParsedFiles(this.ctx, this.data, [file]);
-            await (0, emit_1.emitLoadedFile)(this.options.root, this.options.template, this.options.cacheStore, this.options.typePrefix)(loadFile(this.data)(file));
-        }
-        catch (error) {
-            this.options.logger.error(error instanceof Error ? String(error) : new Error(String(error)));
-        }
-        callback();
-    }
-}
-exports.QueryLoader = QueryLoader;
-//# sourceMappingURL=traverse.js.map

dist/traverse.js.map

-{"version":3,"file":"traverse.js","sourceRoot":"","sources":["../src/traverse.ts"],"names":[],"mappings":";;;AAAA,2BAA6C;AAC7C,mCAA4C;AAC5C,iCAA8B;AAC9B,2CAYoB;AACpB,+BAA0C;AAC1C,8CAmB0B;AAE1B,iCAAwC;AACxC,+BAA+B;AAG/B,MAAM,gBAAgB,GAAG,CAAC,IAAU,EAAQ,EAAE,CAC5C,IAAA,6BAAgB,EAAC,IAAI,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,gBAAgB,CAAC,IAAI,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,MAAM,CAAC;AAE9E,MAAM,qBAAqB,GAAG,CAAC,GAAe,EAAsB,EAAE;IACpE,MAAM,OAAO,GAAuB,EAAE,CAAC;IACvC,IAAI,eAAe,GAAG,KAAK,CAAC;IAE5B,MAAM,OAAO,GAAG,CAAC,IAAU,EAAQ,EAAE;QACnC,IACE,IAAA,gCAAmB,EAAC,IAAI,CAAC;YACzB,IAAA,4BAAe,EAAC,IAAI,CAAC,eAAe,CAAC;YACrC,IAAI,CAAC,YAAY,EAAE,aAAa;YAChC,IAAA,2BAAc,EAAC,IAAI,CAAC,YAAY,CAAC,aAAa,CAAC;YAC/C,IAAI,CAAC,eAAe,CAAC,IAAI,KAAK,kBAAkB,EAChD;YACA,eAAe;gBACb,IAAI,CAAC,YAAY,EAAE,aAAa,CAAC,QAAQ,CAAC,IAAI,CAC5C,CAAC,EAAE,YAAY,EAAE,IAAI,EAAE,EAAE,EAAE,CAAC,CAAC,YAAY,IAAI,IAAI,CAAC,CAAC,IAAI,KAAK,KAAK,CAClE,EAAE,IAAI,CAAC,IAAI,IAAI,eAAe,CAAC;SACnC;aAAM,IACL,IAAA,uCAA0B,EAAC,IAAI,CAAC;YAChC,IAAA,4CAA+B,EAAC,IAAI,CAAC,QAAQ,CAAC;YAC9C,IAAA,yBAAY,EAAC,IAAI,CAAC,GAAG,CAAC;YACtB,IAAI,CAAC,GAAG,CAAC,IAAI,KAAK,eAAe,EACjC;YACA,MAAM,GAAG,GAAG;gBACV,IAAI,EAAE,gBAAgB,CAAC,IAAI,CAAC,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC,OAAO,EAAE;gBACpD,GAAG,EAAE,IAAI,CAAC,QAAQ,CAAC,GAAG,GAAG,CAAC;gBAC1B,QAAQ,EAAE,IAAI,CAAC,QAAQ,CAAC,IAAI;aAC7B,CAAC;YACF,IAAI;gBACF,OAAO,CAAC,IAAI,CAAC,EAAE,GAAG,GAAG,EAAE,cAAc,EAAE,IAAA,0BAAgB,EAAC,IAAA,gBAAM,EAAC,IAAI,CAAC,QAAQ,CAAC,IAAI,CAAC,CAAC,GAAG,CAAC,EAAE,CAAC,CAAC;aAC5F;YAAC,OAAO,KAAK,EAAE;gBACd,MAAM,IAAI,oBAAU,CAAC,GAAG,EAAE,sBAAsB,KAAK,YAAY,KAAK,CAAC,CAAC,CAAC,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,MAAM,CAAC,KAAK,CAAC,EAAE,CAAC,CAAC;aAC3G;SACF;aAAM;YACL,IAAI,CAAC,YAAY,CAAC,OAAO,CAAC,CAAC;SAC5B;IACH,CAAC,CAAC;IAEF,OAAO,CAAC,GAAG,CAAC,CAAC;IACb,OAAO,OAAO,CAAC;AACjB,CAAC,CAAC;AAEF,MAAM,sBAAsB,GAAG,CAAC,IAAY,EAAwB,EAAE;IACpE,MAAM,UAAU,GAAG,IAAA,iBAAY,EAAC,IAAI,EAAE,OAAO,CAAC,CAAC;IAC/C,MAAM,MAAM,GAAG,IAAA,6BAAgB,EAAC,IAAA,eAAQ,EAAC,IAAI,CAAC,EAAE,UAAU,EAAE,yBAAY,CAAC,MAAM,EAAE,IAAI,CAAC,CAAC;IACvF,OAAO,EAAE,IAAI,EAAE,IAAI,EAAE,MAAM,EAAE,IAAI,EAAE,OAAO,EAAE,qBAAqB,CAAC,MAAM,CAAC,EAAE,CAAC;AAC9E,CAAC,CAAC;AAEF,MAAM,eAAe,GAAG,CAAC,IAAY,EAA6B,EAAE;IAClE,MAAM,OAAO,GAAG,IAAA,iBAAY,EAAC,IAAI,EAAE,OAAO,CAAC,CAAC;IAC5C,OAAO,EAAE,IAAI,EAAE,KAAK,EAAE,IAAI,EAAE,OAAO,EAAE,cAAc,EAAE,IAAA,0BAAgB,EAAC,IAAA,gBAAM,EAAC,OAAO,CAAC,CAAC,GAAG,CAAC,EAAE,CAAC;AAC/F,CAAC,CAAC;AAEF,MAAM,iBAAiB,GAAG,CAAC,KAAmB,EAAoB,EAAE,CAClE,KAAK,CAAC,OAAO,CAAC,CAAC,IAAI,EAAE,EAAE,CACrB,IAAI,CAAC,IAAI,KAAK,IAAI,CAAC,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,KAAK,EAAE,EAAE,CAAC,KAAK,CAAC,cAAc,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,cAAc,CAC7F,CAAC;AAEJ,MAAM,uBAAuB,GAAG,KAAK,EACnC,GAAgB,EAChB,IAAkB,EAClB,KAAmB,EACI,EAAE,CAAC,IAAA,iCAAuB,EAAC,GAAG,EAAE,iBAAiB,CAAC,KAAK,CAAC,EAAE,IAAI,CAAC,CAAC;AAEzF,MAAM,OAAO,GAAG,CAAC,KAAc,EAAmC,EAAE,CAClE,KAAK,YAAY,mBAAS,IAAI,KAAK,YAAY,oBAAU,CAAC;AAE5D,MAAM,QAAQ,GACZ,CAAC,IAAkB,EAAE,EAAE,CACvB,CAAC,IAAgB,EAAc,EAAE;IAC/B,IAAI,IAAI,CAAC,IAAI,KAAK,KAAK,EAAE;QACvB,IAAI;YACF,OAAO,EAAE,GAAG,IAAI,EAAE,WAAW,EAAE,IAAA,gCAAsB,EAAC,IAAI,CAAC,CAAC,IAAI,CAAC,cAAc,CAAC,EAAE,CAAC;SACpF;QAAC,OAAO,KAAK,EAAE;YACd,MAAM,OAAO,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,IAAI,gCAAsB,CAAC,IAAI,EAAE,KAAK,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC;SACxE;KACF;SAAM;QACL,OAAO;YACL,GAAG,IAAI;YACP,OAAO,EAAE,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,QAAQ,EAAE,EAAE;gBACrC,IAAI;oBACF,OAAO,EAAE,GAAG,QAAQ,EAAE,WAAW,EAAE,IAAA,gCAAsB,EAAC,IAAI,CAAC,CAAC,QAAQ,CAAC,cAAc,CAAC,EAAE,CAAC;iBAC5F;gBAAC,OAAO,KAAK,EAAE;oBACd,MAAM,OAAO,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,IAAI,uCAA6B,CAAC,IAAI,EAAE,QAAQ,EAAE,KAAK,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC;iBACzF;YACH,CAAC,CAAC;SACH,CAAC;KACH;AACH,CAAC,CAAC;AAEJ,MAAM,SAAS,GAAG,CAAC,IAAY,EAA0B,EAAE;IACzD,IAAI,IAAI,CAAC,QAAQ,CAAC,KAAK,CAAC,EAAE;QACxB,MAAM,IAAI,GAAG,sBAAsB,CAAC,IAAI,CAAC,CAAC;QAC1C,OAAO,IAAI,CAAC,OAAO,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,SAAS,CAAC;KACnD;SAAM;QACL,OAAO,eAAe,CAAC,IAAI,CAAC,CAAC;KAC9B;AACH,CAAC,CAAC;AAEF,MAAa,OAAQ,SAAQ,iBAAQ;IAInC,YAAmB,OAA+F;QAChH,KAAK,CAAC,EAAE,UAAU,EAAE,IAAI,EAAE,CAAC,CAAC;QADX,YAAO,GAAP,OAAO,CAAwF;QAF3G,iBAAY,GAAG,IAAI,GAAG,EAAU,CAAC;QAItC,IAAI,CAAC,MAAM,GAAG,IAAA,WAAI,EAAC,OAAO,CAAC,IAAI,EAAE,OAAO,CAAC,IAAI,CAAC,CAAC;IACjD,CAAC;IAED,IAAI;QACF,IAAI,IAA4B,CAAC;QACjC,OAAO,CAAC,CAAC,IAAI,GAAG,IAAI,CAAC,MAAM,CAAC,IAAI,EAAE,CAAC,CAAC,IAAI,EAAE;YACxC,IAAI,IAAI,CAAC,OAAO,CAAC,UAAU,CAAC,eAAe,CAAC,IAAI,CAAC,KAAK,CAAC,EAAE;gBACvD,MAAM,IAAI,GAAG,SAAS,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC;gBAEnC,IAAI,IAAI,EAAE;oBACR,OAAO,IAAI,CAAC;iBACb;aACF;SACF;QACD,OAAO,SAAS,CAAC;IACnB,CAAC;IAED,SAAS,CAAC,IAAY;QACpB,OAAO,GAAG,EAAE;YACV,MAAM,IAAI,GAAG,SAAS,CAAC,IAAI,CAAC,CAAC;YAC7B,IAAI,IAAI,EAAE;gBACR,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,IAAI,CAAC,cAAc,IAAA,eAAQ,EAAC,IAAI,CAAC,OAAO,CAAC,IAAI,IAAI,GAAG,EAAE,IAAI,CAAC,EAAE,CAAC,CAAC;gBACnF,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;aACjB;QACH,CAAC,CAAC;IACJ,CAAC;IAED,KAAK;QACH,MAAM,IAAI,GAAG,IAAI,CAAC,IAAI,EAAE,CAAC;QACzB,IAAI,IAAI,EAAE;YACR,IAAI,IAAI,CAAC,OAAO,CAAC,KAAK,IAAI,CAAC,IAAI,CAAC,YAAY,CAAC,GAAG,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE;gBAC3D,IAAI,CAAC,YAAY,CAAC,GAAG,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;gBACjC,IAAA,cAAS,EAAC,IAAI,CAAC,IAAI,EAAE,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC,CAAC;aACjD;YACD,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,IAAI,CAAC,cAAc,IAAA,eAAQ,EAAC,IAAI,CAAC,OAAO,CAAC,IAAI,IAAI,GAAG,EAAE,IAAI,CAAC,IAAI,CAAC,EAAE,CAAC,CAAC;YACxF,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;SACjB;aAAM,IAAI,CAAC,IAAI,CAAC,OAAO,CAAC,KAAK,EAAE;YAC9B,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,IAAI,CAAC,MAAM,CAAC,CAAC;YACjC,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;SACjB;IACH,CAAC;CACF;AA/CD,0BA+CC;AAED,MAAa,WAAY,SAAQ,iBAAQ;IAGvC,YACS,OAQN;QAED,KAAK,CAAC,EAAE,UAAU,EAAE,IAAI,EAAE,CAAC,CAAC;QAVrB,YAAO,GAAP,OAAO,CAQb;QAVI,SAAI,GAAiB,EAAE,CAAC;QAa7B,IAAI,CAAC,GAAG,GAAG,EAAE,EAAE,EAAE,OAAO,CAAC,EAAE,EAAE,MAAM,EAAE,OAAO,CAAC,MAAM,IAAI,OAAO,EAAE,CAAC;IACnE,CAAC;IAED,KAAK,CAAC,OAAO,CACX,MAA8D,EAC9D,QAAwC;QAExC,IAAI;YACF,MAAM,WAAW,GAAG,MAAM,CAAC,GAAG,CAAC,CAAC,IAAI,EAAE,EAAE,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC;YACrD,IAAI,CAAC,GAAG,CAAC,MAAM,CAAC,KAAK,CACnB,gBAAgB,IAAA,cAAO,EACrB,WAAW,CAAC,GAAG,CAAC,CAAC,IAAI,EAAE,EAAE,CAAC,GAAG,IAAA,eAAQ,EAAC,IAAI,CAAC,OAAO,CAAC,IAAI,EAAE,IAAI,CAAC,IAAI,CAAC,KAAK,IAAI,CAAC,IAAI,GAAG,CAAC,CACtF,EAAE,CACJ,CAAC;YACF,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,OAAO,CAAC,OAAO;gBAC9B,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,MAAM,KAAK,CAAC;oBACtB,CAAC,CAAC,MAAM,IAAA,qBAAW,EAAC,IAAI,CAAC,GAAG,EAAE,IAAI,CAAC,IAAI,CAAC;oBACxC,CAAC,CAAC,IAAI,CAAC,IAAI;gBACb,CAAC,CAAC,MAAM,uBAAuB,CAAC,IAAI,CAAC,GAAG,EAAE,IAAI,CAAC,IAAI,EAAE,WAAW,CAAC,CAAC;YACpE,MAAM,OAAO,CAAC,GAAG,CACf,WAAW;iBACR,GAAG,CAAC,QAAQ,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;iBACxB,GAAG,CACF,IAAA,qBAAc,EAAC,IAAI,CAAC,OAAO,CAAC,IAAI,EAAE,IAAI,CAAC,OAAO,CAAC,QAAQ,EAAE,IAAI,CAAC,OAAO,CAAC,UAAU,EAAE,IAAI,CAAC,OAAO,CAAC,UAAU,CAAC,CAC3G,CACJ,CAAC;SACH;QAAC,OAAO,KAAK,EAAE;YACd,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,KAAK,CAAC,KAAK,YAAY,KAAK,CAAC,CAAC,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,IAAI,KAAK,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;SAC9F;QACD,QAAQ,EAAE,CAAC;IACb,CAAC;IAED,KAAK,CAAC,MAAM,CACV,IAA0B,EAC1B,QAAwB,EACxB,QAAwC;QAExC,IAAI;YACF,IAAI,CAAC,GAAG,CAAC,MAAM,CAAC,KAAK,CAAC,eAAe,IAAA,eAAQ,EAAC,IAAI,CAAC,OAAO,CAAC,IAAI,EAAE,IAAI,CAAC,IAAI,CAAC,KAAK,IAAI,CAAC,IAAI,GAAG,CAAC,CAAC;YAC9F,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,OAAO,CAAC,OAAO;gBAC9B,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,MAAM,KAAK,CAAC;oBACtB,CAAC,CAAC,MAAM,IAAA,qBAAW,EAAC,IAAI,CAAC,GAAG,EAAE,IAAI,CAAC,IAAI,CAAC;oBACxC,CAAC,CAAC,IAAI,CAAC,IAAI;gBACb,CAAC,CAAC,MAAM,uBAAuB,CAAC,IAAI,CAAC,GAAG,EAAE,IAAI,CAAC,IAAI,EAAE,CAAC,IAAI,CAAC,CAAC,CAAC;YAC/D,MAAM,IAAA,qBAAc,EAClB,IAAI,CAAC,OAAO,CAAC,IAAI,EACjB,IAAI,CAAC,OAAO,CAAC,QAAQ,EACrB,IAAI,CAAC,OAAO,CAAC,UAAU,EACvB,IAAI,CAAC,OAAO,CAAC,UAAU,CACxB,CAAC,QAAQ,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC;SAC9B;QAAC,OAAO,KAAK,EAAE;YACd,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,KAAK,CAAC,KAAK,YAAY,KAAK,CAAC,CAAC,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,IAAI,KAAK,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;SAC9F;QACD,QAAQ,EAAE,CAAC;IACb,CAAC;CACF;AAtED,kCAsEC"}

New alerts

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 1 instance in 1 package

Filesystem access

Supply chain risk

Accesses the file system, and could potentially read sensitive data.

Found 2 instances in 1 package

Long strings

Supply chain risk

Contains long string literals, which may be a sign of obfuscated or packed code.

Found 1 instance in 1 package

Fixed alerts

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 1 instance in 1 package

Filesystem access

Supply chain risk

Accesses the file system, and could potentially read sensitive data.

Found 1 instance in 1 package

Improved metrics

Lines of code

679

1.04%

Worsened metrics

Total package byte prevSize

64555

-4.03%

Dependency count

7

16.67%

Number of package files

25

-10.71%

Number of medium supply chain risk alerts

1

Infinity%

Dependency changes

• + Added

  @supercharge/promise-pool@^2.3.2

• + Added

  @supercharge/promise-pool@2.4.0
  (transitive)