api/consensus: validator proposed blocks endpoint

.changelog/764.feature.md

@@ -0,0 +1 @@
+api/consensus: support filtering blocks by proposer

api/spec/v1.yaml

@@ -191,6 +191,11 @@ paths:
             type: string
           description: A filter on the block hash.
           example: *block_hash_1
+        - in: query
+          name: proposed_by
+          schema:
+            allOf: [$ref: '#/components/schemas/StakingAddress']
+          description: A filter on the proposer of the block.
       responses:
         '200':
           description: A JSON object containing a list of consensus blocks.

storage/client/client.go

@@ -310,6 +310,7 @@ func (c *StorageClient) Blocks(ctx context.Context, r apiTypes.GetConsensusBlock
 		r.After,
 		r.Before,
 		hash,
+		r.ProposedBy,
 		r.Limit,
 		r.Offset,
 	)

storage/client/queries/queries.go

@@ -56,10 +56,16 @@ const (
 			($2::bigint IS NULL OR height <= $2::bigint) AND
 			($3::timestamptz IS NULL OR time >= $3::timestamptz) AND
 			($4::timestamptz IS NULL OR time < $4::timestamptz) AND
-			($5::text IS NULL OR block_hash = $5::text)
+			($5::text IS NULL OR block_hash = $5::text) AND
+			($6::text IS NULL OR proposer_entity_id = (
+				SELECT id
+				FROM chain.entities
+				WHERE address = $6::text
+				LIMIT 1
+			))
 		ORDER BY height DESC
-		LIMIT $6::bigint
-		OFFSET $7::bigint`
+		LIMIT $7::bigint
+		OFFSET $8::bigint`
 
 	Block = `
 		SELECT height, block_hash, time, num_txs, gas_limit, size_limit, epoch, state_root