1 package contentmoderator
2
3
4
5
6
7
8
9 import (
10 "context"
11 "github.com/Azure/go-autorest/autorest"
12 "github.com/Azure/go-autorest/autorest/azure"
13 "github.com/Azure/go-autorest/tracing"
14 "net/http"
15 )
16
17
18
19
20
21
22
23
24
25 type ListManagementTermClient struct {
26 BaseClient
27 }
28
29
30 func NewListManagementTermClient(endpoint string) ListManagementTermClient {
31 return ListManagementTermClient{New(endpoint)}
32 }
33
34
35
36
37
38
39 func (client ListManagementTermClient) AddTerm(ctx context.Context, listID string, term string, language string) (result autorest.Response, err error) {
40 if tracing.IsEnabled() {
41 ctx = tracing.StartSpan(ctx, fqdn+"/ListManagementTermClient.AddTerm")
42 defer func() {
43 sc := -1
44 if result.Response != nil {
45 sc = result.Response.StatusCode
46 }
47 tracing.EndSpan(ctx, sc, err)
48 }()
49 }
50 req, err := client.AddTermPreparer(ctx, listID, term, language)
51 if err != nil {
52 err = autorest.NewErrorWithError(err, "contentmoderator.ListManagementTermClient", "AddTerm", nil, "Failure preparing request")
53 return
54 }
55
56 resp, err := client.AddTermSender(req)
57 if err != nil {
58 result.Response = resp
59 err = autorest.NewErrorWithError(err, "contentmoderator.ListManagementTermClient", "AddTerm", resp, "Failure sending request")
60 return
61 }
62
63 result, err = client.AddTermResponder(resp)
64 if err != nil {
65 err = autorest.NewErrorWithError(err, "contentmoderator.ListManagementTermClient", "AddTerm", resp, "Failure responding to request")
66 return
67 }
68
69 return
70 }
71
72
73 func (client ListManagementTermClient) AddTermPreparer(ctx context.Context, listID string, term string, language string) (*http.Request, error) {
74 urlParameters := map[string]interface{}{
75 "Endpoint": client.Endpoint,
76 }
77
78 pathParameters := map[string]interface{}{
79 "listId": autorest.Encode("path", listID),
80 "term": autorest.Encode("path", term),
81 }
82
83 queryParameters := map[string]interface{}{
84 "language": autorest.Encode("query", language),
85 }
86
87 preparer := autorest.CreatePreparer(
88 autorest.AsPost(),
89 autorest.WithCustomBaseURL("{Endpoint}", urlParameters),
90 autorest.WithPathParameters("/contentmoderator/lists/v1.0/termlists/{listId}/terms/{term}", pathParameters),
91 autorest.WithQueryParameters(queryParameters))
92 return preparer.Prepare((&http.Request{}).WithContext(ctx))
93 }
94
95
96
97 func (client ListManagementTermClient) AddTermSender(req *http.Request) (*http.Response, error) {
98 return client.Send(req, autorest.DoRetryForStatusCodes(client.RetryAttempts, client.RetryDuration, autorest.StatusCodesForRetry...))
99 }
100
101
102
103 func (client ListManagementTermClient) AddTermResponder(resp *http.Response) (result autorest.Response, err error) {
104 err = autorest.Respond(
105 resp,
106 azure.WithErrorUnlessStatusCode(http.StatusOK, http.StatusCreated),
107 autorest.ByClosing())
108 result.Response = resp
109 return
110 }
111
112
113
114
115
116 func (client ListManagementTermClient) DeleteAllTerms(ctx context.Context, listID string, language string) (result String, err error) {
117 if tracing.IsEnabled() {
118 ctx = tracing.StartSpan(ctx, fqdn+"/ListManagementTermClient.DeleteAllTerms")
119 defer func() {
120 sc := -1
121 if result.Response.Response != nil {
122 sc = result.Response.Response.StatusCode
123 }
124 tracing.EndSpan(ctx, sc, err)
125 }()
126 }
127 req, err := client.DeleteAllTermsPreparer(ctx, listID, language)
128 if err != nil {
129 err = autorest.NewErrorWithError(err, "contentmoderator.ListManagementTermClient", "DeleteAllTerms", nil, "Failure preparing request")
130 return
131 }
132
133 resp, err := client.DeleteAllTermsSender(req)
134 if err != nil {
135 result.Response = autorest.Response{Response: resp}
136 err = autorest.NewErrorWithError(err, "contentmoderator.ListManagementTermClient", "DeleteAllTerms", resp, "Failure sending request")
137 return
138 }
139
140 result, err = client.DeleteAllTermsResponder(resp)
141 if err != nil {
142 err = autorest.NewErrorWithError(err, "contentmoderator.ListManagementTermClient", "DeleteAllTerms", resp, "Failure responding to request")
143 return
144 }
145
146 return
147 }
148
149
150 func (client ListManagementTermClient) DeleteAllTermsPreparer(ctx context.Context, listID string, language string) (*http.Request, error) {
151 urlParameters := map[string]interface{}{
152 "Endpoint": client.Endpoint,
153 }
154
155 pathParameters := map[string]interface{}{
156 "listId": autorest.Encode("path", listID),
157 }
158
159 queryParameters := map[string]interface{}{
160 "language": autorest.Encode("query", language),
161 }
162
163 preparer := autorest.CreatePreparer(
164 autorest.AsDelete(),
165 autorest.WithCustomBaseURL("{Endpoint}", urlParameters),
166 autorest.WithPathParameters("/contentmoderator/lists/v1.0/termlists/{listId}/terms", pathParameters),
167 autorest.WithQueryParameters(queryParameters))
168 return preparer.Prepare((&http.Request{}).WithContext(ctx))
169 }
170
171
172
173 func (client ListManagementTermClient) DeleteAllTermsSender(req *http.Request) (*http.Response, error) {
174 return client.Send(req, autorest.DoRetryForStatusCodes(client.RetryAttempts, client.RetryDuration, autorest.StatusCodesForRetry...))
175 }
176
177
178
179 func (client ListManagementTermClient) DeleteAllTermsResponder(resp *http.Response) (result String, err error) {
180 err = autorest.Respond(
181 resp,
182 azure.WithErrorUnlessStatusCode(http.StatusOK, http.StatusNoContent),
183 autorest.ByUnmarshallingJSON(&result.Value),
184 autorest.ByClosing())
185 result.Response = autorest.Response{Response: resp}
186 return
187 }
188
189
190
191
192
193
194 func (client ListManagementTermClient) DeleteTerm(ctx context.Context, listID string, term string, language string) (result String, err error) {
195 if tracing.IsEnabled() {
196 ctx = tracing.StartSpan(ctx, fqdn+"/ListManagementTermClient.DeleteTerm")
197 defer func() {
198 sc := -1
199 if result.Response.Response != nil {
200 sc = result.Response.Response.StatusCode
201 }
202 tracing.EndSpan(ctx, sc, err)
203 }()
204 }
205 req, err := client.DeleteTermPreparer(ctx, listID, term, language)
206 if err != nil {
207 err = autorest.NewErrorWithError(err, "contentmoderator.ListManagementTermClient", "DeleteTerm", nil, "Failure preparing request")
208 return
209 }
210
211 resp, err := client.DeleteTermSender(req)
212 if err != nil {
213 result.Response = autorest.Response{Response: resp}
214 err = autorest.NewErrorWithError(err, "contentmoderator.ListManagementTermClient", "DeleteTerm", resp, "Failure sending request")
215 return
216 }
217
218 result, err = client.DeleteTermResponder(resp)
219 if err != nil {
220 err = autorest.NewErrorWithError(err, "contentmoderator.ListManagementTermClient", "DeleteTerm", resp, "Failure responding to request")
221 return
222 }
223
224 return
225 }
226
227
228 func (client ListManagementTermClient) DeleteTermPreparer(ctx context.Context, listID string, term string, language string) (*http.Request, error) {
229 urlParameters := map[string]interface{}{
230 "Endpoint": client.Endpoint,
231 }
232
233 pathParameters := map[string]interface{}{
234 "listId": autorest.Encode("path", listID),
235 "term": autorest.Encode("path", term),
236 }
237
238 queryParameters := map[string]interface{}{
239 "language": autorest.Encode("query", language),
240 }
241
242 preparer := autorest.CreatePreparer(
243 autorest.AsDelete(),
244 autorest.WithCustomBaseURL("{Endpoint}", urlParameters),
245 autorest.WithPathParameters("/contentmoderator/lists/v1.0/termlists/{listId}/terms/{term}", pathParameters),
246 autorest.WithQueryParameters(queryParameters))
247 return preparer.Prepare((&http.Request{}).WithContext(ctx))
248 }
249
250
251
252 func (client ListManagementTermClient) DeleteTermSender(req *http.Request) (*http.Response, error) {
253 return client.Send(req, autorest.DoRetryForStatusCodes(client.RetryAttempts, client.RetryDuration, autorest.StatusCodesForRetry...))
254 }
255
256
257
258 func (client ListManagementTermClient) DeleteTermResponder(resp *http.Response) (result String, err error) {
259 err = autorest.Respond(
260 resp,
261 azure.WithErrorUnlessStatusCode(http.StatusOK, http.StatusNoContent),
262 autorest.ByUnmarshallingJSON(&result.Value),
263 autorest.ByClosing())
264 result.Response = autorest.Response{Response: resp}
265 return
266 }
267
268
269
270
271
272
273
274 func (client ListManagementTermClient) GetAllTerms(ctx context.Context, listID string, language string, offset *int32, limit *int32) (result Terms, err error) {
275 if tracing.IsEnabled() {
276 ctx = tracing.StartSpan(ctx, fqdn+"/ListManagementTermClient.GetAllTerms")
277 defer func() {
278 sc := -1
279 if result.Response.Response != nil {
280 sc = result.Response.Response.StatusCode
281 }
282 tracing.EndSpan(ctx, sc, err)
283 }()
284 }
285 req, err := client.GetAllTermsPreparer(ctx, listID, language, offset, limit)
286 if err != nil {
287 err = autorest.NewErrorWithError(err, "contentmoderator.ListManagementTermClient", "GetAllTerms", nil, "Failure preparing request")
288 return
289 }
290
291 resp, err := client.GetAllTermsSender(req)
292 if err != nil {
293 result.Response = autorest.Response{Response: resp}
294 err = autorest.NewErrorWithError(err, "contentmoderator.ListManagementTermClient", "GetAllTerms", resp, "Failure sending request")
295 return
296 }
297
298 result, err = client.GetAllTermsResponder(resp)
299 if err != nil {
300 err = autorest.NewErrorWithError(err, "contentmoderator.ListManagementTermClient", "GetAllTerms", resp, "Failure responding to request")
301 return
302 }
303
304 return
305 }
306
307
308 func (client ListManagementTermClient) GetAllTermsPreparer(ctx context.Context, listID string, language string, offset *int32, limit *int32) (*http.Request, error) {
309 urlParameters := map[string]interface{}{
310 "Endpoint": client.Endpoint,
311 }
312
313 pathParameters := map[string]interface{}{
314 "listId": autorest.Encode("path", listID),
315 }
316
317 queryParameters := map[string]interface{}{
318 "language": autorest.Encode("query", language),
319 }
320 if offset != nil {
321 queryParameters["offset"] = autorest.Encode("query", *offset)
322 }
323 if limit != nil {
324 queryParameters["limit"] = autorest.Encode("query", *limit)
325 }
326
327 preparer := autorest.CreatePreparer(
328 autorest.AsGet(),
329 autorest.WithCustomBaseURL("{Endpoint}", urlParameters),
330 autorest.WithPathParameters("/contentmoderator/lists/v1.0/termlists/{listId}/terms", pathParameters),
331 autorest.WithQueryParameters(queryParameters))
332 return preparer.Prepare((&http.Request{}).WithContext(ctx))
333 }
334
335
336
337 func (client ListManagementTermClient) GetAllTermsSender(req *http.Request) (*http.Response, error) {
338 return client.Send(req, autorest.DoRetryForStatusCodes(client.RetryAttempts, client.RetryDuration, autorest.StatusCodesForRetry...))
339 }
340
341
342
343 func (client ListManagementTermClient) GetAllTermsResponder(resp *http.Response) (result Terms, err error) {
344 err = autorest.Respond(
345 resp,
346 azure.WithErrorUnlessStatusCode(http.StatusOK),
347 autorest.ByUnmarshallingJSON(&result),
348 autorest.ByClosing())
349 result.Response = autorest.Response{Response: resp}
350 return
351 }
352
View as plain text