gofmt

Author: Alia5

apiclient/client_test.go

@@ -1,125 +1,125 @@
-package apiclient_test
-
-import (
-	"context"
-	"errors"
-	"testing"
-
-	apiclient "github.com/Alia5/VIIPER/apiclient"
-	apitypes "github.com/Alia5/VIIPER/apitypes"
-
-	"github.com/stretchr/testify/assert"
-)
-
-// testClient constructs a client backed by a simple in-memory responder.
-// responses maps full, already-filled paths (after path param substitution) to raw JSON payloads.
-// If err is non-nil, every request returns that error, simulating dial failures.
-func testClient(responses map[string]string, err error) *apiclient.Client {
-	return apiclient.WithTransport(apiclient.NewMockTransport(func(path string, _ any, _ map[string]string) (string, error) {
-		if err != nil {
-			return "", err
-		}
-		if out, ok := responses[path]; ok {
-			return out, nil
-		}
-		return "", nil
-	}))
-}
-
-func TestHighLevelClient(t *testing.T) {
-	tests := []struct {
-		name       string
-		setup      func(responses map[string]string) (err error)
-		call       func(c *apiclient.Client) (any, error)
-		wantErr    string
-		assertFunc func(t *testing.T, got any)
-	}{
-		{
-			name:  "bus create success",
-			setup: func(responses map[string]string) error { responses["bus/create"] = `{"busId":42}`; return nil },
-			call:  func(c *apiclient.Client) (any, error) { return c.BusCreate(42) },
-			assertFunc: func(t *testing.T, got any) {
-				_, ok := got.(*apitypes.BusCreateResponse)
-				assert.True(t, ok, "expected *apitypes.BusCreateResponse type")
-			},
-		},
-		{
-			name: "bus create error structured",
-			setup: func(responses map[string]string) error {
-				responses["bus/create"] = `{"status":400,"title":"Bad Request","detail":"invalid busId"}`
-				return nil
-			},
-			call:    func(c *apiclient.Client) (any, error) { return c.BusCreate(0) },
-			wantErr: "400 Bad Request: invalid busId",
-		},
-		{
-			name: "devices list",
-			setup: func(responses map[string]string) error {
-				responses["bus/{id}/list"] = `{"devices":[{"busId":1,"devId":"1","vid":"0x1234","pid":"0xabcd","type":"x"}]}`
-				return nil
-			},
-			call:       func(c *apiclient.Client) (any, error) { return c.DevicesList(1) },
-			assertFunc: func(t *testing.T, got any) { assert.NotNil(t, got) },
-		},
-		{
-			name:    "transport failure",
-			setup:   func(responses map[string]string) error { return errors.New("dial fail") },
-			call:    func(c *apiclient.Client) (any, error) { return c.BusList() },
-			wantErr: "dial fail",
-		},
-		{
-			name:    "blank response error",
-			setup:   func(responses map[string]string) error { return nil },
-			call:    func(c *apiclient.Client) (any, error) { return c.BusList() },
-			wantErr: "empty response",
-		},
-		{
-			name:  "devices list empty",
-			setup: func(responses map[string]string) error { responses["bus/{id}/list"] = `{"devices":[]}`; return nil },
-			call:  func(c *apiclient.Client) (any, error) { return c.DevicesList(1) },
-			assertFunc: func(t *testing.T, got any) {
-				resp := got.(*apitypes.DevicesListResponse)
-				assert.Len(t, resp.Devices, 0)
-			},
-		},
-	}
-
-	for _, tt := range tests {
-		t.Run(tt.name, func(t *testing.T) {
-			responses := map[string]string{}
-			errInject := error(nil)
-			if tt.setup != nil {
-				if e := tt.setup(responses); e != nil {
-					errInject = e
-				}
-			}
-			c := testClient(responses, errInject)
-			got, err := tt.call(c)
-			if tt.wantErr != "" {
-				assert.Error(t, err)
-				assert.Contains(t, err.Error(), tt.wantErr)
-				return
-			}
-			assert.NoError(t, err)
-			if tt.assertFunc != nil {
-				tt.assertFunc(t, got)
-			}
-		})
-	}
-}
-
-func TestContextCancellation(t *testing.T) {
-	c := apiclient.WithTransport(apiclient.NewTransport("127.0.0.1:9")) // address irrelevant due to early cancel
-	ctx, cancel := context.WithCancel(context.Background())
-	cancel()
-	_, err := c.BusListCtx(ctx)
-	assert.Error(t, err)
-}
-
-func TestStrictJSONDecode(t *testing.T) {
-	responses := map[string]string{}
-	responses["bus/list"] = `{"buses":[1,2,3],"extra":true}` // extra field should cause decode error
-	c := testClient(responses, nil)
-	_, err := c.BusList()
-	assert.Error(t, err)
-}
+package apiclient_test
+
+import (
+	"context"
+	"errors"
+	"testing"
+
+	apiclient "github.com/Alia5/VIIPER/apiclient"
+	apitypes "github.com/Alia5/VIIPER/apitypes"
+
+	"github.com/stretchr/testify/assert"
+)
+
+// testClient constructs a client backed by a simple in-memory responder.
+// responses maps full, already-filled paths (after path param substitution) to raw JSON payloads.
+// If err is non-nil, every request returns that error, simulating dial failures.
+func testClient(responses map[string]string, err error) *apiclient.Client {
+	return apiclient.WithTransport(apiclient.NewMockTransport(func(path string, _ any, _ map[string]string) (string, error) {
+		if err != nil {
+			return "", err
+		}
+		if out, ok := responses[path]; ok {
+			return out, nil
+		}
+		return "", nil
+	}))
+}
+
+func TestHighLevelClient(t *testing.T) {
+	tests := []struct {
+		name       string
+		setup      func(responses map[string]string) (err error)
+		call       func(c *apiclient.Client) (any, error)
+		wantErr    string
+		assertFunc func(t *testing.T, got any)
+	}{
+		{
+			name:  "bus create success",
+			setup: func(responses map[string]string) error { responses["bus/create"] = `{"busId":42}`; return nil },
+			call:  func(c *apiclient.Client) (any, error) { return c.BusCreate(42) },
+			assertFunc: func(t *testing.T, got any) {
+				_, ok := got.(*apitypes.BusCreateResponse)
+				assert.True(t, ok, "expected *apitypes.BusCreateResponse type")
+			},
+		},
+		{
+			name: "bus create error structured",
+			setup: func(responses map[string]string) error {
+				responses["bus/create"] = `{"status":400,"title":"Bad Request","detail":"invalid busId"}`
+				return nil
+			},
+			call:    func(c *apiclient.Client) (any, error) { return c.BusCreate(0) },
+			wantErr: "400 Bad Request: invalid busId",
+		},
+		{
+			name: "devices list",
+			setup: func(responses map[string]string) error {
+				responses["bus/{id}/list"] = `{"devices":[{"busId":1,"devId":"1","vid":"0x1234","pid":"0xabcd","type":"x"}]}`
+				return nil
+			},
+			call:       func(c *apiclient.Client) (any, error) { return c.DevicesList(1) },
+			assertFunc: func(t *testing.T, got any) { assert.NotNil(t, got) },
+		},
+		{
+			name:    "transport failure",
+			setup:   func(responses map[string]string) error { return errors.New("dial fail") },
+			call:    func(c *apiclient.Client) (any, error) { return c.BusList() },
+			wantErr: "dial fail",
+		},
+		{
+			name:    "blank response error",
+			setup:   func(responses map[string]string) error { return nil },
+			call:    func(c *apiclient.Client) (any, error) { return c.BusList() },
+			wantErr: "empty response",
+		},
+		{
+			name:  "devices list empty",
+			setup: func(responses map[string]string) error { responses["bus/{id}/list"] = `{"devices":[]}`; return nil },
+			call:  func(c *apiclient.Client) (any, error) { return c.DevicesList(1) },
+			assertFunc: func(t *testing.T, got any) {
+				resp := got.(*apitypes.DevicesListResponse)
+				assert.Len(t, resp.Devices, 0)
+			},
+		},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			responses := map[string]string{}
+			errInject := error(nil)
+			if tt.setup != nil {
+				if e := tt.setup(responses); e != nil {
+					errInject = e
+				}
+			}
+			c := testClient(responses, errInject)
+			got, err := tt.call(c)
+			if tt.wantErr != "" {
+				assert.Error(t, err)
+				assert.Contains(t, err.Error(), tt.wantErr)
+				return
+			}
+			assert.NoError(t, err)
+			if tt.assertFunc != nil {
+				tt.assertFunc(t, got)
+			}
+		})
+	}
+}
+
+func TestContextCancellation(t *testing.T) {
+	c := apiclient.WithTransport(apiclient.NewTransport("127.0.0.1:9")) // address irrelevant due to early cancel
+	ctx, cancel := context.WithCancel(context.Background())
+	cancel()
+	_, err := c.BusListCtx(ctx)
+	assert.Error(t, err)
+}
+
+func TestStrictJSONDecode(t *testing.T) {
+	responses := map[string]string{}
+	responses["bus/list"] = `{"buses":[1,2,3],"extra":true}` // extra field should cause decode error
+	c := testClient(responses, nil)
+	_, err := c.BusList()
+	assert.Error(t, err)
+}