Oak-Team
/
oak-domain
13
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 33 Wiki Activity

添加analyzeEntitiesExternal方法，用于外部解析entity数据

This commit is contained in:
Pan Qiancheng 2025-05-06 18:33:53 +08:00
parent c2a5e1bda1
commit e1aeaed465
55 changed files with 149 additions and 153 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
lib/compiler/dependencyBuilder.js
View File

@ -1,6 +1,7 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.analyzeDepedency = void 0;
exports.analyzeDepedency = analyzeDepedency;
exports.default = buildDependency;
const tslib_1 = require("tslib");
const assert_1 = tslib_1.__importDefault(require("assert"));
const path_1 = require("path");
@ -87,7 +88,6 @@ function analyzeDepedency(cwd) {
} while (true);
return depGraph;
}
exports.analyzeDepedency = analyzeDepedency;
function join(...paths) {
const path = (0, path_1.join)(...paths);
return path.replaceAll('\\', '/');
@ -1023,4 +1023,3 @@ function buildDependency(rebuild) {
tryCopyModuleTemplateFiles(cwd, dependencies, briefNames, printer);
}
}
exports.default = buildDependency;

1
lib/compiler/localeBuilder.d.ts vendored
View File

@ -1,4 +1,3 @@
/// <reference types="node" />
import { Hash } from 'crypto';
/**
* 这个类的作用是把项目和所有相关的模块下的locales编译成为src/data/i18n中的数据

3
lib/compiler/routerBuilder.js
View File

@ -1,6 +1,6 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.buildRouter = void 0;
exports.buildRouter = buildRouter;
const tslib_1 = require("tslib");
const path_1 = require("path");
const fs_extra_1 = require("fs-extra");
@ -254,4 +254,3 @@ function buildRouter(projectDir, startupDir, watch) {
watchDir(projectDir, startupDir, type);
}
}
exports.buildRouter = buildRouter;

19
lib/compiler/schemalBuilder.d.ts vendored
View File

@ -1,3 +1,20 @@
import * as ts from 'typescript';
declare const Schema: Record<string, {
schemaAttrs: Array<ts.PropertySignature>;
fulltextIndex?: true;
indexes?: ts.ArrayLiteralExpression;
sourceFile: ts.SourceFile;
enumAttributes: Record<string, string[]>;
locale: ts.ObjectLiteralExpression;
toModi: boolean;
toLog: boolean;
actionType: string;
static: boolean;
inModi: boolean;
relations: false | string[];
extendsFrom: string[];
importAttrFrom: Record<string, [string, string | undefined]>;
}>;
/**
* 此函数不再使用
* @param map
@ -23,6 +40,8 @@ export declare function registerFixedDestinationPathMap(map: Record<string, stri
* @param map
*/
export declare function registerDeducedRelationMap(map: Record<string, string>): void;
export declare const analyzeEntitiesExternal: (inputDir: string, relativePath?: string) => typeof Schema;
export declare function analyzeEntities(inputDir: string, relativePath?: string): void;
export declare function buildSchemaBackup(outputDir: string): void;
export declare function buildSchema(outputDir: string): void;
export {};

23
lib/compiler/schemalBuilder.js
View File

@ -1,6 +1,14 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.buildSchema = exports.buildSchemaBackup = exports.analyzeEntities = exports.registerDeducedRelationMap = exports.registerFixedDestinationPathMap = exports.registerIgnoredRelationPathMap = exports.registerFreeEntities = exports.registerIgnoredForeignKeyMap = void 0;
exports.analyzeEntitiesExternal = void 0;
exports.registerIgnoredForeignKeyMap = registerIgnoredForeignKeyMap;
exports.registerFreeEntities = registerFreeEntities;
exports.registerIgnoredRelationPathMap = registerIgnoredRelationPathMap;
exports.registerFixedDestinationPathMap = registerFixedDestinationPathMap;
exports.registerDeducedRelationMap = registerDeducedRelationMap;
exports.analyzeEntities = analyzeEntities;
exports.buildSchemaBackup = buildSchemaBackup;
exports.buildSchema = buildSchema;
const tslib_1 = require("tslib");
const path_1 = tslib_1.__importDefault(require("path"));
const assert_1 = tslib_1.__importDefault(require("assert"));
@ -4225,7 +4233,6 @@ let FIXED_FOR_ALL_DESTINATION_PATH_ENTITIES = [];
function registerIgnoredForeignKeyMap(map) {
IGNORED_FOREIGN_KEY_MAP = map;
}
exports.registerIgnoredForeignKeyMap = registerIgnoredForeignKeyMap;
/**
* 此函数不再使用
* @param map
@ -4235,7 +4242,6 @@ function registerFreeEntities(selectFreeEntities = [], createFreeEntities = [],
CREATE_FREE_ENTITIES = createFreeEntities;
UPDATE_FREE_ENTITIES = updateFreeEntities;
}
exports.registerFreeEntities = registerFreeEntities;
/**
* 此函数不再使用
* @param map
@ -4245,7 +4251,6 @@ function registerIgnoredRelationPathMap(map) {
IGNORED_RELATION_PATH_MAP[(0, string_1.firstLetterUpperCase)(k)] = map[k];
}
}
exports.registerIgnoredRelationPathMap = registerIgnoredRelationPathMap;
/**
* 很多路径虽然最后指向同一对象，但不能封掉，封了会导致查询的时候找不到对应的路径path
* @param map
@ -4263,7 +4268,6 @@ function registerFixedDestinationPathMap(map) {
}
}
}
exports.registerFixedDestinationPathMap = registerFixedDestinationPathMap;
/**
* 此函数不再使用
* @param map
@ -4282,7 +4286,6 @@ function registerDeducedRelationMap(map) {
DEDUCED_RELATION_MAP[entity] = map[k];
}
}
exports.registerDeducedRelationMap = registerDeducedRelationMap;
/**
* 输出所有和User相关的对象的后继
* 此函数不再使用
@ -4768,6 +4771,11 @@ function outputStyleDict(outputDir, printer) {
const filename = path_1.default.join(outputDir, 'StyleDict.ts');
(0, fs_1.writeFileSync)(filename, result, { flag: 'w' });
}
const analyzeEntitiesExternal = (inputDir, relativePath) => {
analyzeEntities(inputDir, relativePath);
return Schema;
};
exports.analyzeEntitiesExternal = analyzeEntitiesExternal;
function analyzeEntities(inputDir, relativePath) {
const files = (0, fs_1.readdirSync)(inputDir);
const fullFilenames = files.map(ele => {
@ -4784,7 +4792,6 @@ function analyzeEntities(inputDir, relativePath) {
analyzeInModi();
uniqRelationships();
}
exports.analyzeEntities = analyzeEntities;
function buildSchemaBackup(outputDir) {
addReverseRelationship();
// setRelationEntities();
@ -4803,7 +4810,6 @@ function buildSchemaBackup(outputDir) {
outputPackageJson(outputDir);
}
}
exports.buildSchemaBackup = buildSchemaBackup;
function _getAggrKey(entity, foreignKey) {
const aggrKey = `${entity}$${foreignKey}`;
if (process.env.COMPLING_AS_LIB) {
@ -5508,4 +5514,3 @@ function buildSchema(outputDir) {
outputStyleDict(outputDir, printer);
outputIndexTs(outputDir);
}
exports.buildSchema = buildSchema;

1
lib/store/AsyncRowStore.d.ts vendored
View File

@ -1,4 +1,3 @@
/// <reference types="node" />
import { EntityDict, RowStore, OperateOption, OperationResult, SelectOption, Context, TxnOption, OpRecord, AggregationResult, ClusterInfo, OakException } from "../types";
import { EntityDict as BaseEntityDict } from '../base-app-domain';
import { IncomingHttpHeaders } from "http";

2
lib/store/CascadeStore.d.ts vendored
View File

@ -35,7 +35,7 @@ export declare abstract class CascadeStore<ED extends EntityDict & BaseEntityDic
protected abstract aggregateAbjointRowAsync<T extends keyof ED, OP extends SelectOption, Cxt extends AsyncContext<ED>>(entity: T, aggregation: ED[T]['Aggregation'], context: Cxt, option: OP): Promise<AggregationResult<ED[T]['Schema']>>;
protected destructCascadeSelect<T extends keyof ED, OP extends SelectOption, Cxt extends SyncContext<ED> | AsyncContext<ED>>(entity: T, projection2: ED[T]['Projection'], context: Cxt, cascadeSelectFn: <T2 extends keyof ED>(entity2: T2, selection: ED[T2]['Selection'], context: Cxt, op: OP) => Partial<ED[T2]['Schema']>[] | Promise<Partial<ED[T2]['Schema']>[]>, aggregateFn: <T2 extends keyof ED>(entity2: T2, aggregation: ED[T2]['Aggregation'], context: Cxt, op: OP) => AggregationResult<ED[T2]['Schema']> | Promise<AggregationResult<ED[T2]['Schema']>>, option: OP): {
projection: ED[T]["Projection"];
cascadeSelectionFns: ((result: Partial<ED[T]['Schema']>[]) => Promise<void> | void)[];
cascadeSelectionFns: ((result: Partial<ED[T]["Schema"]>[]) => Promise<void> | void)[];
};
/**
* 级联更新

4
lib/store/CascadeStore.js
View File

@ -1,6 +1,7 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.CascadeStore = exports.polishSelection = void 0;
exports.CascadeStore = void 0;
exports.polishSelection = polishSelection;
const tslib_1 = require("tslib");
const assert_1 = tslib_1.__importDefault(require("assert"));
const Entity_1 = require("../types/Entity");
@ -282,7 +283,6 @@ function polishSelection(schema, entity, selection, context, option) {
});
}
}
exports.polishSelection = polishSelection;
/**这个用来处理级联的select和update，对不同能力的 */
class CascadeStore extends RowStore_1.RowStore {
constructor(storageSchema) {

3
lib/store/IntrinsicCheckers.js
View File

@ -1,6 +1,6 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.makeIntrinsicCheckers = void 0;
exports.makeIntrinsicCheckers = makeIntrinsicCheckers;
const tslib_1 = require("tslib");
const types_1 = require("../types");
const lodash_1 = require("../utils/lodash");
@ -386,4 +386,3 @@ function makeIntrinsicCheckers(schema, actionDefDict, attrUpdateMatrix) {
}
return checkers;
}
exports.makeIntrinsicCheckers = makeIntrinsicCheckers;

3
lib/store/IntrinsicLogics.js
View File

@ -1,6 +1,6 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.makeIntrinsicLogics = void 0;
exports.makeIntrinsicLogics = makeIntrinsicLogics;
const triggers_1 = require("./triggers");
const modi_1 = require("./modi");
const IntrinsicCheckers_1 = require("./IntrinsicCheckers");
@ -42,4 +42,3 @@ function makeIntrinsicLogics(schema, actionDefDict, attrUpdateMatrix) {
watchers,
};
}
exports.makeIntrinsicLogics = makeIntrinsicLogics;

4
lib/store/RelationAuth.js
View File

@ -1,6 +1,7 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.getUserRelationsByActions = exports.RelationAuth = void 0;
exports.RelationAuth = void 0;
exports.getUserRelationsByActions = getUserRelationsByActions;
const tslib_1 = require("tslib");
const assert_1 = tslib_1.__importDefault(require("assert"));
const types_1 = require("../types");
@ -1243,4 +1244,3 @@ async function getUserRelationsByActions(params, context) {
userEntities,
};
}
exports.getUserRelationsByActions = getUserRelationsByActions;

9
lib/store/checker.js
View File

@ -1,6 +1,9 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.createCreateCheckers = exports.createRemoveCheckers = exports.translateCheckerInSyncContext = exports.translateCheckerInAsyncContext = void 0;
exports.translateCheckerInAsyncContext = translateCheckerInAsyncContext;
exports.translateCheckerInSyncContext = translateCheckerInSyncContext;
exports.createRemoveCheckers = createRemoveCheckers;
exports.createCreateCheckers = createCreateCheckers;
const tslib_1 = require("tslib");
const assert_1 = tslib_1.__importDefault(require("assert"));
const filter_1 = require("../store/filter");
@ -127,7 +130,6 @@ function translateCheckerInAsyncContext(checker, schema) {
}
}
}
exports.translateCheckerInAsyncContext = translateCheckerInAsyncContext;
function translateCheckerInSyncContext(checker, schema) {
const { entity, type } = checker;
const when = 'before'; // 现在create的relation改成提前的expression检查了，原先是先插入再后检查，性能不行，而且select也需要实现前检查
@ -186,7 +188,6 @@ function translateCheckerInSyncContext(checker, schema) {
}
}
}
exports.translateCheckerInSyncContext = translateCheckerInSyncContext;
/**
* 对对象的删除，检查其是否会产生其他行上的空指针，不允许这种情况的出现
* @param schema
@ -331,7 +332,6 @@ function createRemoveCheckers(schema) {
}
return checkers;
}
exports.createRemoveCheckers = createRemoveCheckers;
function checkAttributeLegal(schema, entity, data) {
const { attributes } = schema[entity];
for (const attr in data) {
@ -478,4 +478,3 @@ function createCreateCheckers(schema) {
}
return checkers;
}
exports.createCreateCheckers = createCreateCheckers;

25
lib/store/filter.js
View File

@ -1,6 +1,17 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.translateFilterToObjectPredicate = exports.checkFilterRepel = exports.checkFilterContains = exports.makeTreeDescendantFilter = exports.makeTreeAncestorFilter = exports.same = exports.getRelevantIds = exports.contains = exports.analyzeFilterRelation = exports.judgeValueRelation = exports.combineFilters = exports.translateCreateDataToFilter = void 0;
exports.translateCreateDataToFilter = translateCreateDataToFilter;
exports.combineFilters = combineFilters;
exports.judgeValueRelation = judgeValueRelation;
exports.analyzeFilterRelation = analyzeFilterRelation;
exports.contains = contains;
exports.getRelevantIds = getRelevantIds;
exports.same = same;
exports.makeTreeAncestorFilter = makeTreeAncestorFilter;
exports.makeTreeDescendantFilter = makeTreeDescendantFilter;
exports.checkFilterContains = checkFilterContains;
exports.checkFilterRepel = checkFilterRepel;
exports.translateFilterToObjectPredicate = translateFilterToObjectPredicate;
const tslib_1 = require("tslib");
const assert_1 = tslib_1.__importDefault(require("assert"));
const types_1 = require("../types");
@ -35,7 +46,6 @@ function translateCreateDataToFilter(schema, entity, data, allowUnrecoganized) {
}
return data2;
}
exports.translateCreateDataToFilter = translateCreateDataToFilter;
/**
* 尽量合并外键的连接，防止在数据库中join的对象过多
* @param entity
@ -483,7 +493,6 @@ function combineFilters(entity, schema, filters, union) {
}
return addFilterSegment(entity, schema, ...filters);
}
exports.combineFilters = combineFilters;
/**
* 在以下判断相容或相斥的过程中，相容/相斥的事实标准是：满足两个条件的查询集合是否被包容/互斥，但如果两个filter在逻辑上相容或者相斥，在事实上不一定相容或者相斥
* 例如：{ a: 1 } 和 { a: { $ne: 1 } } 是明显不相容的查询，但如果数据为空集，则这两个查询并不能否定其相容
@ -902,7 +911,6 @@ function judgeValueRelation(value1, value2, contained) {
return false;
}
}
exports.judgeValueRelation = judgeValueRelation;
/**
* 判断filter条件对compared条件上的attr键值的条件是否相容或相斥
* @param entity
@ -1291,7 +1299,6 @@ function analyzeFilterRelation(entity, schema, filter, compared, contained) {
sureAttributes,
};
}
exports.analyzeFilterRelation = analyzeFilterRelation;
/** 判断filter条件对compared条件是否相容或相斥
* @param entity
* @param schema
@ -1363,7 +1370,6 @@ function contains(entity, schema, filter, contained) {
return judgeFilterRelation(entity, schema, filter, contained, true);
// return false;
}
exports.contains = contains;
/**
* 判断filter1和filter2是否相斥，即filter1和filter2查询的结果一定没有交集
* filter1 = {
@ -1464,7 +1470,6 @@ function getRelevantIds(filter) {
}
return result;
}
exports.getRelevantIds = getRelevantIds;
/**
* 判断两个过滤条件是否完全一致
* @param entity
@ -1479,7 +1484,6 @@ function same(entity, schema, filter1, filter2) {
}
return filter1.id === filter2.id;
}
exports.same = same;
/**
* 寻找在树形结构中满足条件的数据行的上层数据
* 例如在area表中，如果“杭州市”满足这一条件，则希望查到更高层的“浙江省”和“中国”，即可构造出满足条件的filter
@ -1520,7 +1524,6 @@ function makeTreeAncestorFilter(entity, parentKey, filter, level = 1, includeAll
}
return currentLevelInFilter;
}
exports.makeTreeAncestorFilter = makeTreeAncestorFilter;
/**
* 寻找在树形结构中满足条件的数据行的下层数据
* 例如在area表中，如果“杭州市”满足这一条件，则希望查到更低层的“西湖区”，即可构造出满足条件的filter
@ -1555,7 +1558,6 @@ function makeTreeDescendantFilter(entity, parentKey, filter, level = 1, includeA
}
return currentLevelInFilter;
}
exports.makeTreeDescendantFilter = makeTreeDescendantFilter;
function checkDeduceFilters(dfc, context) {
const { $and, $or } = dfc;
if ($and) {
@ -1641,7 +1643,6 @@ function checkFilterContains(entity, context, contained, filter, dataCompare, wa
}
return false;
}
exports.checkFilterContains = checkFilterContains;
function checkFilterRepel(entity, context, filter1, filter2, dataCompare, warningOnDataCompare) {
(0, assert_1.default)(filter2);
const schema = context.getSchema();
@ -1657,7 +1658,6 @@ function checkFilterRepel(entity, context, filter1, filter2, dataCompare, warnin
}
return false;
}
exports.checkFilterRepel = checkFilterRepel;
/**
* 有的场景下将filter当成非结构化属性存储，又想支持对其查询，此时必须将查询的filter进行转换，处理其中$开头的escape
* 只要filter是查询数据的标准子集，查询应当能返回true
@ -1681,7 +1681,6 @@ function translateFilterToObjectPredicate(filter) {
copyInner(filter, translated);
return translated;
}
exports.translateFilterToObjectPredicate = translateFilterToObjectPredicate;
/* export function getCascadeEntityFilter<ED extends EntityDict & BaseEntityDict, T extends keyof ED>(
filter: NonNullable<ED[T]['Filter']>,
attr: keyof NonNullable<ED[T]['Filter']>

11
lib/store/modi.js
View File

@ -1,6 +1,10 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.createModiRelatedTriggers = exports.createModiRelatedCheckers = exports.abandonModis = exports.applyModis = exports.createOperationsFromModies = void 0;
exports.createOperationsFromModies = createOperationsFromModies;
exports.applyModis = applyModis;
exports.abandonModis = abandonModis;
exports.createModiRelatedCheckers = createModiRelatedCheckers;
exports.createModiRelatedTriggers = createModiRelatedTriggers;
const tslib_1 = require("tslib");
const types_1 = require("../types");
const action_1 = require("../actions/action");
@ -20,7 +24,6 @@ function createOperationsFromModies(modies) {
};
});
}
exports.createOperationsFromModies = createOperationsFromModies;
async function applyModis(filter, context, option) {
const closeMode = context.openRootMode();
const result = await context.operate('modi', {
@ -42,7 +45,6 @@ async function applyModis(filter, context, option) {
closeMode();
return result;
}
exports.applyModis = applyModis;
async function abandonModis(filter, context, option) {
const closeMode = context.openRootMode();
const result = context.operate('modi', {
@ -64,7 +66,6 @@ async function abandonModis(filter, context, option) {
closeMode();
return result;
}
exports.abandonModis = abandonModis;
function createModiRelatedCheckers(schema) {
const checkers = [];
for (const entity in schema) {
@ -169,7 +170,6 @@ function createModiRelatedCheckers(schema) {
}
return checkers;
}
exports.createModiRelatedCheckers = createModiRelatedCheckers;
function createModiRelatedTriggers(schema) {
const triggers = [];
for (const entity in schema) {
@ -253,4 +253,3 @@ function createModiRelatedTriggers(schema) {
};
return triggers.concat([applyTrigger]);
}
exports.createModiRelatedTriggers = createModiRelatedTriggers;

3
lib/store/relation.js
View File

@ -1,6 +1,6 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.judgeRelation = void 0;
exports.judgeRelation = judgeRelation;
const tslib_1 = require("tslib");
const assert_1 = tslib_1.__importDefault(require("assert"));
const Demand_1 = require("../types/Demand");
@ -71,4 +71,3 @@ function judgeRelation(schema, entity, attr, allowUnrecognized) {
}
}
}
exports.judgeRelation = judgeRelation;

3
lib/timers/oper.js
View File

@ -1,6 +1,6 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.vaccumOper = void 0;
exports.vaccumOper = vaccumOper;
const Entity_1 = require("../types/Entity");
const vaccum_1 = require("./vaccum");
const filter_1 = require("../store/filter");
@ -61,4 +61,3 @@ async function vaccumOper(option, context) {
...rest,
}, context);
}
exports.vaccumOper = vaccumOper;

3
lib/timers/vaccum.js
View File

@ -1,6 +1,6 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.vaccumEntities = void 0;
exports.vaccumEntities = vaccumEntities;
const tslib_1 = require("tslib");
const dayjs_1 = tslib_1.__importDefault(require("dayjs"));
const fs_1 = require("fs");
@ -108,4 +108,3 @@ async function vaccumEntities(option, context) {
}, { deletePhysically: true });
}
}
exports.vaccumEntities = vaccumEntities;

1
lib/types/AppLoader.d.ts vendored
View File

@ -1,4 +1,3 @@
/// <reference types="node" />
import { IncomingHttpHeaders } from "http";
import { AsyncContext, AsyncRowStore } from "../store/AsyncRowStore";
import { EntityDict, OpRecord } from "./Entity";

1
lib/types/Connector.d.ts vendored
View File

@ -1,4 +1,3 @@
/// <reference types="node" />
import { IncomingHttpHeaders } from "http";
import { SyncContext } from "../store/SyncRowStore";
import { EntityDict, OpRecord } from "./Entity";

4
lib/types/Demand.js
View File

@ -1,10 +1,10 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.SUB_QUERY_PREDICATE_KEYWORD = exports.isRefAttrNode = exports.EXPRESSION_PREFIX = void 0;
exports.SUB_QUERY_PREDICATE_KEYWORD = exports.EXPRESSION_PREFIX = void 0;
exports.isRefAttrNode = isRefAttrNode;
exports.EXPRESSION_PREFIX = '$expr';
function isRefAttrNode(node) {
return node.hasOwnProperty('#attr') || (node.hasOwnProperty('#refId') && node.hasOwnProperty('#refAttr'));
}
exports.isRefAttrNode = isRefAttrNode;
;
exports.SUB_QUERY_PREDICATE_KEYWORD = '#sqp';

1
lib/types/Endpoint.d.ts vendored
View File

@ -1,4 +1,3 @@
/// <reference types="node" />
import { IncomingHttpHeaders, IncomingMessage } from "http";
import { AsyncContext } from "../store/AsyncRowStore";
import { EntityDict } from "./Entity";

4
lib/types/Exception.js
View File

@ -1,6 +1,7 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.makeException = exports.OakApplicationHasToUpgrade = exports.OakSocketConnectException = exports.OakExternalException = exports.OakPreConditionUnsetException = exports.OakDeadlock = exports.OakCongruentRowExists = exports.OakRowLockedException = exports.OakUnloggedInException = exports.OakDataInvisibleException = exports.OakOperationUnpermittedException = exports.OakAttrCantUpdateException = exports.OakAttrNotNullException = exports.OakInputIllegalException = exports.OakRowInconsistencyException = exports.OakSignatureVerificationException = exports.OakClockDriftException = exports.OakServerProxyException = exports.OakNetworkException = exports.OakImportDataParseException = exports.OakUniqueViolationException = exports.OakUserException = exports.OakRowUnexistedException = exports.OakOperExistedException = exports.OakNoRelationDefException = exports.OakDataException = exports.OakPartialSuccess = exports.OakMakeSureByMySelfException = exports.OakRequestTimeoutException = exports.OakException = void 0;
exports.OakApplicationHasToUpgrade = exports.OakSocketConnectException = exports.OakExternalException = exports.OakPreConditionUnsetException = exports.OakDeadlock = exports.OakCongruentRowExists = exports.OakRowLockedException = exports.OakUnloggedInException = exports.OakDataInvisibleException = exports.OakOperationUnpermittedException = exports.OakAttrCantUpdateException = exports.OakAttrNotNullException = exports.OakInputIllegalException = exports.OakRowInconsistencyException = exports.OakSignatureVerificationException = exports.OakClockDriftException = exports.OakServerProxyException = exports.OakNetworkException = exports.OakImportDataParseException = exports.OakUniqueViolationException = exports.OakUserException = exports.OakRowUnexistedException = exports.OakOperExistedException = exports.OakNoRelationDefException = exports.OakDataException = exports.OakPartialSuccess = exports.OakMakeSureByMySelfException = exports.OakRequestTimeoutException = exports.OakException = void 0;
exports.makeException = makeException;
const relation_1 = require("../store/relation");
const lodash_1 = require("../utils/lodash");
class OakException extends Error {
@ -552,4 +553,3 @@ function makeException(data) {
return e;
}
}
exports.makeException = makeException;

25
lib/types/Expression.js
View File

@ -1,6 +1,17 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.getAttrRefInExpression = exports.execOp = exports.opMultipleParams = exports.isExpression = exports.isAggrExpression = exports.isStringExpression = exports.isMathExpression = exports.isCompareExpression = exports.isBoolExpression = exports.isLogicExpression = exports.isDateExpression = exports.isGeoExpression = void 0;
exports.isGeoExpression = isGeoExpression;
exports.isDateExpression = isDateExpression;
exports.isLogicExpression = isLogicExpression;
exports.isBoolExpression = isBoolExpression;
exports.isCompareExpression = isCompareExpression;
exports.isMathExpression = isMathExpression;
exports.isStringExpression = isStringExpression;
exports.isAggrExpression = isAggrExpression;
exports.isExpression = isExpression;
exports.opMultipleParams = opMultipleParams;
exports.execOp = execOp;
exports.getAttrRefInExpression = getAttrRefInExpression;
const tslib_1 = require("tslib");
const assert_1 = tslib_1.__importDefault(require("assert"));
const dayjs_1 = tslib_1.__importDefault(require("dayjs"));
@ -52,7 +63,6 @@ function isGeoExpression(expression) {
}
return false;
}
exports.isGeoExpression = isGeoExpression;
function isDateExpression(expression) {
if (Object.keys(expression).length == 1) {
const op = Object.keys(expression)[0];
@ -63,7 +73,6 @@ function isDateExpression(expression) {
}
return false;
}
exports.isDateExpression = isDateExpression;
function isLogicExpression(expression) {
if (Object.keys(expression).length == 1) {
const op = Object.keys(expression)[0];
@ -73,7 +82,6 @@ function isLogicExpression(expression) {
}
return false;
}
exports.isLogicExpression = isLogicExpression;
function isBoolExpression(expression) {
if (Object.keys(expression).length == 1) {
const op = Object.keys(expression)[0];
@ -83,7 +91,6 @@ function isBoolExpression(expression) {
}
return false;
}
exports.isBoolExpression = isBoolExpression;
function isCompareExpression(expression) {
if (Object.keys(expression).length == 1) {
const op = Object.keys(expression)[0];
@ -94,7 +101,6 @@ function isCompareExpression(expression) {
}
return false;
}
exports.isCompareExpression = isCompareExpression;
function isMathExpression(expression) {
if (Object.keys(expression).length == 1) {
const op = Object.keys(expression)[0];
@ -105,7 +111,6 @@ function isMathExpression(expression) {
}
return false;
}
exports.isMathExpression = isMathExpression;
function isStringExpression(expression) {
if (Object.keys(expression).length == 1) {
const op = Object.keys(expression)[0];
@ -115,7 +120,6 @@ function isStringExpression(expression) {
}
return false;
}
exports.isStringExpression = isStringExpression;
function isAggrExpression(expression) {
if (Object.keys(expression).length == 1) {
const op = Object.keys(expression)[0];
@ -125,17 +129,14 @@ function isAggrExpression(expression) {
}
return false;
}
exports.isAggrExpression = isAggrExpression;
function isExpression(expression) {
return typeof expression === 'object' && Object.keys(expression).length === 1 && Object.keys(expression)[0].startsWith('$');
}
exports.isExpression = isExpression;
function opMultipleParams(op) {
return !['$year', '$month', '$weekday', '$weekOfYear', '$day', '$dayOfMonth',
'$dayOfWeek', '$dayOfYear', '$not', '$true', '$false', '$abs',
'$round', '$floor', '$ceil', '$$max', '$$min', '$$sum', '$$avg', '$$count'].includes(op);
}
exports.opMultipleParams = opMultipleParams;
function execOp(op, params) {
switch (op) {
case '$gt': {
@ -350,7 +351,6 @@ function execOp(op, params) {
}
}
}
exports.execOp = execOp;
/**
* 检查一个表达式，并分析其涉及到的属性
* @param expression
@ -391,4 +391,3 @@ function getAttrRefInExpression(expression) {
check(expression);
return result;
}
exports.getAttrRefInExpression = getAttrRefInExpression;

1
lib/utils/SimpleConnector.d.ts vendored
View File

@ -1,4 +1,3 @@
/// <reference types="node" />
import { IncomingHttpHeaders } from "http";
import { SyncContext } from '../store/SyncRowStore';
import { Connector, EntityDict, OakException, OpRecord } from "../types";

1
lib/utils/assert.d.ts vendored
View File

@ -1,4 +1,3 @@
/// <reference types="node" />
/**
* 防止assert打包体积过大，从这里引用
*/

3
lib/utils/date.js
View File

@ -1,6 +1,6 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.excelStringToDate = void 0;
exports.excelStringToDate = excelStringToDate;
const tslib_1 = require("tslib");
const dayjs_1 = tslib_1.__importDefault(require("dayjs"));
function excelStringToDate(str) {
@ -15,4 +15,3 @@ function excelStringToDate(str) {
}
return Date.parse(str);
}
exports.excelStringToDate = excelStringToDate;

3
lib/utils/domain.js
View File

@ -1,6 +1,6 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.composeUrl = void 0;
exports.composeUrl = composeUrl;
function composeUrl(url, params) {
const urlSp = new URLSearchParams(params);
if (url.includes('?')) {
@ -8,4 +8,3 @@ function composeUrl(url, params) {
}
return `${url}?${urlSp}`;
}
exports.composeUrl = composeUrl;

3
lib/utils/executor.js
View File

@ -1,6 +1,6 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.pipeline = void 0;
exports.pipeline = pipeline;
/**
*
* @param units 各个执行单元，需要流水线执行，可能是同步也可能是异步
@ -19,4 +19,3 @@ function pipeline(...units) {
};
return exec(0);
}
exports.pipeline = pipeline;

11
lib/utils/geo.js
View File

@ -1,6 +1,10 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.gcj02towgs84 = exports.wgs84togcj02 = exports.gcj02tobd09 = exports.bd09togcj02 = exports.getDistanceBetweenPoints = void 0;
exports.getDistanceBetweenPoints = getDistanceBetweenPoints;
exports.bd09togcj02 = bd09togcj02;
exports.gcj02tobd09 = gcj02tobd09;
exports.wgs84togcj02 = wgs84togcj02;
exports.gcj02towgs84 = gcj02towgs84;
/**
* 计算地球上两点之间的球面距离
*/
@ -21,7 +25,6 @@ function getDistanceBetweenPoints(lat1, lon1, lat2, lon2) {
const d = R * c;
return d * 1000;
}
exports.getDistanceBetweenPoints = getDistanceBetweenPoints;
//定义一些常量
const x_PI = 3.14159265358979324 * 3000.0 / 180.0;
const PI = 3.1415926535897932384626;
@ -71,7 +74,6 @@ function bd09togcj02(coord) {
const gg_lat = z * Math.sin(theta);
return [gg_lng, gg_lat];
}
exports.bd09togcj02 = bd09togcj02;
;
/**
* 火星坐标系 (GCJ-02) 与百度坐标系 (BD-09) 的转换
@ -88,7 +90,6 @@ function gcj02tobd09(coord) {
const bd_lat = z * Math.sin(theta) + 0.006;
return [bd_lng, bd_lat];
}
exports.gcj02tobd09 = gcj02tobd09;
;
/**
* WGS84转GCj02
@ -115,7 +116,6 @@ function wgs84togcj02(coord) {
return [mglng, mglat];
}
}
exports.wgs84togcj02 = wgs84togcj02;
;
/**
* GCJ02 转换为 WGS84
@ -142,5 +142,4 @@ function gcj02towgs84(coord) {
return [lng * 2 - mglng, lat * 2 - mglat];
}
}
exports.gcj02towgs84 = gcj02towgs84;
;

6
lib/utils/lodash.js
View File

@ -1,6 +1,8 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.pullAll = exports.unionBy = exports.groupBy = exports.differenceBy = exports.difference = exports.union = exports.isEqual = exports.pick = exports.cloneDeep = exports.mergeConcatMany = exports.mergeConcatArray = exports.mergeWith = exports.merge = exports.omit = exports.intersectionBy = exports.intersection = exports.set = exports.get = exports.uniqBy = exports.uniq = exports.pull = exports.unset = void 0;
exports.pullAll = exports.unionBy = exports.groupBy = exports.differenceBy = exports.difference = exports.union = exports.isEqual = exports.pick = exports.cloneDeep = exports.mergeWith = exports.merge = exports.omit = exports.intersectionBy = exports.intersection = exports.set = exports.get = exports.uniqBy = exports.uniq = exports.pull = exports.unset = void 0;
exports.mergeConcatArray = mergeConcatArray;
exports.mergeConcatMany = mergeConcatMany;
const tslib_1 = require("tslib");
/**
* 避免lodash打包体积过大
@ -65,11 +67,9 @@ function mergeConcatArray(object, source) {
}
});
}
exports.mergeConcatArray = mergeConcatArray;
function mergeConcatMany(array) {
if (array.length === 0) {
return undefined;
}
return array.reduce((prev, current) => mergeConcatArray(prev, current));
}
exports.mergeConcatMany = mergeConcatMany;

2
lib/utils/module/combine.common.js
View File

@ -1,5 +1,6 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.default = combineBaseModules;
const tslib_1 = require("tslib");
const lodash_1 = require("../../utils/lodash");
const assert_1 = tslib_1.__importDefault(require("assert"));
@ -24,4 +25,3 @@ function combineBaseModules(...modules) {
common: (0, lodash_1.mergeConcatArray)(prev.common, current.common),
}));
}
exports.default = combineBaseModules;

2
lib/utils/module/combine.dev.d.ts vendored
View File

@ -5,7 +5,7 @@ import { EntityDict as BaseEntityDict } from '../../base-app-domain';
import { Aspect, Exportation, Importation, Routine, Timer, Trigger, Watcher } from '../../types';
export default function combineModuleDev<ED extends EntityDict & BaseEntityDict, Cxt extends AsyncContext<ED>, FrontCxt extends SyncContext<ED>>(...modules: string[]): {
aspectDict: Record<string, Aspect<ED, Cxt>>;
data: { [T in keyof ED]?: ED[T]["OpSchema"][] | undefined; };
data: { [T in keyof ED]?: Array<ED[T]["OpSchema"]>; };
importations: Importation<ED, keyof ED, string, Cxt>;
exportations: Exportation<ED, keyof ED, string, Cxt>;
watchers: Watcher<ED, keyof ED, Cxt>[];

2
lib/utils/module/combine.dev.js
View File

@ -1,5 +1,6 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.default = combineModuleDev;
const tslib_1 = require("tslib");
const combine_common_1 = tslib_1.__importDefault(require("./combine.common"));
const lodash_1 = require("../../utils/lodash");
@ -52,4 +53,3 @@ function combineModuleDev(...modules) {
...others,
};
}
exports.default = combineModuleDev;

2
lib/utils/module/combine.prod.js
View File

@ -1,8 +1,8 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.default = combineModuleDev;
const tslib_1 = require("tslib");
const combine_common_1 = tslib_1.__importDefault(require("./combine.common"));
function combineModuleDev(...modules) {
return (0, combine_common_1.default)(...modules);
}
exports.default = combineModuleDev;

2
lib/utils/module/combine.server.d.ts vendored
View File

@ -5,7 +5,7 @@ import { EntityDict as BaseEntityDict } from '../../base-app-domain';
import { Aspect, Exportation, Importation, Routine, Timer, Trigger, Watcher } from '../../types';
export default function combineModuleServer<ED extends EntityDict & BaseEntityDict, Cxt extends AsyncContext<ED>, FrontCxt extends SyncContext<ED>>(...modules: string[]): {
aspectDict: Record<string, Aspect<ED, Cxt>>;
data: { [T in keyof ED]?: ED[T]["OpSchema"][] | undefined; };
data: { [T in keyof ED]?: Array<ED[T]["OpSchema"]>; };
importations: Importation<ED, keyof ED, string, Cxt>;
exportations: Exportation<ED, keyof ED, string, Cxt>;
watchers: Watcher<ED, keyof ED, Cxt>[];

2
lib/utils/module/combine.server.js
View File

@ -1,5 +1,6 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.default = combineModuleServer;
const tslib_1 = require("tslib");
const combine_common_1 = tslib_1.__importDefault(require("./combine.common"));
const lodash_1 = require("../../utils/lodash");
@ -52,4 +53,3 @@ function combineModuleServer(...modules) {
...others,
};
}
exports.default = combineModuleServer;

3
lib/utils/operationResult.js
View File

@ -1,6 +1,6 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.mergeOperationResult = void 0;
exports.mergeOperationResult = mergeOperationResult;
const lodash_1 = require("../utils/lodash");
function mergeOperationResult(result, toBeMerged) {
for (const entity in toBeMerged) {
@ -16,4 +16,3 @@ function mergeOperationResult(result, toBeMerged) {
}
return result;
}
exports.mergeOperationResult = mergeOperationResult;

5
lib/utils/projection.js
View File

@ -1,6 +1,7 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.traverseProjection = exports.makeProjection = void 0;
exports.makeProjection = makeProjection;
exports.traverseProjection = traverseProjection;
const Entity_1 = require("../types/Entity");
const relation_1 = require("../store/relation");
function makeProjection(entity, schema) {
@ -13,7 +14,6 @@ function makeProjection(entity, schema) {
}));
return projection;
}
exports.makeProjection = makeProjection;
function traverseProjection(entity, schema, projection, callback) {
const access = (entity2, proj) => {
callback(entity2, proj);
@ -32,4 +32,3 @@ function traverseProjection(entity, schema, projection, callback) {
};
access(entity, projection);
}
exports.traverseProjection = traverseProjection;

3
lib/utils/random/random.js
View File

@ -1,6 +1,6 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.getRandomValues = void 0;
exports.getRandomValues = getRandomValues;
const node_crypto_1 = require("node:crypto");
async function getRandomValues(length) {
if (length > 65536) {
@ -16,4 +16,3 @@ async function getRandomValues(length) {
});
});
}
exports.getRandomValues = getRandomValues;

3
lib/utils/random/random.mp.js
View File

@ -1,7 +1,7 @@
"use strict";
/// <reference types="wechat-miniprogram" />
Object.defineProperty(exports, "__esModule", { value: true });
exports.getRandomValues = void 0;
exports.getRandomValues = getRandomValues;
async function getRandomValues(length) {
if (length > 65536) {
throw new Error('Can only request a maximum of 65536 bytes');
@ -11,4 +11,3 @@ async function getRandomValues(length) {
});
return new Uint8Array(randomValues);
}
exports.getRandomValues = getRandomValues;

3
lib/utils/random/random.native.js
View File

@ -1,6 +1,6 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.getRandomValues = void 0;
exports.getRandomValues = getRandomValues;
const tslib_1 = require("tslib");
const crypto_1 = tslib_1.__importDefault(require("crypto"));
async function getRandomValues(length) {
@ -11,4 +11,3 @@ async function getRandomValues(length) {
return new Uint8Array(randomValues);
;
}
exports.getRandomValues = getRandomValues;

3
lib/utils/random/random.web.js
View File

@ -1,6 +1,6 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.getRandomValues = void 0;
exports.getRandomValues = getRandomValues;
async function getRandomValues(length) {
if (length > 65536) {
throw new Error('Can only request a maximum of 65536 bytes');
@ -8,4 +8,3 @@ async function getRandomValues(length) {
const randomValues = window.crypto.getRandomValues(new Uint8Array(length));
return new Uint8Array(randomValues);
}
exports.getRandomValues = getRandomValues;

7
lib/utils/relationPath.js
View File

@ -1,6 +1,8 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.destructDirectPath = exports.destructDirectUserPath = exports.destructRelationPath = void 0;
exports.destructRelationPath = destructRelationPath;
exports.destructDirectUserPath = destructDirectUserPath;
exports.destructDirectPath = destructDirectPath;
const tslib_1 = require("tslib");
const assert_1 = tslib_1.__importDefault(require("assert"));
const relation_1 = require("../store/relation");
@ -106,7 +108,6 @@ function destructRelationPath(schema, entity, path, relationFilter, recursive) {
};
return makeIter(entity, 0);
}
exports.destructRelationPath = destructRelationPath;
/**
* 根据entity的相对path，找到其根结点以及相应的user对象
* @param schema
@ -131,7 +132,6 @@ function destructDirectUserPath(schema, entity, path) {
}
};
}
exports.destructDirectUserPath = destructDirectUserPath;
/**
* 根据entity的相对path，找到对应的根结点对象数据行
* @param schema
@ -270,4 +270,3 @@ function destructDirectPath(schema, entity, path) {
};
return makeIter(entity, 0);
}
exports.destructDirectPath = destructDirectPath;

5
lib/utils/row.js
View File

@ -1,6 +1,7 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.compareRows = exports.compareRow = void 0;
exports.compareRow = compareRow;
exports.compareRows = compareRows;
const tslib_1 = require("tslib");
const lodash_1 = require("./lodash");
const relation_1 = require("../store/relation");
@ -49,7 +50,6 @@ function compareRow(schema, entity, row1, row2) {
}
return true;
}
exports.compareRow = compareRow;
/**
* 比较两行数据是否完全相等
* @param entity
@ -72,4 +72,3 @@ function compareRows(schema, entity, rows1, rows2) {
}
return true;
}
exports.compareRows = compareRows;

8
lib/utils/string.js
View File

@ -1,14 +1,15 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.unescapeUnicode = exports.randomPrefixedString = exports.random = exports.template = exports.firstLetterUpperCase = exports.firstLetterLowerCase = void 0;
exports.randomPrefixedString = exports.random = exports.template = void 0;
exports.firstLetterLowerCase = firstLetterLowerCase;
exports.firstLetterUpperCase = firstLetterUpperCase;
exports.unescapeUnicode = unescapeUnicode;
function firstLetterLowerCase(s) {
return s.slice(0, 1).toLowerCase().concat(s.slice(1));
}
exports.firstLetterLowerCase = firstLetterLowerCase;
function firstLetterUpperCase(s) {
return s.slice(0, 1).toUpperCase().concat(s.slice(1));
}
exports.firstLetterUpperCase = firstLetterUpperCase;
/**
* 模板字符串 使用 定义const NotFilled = template`${0}未填写`; 调用NotFilled('姓名') 等于姓名未填写
* @param strings
@ -65,5 +66,4 @@ function unescapeUnicode(str) {
return String.fromCharCode(parseInt(match.replace(/\\u/g, ''), 16));
});
}
exports.unescapeUnicode = unescapeUnicode;
;

1
lib/utils/url/index.d.ts vendored
View File

@ -1,4 +1,3 @@
/// <reference types="node" />
import { URL, URLSearchParams } from 'node:url';
import type { UrlObject } from 'node:url';
declare const url: typeof URL;

7
lib/utils/url/index.native.d.ts vendored
View File

@ -1,12 +1,13 @@
declare const url: {
new (url: string | URL, base?: string | URL | undefined): URL;
new (url: string | URL, base?: string | URL): URL;
prototype: URL;
canParse(url: string | URL, base?: string | undefined): boolean;
canParse(url: string | URL, base?: string | URL): boolean;
createObjectURL(obj: Blob | MediaSource): string;
parse(url: string | URL, base?: string | URL): URL | null;
revokeObjectURL(url: string): void;
};
declare const urlSearchParams: {
new (init?: string | string[][] | Record<string, string> | URLSearchParams | undefined): URLSearchParams;
new (init?: string[][] | Record<string, string> | string | URLSearchParams): URLSearchParams;
prototype: URLSearchParams;
};
export { url, urlSearchParams };

7
lib/utils/url/index.web.d.ts vendored
View File

@ -1,12 +1,13 @@
declare const url: {
new (url: string | URL, base?: string | URL | undefined): URL;
new (url: string | URL, base?: string | URL): URL;
prototype: URL;
canParse(url: string | URL, base?: string | undefined): boolean;
canParse(url: string | URL, base?: string | URL): boolean;
createObjectURL(obj: Blob | MediaSource): string;
parse(url: string | URL, base?: string | URL): URL | null;
revokeObjectURL(url: string): void;
};
declare const urlSearchParams: {
new (init?: string | string[][] | Record<string, string> | URLSearchParams | undefined): URLSearchParams;
new (init?: string[][] | Record<string, string> | string | URLSearchParams): URLSearchParams;
prototype: URLSearchParams;
};
export { url, urlSearchParams };

9
lib/utils/url/whatwg-url/lib/infra.js
View File

@ -1,22 +1,21 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.isASCIIHex = exports.isASCIIAlphanumeric = exports.isASCIIAlpha = exports.isASCIIDigit = void 0;
exports.isASCIIDigit = isASCIIDigit;
exports.isASCIIAlpha = isASCIIAlpha;
exports.isASCIIAlphanumeric = isASCIIAlphanumeric;
exports.isASCIIHex = isASCIIHex;
function isASCIIDigit(c) {
return c >= 0x30 && c <= 0x39;
}
exports.isASCIIDigit = isASCIIDigit;
function isASCIIAlpha(c) {
return (c >= 0x41 && c <= 0x5A) || (c >= 0x61 && c <= 0x7A);
}
exports.isASCIIAlpha = isASCIIAlpha;
function isASCIIAlphanumeric(c) {
return isASCIIAlpha(c) || isASCIIDigit(c);
}
exports.isASCIIAlphanumeric = isASCIIAlphanumeric;
function isASCIIHex(c) {
return isASCIIDigit(c) || (c >= 0x41 && c <= 0x46) || (c >= 0x61 && c <= 0x66);
}
exports.isASCIIHex = isASCIIHex;
exports.default = {
isASCIIDigit,
isASCIIAlpha,

1
lib/utils/url/whatwg-url/lib/urlencoded.d.ts vendored
View File

@ -1,4 +1,3 @@
/// <reference types="node" />
import { Buffer } from 'buffer';
declare function percentEncode(c: number): string;
declare function percentDecode(input: Buffer): Buffer;

2
lib/utils/url/whatwg-url/lib/utils.d.ts vendored
View File

@ -1,4 +1,4 @@
declare function isObject(value: null): boolean;
declare function isObject(value: null): value is never;
declare function hasOwn(obj: any, prop: PropertyKey): boolean;
declare function getSameObject(wrapper: any, prop: string, creator: () => any): any;
declare function wrapperForImpl(impl: any): any;

21
lib/utils/uuid.js
View File

@ -1,6 +1,15 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.decompressFrom32 = exports.compressTo32 = exports.formUuid = exports.generateNewId = exports.setGenerateIdOption = exports.produceIds = exports.generateNewIdAsync = exports.expandUuidTo36Bytes = exports.shrinkUuidTo32Bytes = exports.sequentialUuid = void 0;
exports.sequentialUuid = sequentialUuid;
exports.shrinkUuidTo32Bytes = shrinkUuidTo32Bytes;
exports.expandUuidTo36Bytes = expandUuidTo36Bytes;
exports.generateNewIdAsync = generateNewIdAsync;
exports.produceIds = produceIds;
exports.setGenerateIdOption = setGenerateIdOption;
exports.generateNewId = generateNewId;
exports.formUuid = formUuid;
exports.compressTo32 = compressTo32;
exports.decompressFrom32 = decompressFrom32;
// import { v4 } from 'uuid';
const random_1 = require("./random/random");
let _nodeId;
@ -100,15 +109,12 @@ function sequentialUuid({ random }) {
}
return unsafeStringify(b);
}
exports.sequentialUuid = sequentialUuid;
function shrinkUuidTo32Bytes(uuid) {
return uuid.replace(/\-/g, '');
}
exports.shrinkUuidTo32Bytes = shrinkUuidTo32Bytes;
function expandUuidTo36Bytes(uuidShrinked) {
return `${uuidShrinked.slice(0, 8)}-${uuidShrinked.slice(8, 12)}-${uuidShrinked.slice(12, 16)}-${uuidShrinked.slice(16, 20)}-${uuidShrinked.slice(20)}`;
}
exports.expandUuidTo36Bytes = expandUuidTo36Bytes;
// 直接生成uuid的接口，为了适配各种环境，写成异步
async function generateNewIdAsync(option) {
const option2 = option || ID_OPTION;
@ -117,7 +123,6 @@ async function generateNewIdAsync(option) {
} */
return sequentialUuid({ random: await (0, random_1.getRandomValues)(16) });
}
exports.generateNewIdAsync = generateNewIdAsync;
// 实现同步的id缓存接口，以便于前台使用
const ID_BUFFER = [];
let ID_OPTION = {};
@ -127,14 +132,12 @@ async function produceIds() {
ID_BUFFER.push(await generateNewIdAsync());
}
}
exports.produceIds = produceIds;
produceIds();
function setGenerateIdOption(option) {
ID_OPTION = option;
ID_BUFFER.splice(0, ID_BUFFER.length);
return produceIds();
}
exports.setGenerateIdOption = setGenerateIdOption;
function generateNewId() {
if (ID_BUFFER.length > 0) {
const id = ID_BUFFER.pop();
@ -156,7 +159,6 @@ function generateNewId() {
return sequentialUuid({ random });
}
}
exports.generateNewId = generateNewId;
function stringToArrayBuffer(str) {
var bytes = new Array();
var len, c;
@ -215,11 +217,9 @@ function formUuid(...input) {
} while (i < 16);
return unsafeStringify(b);
}
exports.formUuid = formUuid;
function compressTo32(uuid) {
return uuid.replace(/-/g, '');
}
exports.compressTo32 = compressTo32;
function decompressFrom32(compressed) {
return [
compressed.slice(0, 8),
@ -229,4 +229,3 @@ function decompressFrom32(compressed) {
compressed.slice(20)
].join('-');
}
exports.decompressFrom32 = decompressFrom32;

6
lib/utils/validator.js
View File

@ -3,7 +3,9 @@
*/
'use strict';
Object.defineProperty(exports, "__esModule", { value: true });
exports.checkAttributesScope = exports.checkAttributesNotNull = exports.isEmail = exports.isVehicleNumber = exports.isMoney = exports.isNumber = exports.isTel = exports.isPhone = exports.isDigital = exports.isSizedCaptcha = exports.isNickname = exports.isUrl = exports.isSoldierNumber = exports.isBirthNumber = exports.isTwCardNumber = exports.isAmCardNumber = exports.isHkCardNumber = exports.isPassportNumber = exports.isIdCardNumber = exports.isCaptcha = exports.isPassword = exports.isMobile = void 0;
exports.isEmail = exports.isVehicleNumber = exports.isMoney = exports.isNumber = exports.isTel = exports.isPhone = exports.isDigital = exports.isSizedCaptcha = exports.isNickname = exports.isUrl = exports.isSoldierNumber = exports.isBirthNumber = exports.isTwCardNumber = exports.isAmCardNumber = exports.isHkCardNumber = exports.isPassportNumber = exports.isIdCardNumber = exports.isCaptcha = exports.isPassword = exports.isMobile = void 0;
exports.checkAttributesNotNull = checkAttributesNotNull;
exports.checkAttributesScope = checkAttributesScope;
const types_1 = require("../types");
const isMobile = (text) => {
return ((text) && (typeof text === "string") && ((/^1[3|4|5|6|7|8|9]\d{9}$/.test(text))));
@ -122,7 +124,6 @@ function checkAttributesNotNull(entity, data, attributes, allowEmpty) {
throw new types_1.OakAttrNotNullException(entity, attrs, 'error::attributesNull');
}
}
exports.checkAttributesNotNull = checkAttributesNotNull;
;
function checkAttributesScope(entity, data, attributes) {
const attrs = attributes.filter(attr => !data.hasOwnProperty(attr));
@ -130,4 +131,3 @@ function checkAttributesScope(entity, data, attributes) {
throw new types_1.OakInputIllegalException(entity, attrs, 'error::attributesCantUpdate');
}
}
exports.checkAttributesScope = checkAttributesScope;

5
lib/utils/version.js
View File

@ -1,6 +1,7 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.isVersion = exports.compareVersion = void 0;
exports.compareVersion = compareVersion;
exports.isVersion = isVersion;
/**
* 版本比较
* @param curVersion 当前版本
@ -18,7 +19,6 @@ function compareVersion(curVersion, reqVersion) {
}
return 0;
}
exports.compareVersion = compareVersion;
;
/**
* 是不是一个有效的版本号
@ -28,4 +28,3 @@ exports.compareVersion = compareVersion;
function isVersion(version) {
return /([1-9][0-9]*|[0-9])\.([1-9][0-9]*|[0-9])*\.([1-9][0-9]*|[0-9])*(\-[0-9A-Za-z-](\.[0-9A-Za-z-])*)*/g.test(version);
}
exports.isVersion = isVersion;

5
src/compiler/schemalBuilder.ts
View File

@ -8806,6 +8806,11 @@ function outputStyleDict(outputDir: string, printer: ts.Printer) {
writeFileSync(filename, result, { flag: 'w' });
}
export const analyzeEntitiesExternal = (inputDir: string, relativePath?: string): typeof Schema => {
analyzeEntities(inputDir, relativePath);
return Schema;
}
export function analyzeEntities(inputDir: string, relativePath?: string) {
const files = readdirSync(inputDir);
const fullFilenames = files.map(