storagenode: support setup subcommand with modular storagenode

Change-Id: I15fa7e9dd1e5a975e58f0ea0bbba7900ef289dea

Author: elek

shared/modular/cli/config.go

@@ -16,6 +16,11 @@ import (
 	"gopkg.in/yaml.v2"
 )
 
+// ConfigDir is a view of the ConfigSupport.configDir.
+type ConfigDir struct {
+	Dir string
+}
+
 // ConfigSupport is a clingy helper, which loads the configuration.
 type ConfigSupport struct {
 	configDir   string

shared/modular/cli/mudrunner.go

@@ -46,6 +46,12 @@ func Run(module func(ball *mud.Ball)) {
 	})
 
 	cfg := &ConfigSupport{}
+	mud.Supply[*ConfigSupport](ball, cfg)
+	mud.View[*ConfigSupport, ConfigDir](ball, func(support *ConfigSupport) ConfigDir {
+		return ConfigDir{
+			Dir: support.configDir,
+		}
+	})
 	ok, err := clingy.Environment{
 		Dynamic: cfg.GetValue,
 	}.Run(ctx, clingyRunner(cfg, ball))

storagenode/run/mud.go

@@ -5,6 +5,7 @@ package root
 
 import (
 	"storj.io/storj/shared/modular"
+	"storj.io/storj/shared/modular/cli"
 	"storj.io/storj/shared/modular/logger"
 	"storj.io/storj/shared/mud"
 	"storj.io/storj/storagenode"
@@ -15,4 +16,6 @@ func Module(ball *mud.Ball) {
 	logger.Module(ball)
 	modular.IdentityModule(ball)
 	storagenode.Module(ball)
+	mud.Provide[*Setup](ball, NewSetup)
+	cli.RegisterSubcommand[*Setup](ball, "setup", "setup storagenode configuration")
 }

storagenode/run/setup.go

@@ -0,0 +1,57 @@
+// Copyright (C) 2025 Storj Labs, Inc.
+// See LICENSE for copying information.
+
+package root
+
+import (
+	"context"
+	"fmt"
+
+	"go.uber.org/zap"
+
+	"storj.io/common/fpath"
+	"storj.io/common/identity"
+	"storj.io/storj/shared/modular/cli"
+	"storj.io/storj/storagenode/storagenodedb"
+)
+
+// SetupArgs contains arguments for the setup command.
+type SetupArgs struct {
+}
+
+// Setup handles storagenode configuration setup.
+type Setup struct {
+	dbConfig storagenodedb.Config
+	confDir  cli.ConfigDir
+	identity *identity.FullIdentity
+}
+
+// NewSetup creates a new Setup instance for storagenode configuration.
+func NewSetup(dbConfig storagenodedb.Config, confDir cli.ConfigDir, identity *identity.FullIdentity) *Setup {
+	return &Setup{
+		dbConfig: dbConfig,
+		confDir:  confDir,
+		identity: identity,
+	}
+}
+
+// Run executes the storagenode setup process.
+func (s *Setup) Run(ctx context.Context) error {
+	setupDir := s.confDir.Dir
+	valid, _ := fpath.IsValidSetupDir(setupDir)
+	if !valid {
+		return fmt.Errorf("storagenode configuration already exists (%v)", setupDir)
+	}
+
+	// create db
+	db, err := storagenodedb.OpenNew(ctx, zap.L().Named("db"), s.dbConfig)
+	if err != nil {
+		return err
+	}
+
+	if err := db.Pieces().CreateVerificationFile(ctx, s.identity.ID); err != nil {
+		return err
+	}
+
+	return nil
+}