feat: add send-file and transfer CLI commands

Add P2P file transfer commands:
- send-file: send a file to another agent with progress tracking
- transfer: view active/recent file transfer status

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: gcmsg

internal/cmd/root.go

@@ -56,6 +56,10 @@ func Run(args []string) int {
 		return RunReputation(args[1:], serverURL)
 	case "identity":
 		return RunIdentity(args[1:], serverURL)
+	case "send-file":
+		return RunSendFile(args[1:], serverURL)
+	case "transfer":
+		return RunTransfer(args[1:], serverURL)
 	case "mcp":
 		return RunMCP(args[1:], serverURL)
 	case "acp":
@@ -84,6 +88,8 @@ Commands:
   health      Check server health
   config      Manage CLI configuration
   reputation  Reputation scores (show, list)
+  send-file   Send a file to another agent (P2P)
+  transfer    Manage file transfers (status)
   identity    Identity anchoring (anchor, verify)
   mcp         MCP server for AI tool integration (serve)
   acp         ACP stdio bridge for agent communication (serve)

internal/cmd/send_file.go

@@ -0,0 +1,100 @@
+package cmd
+
+import (
+	"context"
+	"flag"
+	"fmt"
+	"os"
+	"os/signal"
+	"syscall"
+	"time"
+
+	agent "github.com/peerclaw/peerclaw-agent"
+)
+
+// RunSendFile handles the "send-file" subcommand.
+func RunSendFile(args []string, serverURL string) int {
+	fs := flag.NewFlagSet("send-file", flag.ExitOnError)
+	addServerFlag(fs, &serverURL)
+	to := fs.String("to", "", "Destination agent ID (required)")
+	filePath := fs.String("file", "", "Path to file to send (required)")
+	keypairPath := fs.String("keypair", "", "Path to Ed25519 keypair file")
+	trustStorePath := fs.String("trust-store", "", "Path to trust store file")
+	fs.Parse(args)
+
+	if *to == "" || *filePath == "" {
+		fmt.Fprintf(os.Stderr, "Error: --to and --file are required\n")
+		fs.Usage()
+		return 1
+	}
+
+	// Verify file exists.
+	info, err := os.Stat(*filePath)
+	if err != nil {
+		fmt.Fprintf(os.Stderr, "Error: %v\n", err)
+		return 1
+	}
+
+	ctx, cancel := signal.NotifyContext(context.Background(), syscall.SIGINT, syscall.SIGTERM)
+	defer cancel()
+
+	// Create agent for P2P transfer.
+	a, err := agent.New(agent.Options{
+		Name:           "peerclaw-cli-sender",
+		ServerURL:      serverURL,
+		Capabilities:   []string{"file_transfer"},
+		KeypairPath:    *keypairPath,
+		TrustStorePath: *trustStorePath,
+	})
+	if err != nil {
+		fmt.Fprintf(os.Stderr, "Error creating agent: %v\n", err)
+		return 1
+	}
+
+	if err := a.Start(ctx); err != nil {
+		fmt.Fprintf(os.Stderr, "Error starting agent: %v\n", err)
+		return 1
+	}
+	defer a.Stop(context.Background())
+
+	fmt.Printf("Sending %s (%d bytes) to %s...\n", info.Name(), info.Size(), *to)
+
+	fileID, err := a.SendFile(ctx, *to, *filePath)
+	if err != nil {
+		fmt.Fprintf(os.Stderr, "Error: %v\n", err)
+		return 1
+	}
+
+	fmt.Printf("Transfer initiated: %s\n", fileID)
+
+	// Poll for progress.
+	ticker := time.NewTicker(2 * time.Second)
+	defer ticker.Stop()
+
+	for {
+		select {
+		case <-ctx.Done():
+			fmt.Fprintf(os.Stderr, "\nTransfer cancelled\n")
+			_ = a.CancelTransfer(fileID)
+			return 1
+		case <-ticker.C:
+			ti, ok := a.GetTransfer(fileID)
+			if !ok {
+				continue
+			}
+			fmt.Printf("\r  Progress: %.1f%% (%d bytes sent)", ti.Progress*100, ti.BytesSent)
+
+			switch ti.State {
+			case "done":
+				fmt.Printf("\nTransfer complete!\n")
+				return 0
+			case "failed":
+				fmt.Fprintf(os.Stderr, "\nTransfer failed: %s\n", ti.Error)
+				return 1
+			case "cancelled":
+				fmt.Fprintf(os.Stderr, "\nTransfer cancelled\n")
+				return 1
+			}
+		}
+	}
+}

internal/cmd/transfer.go

@@ -0,0 +1,98 @@
+package cmd
+
+import (
+	"context"
+	"flag"
+	"fmt"
+	"os"
+	"os/signal"
+	"syscall"
+
+	agent "github.com/peerclaw/peerclaw-agent"
+)
+
+// RunTransfer handles the "transfer" subcommand.
+func RunTransfer(args []string, serverURL string) int {
+	if len(args) < 1 {
+		fmt.Fprintf(os.Stderr, "Usage: peerclaw transfer <status> [options]\n")
+		return 1
+	}
+
+	switch args[0] {
+	case "status":
+		return runTransferStatus(args[1:], serverURL)
+	default:
+		fmt.Fprintf(os.Stderr, "unknown transfer subcommand: %s\n", args[0])
+		return 1
+	}
+}
+
+func runTransferStatus(args []string, serverURL string) int {
+	fs := flag.NewFlagSet("transfer status", flag.ExitOnError)
+	addServerFlag(fs, &serverURL)
+	addOutputFlag(fs)
+	transferID := fs.String("transfer-id", "", "Specific transfer ID to show")
+	keypairPath := fs.String("keypair", "", "Path to Ed25519 keypair file")
+	trustStorePath := fs.String("trust-store", "", "Path to trust store file")
+	fs.Parse(args)
+
+	ctx, cancel := signal.NotifyContext(context.Background(), syscall.SIGINT, syscall.SIGTERM)
+	defer cancel()
+
+	// Create agent to query transfers.
+	a, err := agent.New(agent.Options{
+		Name:           "peerclaw-cli",
+		ServerURL:      serverURL,
+		KeypairPath:    *keypairPath,
+		TrustStorePath: *trustStorePath,
+	})
+	if err != nil {
+		fmt.Fprintf(os.Stderr, "Error creating agent: %v\n", err)
+		return 1
+	}
+
+	if err := a.Start(ctx); err != nil {
+		fmt.Fprintf(os.Stderr, "Error starting agent: %v\n", err)
+		return 1
+	}
+	defer a.Stop(context.Background())
+
+	if *transferID != "" {
+		ti, ok := a.GetTransfer(*transferID)
+		if !ok {
+			fmt.Fprintf(os.Stderr, "Transfer not found: %s\n", *transferID)
+			return 1
+		}
+		PrintJSON(ti)
+		return 0
+	}
+
+	transfers := a.ListTransfers()
+	if len(transfers) == 0 {
+		fmt.Println("No active transfers")
+		return 0
+	}
+
+	headers := []string{"ID", "FILE", "PEER", "DIR", "STATE", "PROGRESS"}
+	var rows [][]string
+	for _, t := range transfers {
+		rows = append(rows, []string{
+			t.FileID[:8] + "...",
+			t.FileName,
+			truncateID(t.PeerID),
+			string(t.Direction),
+			string(t.State),
+			fmt.Sprintf("%.1f%%", t.Progress*100),
+		})
+	}
+
+	PrintAuto(headers, rows, transfers)
+	return 0
+}
+
+func truncateID(id string) string {
+	if len(id) > 12 {
+		return id[:12] + "..."
+	}
+	return id
+}