Oak-Team
/
oak-backend-base
13
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 18 Wiki Activity

修正了一个变量名

This commit is contained in:
Xu Chang 2024-03-21 14:03:04 +08:00
parent b99886f0f8
commit f2a1b0ee17
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
lib/Synchronizer.js
View File

@ -494,12 +494,12 @@ class Synchronizer {
}
let maxBornAt = this.pullMaxBornAtMap[entityId];
const opers = body;
const outdatedOpers = opers.filter(ele => ele.$$seq$$ <= maxBornAt);
const staleOpers = opers.filter(ele => ele.$$seq$$ <= maxBornAt);
const freshOpers = opers.filter(ele => ele.$$seq$$ > maxBornAt);
await Promise.all([
// 无法严格保证推送按bornAt，所以一旦还有outdatedOpers，检查其已经被apply
(async () => {
const ids = outdatedOpers.map(ele => ele.id);
const ids = staleOpers.map(ele => ele.id);
if (ids.length > 0) {
const opersExisted = await context.select('oper', {
data: {

4
src/Synchronizer.ts
View File

@ -652,7 +652,7 @@ export default class Synchronizer<ED extends EntityDict & BaseEntityDict, Cxt ex
let maxBornAt = this.pullMaxBornAtMap[entityId]!;
const opers = body as ED['oper']['Schema'][];
const outdatedOpers = opers.filter(
const staleOpers = opers.filter(
ele => ele.$$seq$$ <= maxBornAt
);
const freshOpers = opers.filter(
@ -663,7 +663,7 @@ export default class Synchronizer<ED extends EntityDict & BaseEntityDict, Cxt ex
[
// 无法严格保证推送按bornAt，所以一旦还有outdatedOpers，检查其已经被apply
(async () => {
const ids = outdatedOpers.map(
const ids = staleOpers.map(
ele => ele.id
);
if (ids.length > 0) {