Few changes to postgres dataapi

blocknative · Mar 22, 2023 · ca7a70b · ca7a70b
1 parent 20e8aa3
commit ca7a70b
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 5 deletions.
diff --git a/datastore/evidence/postgres/blocks.go b/datastore/evidence/postgres/blocks.go
@@ -48,7 +48,7 @@ func (s *Datastore) GetBuilderBlockSubmissions(ctx context.Context, headSlot uin
 		i++
 	}
 
-	if payload.BlockHash != [32]byte{} {
+	if payload.BlockHash != Emptybytes32 {
 		parts = append(parts, "block_hash = $"+strconv.Itoa(i))
 		data = append(data, payload.BlockHash.String())
 		i++

diff --git a/datastore/evidence/postgres/payload.go b/datastore/evidence/postgres/payload.go
@@ -50,9 +50,9 @@ func (s *Datastore) GetDeliveredPayloads(ctx context.Context, headSlot uint64, q
 		i++
 	}
 
-	if queryArgs.BlockHash != [32]byte{} {
+	if queryArgs.BlockHash != Emptybytes32 {
 		parts = append(parts, "block_hash = $"+strconv.Itoa(i))
-		data = append(data, queryArgs.BlockHash)
+		data = append(data, queryArgs.BlockHash.String())
 		i++
 	}
 
@@ -62,8 +62,8 @@ func (s *Datastore) GetDeliveredPayloads(ctx context.Context, headSlot uint64, q
 		i++
 	}
 
-	if queryArgs.Pubkey.String() != "" {
-		parts = append(parts, "builder_pubkey = $"+strconv.Itoa(i))
+	if queryArgs.Pubkey != Emptybytes48 {
+		parts = append(parts, "proposer_pubkey = $"+strconv.Itoa(i))
 		data = append(data, queryArgs.Pubkey.String())
 		i++
 	}

diff --git a/datastore/evidence/postgres/postgres.go b/datastore/evidence/postgres/postgres.go
@@ -4,6 +4,11 @@ import (
 	"database/sql"
 )
 
+var (
+	Emptybytes32 = [32]byte{}
+	Emptybytes48 = [48]byte{}
+)
+
 var SlotsPerEpoch = 32
 
 type Datastore struct {