Oak-Team
/
oak-memory-tree-store
13
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 9 Wiki Activity

一个小笔误，以及加上了store的commit次数信息

This commit is contained in:
Xu Chang 2022-04-18 16:14:37 +08:00
parent 6f9abca130
commit 7e6ab43b00
1 changed files with 33 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
src/store.ts
View File

@ -1,4 +1,4 @@
import { assign, cloneDeep, get, last, set, unset } from 'lodash';
import { assign, cloneDeep, get, keys, last, set, unset } from 'lodash';
import assert from 'assert';
import { SelectionResult2, DeduceCreateSingleOperation, DeduceFilter, DeduceSelection, EntityShape, DeduceRemoveOperation, DeduceUpdateOperation, DeduceSorter, DeduceSorterAttr, OperationResult, OperateParams, OpRecord, DeduceCreateOperationData, DeduceUpdateOperationData, UpdateOpResult, RemoveOpResult, SelectOpResult, EntityDict, SelectRowShape } from "oak-domain/lib/types/Entity";
import { ExpressionKey, EXPRESSION_PREFIX, NodeId, RefAttr } from 'oak-domain/lib/types/Demand';
@ -27,13 +27,12 @@ function obscurePass(row: any, attr: string, params: OperateParams): boolean {
}
export default class TreeStore<ED extends EntityDict> extends CascadeStore<ED> {
store: {
private store: {
[T in keyof ED]?: {
[ID: string]: RowNode;
};
};
immutable: boolean;
activeTxnDict: {
private activeTxnDict: {
[T: string]: {
nodeHeader?: RowNode;
create: number;
@ -41,6 +40,12 @@ export default class TreeStore<ED extends EntityDict> extends CascadeStore<ED> {
remove: number;
};
};
private stat: {
create: number;
update: number;
remove: number;
commit: number;
};
setInitialData(data: {
[T in keyof ED]?: {
@ -52,7 +57,7 @@ export default class TreeStore<ED extends EntityDict> extends CascadeStore<ED> {
this.store[entity] = {};
}
for (const rowId in data[entity]) {
set(this.store, `${entity}.${rowId}.#current`, data[entity]![rowId]);
set(this.store, `${entity}.${rowId}.$current`, data[entity]![rowId]);
}
}
}
@ -76,18 +81,28 @@ export default class TreeStore<ED extends EntityDict> extends CascadeStore<ED> {
return result;
}
constructor(storageSchema: StorageSchema<ED>, immutable: boolean = false, initialData?: {
constructor(storageSchema: StorageSchema<ED>, initialData?: {
[T in keyof ED]?: {
[ID: string]: ED[T]['OpSchema'];
};
}, stat?: {
create: number;
update: number;
remove: number;
commit: number;
}) {
super(storageSchema);
this.immutable = immutable;
this.store = {};
if (initialData) {
this.setInitialData(initialData);
}
this.activeTxnDict = {};
this.stat = stat || {
create: 0,
update: 0,
remove: 0,
commit: 0,
};
}
private constructRow(node: RowNode, context: Context<ED>) {
@ -1104,6 +1119,10 @@ export default class TreeStore<ED extends EntityDict> extends CascadeStore<ED> {
txnNode[action]++;
}
getStat() {
return this.stat;
}
async begin() {
const uuid = v4({ random: await getRandomValues(16) })
assert(!this.activeTxnDict.hasOwnProperty(uuid));
@ -1138,6 +1157,13 @@ export default class TreeStore<ED extends EntityDict> extends CascadeStore<ED> {
}
node = node2;
}
if (this.activeTxnDict[uuid].create || this.activeTxnDict[uuid].update || this.activeTxnDict[uuid].remove) {
this.stat.create += this.activeTxnDict[uuid].create;
this.stat.update += this.activeTxnDict[uuid].update;
this.stat.remove += this.activeTxnDict[uuid].remove;
this.stat.commit ++;
}
unset(this.activeTxnDict, uuid);
}