feat(indexer-service): Sender denylist (#109)

* feat(indexer-service): Sender denylist indexer-service will reject all paid queries from denied senders. Denylist DB table updates are watched through PG notifications. Signed-off-by: Alexis Asseman <[email protected]> * refactor: cleaner sender_denylist_watcher shutdown Signed-off-by: Alexis Asseman <[email protected]> * refactor: remove unnecessary Arc on CancellationToken Signed-off-by: Alexis Asseman <[email protected]> * fix: proper signers support after #110 Signed-off-by: Alexis Asseman <[email protected]> --------- Signed-off-by: Alexis Asseman <[email protected]>
graphprotocol · Jan 23, 2024 · be4ad96 · be4ad96
1 parent 36a73a9
commit be4ad96
Show file tree

Hide file tree

Showing 9 changed files with 329 additions and 23 deletions.
diff --git a/.sqlx/query-019bf1fa6c038ad1027e2b67a949d67ae9dd5fbc3f3e0091f127c95264319e63.json b/.sqlx/query-019bf1fa6c038ad1027e2b67a949d67ae9dd5fbc3f3e0091f127c95264319e63.json
diff --git a/.sqlx/query-48e85bc0089528df458970d0aeee72f26fad65b8e3cbb706bc17bb7140e47192.json b/.sqlx/query-48e85bc0089528df458970d0aeee72f26fad65b8e3cbb706bc17bb7140e47192.json
diff --git a/.sqlx/query-b5eeb6b9501c2f2ca883040d9f62cc59876e13468b43b3fb5860592918e647f0.json b/.sqlx/query-b5eeb6b9501c2f2ca883040d9f62cc59876e13468b43b3fb5860592918e647f0.json
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/common/Cargo.toml b/common/Cargo.toml
@@ -45,6 +45,7 @@ autometrics = { version = "0.6.0", features = ["prometheus-exporter"] }
 tracing = "0.1.40"
 tower = "0.4.13"
 tower_governor = "0.1.0"
+tokio-util = "0.7.10"
 
 [dev-dependencies]
 env_logger = "0.9.0"

diff --git a/common/src/indexer_service/http/indexer_service.rs b/common/src/indexer_service/http/indexer_service.rs
@@ -288,7 +288,8 @@ impl IndexerService {
                 chain_id: options.config.scalar.chain_id,
                 verifying_contract: options.config.scalar.receipts_verifier_address,
             },
-        );
+        )
+        .await;
 
         let state = Arc::new(IndexerServiceState {
             config: options.config.clone(),