WIP

Author: jshufro

rocketpool/node/http.go

@@ -0,0 +1,46 @@
+package node
+
+import (
+	"context"
+	"fmt"
+	"log"
+	"net/http"
+
+	"github.com/rocket-pool/smartnode/shared/services/config"
+	cfgtypes "github.com/rocket-pool/smartnode/shared/types/config"
+	"google.golang.org/genproto/googleapis/maps/routes/v1"
+)
+
+type httpServer struct {
+	server *http.Server
+}
+
+func startHTTP(ctx context.Context, cfg *config.RocketPoolConfig) {
+	host := "127.0.0.1"
+	if cfg.Smartnode.OpenAPIPort.Value == cfgtypes.RPC_OpenLocalhost {
+		host = "0.0.0.0"
+	}
+
+	port, ok := cfg.Smartnode.APIPort.Value.(uint16)
+	if !ok {
+		log.Fatalf("Error getting API port: %v", err)
+	}
+
+	httpServer := &httpServer{}
+
+	server := &http.Server{
+		Addr:    fmt.Sprintf("%s:%d", host, port),
+		Handler: httpServer,
+	}
+
+	httpServer.server = server
+}
+
+func (s *httpServer) ServeHTTP(w http.ResponseWriter, r *http.Request) {
+
+	w.WriteHeader(http.StatusOK)
+	w.Write([]byte("Hello, World!"))
+}
+
+func (s *httpServer) addRoute(r *routes.Route) {
+}

rocketpool/node/node.go

@@ -1,6 +1,7 @@
 package node
 
 import (
+	"context"
 	"fmt"
 	"math/big"
 	"net/http"
@@ -119,6 +120,12 @@ func run(c *cli.Context) error {
 	m := state.NewNetworkStateManager(rp, cfg.Smartnode.GetStateManagerContracts(), bc, &updateLog)
 	stateLocker := collectors.NewStateLocker()
 
+	// Create a context for the daemon
+	ctx := context.Background()
+
+	// Start the HTTP server
+	startHTTP(ctx, cfg)
+
 	// Initialize tasks
 	manageFeeRecipient, err := newManageFeeRecipient(c, log.NewColorLogger(ManageFeeRecipientColor))
 	if err != nil {

rocketpool/node/routes/state.go

@@ -0,0 +1 @@
+package routes