From ab2a4eafd9dc0440521b59cef2c246b249b2964c Mon Sep 17 00:00:00 2001
From: Conflux <wanliqunn@163.com>
Date: Thu, 21 Nov 2024 19:10:37 +0800
Subject: [PATCH] add missing

---
 indexer/gateway/status.go | 73 +++++++++++++++++++++++++++++++++++++++
 1 file changed, 73 insertions(+)
 create mode 100644 indexer/gateway/status.go

diff --git a/indexer/gateway/status.go b/indexer/gateway/status.go
new file mode 100644
index 0000000..28df26a
--- /dev/null
+++ b/indexer/gateway/status.go
@@ -0,0 +1,73 @@
+package gateway
+
+import (
+	"context"
+	"fmt"
+	"net/http"
+	"strconv"
+
+	"github.com/0glabs/0g-storage-client/node"
+	"github.com/ethereum/go-ethereum/common"
+	"github.com/gin-gonic/gin"
+)
+
+func getFileStatus(c *gin.Context) {
+	cid := c.Param("cid")
+
+	var root common.Hash
+	var txSeq *uint64
+
+	if v, err := strconv.ParseUint(cid, 10, 64); err == nil { // TxnSeq is used as cid
+		txSeq = &v
+	} else {
+		root = common.HexToHash(cid)
+	}
+
+	if txSeq == nil && (root == common.Hash{}) {
+		c.JSON(http.StatusBadRequest, "Either 'root' or 'txSeq' must be provided")
+		return
+	}
+
+	fileInfo, err := getFileInfo(c, root, txSeq)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, fmt.Sprintf("Failed to retrieve file info: %v", err))
+		return
+	}
+
+	if fileInfo == nil {
+		c.JSON(http.StatusNotFound, "File not found")
+		return
+	}
+
+	c.JSON(http.StatusOK, fileInfo)
+}
+
+func getNodeStatus(c *gin.Context) {
+	if len(clients) == 0 {
+		c.JSON(http.StatusInternalServerError, "no clients available")
+		return
+	}
+
+	var finalStatus *node.Status
+	for _, client := range clients {
+		status, err := client.GetStatus(context.Background())
+		if err != nil {
+			c.JSON(http.StatusInternalServerError, fmt.Sprintf("Failed to retrieve node status: %v", err))
+		}
+
+		if finalStatus == nil {
+			finalStatus = &status
+			continue
+		}
+
+		if finalStatus.LogSyncHeight > status.LogSyncHeight {
+			finalStatus.LogSyncHeight = status.LogSyncHeight
+			finalStatus.LogSyncBlock = status.LogSyncBlock
+		}
+
+		finalStatus.ConnectedPeers = max(finalStatus.ConnectedPeers, status.ConnectedPeers)
+		finalStatus.NextTxSeq = min(finalStatus.NextTxSeq, status.NextTxSeq)
+	}
+
+	c.JSON(http.StatusOK, finalStatus)
+}