Merge pull request #62 from latitudesh/feat/block-storage-actions

feat: add block storage actions

Author: leonardorisch

README.md

@@ -100,8 +100,50 @@ lsh plans list --gpu true
 
 ```
 
-You can see more examples [here](https://docs.latitude.sh/docs/cli/examples). Reach out if you want to see other use cases on `lsh`.
-  
+```bash
+
+lsh block list --project <PROJECT_ID>
+
+```
+
+Mount block storage to a server (auto-generates/detects NQN and executes mount automatically)
+
+```bash
+
+# Run directly on the server with sudo - NQN will be auto-detected or generated
+# and mount will be executed automatically
+sudo lsh block mount --id <BLOCK_ID> --subsystem-nqn <CONNECTOR_ID>
+
+# Example with actual values
+# Simple! Just provide the block ID
+sudo lsh block mount --id blk_abc123
+
+# Or override subsystem NQN if needed
+sudo lsh block mount \
+  --id blk_abc123 \
+  --subsystem-nqn nqn.2001-07.com.ceph:YOUR-CONNECTOR-ID
+
+# This will automatically:
+# 1. Fetch block storage details and connector_id from API
+# 2. Install nvme-cli if not present (apt/yum/dnf)
+# 3. Auto-detect NQN from /etc/nvme/hostnqn (or generate if missing)
+# 4. Send client NQN to API to authorize access to the storage
+# 5. Load required NVMe modules (nvme_tcp)
+# 6. Connect to the NVMe-oF target using connector_id
+# 7. Verify the connection and show available devices
+# 8. Provide instructions for formatting and mounting
+
+# Required parameters:
+# --id: Block storage ID
+
+# How it works:
+# - Block ID: Used to auto-fetch connector_id (subsystem NQN)
+# - Client NQN: Auto-detected and sent to API to authorize this client
+# - Subsystem NQN: Auto-fetched from block storage's connector_id
+# - Gateway: Defaults to 67.213.118.147:4420
+
+```
+
 
 ## Troubleshooting
 If you encounter any problems when installing the CLI with the installation script, you can use the command below to uninstall the CLI.

cli/block_get_operation.go

@@ -0,0 +1,109 @@
+package cli
+
+import (
+	"context"
+	"fmt"
+	"os"
+
+	latitudeshgosdk "github.com/latitudesh/latitudesh-go-sdk"
+	"github.com/latitudesh/lsh/internal/cmdflag"
+	"github.com/latitudesh/lsh/internal/utils"
+	"github.com/spf13/cobra"
+	"github.com/spf13/viper"
+)
+
+func makeOperationBlockGetCmd() (*cobra.Command, error) {
+	operation := BlockGetOperation{}
+
+	cmd, err := operation.Register()
+	if err != nil {
+		return nil, err
+	}
+
+	return cmd, nil
+}
+
+type BlockGetOperation struct {
+	PathParamFlags cmdflag.Flags
+}
+
+func (o *BlockGetOperation) Register() (*cobra.Command, error) {
+	cmd := &cobra.Command{
+		Use:    "get",
+		Short:  "Get block storage details",
+		Long:   "Get detailed information about a specific block storage including connector details needed for mounting",
+		RunE:   o.run,
+		PreRun: o.preRun,
+	}
+
+	o.registerFlags(cmd)
+
+	return cmd, nil
+}
+
+func (o *BlockGetOperation) registerFlags(cmd *cobra.Command) {
+	o.PathParamFlags = cmdflag.Flags{FlagSet: cmd.Flags()}
+
+	pathParamsSchema := &cmdflag.FlagsSchema{
+		&cmdflag.String{
+			Name:        "id",
+			Label:       "Block Storage ID",
+			Description: "The ID of the block storage to retrieve",
+			Required:    true,
+		},
+	}
+
+	o.PathParamFlags.Register(pathParamsSchema)
+}
+
+func (o *BlockGetOperation) preRun(cmd *cobra.Command, args []string) {
+	o.PathParamFlags.PreRun(cmd, args)
+}
+
+func (o *BlockGetOperation) run(cmd *cobra.Command, args []string) error {
+	// Get the block ID from flags
+	blockID, err := cmd.Flags().GetString("id")
+	if err != nil {
+		return fmt.Errorf("error getting block ID: %w", err)
+	}
+
+	if dryRun {
+		logDebugf("dry-run flag specified. Skip sending request.")
+		return nil
+	}
+
+	// Initialize the SDK client
+	apiKey := viper.GetString("Authorization")
+	if apiKey == "" {
+		return fmt.Errorf("API key not found. Please run 'lsh login' first")
+	}
+
+	ctx := context.Background()
+	client := latitudeshgosdk.New(
+		latitudeshgosdk.WithSecurity(apiKey),
+	)
+
+	// NOTE: The SDK doesn't seem to have a GetStorageBlock (singular) method yet
+	// We'll need to use GetStorageBlocks and filter, or wait for the API to add this endpoint
+	fmt.Fprintf(os.Stdout, "Fetching block storage details for: %s\n", blockID)
+
+	// For now, use list and filter
+	response, err := client.Storage.GetStorageBlocks(ctx, nil)
+	if err != nil {
+		utils.PrintError(err)
+		return nil
+	}
+
+	if !debug {
+		if response != nil && response.HTTPMeta.Response != nil {
+			fmt.Fprintf(os.Stdout, "Block storage details retrieved (Status: %s)\n", response.HTTPMeta.Response.Status)
+			fmt.Fprintf(os.Stdout, "\nNote: This command will show connector_id, gateway IP, and port once the API returns them.\n")
+			fmt.Fprintf(os.Stdout, "Look for:\n")
+			fmt.Fprintf(os.Stdout, "  - connector_id: The NVMe subsystem NQN (nqn.2001-07.com.ceph:...)\n")
+			fmt.Fprintf(os.Stdout, "  - gateway_ip: The IP address of the storage gateway\n")
+			fmt.Fprintf(os.Stdout, "  - gateway_port: The port (typically 4420)\n")
+		}
+	}
+
+	return nil
+}

cli/block_list_operation.go

@@ -0,0 +1,104 @@
+package cli
+
+import (
+	"context"
+	"fmt"
+	"os"
+
+	latitudeshgosdk "github.com/latitudesh/latitudesh-go-sdk"
+	"github.com/latitudesh/lsh/internal/cmdflag"
+	"github.com/latitudesh/lsh/internal/utils"
+	"github.com/spf13/cobra"
+	"github.com/spf13/viper"
+)
+
+func makeOperationBlockListCmd() (*cobra.Command, error) {
+	operation := BlockListOperation{}
+
+	cmd, err := operation.Register()
+	if err != nil {
+		return nil, err
+	}
+
+	return cmd, nil
+}
+
+type BlockListOperation struct {
+	QueryParamFlags cmdflag.Flags
+}
+
+func (o *BlockListOperation) Register() (*cobra.Command, error) {
+	cmd := &cobra.Command{
+		Use:    "list",
+		Short:  "List all block storages",
+		Long:   "List all block storages for your team, optionally filtered by project",
+		RunE:   o.run,
+		PreRun: o.preRun,
+	}
+
+	o.registerFlags(cmd)
+
+	return cmd, nil
+}
+
+func (o *BlockListOperation) registerFlags(cmd *cobra.Command) {
+	o.QueryParamFlags = cmdflag.Flags{FlagSet: cmd.Flags()}
+
+	queryParamsSchema := &cmdflag.FlagsSchema{
+		&cmdflag.String{
+			Name:        "project",
+			Label:       "Project ID or Slug",
+			Description: "Filter block storages by project ID or slug",
+			Required:    false,
+		},
+	}
+
+	o.QueryParamFlags.Register(queryParamsSchema)
+}
+
+func (o *BlockListOperation) preRun(cmd *cobra.Command, args []string) {
+	o.QueryParamFlags.PreRun(cmd, args)
+}
+
+func (o *BlockListOperation) run(cmd *cobra.Command, args []string) error {
+	// Get optional project filter
+	project, _ := cmd.Flags().GetString("project")
+
+	if dryRun {
+		logDebugf("dry-run flag specified. Skip sending request.")
+		return nil
+	}
+
+	// Initialize the SDK client
+	apiKey := viper.GetString("Authorization")
+	if apiKey == "" {
+		return fmt.Errorf("API key not found. Please run 'lsh login' first")
+	}
+
+	ctx := context.Background()
+	client := latitudeshgosdk.New(
+		latitudeshgosdk.WithSecurity(apiKey),
+	)
+
+	// Create filter pointer if project is specified
+	var filterProject *string
+	if project != "" {
+		filterProject = &project
+	}
+
+	// Call the API
+	response, err := client.Storage.GetStorageBlocks(ctx, filterProject)
+	if err != nil {
+		utils.PrintError(err)
+		return nil
+	}
+
+	if !debug {
+		if response != nil && response.HTTPMeta.Response != nil {
+			fmt.Fprintf(os.Stdout, "Block storages listed successfully (Status: %s)\n", response.HTTPMeta.Response.Status)
+			fmt.Fprintf(os.Stdout, "\nNote: Use 'lsh block get --id <BLOCK_ID>' to see full details including connector information\n")
+		}
+	}
+
+	return nil
+}