stackstate-cli/cmd/topologysync/topologysync_describe_test.go at 755715af5bce356ab0be88378fac6c8981a96a25 · StackVista/stackstate-cli · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
package topologysync

import (
	"fmt"
	"testing"

	"github.com/stackvista/stackstate-cli/generated/stackstate_api"
	"github.com/stackvista/stackstate-cli/internal/di"
	"github.com/stackvista/stackstate-cli/internal/printer"
	"github.com/stretchr/testify/assert"
)

var (
	Error1 = stackstate_api.NewTopologyStreamError(stackstate_api.MESSAGELEVEL_WARN, "Oops")
	Error2 = stackstate_api.NewTopologyStreamError(stackstate_api.MESSAGELEVEL_ERROR, "Welp, better leave the premises quickly.")
	Error3 = (func() *stackstate_api.TopologyStreamError {
		t := stackstate_api.NewTopologyStreamError(stackstate_api.MESSAGELEVEL_INFO, "I don't think this one will happen at all.")
		t.SetExternalId("SomeId")
		return t
	})()

	SomeErrors = []stackstate_api.TopologyStreamError{
		*Error1,
		*Error2,
		*Error3,
	}

	SomeTopoDetails = stackstate_api.NewTopologyStreamListItemWithErrorDetails(*Topo1, SomeErrors)
)

func TestTopologyDescribeJsonId(t *testing.T) {
	cli := di.NewMockDeps(t)
	cmd := DescribeCommand(&cli.Deps)
	cli.MockClient.ApiMocks.TopologySynchronizationApi.GetTopologySynchronizationStreamByIdResponse.Result = *SomeTopoDetails

	id := fmt.Sprintf("%d", SomeTopoDetails.Item.NodeId)

	di.ExecuteCommandWithContextUnsafe(&cli.Deps, cmd, "--id", id, "-o", "json")

	calls := *cli.MockClient.ApiMocks.TopologySynchronizationApi.GetTopologySynchronizationStreamByIdCalls
	assert.Len(t, calls, 1)
	assert.Equal(t, id, *calls[0].Pidentifier)
	assert.Equal(t, NodeIdType, *calls[0].PidentifierType)

	expected := []map[string]interface{}{
		{
			"synchronization": SomeTopoDetails,
		},
	}

	assert.Equal(t, expected, *cli.MockPrinter.PrintJsonCalls)
}

func TestTopologyDescribeJsonIdentifier(t *testing.T) {
	cli := di.NewMockDeps(t)
	cmd := DescribeCommand(&cli.Deps)
	cli.MockClient.ApiMocks.TopologySynchronizationApi.GetTopologySynchronizationStreamByIdResponse.Result = *SomeTopoDetails

	identifier := "urn:stackstate:some:id"

	di.ExecuteCommandWithContextUnsafe(&cli.Deps, cmd, "--identifier", identifier, "-o", "json")

	calls := *cli.MockClient.ApiMocks.TopologySynchronizationApi.GetTopologySynchronizationStreamByIdCalls
	assert.Len(t, calls, 1)
	assert.Equal(t, identifier, *calls[0].Pidentifier)
	assert.Equal(t, IdentifierType, *calls[0].PidentifierType)

	expected := []map[string]interface{}{
		{
			"synchronization": SomeTopoDetails,
		},
	}

	assert.Equal(t, expected, *cli.MockPrinter.PrintJsonCalls)
}

func TestTopologySyncDescribeErrors(t *testing.T) {
	cli := di.NewMockDeps(t)
	cmd := DescribeCommand(&cli.Deps)
	cli.MockClient.ApiMocks.TopologySynchronizationApi.GetTopologySynchronizationStreamByIdResponse.Result = *SomeTopoDetails

	id := SomeTopoDetails.Item.NodeId

	di.ExecuteCommandWithContextUnsafe(&cli.Deps, cmd, "--id", fmt.Sprintf("%d", id))

	expectedTableCall := []printer.TableData{
		{
			Header: []string{"Id", "Name", "Identifier", "Components", "Relations", "Errors"},
			Data: [][]interface{}{
				{Topo1.NodeId, Topo1.Name, "-", "+0       -0", "+0       -0", int64(0)},
			},
			MissingTableDataMsg: printer.NotFoundMsg{Types: "synchronizations"},
		},
		{
			Header: []string{"External ID", "Level", "Message"},
			Data: [][]interface{}{
				{"-", Error1.Level, Error1.Message},
				{"-", Error2.Level, Error2.Message},
				{*Error3.ExternalId, Error3.Level, Error3.Message},
			},
			MissingTableDataMsg: printer.NotFoundMsg{Types: "synchronization errors"},
		},
	}

	assert.Equal(t, expectedTableCall, *cli.MockPrinter.TableCalls)
}