Merge pull request #128 from KenshiTech/feat/refine-consensus

Feat/refine consensus
TimeleapLabs · Apr 15, 2024 · 19830ed · 19830ed
2 parents ab4ddd5 + 5bfffd3
commit 19830ed
Show file tree

Hide file tree

Showing 38 changed files with 2,843 additions and 288 deletions.
diff --git a/internal/app/consumer.go b/internal/app/consumer.go
@@ -34,7 +34,7 @@ func Consumer() {
 	pos := pos.New(ethRPC)
 	db.Start()
 
-	correctnessService := correctnessService.New(ethRPC)
+	correctnessService := correctnessService.New(ethRPC, pos)
 	evmLogService := evmlogService.New(ethRPC, pos)
 	uniswapService := uniswapService.New(ethRPC, pos)
 

diff --git a/internal/datasets/bls.go b/internal/datasets/bls.go
@@ -15,14 +15,12 @@ type Signer struct {
 type Signature struct {
 	Signature bls12381.G1Affine
 	Signer    Signer
-	Processed bool
 }
 
 func (s *Signature) Sia() *sia.Sia {
 	return new(sia.Sia).
 		AddByteArray8(s.Signature.Marshal()).
-		EmbedSia(s.Signer.Sia()).
-		AddBool(s.Processed)
+		EmbedSia(s.Signer.Sia())
 }
 
 func (s *Signature) DeSia(sia *sia.Sia) *Signature {
@@ -33,7 +31,6 @@ func (s *Signature) DeSia(sia *sia.Sia) *Signature {
 	}
 
 	s.Signer.DeSia(sia)
-	s.Processed = sia.ReadBool()
 
 	return s
 }

diff --git a/internal/ent/assetprice.go b/internal/ent/assetprice.go
diff --git a/internal/ent/assetprice/assetprice.go b/internal/ent/assetprice/assetprice.go
diff --git a/internal/ent/assetprice/where.go b/internal/ent/assetprice/where.go
diff --git a/internal/ent/assetprice_create.go b/internal/ent/assetprice_create.go