From 7cd05b2bf9c284d5bc2680d57713dc18124bc4dc Mon Sep 17 00:00:00 2001
From: Joe Bryan <joemfb@gmail.com>
Date: Thu, 21 Apr 2022 15:26:17 -0400
Subject: [PATCH] vere: adds runtime status endpoint (reflecting current
 spinner state)

---
 pkg/urbit/vere/io/http.c | 34 ++++++++++++++++++++++++++++++++++
 1 file changed, 34 insertions(+)

diff --git a/pkg/urbit/vere/io/http.c b/pkg/urbit/vere/io/http.c
index 4da5c59c6..403a9c35e 100644
--- a/pkg/urbit/vere/io/http.c
+++ b/pkg/urbit/vere/io/http.c
@@ -917,6 +917,34 @@ _http_seq_accept(h2o_handler_t* han_u, h2o_req_t* rec_u)
   return 0;
 }
 
+/* _http_sat_accept(): handle incoming http request on status endpoint
+*/
+static c3_i
+_http_sat_accept(h2o_handler_t* han_u, h2o_req_t* rec_u)
+{
+  c3_o bus_o;
+  {
+    u3_hcon* hon_u = _http_rec_sock(rec_u);
+    u3_httd* htd_u = hon_u->htp_u->htd_u;
+    u3_pier* pir_u = htd_u->car_u.pir_u;
+    bus_o = pir_u->god_u->pin_o;
+  }
+
+  if ( c3y == bus_o ) {
+    rec_u->res.status = 429;
+    rec_u->res.reason = "busy";
+  }
+  else {
+    rec_u->res.status = 204;
+    rec_u->res.reason = "no content";
+  }
+
+  rec_u->res.content_length = 0;
+  h2o_send_inline(rec_u, NULL, 0);
+
+  return 0;
+}
+
 /* _http_rec_accept(); handle incoming http request from h2o.
 */
 static c3_i
@@ -1430,6 +1458,12 @@ _http_serv_init_h2o(SSL_CTX* tls_u, c3_o log, c3_o red)
     pac_u = h2o_config_register_path(h2o_u->hos_u, "/~_~/slog", 0);
     han_u = h2o_create_handler(pac_u, sizeof(*han_u));
     han_u->on_req = _http_seq_accept;
+
+    //  status (per spinner)
+    //
+    pac_u = h2o_config_register_path(h2o_u->hos_u, "/~_~/healthz", 0);
+    han_u = h2o_create_handler(pac_u, sizeof(*han_u));
+    han_u->on_req = _http_sat_accept;
   }
 
   if ( c3y == log ) {