[Tenscan] Endpoint for health check

go/obsclient/obsclient.go

@@ -86,8 +86,8 @@ func (oc *ObsClient) BatchHeaderByHash(hash gethcommon.Hash) (*common.BatchHeade
 	return batchHeader, err
 }
 
-// Health returns the health of the node.
-func (oc *ObsClient) Health() (bool, error) {
+// HealthStatusOfNode returns the health of the node.
+func (oc *ObsClient) HealthStatusOfNode() (bool, error) {
 	var healthy *hostcommon.HealthCheck
 	err := oc.rpcClient.Call(&healthy, rpc.Health)
 	if err != nil {

integration/networktest/env/dev_network.go

@@ -50,7 +50,7 @@ func awaitHealthStatus(rpcAddress string, timeout time.Duration) error {
 			return fmt.Errorf("failed dial host (%s): %w", rpcAddress, err)
 		}
 		defer c.Close()
-		healthy, err := c.Health()
+		healthy, err := c.HealthStatusOfNode()
 		if err != nil {
 			return fmt.Errorf("failed to get host health (%s): %w", rpcAddress, err)
 		}

integration/networktest/util.go

@@ -24,7 +24,7 @@ func NodeHealthCheck(rpcAddress string) error {
 	if err != nil {
 		return err
 	}
-	health, err := client.Health()
+	health, err := client.HealthStatusOfNode()
 	if err != nil {
 		return err
 	}

integration/simulation/network/socket.go

@@ -181,7 +181,7 @@ func (n *networkOfSocketNodes) createConnections(simParams *params.SimParams) er
 		startTime := time.Now()
 		healthy := false
 		for ; !healthy; time.Sleep(500 * time.Millisecond) {
-			healthy, _ = client.Health()
+			healthy, _ = client.HealthStatusOfNode()
 			if time.Now().After(startTime.Add(3 * time.Minute)) {
 				return fmt.Errorf("nodes not healthy after 3 minutes")
 			}

integration/simulation/simulation.go

@@ -288,7 +288,7 @@ func (s *Simulation) prefundL1Accounts() {
 
 func (s *Simulation) checkHealthStatus() {
 	for _, client := range s.RPCHandles.ObscuroClients {
-		if healthy, err := client.Health(); !healthy || err != nil {
+		if healthy, err := client.HealthStatusOfNode(); !healthy || err != nil {
 			panic("Client is not healthy: " + err.Error())
 		}
 	}

testnet/launcher/docker.go

@@ -225,7 +225,7 @@ func waitForHealthyNode(port int) error { // todo: hook the cfg
 			defer client.Stop()
 
 			obsClient := obsclient.NewObsClient(client)
-			health, err := obsClient.Health()
+			health, err := obsClient.HealthStatusOfNode()
 			if err != nil {
 				return err
 			}

tools/tenscan/backend/obscuroscan_backend.go

@@ -30,6 +30,10 @@ func (b *Backend) GetLatestBatch() (*common.BatchHeader, error) {
 	return b.obsClient.BatchHeaderByNumber(nil)
 }
 
+func (b *Backend) GetHealthStatus() (bool, error) {
+	return b.obsClient.HealthStatusOfNode()
+}
+
 func (b *Backend) GetLatestRollup() (*common.RollupHeader, error) {
 	return &common.RollupHeader{}, nil
 }

tools/tenscan/backend/webserver/webserver_routes_items.go

@@ -17,6 +17,13 @@ func routeItems(r *gin.Engine, server *WebServer) {
 	r.GET("/items/batches/", server.getBatchListing)
 	r.GET("/items/blocks/", server.getBlockListing)
 	r.GET("/info/obscuro/", server.getConfig)
+	r.POST("/info/health/", server.getHealthStatus)
+}
+
+func (w *WebServer) getHealthStatus(c *gin.Context) {
+	healthStatus, err := w.backend.GetHealthStatus()
+
+	c.JSON(http.StatusOK, gin.H{"result": healthStatus, "errors": fmt.Sprintf("%s", err)})
 }
 
 func (w *WebServer) getLatestBatch(c *gin.Context) {