From 1c19b3823dff8d8c18db7bbc8a423c8cab920c9e Mon Sep 17 00:00:00 2001
From: lightning-li <lightningli0504@gmail.com>
Date: Tue, 5 Nov 2024 17:04:33 +0800
Subject: [PATCH] enhance data source verification and improve prover check
 status script (#82)

---
 check_prover_status.py | 20 ++++++++++----------
 src/utils/utils.go     |  3 +++
 2 files changed, 13 insertions(+), 10 deletions(-)

diff --git a/check_prover_status.py b/check_prover_status.py
index 6d63724..158570a 100644
--- a/check_prover_status.py
+++ b/check_prover_status.py
@@ -21,24 +21,24 @@ def rerun():
 if __name__ == "__main__":
     os.chdir("src/dbtool")
     prev_delta = get_delta()
-    print("prev_delta ", prev_delta)
+    print("prev_delta ", prev_delta, flush=True)
     while True:
         time.sleep(60)
         cur_delta = get_delta()
-        print("cur_delta ", cur_delta)
+        print("cur_delta ", cur_delta, flush=True)
         if prev_delta != cur_delta or prev_delta == 0:
             break
 
     rerun_retry = 0
     while True:
-        time.sleep(5*60)
+        time.sleep(8*60)
         cur_delta = get_delta()
         if prev_delta == 0 or cur_delta == 0:
-            print("all proofs has been generated")
+            print("all proofs has been generated", flush=True)
             break
         if cur_delta == prev_delta:
-            print("there is no new proof generate in 2 minutes, it means all prover finished running")
-            print("there are ", cur_delta, " proofs need to rerun")
+            print("there is no new proof generate in 8 minutes, it means all prover finished running", flush=True)
+            print("there are ", cur_delta, " proofs need to rerun", flush=True)
             os.chdir("../prover")
             rerun()
             os.chdir("../dbtool")
@@ -47,13 +47,13 @@ def rerun():
                 print("rerun successfully")
                 break
             else:
-                print("after rerun, there is still ", delta, " proof, will retry...")
+                print("after rerun, there is still ", delta, " proof, will retry...", flush=True)
                 rerun_retry += 1
                 if rerun_retry > 3:
-                    print("rerun failed too many times, need manually check")
+                    print("rerun failed too many times, need manually check", flush=True)
                     exit(0)
 
-        print("current delta is ", cur_delta, " previous delta is ", prev_delta)
+        print("current delta is ", cur_delta, " previous delta is ", prev_delta, flush=True)
         prev_delta = cur_delta
 
-    print("successfully...")
\ No newline at end of file
+    print("successfully...", flush=True)
\ No newline at end of file
diff --git a/src/utils/utils.go b/src/utils/utils.go
index 5531c58..417676b 100644
--- a/src/utils/utils.go
+++ b/src/utils/utils.go
@@ -421,6 +421,9 @@ func ParseTiersRatioFromStr(tiersRatioEnc string) ([TierCount]TierRatio, error)
 			BoundaryValue: boundaryValueBigInt,
 			Ratio:         uint8(ratio),
 		})
+		if i > 0 && tiersRatio[i].BoundaryValue.Cmp(tiersRatio[i-1].BoundaryValue) <= 0 {
+			return PaddingTierRatios([]TierRatio{}), errors.New("tiers boundry value data wrong")
+		}
 	}
 	CalculatePrecomputedValue(tiersRatio)
 	return PaddingTierRatios(tiersRatio), nil