-
Notifications
You must be signed in to change notification settings - Fork 63
/
objects_get_channel_metadata_test.go
97 lines (76 loc) · 2.52 KB
/
objects_get_channel_metadata_test.go
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
package pubnub
import (
"fmt"
"testing"
h "github.com/pubnub/go/v7/tests/helpers"
"github.com/pubnub/go/v7/utils"
"github.com/stretchr/testify/assert"
)
func AssertGetChannelMetadata(t *testing.T, checkQueryParam, testContext bool) {
assert := assert.New(t)
pn := NewPubNub(NewDemoConfig())
incl := []PNChannelMetadataInclude{
PNChannelMetadataIncludeCustom,
}
custom := make(map[string]interface{})
custom["a"] = "b"
custom["c"] = "d"
queryParam := map[string]string{
"q1": "v1",
"q2": "v2",
}
if !checkQueryParam {
queryParam = nil
}
inclStr := EnumArrayToStringArray(incl)
o := newGetChannelMetadataBuilder(pn)
if testContext {
o = newGetChannelMetadataBuilderWithContext(pn, backgroundContext)
}
o.Include(incl)
o.Channel("id0")
o.QueryParam(queryParam)
path, err := o.opts.buildPath()
assert.Nil(err)
h.AssertPathsEqual(t,
fmt.Sprintf("/v2/objects/%s/channels/%s", pn.Config.SubscribeKey, "id0"),
path, []int{})
body, err := o.opts.buildBody()
assert.Nil(err)
assert.Empty(body)
if checkQueryParam {
u, _ := o.opts.buildQuery()
assert.Equal("v1", u.Get("q1"))
assert.Equal("v2", u.Get("q2"))
assert.Equal(string(utils.JoinChannels(inclStr)), u.Get("include"))
}
}
func TestGetChannelMetadata(t *testing.T) {
AssertGetChannelMetadata(t, true, false)
}
func TestGetChannelMetadataContext(t *testing.T) {
AssertGetChannelMetadata(t, true, true)
}
func TestGetChannelMetadataResponseValueError(t *testing.T) {
assert := assert.New(t)
pn := NewPubNub(NewDemoConfig())
opts := newGetChannelMetadataOpts(pn, pn.ctx)
jsonBytes := []byte(`s`)
_, _, err := newPNGetChannelMetadataResponse(jsonBytes, opts, StatusResponse{})
assert.Equal("pubnub/parsing: Error unmarshalling response: {s}", err.Error())
}
func TestGetChannelMetadataResponseValuePass(t *testing.T) {
assert := assert.New(t)
pn := NewPubNub(NewDemoConfig())
opts := newGetChannelMetadataOpts(pn, pn.ctx)
jsonBytes := []byte(`{"status":200,"data":{"id":"id0","name":"name","description":"desc","custom":{"a":"b"},"created":"2019-08-20T13:26:08.341297Z","updated":"2019-08-20T13:26:08.341297Z","eTag":"Aee9zsKNndXlHw"}}`)
r, _, err := newPNGetChannelMetadataResponse(jsonBytes, opts, StatusResponse{})
assert.Equal("id0", r.Data.ID)
assert.Equal("name", r.Data.Name)
assert.Equal("desc", r.Data.Description)
//assert.Equal("2019-08-20T13:26:08.341297Z", r.Data.Created)
assert.Equal("2019-08-20T13:26:08.341297Z", r.Data.Updated)
assert.Equal("Aee9zsKNndXlHw", r.Data.ETag)
assert.Equal("b", r.Data.Custom["a"])
assert.Nil(err)
}