From f56c95c082bcb12ee939778523990b5db11df6d0 Mon Sep 17 00:00:00 2001 From: turtton Date: Wed, 29 Mar 2023 17:27:03 +0900 Subject: [PATCH 1/2] Fixed: - Fixed a problem with transferDoc returning incorrect results --- src/index.ts | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/index.ts b/src/index.ts index 1dcc827..304f8b9 100644 --- a/src/index.ts +++ b/src/index.ts @@ -369,6 +369,7 @@ async function eachProc(syncKey: string, config: eachConf) { while (running[syncKey]) { await delay(100); } + let result = true; try { running[syncKey] = true; if (isKnownFile(syncKey, fromDoc._id, fromDoc._rev)) { @@ -395,11 +396,12 @@ async function eachProc(syncKey: string, config: eachConf) { } catch (ex) { log("Exception on transfer doc"); log(ex); + result = false; } } finally { running[syncKey] = false; } - return false; + return result; } if (config.sync_on_connect || config.server.initialScan) { From 95ad220f30a58bd4608c7e33500c96408d419b52 Mon Sep 17 00:00:00 2001 From: turtton Date: Wed, 29 Mar 2023 17:31:16 +0900 Subject: [PATCH 2/2] Improved: - Hide `stderr` log when processors exit without error --- src/index.ts | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/index.ts b/src/index.ts index 304f8b9..5ec4739 100644 --- a/src/index.ts +++ b/src/index.ts @@ -82,7 +82,10 @@ async function runEngine() { log(`Failed! Reason:${result.reason}`); } else { log(`OK: stdout:${result.value.stdout}`); - log(`OK: stderr:${result.value.stderr}`); + const stderr = result.value.stderr; + if (stderr !== "") { + log(`OK: stderr:${stderr}`); + } } } }