Add /status endpoint to signer

libsigner/src/events.rs

@@ -211,6 +211,8 @@ pub enum SignerEvent {
     SignerMessages(Vec<SignerMessage>),
     /// A new block proposal validation response from the node
     BlockValidationResponse(BlockValidateResponse),
+    /// Status endpoint request
+    StatusCheck,
 }
 
 /// Trait to implement a stop-signaler for the event receiver thread.
@@ -381,6 +383,14 @@ impl EventReceiver for SignerEventReceiver {
                 return Err(EventError::Terminated);
             }
             let request = http_server.recv()?;
+
+            if request.url() == "/status" {
+                request
+                .respond(HttpResponse::from_string("OK"))
+                .expect("response failed");
+                return Ok(SignerEvent::StatusCheck);
+            }
+
             if request.method() != &HttpMethod::Post {
                 return Err(EventError::MalformedRequest(format!(
                     "Unrecognized method '{}'",

libsigner/src/tests/mod.rs

@@ -16,7 +16,7 @@
 
 mod http;
 
-use std::io::Write;
+use std::io::{Read, Write};
 use std::net::{SocketAddr, TcpStream, ToSocketAddrs};
 use std::sync::mpsc::{channel, Receiver, Sender};
 use std::time::Duration;
@@ -138,6 +138,24 @@ fn test_simple_signer() {
 
             num_sent += 1;
         }
+        // Test the /status endpoint
+        {
+            let mut sock = match TcpStream::connect(endpoint) {
+                Ok(sock) => sock,
+                Err(..) => {
+                    sleep_ms(100);
+                    return;
+                }
+            };
+            let req = "GET /status HTTP/1.0\r\nConnection: close\r\n\r\n";
+            sock.write_all(req.as_bytes()).unwrap();
+            let mut buf = [0; 128];
+            sock.read(&mut buf).unwrap();
+            let res_str = std::str::from_utf8(&buf).unwrap();
+            let expected_status_res = "HTTP/1.0 200 OK\r\n";
+            assert_eq!(expected_status_res, &res_str[..expected_status_res.len()]);
+            sock.flush().unwrap();
+        }
     });
 
     let running_signer = signer.spawn(endpoint).unwrap();

stacks-signer/src/runloop.rs

@@ -805,6 +805,9 @@ impl<C: Coordinator> SignerRunLoop<Vec<OperationResult>, RunLoopCommand> for Run
                 debug!("Received block proposals from the miners...");
                 self.handle_proposed_blocks(blocks);
             }
+            Some(SignerEvent::StatusCheck) => {
+                debug!("Received a status check event.")
+            }
             None => {
                 // No event. Do nothing.
                 debug!("No event received")