diff --git a/kvdb_stage_demo/entry/src/main/ets/MainAbility/MainAbility.ts b/kvdb_stage_demo/entry/src/main/ets/MainAbility/MainAbility.ts index fcaa9d3742b5ab6c8204b9502bc6a084a57bd389..3b7217c7c2e0658671b7d4f5360eafa3c18c0f8f 100644 --- a/kvdb_stage_demo/entry/src/main/ets/MainAbility/MainAbility.ts +++ b/kvdb_stage_demo/entry/src/main/ets/MainAbility/MainAbility.ts @@ -295,7 +295,13 @@ export default class MainAbility extends Ability { var devices = this.deviceList; console.info('[JSDemo] Sync start'); this.logText += "Sync start\r\n"; - this.kvStore.sync(devices, globalThis.syncMode); + try{ + this.kvStore.sync(devices, globalThis.syncMode); + }catch (e){ + console.info('[JSDemo] Sync error, err: ' + JSON.stringify(e) + '.'); + this.logText += ("Sync error, err:"+ JSON.stringify(e) +"\r\n"); + } + }) globalThis.DeleteAllData = (() =>{ @@ -324,8 +330,8 @@ export default class MainAbility extends Ability { }); } catch(e) { - console.log("[JSDemo] DeleteAllData err " + e); - this.logText += "DeleteAllData err" +JSON.stringify(e)+ "\r\n"; + console.log("[JSDemo] DeleteAllData err " + JSON.stringify(e)); + this.logText += ("DeleteAllData err" +JSON.stringify(e)+ "\r\n"); } }) @@ -402,12 +408,11 @@ export default class MainAbility extends Ability { this.logText += "RegSyncComplete kvStore is null.\r\n"; return; } - if (!this.syncListenerStarted) { - globalThis.startSyncListener(); - this.logText += "Register syncComplete callback success.\r\n"; - } else { - this.logText += "SyncComplete callback already registed.\r\n"; + if (this.syncListenerStarted) { + this.logText += "SyncComplete callback already registed, now RegSyncComplete again start...\r\n"; } + globalThis.startSyncListener(); + this.logText += "Register syncComplete callback success.\r\n"; }) globalThis.RegDataChange = (() =>{ @@ -418,12 +423,11 @@ export default class MainAbility extends Ability { this.logText += "RegDataChange kvStore is null.\r\n"; return; } - if (!this.dataListenerStarted) { - globalThis.startDataListener(); - this.logText += "Register dataChange callback success.\r\n"; - } else { - this.logText += "DataChange callback already registed.\r\n"; + if (this.dataListenerStarted) { + this.logText += "DataChange callback already registed. now RegDataChange again start...\r\n"; } + globalThis.startDataListener(); + this.logText += "Register dataChange callback success.\r\n"; }) globalThis.printChangeData = ((notification) =>{ @@ -466,8 +470,8 @@ export default class MainAbility extends Ability { }); this.dataListenerStarted = true; }catch(e) { - console.info("[JSDemo] startDataListener err " + e); - that.logText += "startDataListener err ." + e + "\r\n"; + console.info("[JSDemo] startDataListener err " + JSON.stringify(e)); + that.logText += "startDataListener err ." + JSON.stringify(e) + "\r\n"; this.dataListenerStarted = false; } }) @@ -495,8 +499,8 @@ export default class MainAbility extends Ability { }); this.syncListenerStarted = true; }catch(e) { - console.info("[JSDemo] startSyncListener err " + e); - that.logText += "startSyncListener err.\r\n"; + console.info("[JSDemo] startSyncListener err " + JSON.stringify(e)); + that.logText += ("startSyncListener err," + JSON.stringify(e) + ".\r\n"); this.syncListenerStarted = false; } })