delay 40s propose txs + check for closed connection on sse event subs…

…cription during connectivityCheck
Smoothly-Protocol · Nov 30, 2023 · a68ae20 · a68ae20
1 parent 13edad7
commit a68ae20
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/src/oracle/oracle.ts b/src/oracle/oracle.ts
@@ -76,7 +76,8 @@ export class Oracle extends Config {
   async checkConnectivity(logs: boolean) {
     try { 
       const switched = await this.switchToBackup(logs);
-      if(switched) {
+      const isClosed = this.event.readyState == EventSource.CLOSED;
+      if(switched || isClosed) {
         this.event.close();
         EpochListener(this);
       }

diff --git a/src/oracle/rebalancer.ts b/src/oracle/rebalancer.ts
@@ -44,7 +44,7 @@ export async function Rebalancer (oracle: Oracle, data: any) {
 export async function proposeEpoch(epochData: any, oracle: Oracle, priority: number): Promise<void> {
   try {
     // Random priority to avoid failed tx
-    await setTimeout((priority * 30) * 1000);
+    await setTimeout((priority * 40) * 1000);
 
     // Submit vote 
     const contract = oracle.governance;