Add configurable start height for tendermint chains to hubble (#1952)

unionlabs · May 31, 2024 · c195d8c · c195d8c
2 parents 2bc16dd + 355fb7c
commit c195d8c
Show file tree

Hide file tree

Showing 9 changed files with 246 additions and 104 deletions.
diff --git a/dictionary.txt b/dictionary.txt
@@ -1,4 +1,3 @@
-
 0xbonlulu
 0xc0dejug
 0xkaiserkarel
@@ -526,6 +525,7 @@ hlist
 hmac
 holiman
 horcrux
+httpie
 httptemplate
 hxtmjjsrmzsjyc
 hypertable

diff --git a/flake.nix b/flake.nix
@@ -489,6 +489,7 @@
               openssl
               pkg-config
               protobuf
+              httpie
               self'.packages.tdc
               self'.packages.voy-send-msg
               yq

diff --git a/...a8dfa1a6cc39b88776080d3a082e33955fe2.json → ...c8a7a16514352cdb7319816d49dd5a8b0df1.json b/...a8dfa1a6cc39b88776080d3a082e33955fe2.json → ...c8a7a16514352cdb7319816d49dd5a8b0df1.json
diff --git a/...7bb4555f1fcefdfb7dcd015c01ec1b1a2019.json → ...45d2f5ea907b8343e14fe1b78fb2cd44d929.json b/...7bb4555f1fcefdfb7dcd015c01ec1b1a2019.json → ...45d2f5ea907b8343e14fe1b78fb2cd44d929.json
diff --git a/hubble/hubble.nix b/hubble/hubble.nix
@@ -66,8 +66,10 @@
           type = types.listOf (
             types.submodule {
               options.url = mkOption { type = types.str; example = "https://rpc.example.com"; };
+              options.grpc_url = mkOption { type = types.nullOr types.str; example = "https://grpc.example.com"; default = null; };
               options.type = mkOption { type = types.enum [ "tendermint" "ethereum" ]; };
-              options.start = mkOption { type = types.int; example = 1; default = 0; };
+              options.start_height = mkOption { type = types.int; example = 1; default = 0; };
+              options.chunk_size = mkOption { type = types.int; example = 1; default = 200; };
               options.until = mkOption { type = types.int; example = 1; default = 1000000000000; };
               options.harden = mkOption { type = types.bool; example = true; default = true; };
             }
@@ -109,10 +111,14 @@
           {
             wantedBy = [ "multi-user.target" ];
             description = "Hubble";
+            unitConfig = {
+              StartLimitIntervalSec = mkForce 0;
+            };
             serviceConfig = {
               Type = "simple";
               ExecStart = pkgs.lib.getExe hubble-systemd-script;
               Restart = mkForce "always";
+              RestartSec = mkForce 3;
             };
             environment = {
               RUST_LOG = "${cfg.log-level}";

diff --git a/hubble/src/chain_id_query.rs b/hubble/src/chain_id_query.rs
@@ -47,7 +47,7 @@ pub async fn tx(db: PgPool, indexers: Indexers) {
                     SELECT
                         cl.client_id, ch.id
                     FROM
-                        v0.create_clients cl
+                        v0_cosmos.create_client cl
                     JOIN
                         v0.chains ch
                     ON
@@ -165,7 +165,7 @@ pub async fn tx(db: PgPool, indexers: Indexers) {
                     SELECT
                         cl.transaction_hash, cl.client_id, ch.id
                     FROM
-                        v0.evm_client_created cl
+                        v0_evm.client_created cl
                     JOIN
                         v0.chains ch
                     ON