/
objects_remove_channel_metadata.go
136 lines (104 loc) · 3.73 KB
/
objects_remove_channel_metadata.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
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
package pubnub
import (
"bytes"
"encoding/json"
"fmt"
"io/ioutil"
"net/http"
"net/url"
"github.com/pubnub/go/v7/pnerr"
)
var emptyPNRemoveChannelMetadataResponse *PNRemoveChannelMetadataResponse
const removeChannelMetadataPath = "/v2/objects/%s/channels/%s"
type removeChannelMetadataBuilder struct {
opts *removeChannelMetadataOpts
}
func newRemoveChannelMetadataBuilder(pubnub *PubNub) *removeChannelMetadataBuilder {
return newRemoveChannelMetadataBuilderWithContext(pubnub, pubnub.ctx)
}
func newRemoveChannelMetadataOpts(pubnub *PubNub, ctx Context) *removeChannelMetadataOpts {
return &removeChannelMetadataOpts{endpointOpts: endpointOpts{pubnub: pubnub, ctx: ctx}}
}
func newRemoveChannelMetadataBuilderWithContext(pubnub *PubNub,
context Context) *removeChannelMetadataBuilder {
builder := removeChannelMetadataBuilder{
opts: newRemoveChannelMetadataOpts(pubnub, context)}
return &builder
}
func (b *removeChannelMetadataBuilder) Channel(channel string) *removeChannelMetadataBuilder {
b.opts.Channel = channel
return b
}
// QueryParam accepts a map, the keys and values of the map are passed as the query string parameters of the URL called by the API.
func (b *removeChannelMetadataBuilder) QueryParam(queryParam map[string]string) *removeChannelMetadataBuilder {
b.opts.QueryParam = queryParam
return b
}
// Transport sets the Transport for the removeChannelMetadata request.
func (b *removeChannelMetadataBuilder) Transport(tr http.RoundTripper) *removeChannelMetadataBuilder {
b.opts.Transport = tr
return b
}
// Execute runs the removeChannelMetadata request.
func (b *removeChannelMetadataBuilder) Execute() (*PNRemoveChannelMetadataResponse, StatusResponse, error) {
rawJSON, status, err := executeRequest(b.opts)
if err != nil {
return emptyPNRemoveChannelMetadataResponse, status, err
}
return newPNRemoveChannelMetadataResponse(rawJSON, b.opts, status)
}
type removeChannelMetadataOpts struct {
endpointOpts
Channel string
QueryParam map[string]string
Transport http.RoundTripper
}
func (o *removeChannelMetadataOpts) validate() error {
if o.config().SubscribeKey == "" {
return newValidationError(o, StrMissingSubKey)
}
if o.Channel == "" {
return newValidationError(o, StrMissingChannel)
}
return nil
}
func (o *removeChannelMetadataOpts) buildPath() (string, error) {
return fmt.Sprintf(removeChannelMetadataPath,
o.pubnub.Config.SubscribeKey, o.Channel), nil
}
func (o *removeChannelMetadataOpts) buildQuery() (*url.Values, error) {
q := defaultQuery(o.pubnub.Config.UUID, o.pubnub.telemetryManager)
SetQueryParam(q, o.QueryParam)
return q, nil
}
func (o *removeChannelMetadataOpts) httpMethod() string {
return "DELETE"
}
func (o *removeChannelMetadataOpts) isAuthRequired() bool {
return true
}
func (o *removeChannelMetadataOpts) requestTimeout() int {
return o.pubnub.Config.NonSubscribeRequestTimeout
}
func (o *removeChannelMetadataOpts) connectTimeout() int {
return o.pubnub.Config.ConnectTimeout
}
func (o *removeChannelMetadataOpts) operationType() OperationType {
return PNRemoveChannelMetadataOperation
}
// PNRemoveChannelMetadataResponse is the Objects API Response for delete space
type PNRemoveChannelMetadataResponse struct {
status int `json:"status"`
Data interface{} `json:"data"`
}
func newPNRemoveChannelMetadataResponse(jsonBytes []byte, o *removeChannelMetadataOpts,
status StatusResponse) (*PNRemoveChannelMetadataResponse, StatusResponse, error) {
resp := &PNRemoveChannelMetadataResponse{}
err := json.Unmarshal(jsonBytes, &resp)
if err != nil {
e := pnerr.NewResponseParsingError("Error unmarshalling response",
ioutil.NopCloser(bytes.NewBufferString(string(jsonBytes))), err)
return emptyPNRemoveChannelMetadataResponse, status, e
}
return resp, status, nil
}