Use SDK for logs

Author: sjmiller609

pkg/cmd/logs.go

@@ -3,12 +3,9 @@ package cmd
 import (
 	"context"
 	"fmt"
-	"io"
-	"net/http"
-	"net/url"
-	"os"
 
 	"github.com/onkernel/hypeman-go"
+	"github.com/onkernel/hypeman-go/option"
 	"github.com/urfave/cli/v3"
 )
 
@@ -46,54 +43,27 @@ func handleLogs(ctx context.Context, cmd *cli.Command) error {
 		return err
 	}
 
-	// Build URL for logs endpoint
-	baseURL := cmd.Root().String("base-url")
-	if baseURL == "" {
-		baseURL = os.Getenv("HYPEMAN_BASE_URL")
+	params := hypeman.InstanceLogsParams{}
+	if cmd.IsSet("follow") {
+		params.Follow = hypeman.Opt(cmd.Bool("follow"))
 	}
-	if baseURL == "" {
-		baseURL = "http://localhost:8080"
+	if cmd.IsSet("tail") {
+		params.Tail = hypeman.Opt(int64(cmd.Int("tail")))
 	}
 
-	u, err := url.Parse(baseURL)
-	if err != nil {
-		return fmt.Errorf("invalid base URL: %w", err)
-	}
-	u.Path = fmt.Sprintf("/instances/%s/logs", instanceID)
-
-	// Add query parameters
-	q := u.Query()
-	q.Set("tail", fmt.Sprintf("%d", cmd.Int("tail")))
-	if cmd.Bool("follow") {
-		q.Set("follow", "true")
-	}
-	u.RawQuery = q.Encode()
-
-	// Make HTTP request
-	req, err := http.NewRequestWithContext(ctx, "GET", u.String(), nil)
-	if err != nil {
-		return fmt.Errorf("failed to create request: %w", err)
-	}
-
-	apiKey := os.Getenv("HYPEMAN_API_KEY")
-	if apiKey != "" {
-		req.Header.Set("Authorization", fmt.Sprintf("Bearer %s", apiKey))
-	}
-
-	resp, err := http.DefaultClient.Do(req)
-	if err != nil {
-		return fmt.Errorf("failed to fetch logs: %w", err)
-	}
-	defer resp.Body.Close()
+	stream := client.Instances.LogsStreaming(
+		ctx,
+		instanceID,
+		params,
+		option.WithMiddleware(debugMiddleware(cmd.Root().Bool("debug"))),
+	)
+	defer stream.Close()
 
-	if resp.StatusCode != http.StatusOK {
-		body, _ := io.ReadAll(resp.Body)
-		return fmt.Errorf("failed to fetch logs (HTTP %d): %s", resp.StatusCode, string(body))
+	for stream.Next() {
+		fmt.Println(stream.Current())
 	}
 
-	// Stream the response to stdout
-	_, err = io.Copy(os.Stdout, resp.Body)
-	return err
+	return stream.Err()
 }