Add absent parameter to GET /v2/blocks

AlgoNode · Oct 18, 2024 · 92b57ad · 92b57ad
1 parent 56adbcd
commit 92b57ad
Show file tree

Hide file tree

Showing 11 changed files with 494 additions and 415 deletions.
diff --git a/api/converter_utils.go b/api/converter_utils.go
@@ -860,6 +860,15 @@ func (si *ServerImplementation) blockParamsToBlockFilter(params generated.Search
 				filter.ExpiredParticipationAccounts[addr] = struct{}{}
 			}
 		}
+
+		filter.AbsentParticipationAccounts = make(map[sdk.Address]struct{}, 0)
+		if params.Absent != nil {
+			for _, s := range *params.Absent {
+				var addr sdk.Address
+				addr, errorArr = decodeSdkAddress(s, "absent", errorArr)
+				filter.AbsentParticipationAccounts[addr] = struct{}{}
+			}
+		}
 	}
 
 	// If there were any errorArr while setting up the BlockFilter, return now.

diff --git a/api/generated/common/routes.go b/api/generated/common/routes.go
diff --git a/api/generated/common/types.go b/api/generated/common/types.go
diff --git a/api/generated/v2/routes.go b/api/generated/v2/routes.go
diff --git a/api/generated/v2/types.go b/api/generated/v2/types.go
diff --git a/api/indexer.oas2.json b/api/indexer.oas2.json
@@ -890,6 +890,9 @@
           },
           {
             "$ref": "#/parameters/expired"
+          },
+          {
+            "$ref": "#/parameters/absent"
           }
         ],
         "responses": {
@@ -2732,6 +2735,17 @@
     }
   },
   "parameters": {
+    "absent": {
+      "type": "array",
+      "items": {
+        "type": "string",
+        "x-algorand-format": "Address"
+      },
+      "description": "Absent participation accounts. Comma separated list of addresses.",
+      "name": "absent",
+      "in": "query",
+      "required": false
+    },
     "expired": {
       "type": "array",
       "items": {

diff --git a/api/indexer.oas3.yml b/api/indexer.oas3.yml
@@ -1,6 +1,20 @@
 {
   "components": {
     "parameters": {
+      "absent": {
+        "description": "Absent participation accounts. Comma separated list of addresses.",
+        "explode": false,
+        "in": "query",
+        "name": "absent",
+        "schema": {
+          "items": {
+            "type": "string",
+            "x-algorand-format": "Address"
+          },
+          "type": "array"
+        },
+        "style": "form"
+      },
       "account-id": {
         "description": "account string",
         "in": "path",
@@ -4917,6 +4931,20 @@
               "type": "array"
             },
             "style": "form"
+          },
+          {
+            "description": "Absent participation accounts. Comma separated list of addresses.",
+            "explode": false,
+            "in": "query",
+            "name": "absent",
+            "schema": {
+              "items": {
+                "type": "string",
+                "x-algorand-format": "Address"
+              },
+              "type": "array"
+            },
+            "style": "form"
           }
         ],
         "responses": {

diff --git a/idb/idb.go b/idb/idb.go
@@ -237,6 +237,7 @@ type BlockFilter struct {
 	BeforeTime                   time.Time
 	Proposers                    map[sdk.Address]struct{}
 	ExpiredParticipationAccounts map[sdk.Address]struct{}
+	AbsentParticipationAccounts  map[sdk.Address]struct{}
 }
 
 // TransactionFilter is a parameter object with all the transaction filter options.

diff --git a/idb/postgres/internal/schema/setup_postgres.sql b/idb/postgres/internal/schema/setup_postgres.sql
@@ -7,7 +7,8 @@ CREATE TABLE public.block_header (
     CONSTRAINT block_header_pkey PRIMARY KEY (round ASC),
     INDEX block_header_time (realtime ASC),
     INDEX block_header_idx_proposer (((header->'prp')::TEXT), round) WHERE (header->'prp') IS NOT NULL,
-    INVERTED INDEX block_header_expired ((header->'partupdrmv')) WHERE (header->'partupdrmv' IS NOT NULL)
+    INVERTED INDEX block_header_expired ((header->'partupdrmv')) WHERE (header->'partupdrmv' IS NOT NULL),
+    INVERTED INDEX block_header_absent ((header->'partupdabs')) WHERE (header->'partupdabs' IS NOT NULL)
 );
 
 CREATE TABLE public.txn (

diff --git a/idb/postgres/internal/schema/setup_postgres_sql.go b/idb/postgres/internal/schema/setup_postgres_sql.go
diff --git a/idb/postgres/postgres.go b/idb/postgres/postgres.go
@@ -777,6 +777,16 @@ func buildBlockQuery(bf idb.BlockFilter) (query string, whereArgs []interface{},
 				fmt.Sprintf("( (header->'partupdrmv') IS NOT NULL AND (header->'partupdrmv') ?| array[%s] )", strings.Join(expiredStr, ",")),
 			)
 		}
+		if len(bf.AbsentParticipationAccounts) > 0 {
+			var absentStr []string
+			for addr := range bf.AbsentParticipationAccounts {
+				absentStr = append(absentStr, `'`+addr.String()+`'`)
+			}
+			whereParts = append(
+				whereParts,
+				fmt.Sprintf("( (header->'partupdabs') IS NOT NULL AND (header->'partupdabs') ?| array[%s] )", strings.Join(absentStr, ",")),
+			)
+		}
 	}
 
 	// SELECT, FROM