|
|
@@ -22,10 +22,10 @@ async function run() {
|
|
|
// 读取远程syncevent表
|
|
|
const synceventTB = remoteDB.collection("syncevents");
|
|
|
// get current local slave sync seq (use mongoose)
|
|
|
- let seq = -1;
|
|
|
+ let seq = INIT_SEQ;
|
|
|
let seqDoc = await SyncSeq.findOne();
|
|
|
if (seqDoc) seq = seqDoc.seq;
|
|
|
- else seqDoc = new SyncSeq({seq: INIT_SEQ});
|
|
|
+ else seqDoc = new SyncSeq({seq});
|
|
|
|
|
|
let count, localtb, remotetb, localdoc, remotedoc;
|
|
|
setTimeout(async function cycleRun() {
|
