gui: vote slot message

Author: jherrera-jump

book/api/websocket.md

@@ -293,6 +293,14 @@ The largest slot for which the validator sent out a repair request.
 This slot has the same problem as `summary.turbine_slot` (it might
 sporadically become unboundedly large) and provides the same guarantees.
 
+#### `summary.vote_slot`
+| frequency       | type           | example |
+|-----------------|----------------|---------|
+| *Once* + *Live* | `number\|null` | `100`   |
+
+The most recent replayed slot this node was in the process of voting on.
+May be `null` at startup if voting has not started.
+
 #### `summary.caught_up_slot`
 | frequency       | type           | example |
 |-----------------|----------------|---------|

src/disco/gui/fd_gui_peers.c

@@ -675,6 +675,7 @@ fd_gui_peers_handle_vote_update( fd_gui_peers_ctx_t *  peers,
                                  fd_gui_peers_vote_t * votes,
                                  ulong                 vote_cnt,
                                  long                  now,
+                                 fd_pubkey_t *         identity,
                                  char                  country_code_map[ static 512 ][ 3 ] ) {
   (void)now;
   fd_gui_peers_vote_t * votes_sorted  = votes;
@@ -718,6 +719,12 @@ fd_gui_peers_handle_vote_update( fd_gui_peers_ctx_t *  peers,
   for( ulong i=0UL; i<vote_cnt; i++ ) {
     if( FD_UNLIKELY( votes_sorted[ i ].stake==ULONG_MAX ) ) continue;
 
+    if( FD_UNLIKELY( !memcmp( &votes_sorted[ i ].node_account, identity->uc, sizeof(fd_pubkey_t) ) && peers->slot_voted!=votes_sorted[ i ].last_vote_slot ) ) {
+      peers->slot_voted = votes_sorted[ i ].last_vote_slot;
+      fd_gui_peers_printf_vote_slot( peers );
+      fd_http_server_ws_broadcast( peers->http );
+    }
+
     ulong peer_idx = fd_gui_peers_node_pubkey_map_idx_query( peers->node_pubkey_map, &votes_sorted[ i ].node_account, ULONG_MAX, peers->contact_info_table );
     if( FD_UNLIKELY( peer_idx==ULONG_MAX ) ) continue; /* peer not on gossip */
 

src/disco/gui/fd_gui_peers.h

@@ -337,6 +337,8 @@ struct fd_gui_peers_ctx {
   fd_gui_peers_gossip_stats_t gossip_stats  [ 1 ];
   fd_gui_peers_node_t contact_info_table[ FD_CONTACT_INFO_TABLE_SIZE ];
 
+  ulong slot_voted; /* last vote slot for this validator */
+
   fd_gui_peers_vote_t votes        [ FD_RUNTIME_MAX_VOTE_ACCOUNTS ];
   fd_gui_peers_vote_t votes_scratch[ FD_RUNTIME_MAX_VOTE_ACCOUNTS ]; /* for fast stable sort */
 };
@@ -395,6 +397,7 @@ fd_gui_peers_handle_vote_update( fd_gui_peers_ctx_t *  peers,
                                  fd_gui_peers_vote_t * votes,
                                  ulong                 vote_cnt,
                                  long                  now,
+                                 fd_pubkey_t *         identity,
                                  char                  country_code_map[ static 512 ][ 3 ] );
 
 void

src/disco/gui/fd_gui_printf.c

@@ -242,6 +242,14 @@ fd_gui_printf_repair_slot( fd_gui_t * gui ) {
   jsonp_close_envelope( gui->http );
 }
 
+void
+fd_gui_peers_printf_vote_slot( fd_gui_peers_ctx_t * peers ) {
+  jsonp_open_envelope( peers->http, "summary", "vote_slot" );
+    if( FD_LIKELY( peers->slot_voted!=ULONG_MAX  ) ) jsonp_ulong( peers->http, "value", peers->slot_voted );
+    else                                             jsonp_null ( peers->http, "value" );
+  jsonp_close_envelope( peers->http );
+}
+
 void
 fd_gui_printf_turbine_slot( fd_gui_t * gui ) {
   jsonp_open_envelope( gui->http, "summary", "turbine_slot" );

src/disco/gui/fd_gui_printf.h

@@ -36,6 +36,7 @@ void fd_gui_printf_estimated_slot( fd_gui_t * gui );
 void fd_gui_printf_estimated_tps( fd_gui_t * gui );
 void fd_gui_printf_shred_updates( fd_gui_t * gui );
 void fd_gui_printf_catch_up_history( fd_gui_t * gui );
+void fd_gui_peers_printf_vote_slot( fd_gui_peers_ctx_t * peers );
 
 void
 fd_gui_printf_null_query_response( fd_http_server_t * http,

src/disco/gui/fd_gui_tile.c

@@ -363,7 +363,7 @@ after_frag( fd_gui_ctx_t *      ctx,
         fd_stem_publish( stem, ctx->replay_out->idx, replay->bank_idx, 0UL, 0UL, 0UL, 0UL, 0UL );
 
         /* update vote info */
-        fd_gui_peers_handle_vote_update( ctx->peers, ctx->peers->votes, vote_count, fd_clock_now( ctx->clock ), ctx->gui->ipinfo.country_code );
+        fd_gui_peers_handle_vote_update( ctx->peers, ctx->peers->votes, vote_count, fd_clock_now( ctx->clock ), ctx->gui->summary.identity_key, ctx->gui->ipinfo.country_code );
 
         /* update slot data */
         fd_gui_handle_replay_update( ctx->gui, &slot_completed, fd_clock_now( ctx->clock ) );