feat: move Node Services creation from cmd to internal Library

cmd/cartesi-rollups-node/main.go

@@ -10,12 +10,12 @@ import (
 	"time"
 
 	"github.com/cartesi/rollups-node/internal/config"
+	"github.com/cartesi/rollups-node/internal/node"
 	"github.com/cartesi/rollups-node/internal/services"
 )
 
 func main() {
 	startTime := time.Now()
-	var s []services.Service
 
 	ctx, stop := signal.NotifyContext(context.Background(), syscall.SIGINT, syscall.SIGTERM)
 	defer stop()
@@ -24,35 +24,7 @@ func main() {
 
 	nodeConfig.Validate()
 
-	sunodoValidatorEnabled := nodeConfig.CartesiExperimentalSunodoValidatorEnabled()
-	if !sunodoValidatorEnabled {
-		// add Redis first
-		s = append(s, newRedis(nodeConfig))
-	}
-
-	// add services without dependencies
-	s = append(s, newGraphQLServer(nodeConfig))
-	s = append(s, newIndexer(nodeConfig))
-	s = append(s, newStateServer(nodeConfig))
-
-	// start either the server manager or host runner
-	if nodeConfig.CartesiFeatureHostMode() {
-		s = append(s, newHostRunner(nodeConfig))
-	} else {
-		s = append(s, newServerManager(nodeConfig))
-	}
-
-	// enable claimer if reader mode and sunodo validator mode are disabled
-	if !nodeConfig.CartesiFeatureDisableClaimer() && !sunodoValidatorEnabled {
-		s = append(s, newAuthorityClaimer(nodeConfig))
-	}
-
-	// add services with dependencies
-	s = append(s, newAdvanceRunner(nodeConfig)) // Depends on the server-manager/host-runner
-	s = append(s, newDispatcher(nodeConfig))    // Depends on the state server
-	s = append(s, newInspectServer(nodeConfig)) // Depends on the server-manager/host-runner
-
-	s = append(s, newHttpService(nodeConfig))
+	s := node.NewNodeServices(nodeConfig)
 
 	ready := make(chan struct{}, 1)
 	// logs startup time
@@ -66,7 +38,11 @@ func main() {
 	}()
 
 	// start supervisor
-	supervisor := newSupervisorService(s)
+	supervisor := services.SupervisorService{
+		Name:     "rollups-node",
+		Services: s,
+	}
+
 	if err := supervisor.Start(ctx, ready); err != nil {
 		config.ErrorLogger.Print(err)
 	}

internal/config/generate/main.go

@@ -73,7 +73,7 @@ func writeCode(envs []Env) {
 			//Getter
 			addLine(&code, "func (nodeConfig* NodeConfig) "+name+"() "+env.GoType+" {")
 			addLine(&code, "if nodeConfig."+varName+" == nil {")
-			addLine(&code, `panic("Variable `+env.Name+` is not set")`)
+			addLine(&code, `fail("missing required %s env var","`+env.Name+`")`)
 			addLine(&code, "}")
 			addLine(&code, "return *nodeConfig."+varName)
 			addLine(&code, "}")

internal/config/validate.go

@@ -8,7 +8,7 @@ func (nodeConfig *NodeConfig) Validate() {
 	if nodeConfig.cartesiExperimentalSunodoValidatorEnabled != nil &&
 		*nodeConfig.cartesiExperimentalSunodoValidatorEnabled {
 		if nodeConfig.cartesiExperimentalSunodoValidatorRedisEndpoint == nil {
-			panic("Missing CARTESI_EXPERIMENTAL_SUNODO_VALIDATOR_REDIS_ENDPOINT config")
+			fail("Missing required %s env var", "CARTESI_EXPERIMENTAL_SUNODO_VALIDATOR_REDIS_ENDPOINT")
 		}
 	}
 
@@ -19,43 +19,43 @@ func (nodeConfig *NodeConfig) Validate() {
 	}
 
 	if nodeConfig.cartesiBlockchainHttpEndpoint == nil {
-		panic("Missing CARTESI_BLOCKCHAIN_HTTP_ENDPOINT")
+		fail("Missing required %s env var", "CARTESI_BLOCKCHAIN_HTTP_ENDPOINT")
 	}
 
 	if nodeConfig.cartesiBlockchainId == nil {
-		panic("Missing CARTESI_BLOCKCHAIN_ID config")
+		fail("Missing required %s env var", "CARTESI_BLOCKCHAIN_ID")
 	}
 
 	if nodeConfig.cartesiBlockchainWsEndpoint == nil {
-		panic("Missing CARTESI_BLOCKCHAIN_WS_ENDPOINT config")
+		fail("Missing required %s env var", "CARTESI_BLOCKCHAIN_WS_ENDPOINT")
 	}
 
 	if nodeConfig.cartesiContractsInputBoxDeploymentBlockNumber == nil {
-		panic("Missing CARTESI_CONTRACTS_INPUT_BOX_DEPLOYMENT_BLOCK_NUMBER config")
+		fail("Missing required %s env var", "CARTESI_CONTRACTS_INPUT_BOX_DEPLOYMENT_BLOCK_NUMBER")
 	}
 
 	if nodeConfig.cartesiContractsApplicationAddress == nil {
-		panic("Missing CARTESI_CONTRACTS_APPLICATION_ADDRESS config")
+		fail("Missing required %s env var", "CARTESI_CONTRACTS_APPLICATION_ADDRESS")
 	}
 
 	if nodeConfig.cartesiContractsApplicationDeploymentBlockNumber == nil {
-		panic("Missing CARTESI_CONTRACTS_APPLICATION_DEPLOYMENT_BLOCK_NUMBER config")
+		fail("Missing required %s env var", "CARTESI_CONTRACTS_APPLICATION_DEPLOYMENT_BLOCK_NUMBER")
 	}
 
 	if nodeConfig.cartesiContractsAuthorityAddress == nil {
-		panic("Missing CARTESI_CONTRACTS_AUTHORITY_ADDRESS config")
+		fail("Missing required %s env var", "CARTESI_CONTRACTS_AUTHORITY_ADDRESS")
 	}
 
 	if nodeConfig.cartesiContractsHistoryAddress == nil {
-		panic("Missing CARTESI_CONTRACTS_HISTORY_ADDRESS config")
+		fail("Missing required %s env var", "CARTESI_CONTRACTS_HISTORY_ADDRESS")
 	}
 
 	if nodeConfig.cartesiContractsInputBoxAddress == nil {
-		panic("Missing CARTESI_CONTRACTS_INPUT_BOX_ADDRESS config")
+		fail("Missing required %s env var", "CARTESI_CONTRACTS_INPUT_BOX_ADDRESS")
 	}
 
 	if nodeConfig.cartesiSnapshotDir == nil {
-		panic("Missing CARTESI_SNAPSHOT_DIR config")
+		fail("Missing required %s env var", "CARTESI_SNAPSHOT_DIR")
 	}
 
 }

cmd/cartesi-rollups-node/handlers.go → internal/node/handlers.go

@@ -1,7 +1,7 @@
 // (c) Cartesi and individual authors (see AUTHORS)
 // SPDX-License-Identifier: Apache-2.0 (see LICENSE)
 
-package main
+package node
 
 import (
 	"fmt"

cmd/cartesi-rollups-node/services.go → internal/node/node_services.go

@@ -1,7 +1,7 @@
 // (c) Cartesi and individual authors (see AUTHORS)
 // SPDX-License-Identifier: Apache-2.0 (see LICENSE)
 
-package main
+package node
 
 import (
 	"fmt"
@@ -387,13 +387,6 @@ func newStateServer(nodeConfig config.NodeConfig) services.CommandService {
 	return s
 }
 
-func newSupervisorService(s []services.Service) services.SupervisorService {
-	return services.SupervisorService{
-		Name:     "rollups-node",
-		Services: s,
-	}
-}
-
 func newHttpService(nodeConfig config.NodeConfig) services.HttpService {
 	addr := fmt.Sprintf(
 		"%v:%v",
@@ -407,3 +400,38 @@ func newHttpService(nodeConfig config.NodeConfig) services.HttpService {
 		Handler: handler,
 	}
 }
+
+func NewNodeServices(nodeConfig config.NodeConfig) []services.Service {
+	var s []services.Service
+	sunodoValidatorEnabled := nodeConfig.CartesiExperimentalSunodoValidatorEnabled()
+	if !sunodoValidatorEnabled {
+		// add Redis first
+		s = append(s, newRedis(nodeConfig))
+	}
+
+	// add services without dependencies
+	s = append(s, newGraphQLServer(nodeConfig))
+	s = append(s, newIndexer(nodeConfig))
+	s = append(s, newStateServer(nodeConfig))
+
+	// start either the server manager or host runner
+	if nodeConfig.CartesiFeatureHostMode() {
+		s = append(s, newHostRunner(nodeConfig))
+	} else {
+		s = append(s, newServerManager(nodeConfig))
+	}
+
+	// enable claimer if reader mode and sunodo validator mode are disabled
+	if !nodeConfig.CartesiFeatureDisableClaimer() && !sunodoValidatorEnabled {
+		s = append(s, newAuthorityClaimer(nodeConfig))
+	}
+
+	// add services with dependencies
+	s = append(s, newAdvanceRunner(nodeConfig)) // Depends on the server-manager/host-runner
+	s = append(s, newDispatcher(nodeConfig))    // Depends on the state server
+	s = append(s, newInspectServer(nodeConfig)) // Depends on the server-manager/host-runner
+
+	s = append(s, newHttpService(nodeConfig))
+
+	return s
+}