feat(node): add apis package

.gitignore

@@ -25,3 +25,5 @@ postgres
 .env
 docker-compose.local.yaml
 docker-compose.local.yml
+docker-compose.debug.yaml
+docker-compose.debug.yml

cmd/node/apis/apis.go

@@ -0,0 +1,33 @@
+package apis
+
+import (
+	"github.com/gin-gonic/gin"
+	msghandler "github.com/machinefi/w3bstream-mainnet/msg/handler"
+	"github.com/machinefi/w3bstream-mainnet/vm"
+	"github.com/pkg/errors"
+)
+
+func NewServer(ep string, mh *msghandler.Handler) *Server {
+	s := &Server{
+		endpoint:   ep,
+		engine:     gin.Default(),
+		msgHandler: mh,
+	}
+	s.engine.POST("/message", s.handleRequest)
+	return s
+}
+
+type Server struct {
+	engine     *gin.Engine
+	endpoint   string
+	msgHandler *msghandler.Handler
+	vmHandler  *vm.Handler
+}
+
+// this func will block caller
+func (s *Server) Run() error {
+	if err := s.engine.Run(s.endpoint); err != nil {
+		return errors.Wrap(err, "start http server failed")
+	}
+	return nil
+}

cmd/node/apis/handlers.go

@@ -0,0 +1,27 @@
+package apis
+
+import (
+	"github.com/gin-gonic/gin"
+	"github.com/machinefi/w3bstream-mainnet/msg"
+	"log/slog"
+	"net/http"
+)
+
+func (s *Server) handleRequest(c *gin.Context) {
+	req := &msgReq{}
+	if err := c.ShouldBindJSON(req); err != nil {
+		c.JSON(http.StatusBadRequest, newErrResp(err))
+		return
+	}
+	slog.Debug("received your message, handling")
+	if err := s.msgHandler.Handle(&msg.Msg{
+		ProjectID:      req.ProjectID,
+		ProjectVersion: req.ProjectVersion,
+		Data:           req.Data,
+	}); err != nil {
+		c.JSON(http.StatusInternalServerError, newErrResp(err))
+		return
+	}
+
+	c.Status(http.StatusOK)
+}

cmd/node/common.go → cmd/node/apis/types.go

@@ -1,4 +1,4 @@
-package main
+package apis
 
 type errResp struct {
 	Error string `json:"error,omitempty"`

cmd/node/main.go

@@ -1,22 +1,17 @@
 package main
 
 import (
+	"github.com/machinefi/w3bstream-mainnet/cmd/node/apis"
+	"github.com/machinefi/w3bstream-mainnet/enums"
+	"github.com/machinefi/w3bstream-mainnet/msg/handler"
+	"github.com/machinefi/w3bstream-mainnet/vm"
+	"github.com/spf13/viper"
 	"log"
-	"log/slog"
-	"net/http"
 	"os"
 	"os/signal"
 	"syscall"
 
-	"github.com/machinefi/w3bstream-mainnet/enums"
 	"github.com/machinefi/w3bstream-mainnet/project"
-
-	"github.com/gin-gonic/gin"
-	"github.com/spf13/viper"
-
-	"github.com/machinefi/w3bstream-mainnet/msg"
-	"github.com/machinefi/w3bstream-mainnet/msg/handler"
-	"github.com/machinefi/w3bstream-mainnet/vm"
 )
 
 func main() {
@@ -36,29 +31,8 @@ func main() {
 		viper.GetString(enums.EnvKeyProjectConfigPath),
 	)
 
-	router := gin.Default()
-	router.POST("/message", func(c *gin.Context) {
-		var req msgReq
-		if err := c.ShouldBindJSON(&req); err != nil {
-			c.JSON(http.StatusBadRequest, newErrResp(err))
-			return
-		}
-		msg := &msg.Msg{
-			ProjectID:      req.ProjectID,
-			ProjectVersion: req.ProjectVersion,
-			Data:           req.Data,
-		}
-		slog.Debug("received your message, handling")
-		if err := msgHandler.Handle(msg); err != nil {
-			c.JSON(http.StatusInternalServerError, newErrResp(err))
-			return
-		}
-
-		c.Status(http.StatusOK)
-	})
-
 	go func() {
-		if err := router.Run(viper.Get("ENDPOINT").(string)); err != nil {
+		if err := apis.NewServer(viper.GetString(enums.EnvKeyServiceEndpoint), msgHandler).Run(); err != nil {
 			log.Fatal(err)
 		}
 	}()