Migrate to cobra (issue #46)

api/api_client_audit.go

@@ -0,0 +1,31 @@
+// Copyright (c) 2017-2022 Ingram Micro Inc.
+
+package api
+
+import (
+	"context"
+	"github.com/ingrammicro/cio/logger"
+	"github.com/ingrammicro/cio/types"
+)
+
+// ListEvents returns the list of events as an array of Event
+func (imco *ClientAPI) ListEvents(ctx context.Context) (events []*types.Event, err error) {
+	logger.DebugFuncInfo()
+
+	_, err = imco.GetAndCheck(ctx, PathAuditEvents, true, &events)
+	if err != nil {
+		return nil, err
+	}
+	return events, nil
+}
+
+// ListSysEvents returns the list of events as an array of Event
+func (imco *ClientAPI) ListSysEvents(ctx context.Context) (events []*types.Event, err error) {
+	logger.DebugFuncInfo()
+
+	_, err = imco.GetAndCheck(ctx, PathAuditSystemEvents, true, &events)
+	if err != nil {
+		return nil, err
+	}
+	return events, nil
+}

api/api_client_audit_test.go

@@ -0,0 +1,93 @@
+package api
+
+import (
+	"context"
+	"fmt"
+	"github.com/ingrammicro/cio/internal/testutils"
+	"github.com/ingrammicro/cio/types"
+	"net/http"
+	"net/http/httptest"
+	"reflect"
+	"strings"
+	"testing"
+)
+
+func TestListEvents(t *testing.T) {
+	tests := map[string]struct {
+		expected any
+		server   *httptest.Server
+	}{
+		"if defined endpoint for API service is resolving properly": {
+			expected: []*types.Event{},
+			server:   testutils.NewServer(http.StatusOK, []*types.Event{}),
+		},
+		"if defined endpoint for API service is invalid or cannot be reached": {
+			expected: "Cannot execute request",
+			server:   nil,
+		},
+	}
+
+	config, svc, err := InitConfigAndClientAPI()
+	if err != nil {
+		t.Errorf("Unexpected error: %v\n", err)
+		return
+	}
+
+	for title, test := range tests {
+		t.Run(title, func(t *testing.T) {
+			if test.server != nil {
+				server := test.server
+				defer server.Close()
+				config.APIEndpoint = server.URL
+			}
+
+			events, err := svc.ListEvents(context.Background())
+			if err != nil && !strings.Contains(err.Error(), fmt.Sprintf("%s", test.expected)) {
+				t.Errorf("Unexpected error: %v\n", err)
+			}
+			if err == nil && !reflect.DeepEqual(events, test.expected) {
+				t.Errorf("Unexpected response: %v. Expected: %v\n", events, test.expected)
+			}
+		})
+	}
+}
+
+func TestListSysEvents(t *testing.T) {
+	tests := map[string]struct {
+		expected any
+		server   *httptest.Server
+	}{
+		"if defined endpoint for API service is resolving properly": {
+			expected: []*types.Event{},
+			server:   testutils.NewServer(http.StatusOK, []*types.Event{}),
+		},
+		"if defined endpoint for API service is invalid or cannot be reached": {
+			expected: "Cannot execute request",
+			server:   nil,
+		},
+	}
+
+	config, svc, err := InitConfigAndClientAPI()
+	if err != nil {
+		t.Errorf("Unexpected error: %v\n", err)
+		return
+	}
+
+	for title, test := range tests {
+		t.Run(title, func(t *testing.T) {
+			if test.server != nil {
+				server := test.server
+				defer server.Close()
+				config.APIEndpoint = server.URL
+			}
+
+			events, err := svc.ListSysEvents(context.Background())
+			if err != nil && !strings.Contains(err.Error(), fmt.Sprintf("%s", test.expected)) {
+				t.Errorf("Unexpected error: %v\n", err)
+			}
+			if err == nil && !reflect.DeepEqual(events, test.expected) {
+				t.Errorf("Unexpected response: %v. Expected: %v\n", events, test.expected)
+			}
+		})
+	}
+}