bundle: show stale bundle tile in gui

.gitignore

@@ -10,6 +10,7 @@ genhtml/
 target/
 *.lcov
 *.profraw
+*.profdata
 /report
 flamegraph.html
 perf.data

NOTICE

@@ -279,7 +279,7 @@ with this software. If not, see
 
 =======================================================================
 
-'src/flamenco/nanopb' is currently a copy of the Nanopb library at
+'src/ballet/nanopb' is currently a copy of the Nanopb library at
 https://jpa.kapsi.fi/nanopb/ (imported ca 2023-Nov).
 
 Copyright (c) 2011 Petteri Aimonen <jpa at nanopb.mail.kapsi.fi>
@@ -466,3 +466,37 @@ ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
 WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
 ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
 OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
+
+=======================================================================
+
+The fd_h2 library (src/waltz/h2) includes a modified version of the
+HPACK Huffman decoder from nghttp2 (circa 2025-Mar).  Original sources:
+- https://github.com/nghttp2/nghttp2/blob/master/lib/nghttp2_hd.h
+- https://github.com/nghttp2/nghttp2/blob/master/lib/nghttp2_hd_huffman.h
+- https://github.com/nghttp2/nghttp2/blob/master/lib/nghttp2_hd_huffman.c
+- https://github.com/nghttp2/nghttp2/blob/master/lib/nghttp2_hd_huffman_data.c
+
+/*
+ * nghttp2 - HTTP/2 C Library
+ *
+ * Copyright (c) 2013 Tatsuhiro Tsujikawa
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining
+ * a copy of this software and associated documentation files (the
+ * "Software"), to deal in the Software without restriction, including
+ * without limitation the rights to use, copy, modify, merge, publish,
+ * distribute, sublicense, and/or sell copies of the Software, and to
+ * permit persons to whom the Software is furnished to do so, subject to
+ * the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be
+ * included in all copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
+ * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+ * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
+ * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
+ * LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
+ * OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+ * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */

book/api/metrics-generated.md

@@ -149,6 +149,16 @@
 | bundle_​transaction_​received | `counter` | Total count of transactions received, including transactions within bundles |
 | bundle_​packet_​received | `counter` | Total count of packets received |
 | bundle_​bundle_​received | `counter` | Total count of bundles received |
+| bundle_​errors_​protobuf | `counter` | Number of gRPC errors encountered (Protobuf decode/encode error) |
+| bundle_​errors_​transport | `counter` | Number of gRPC errors encountered (Transport error) |
+| bundle_​errors_​timeout | `counter` | Number of gRPC errors encountered (I/O timeout) |
+| bundle_​errors_​no_​fee_​info | `counter` | Number of gRPC errors encountered (Bundle dropped due to missing fee info) |
+| bundle_​errors_​ssl_​alloc | `counter` | Number of gRPC errors encountered (OpenSSL alloc fail) |
+| bundle_​heap_​size | `gauge` | Workspace heap size |
+| bundle_​heap_​free_​bytes | `gauge` | Approx free space in workspace |
+| bundle_​shredstream_​heartbeats | `counter` | Number of ShredStream heartbeats successfully sent |
+| bundle_​keepalives | `counter` | Number of HTTP/2 PINGs acknowledged by server |
+| bundle_​connected | `gauge` | 1 if connected to the bundle server, 0 if not |
 
 ## Verify Tile
 | Metric | Type | Description |

plugin/bundle/test-server/Cargo.toml → contrib/bundle-test-server/Cargo.toml

@@ -3,9 +3,6 @@ name = "bundle-test-server"
 version = "0.1.0"
 edition = "2021"
 
-[[bin]]
-name = "bundlesvr"
-
 [dependencies]
 tonic = { version = "0.12.2", features = ["tls-roots", "tls", "tls-webpki-roots"] }
 prost = "0.13.3"

plugin/bundle/build.rs → contrib/bundle-test-server/build.rs

@@ -24,8 +24,8 @@ fn main() -> Result<(), std::io::Error> {
     }
 
     configure()
-        .build_client(true)
-        .build_server(false)
+        .build_client(false)
+        .build_server(true)
         .type_attribute(
             "TransactionErrorType",
             "#[cfg_attr(test, derive(enum_iterator::Sequence))]",
@@ -34,5 +34,5 @@ fn main() -> Result<(), std::io::Error> {
             "InstructionErrorType",
             "#[cfg_attr(test, derive(enum_iterator::Sequence))]",
         )
-        .compile_protos(&protos, &[proto_base_path])
+        .compile_protos(&protos, &[std::path::PathBuf::from("protos")])
 }

plugin/bundle/test-server/src/bin/bundlesvr.rs → contrib/bundle-test-server/src/main.rs

@@ -1,10 +1,10 @@
 use std::iter;
 use std::pin::Pin;
 
-use bundle_test_server::proto::auth::{self, Token};
-use bundle_test_server::proto::auth::auth_service_server::{AuthService, AuthServiceServer};
-use bundle_test_server::proto::bundle::{Bundle, BundleUuid};
-use bundle_test_server::proto::packet::{Packet, PacketBatch};
+use crate::proto::auth::{self, Token};
+use crate::proto::auth::auth_service_server::{AuthService, AuthServiceServer};
+use crate::proto::bundle::{Bundle, BundleUuid};
+use crate::proto::packet::{Packet, PacketBatch};
 use chrono::{Duration, Utc};
 use futures::{stream, StreamExt};
 use log::info;
@@ -13,15 +13,36 @@ use tonic::{transport::Server, Request, Response, Status};
 use futures_util::stream::Stream;
 use base64::prelude::*;
 
-use bundle_test_server::proto::block_engine::block_engine_validator_server::{BlockEngineValidator, BlockEngineValidatorServer};
-use bundle_test_server::proto::block_engine::{SubscribePacketsRequest, SubscribePacketsResponse, SubscribeBundlesRequest, SubscribeBundlesResponse, BlockBuilderFeeInfoRequest, BlockBuilderFeeInfoResponse};
+use crate::proto::block_engine::block_engine_validator_server::{BlockEngineValidator, BlockEngineValidatorServer};
+use crate::proto::block_engine::{SubscribePacketsRequest, SubscribePacketsResponse, SubscribeBundlesRequest, SubscribeBundlesResponse, BlockBuilderFeeInfoRequest, BlockBuilderFeeInfoResponse};
 
 #[derive(Debug, Default)]
 pub struct BlockEngineValidatorService;
 
 type PacketResponseStream = Pin<Box<dyn Stream<Item = Result<SubscribePacketsResponse, Status>> + Send>>;
 type BundleResponseStream = Pin<Box<dyn Stream<Item = Result<SubscribeBundlesResponse, Status>> + Send>>;
 
+pub mod proto {
+    pub mod auth {
+        tonic::include_proto!("auth");
+    }
+    pub mod block_engine {
+        tonic::include_proto!("block_engine");
+    }
+    pub mod bundle {
+        tonic::include_proto!("bundle");
+    }
+    pub mod packet {
+        tonic::include_proto!("packet");
+    }
+    pub mod relayer {
+        tonic::include_proto!("relayer");
+    }
+    pub mod shared {
+        tonic::include_proto!("shared");
+    }
+}
+
 #[tonic::async_trait]
 impl BlockEngineValidator for BlockEngineValidatorService {
     type SubscribePacketsStream = PacketResponseStream;
@@ -115,14 +136,14 @@ impl AuthService for Auth {
     ) -> Result<Response<auth::GenerateAuthTokensResponse>, Status> {
         Ok(Response::new(auth::GenerateAuthTokensResponse {
             access_token: Some(Token {
-                value: "".to_string(),
+                value: "token".to_string(),
                 expires_at_utc: Some(Timestamp {
                     seconds: (Utc::now() + Duration::seconds(60)).timestamp(),
                     nanos: 0,
                 }),
             }),
             refresh_token: Some(Token {
-                value: "".to_string(),
+                value: "token".to_string(),
                 expires_at_utc: Some(Timestamp {
                     seconds: (Utc::now() + Duration::seconds(60)).timestamp(),
                     nanos: 0,