wip: plugin work

Author: mfreeman451

sdk/camera_http.go

@@ -0,0 +1,78 @@
+package sdk
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"strings"
+	"time"
+)
+
+var errCameraHostRequired = errors.New("host is required")
+
+// CameraHTTPClient wraps the shared HTTP request behavior for camera plugins.
+type CameraHTTPClient struct {
+	BaseURL    string
+	Timeout    time.Duration
+	AuthHeader string
+}
+
+// NewCameraHTTPClient builds a shared HTTP client from camera plugin config.
+func NewCameraHTTPClient(cfg CameraPluginConfig, fallbackTimeout time.Duration) (*CameraHTTPClient, error) {
+	host := strings.TrimSpace(cfg.Host)
+	if host == "" {
+		return nil, errCameraHostRequired
+	}
+
+	scheme, err := cfg.NormalizedScheme()
+	if err != nil {
+		return nil, err
+	}
+
+	return &CameraHTTPClient{
+		BaseURL:    fmt.Sprintf("%s://%s", scheme, host),
+		Timeout:    cfg.ParsedTimeout(fallbackTimeout),
+		AuthHeader: cfg.BasicAuthHeader(),
+	}, nil
+}
+
+// URL resolves a relative path against the camera base URL.
+func (c *CameraHTTPClient) URL(path string) string {
+	if c == nil {
+		return path
+	}
+
+	return c.BaseURL + path
+}
+
+// DoContext performs an HTTP request with the shared auth and timeout settings.
+func (c *CameraHTTPClient) DoContext(ctx context.Context, req HTTPRequest) (*HTTPResponse, error) {
+	if c == nil {
+		return nil, errCameraHostRequired
+	}
+
+	if req.URL == "" {
+		req.URL = c.BaseURL
+	}
+	if req.TimeoutMS == 0 {
+		req.TimeoutMS = int(c.Timeout.Milliseconds())
+	}
+	if c.AuthHeader != "" {
+		if req.Headers == nil {
+			req.Headers = map[string]string{}
+		}
+		if _, ok := req.Headers["Authorization"]; !ok {
+			req.Headers["Authorization"] = c.AuthHeader
+		}
+	}
+
+	return HTTP.DoContext(ctx, req)
+}
+
+// GetContext performs a GET request against a relative path.
+func (c *CameraHTTPClient) GetContext(ctx context.Context, path string) (*HTTPResponse, error) {
+	return c.DoContext(ctx, HTTPRequest{
+		Method: "GET",
+		URL:    c.URL(path),
+	})
+}

sdk/camera_http_test.go

@@ -0,0 +1,40 @@
+package sdk
+
+import (
+	"testing"
+	"time"
+)
+
+func TestNewCameraHTTPClient(t *testing.T) {
+	t.Parallel()
+
+	client, err := NewCameraHTTPClient(CameraPluginConfig{
+		Host:     " camera.local ",
+		Scheme:   "HTTPS",
+		Timeout:  "15s",
+		Username: "root",
+		Password: "secret",
+	}, 3*time.Second)
+	if err != nil {
+		t.Fatalf("expected client, got error %v", err)
+	}
+
+	if client.BaseURL != "https://camera.local" {
+		t.Fatalf("unexpected base URL: %q", client.BaseURL)
+	}
+	if client.Timeout != 15*time.Second {
+		t.Fatalf("unexpected timeout: %s", client.Timeout)
+	}
+	if client.AuthHeader != "Basic cm9vdDpzZWNyZXQ=" {
+		t.Fatalf("unexpected auth header: %q", client.AuthHeader)
+	}
+}
+
+func TestCameraHTTPClientURL(t *testing.T) {
+	t.Parallel()
+
+	client := &CameraHTTPClient{BaseURL: "https://camera.local"}
+	if got := client.URL("/axis-cgi/basicdeviceinfo.cgi"); got != "https://camera.local/axis-cgi/basicdeviceinfo.cgi" {
+		t.Fatalf("unexpected camera URL: %q", got)
+	}
+}