1 package graphrbac
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/autorest/to"
14 "github.com/Azure/go-autorest/tracing"
15 "net/http"
16 )
17
18
19 type SignedInUserClient struct {
20 BaseClient
21 }
22
23
24 func NewSignedInUserClient(tenantID string) SignedInUserClient {
25 return NewSignedInUserClientWithBaseURI(DefaultBaseURI, tenantID)
26 }
27
28
29
30 func NewSignedInUserClientWithBaseURI(baseURI string, tenantID string) SignedInUserClient {
31 return SignedInUserClient{NewWithBaseURI(baseURI, tenantID)}
32 }
33
34
35 func (client SignedInUserClient) Get(ctx context.Context) (result User, err error) {
36 if tracing.IsEnabled() {
37 ctx = tracing.StartSpan(ctx, fqdn+"/SignedInUserClient.Get")
38 defer func() {
39 sc := -1
40 if result.Response.Response != nil {
41 sc = result.Response.Response.StatusCode
42 }
43 tracing.EndSpan(ctx, sc, err)
44 }()
45 }
46 req, err := client.GetPreparer(ctx)
47 if err != nil {
48 err = autorest.NewErrorWithError(err, "graphrbac.SignedInUserClient", "Get", nil, "Failure preparing request")
49 return
50 }
51
52 resp, err := client.GetSender(req)
53 if err != nil {
54 result.Response = autorest.Response{Response: resp}
55 err = autorest.NewErrorWithError(err, "graphrbac.SignedInUserClient", "Get", resp, "Failure sending request")
56 return
57 }
58
59 result, err = client.GetResponder(resp)
60 if err != nil {
61 err = autorest.NewErrorWithError(err, "graphrbac.SignedInUserClient", "Get", resp, "Failure responding to request")
62 return
63 }
64
65 return
66 }
67
68
69 func (client SignedInUserClient) GetPreparer(ctx context.Context) (*http.Request, error) {
70 pathParameters := map[string]interface{}{
71 "tenantID": autorest.Encode("path", client.TenantID),
72 }
73
74 const APIVersion = "1.6"
75 queryParameters := map[string]interface{}{
76 "api-version": APIVersion,
77 }
78
79 preparer := autorest.CreatePreparer(
80 autorest.AsGet(),
81 autorest.WithBaseURL(client.BaseURI),
82 autorest.WithPathParameters("/{tenantID}/me", pathParameters),
83 autorest.WithQueryParameters(queryParameters))
84 return preparer.Prepare((&http.Request{}).WithContext(ctx))
85 }
86
87
88
89 func (client SignedInUserClient) GetSender(req *http.Request) (*http.Response, error) {
90 return client.Send(req, autorest.DoRetryForStatusCodes(client.RetryAttempts, client.RetryDuration, autorest.StatusCodesForRetry...))
91 }
92
93
94
95 func (client SignedInUserClient) GetResponder(resp *http.Response) (result User, err error) {
96 err = autorest.Respond(
97 resp,
98 azure.WithErrorUnlessStatusCode(http.StatusOK),
99 autorest.ByUnmarshallingJSON(&result),
100 autorest.ByClosing())
101 result.Response = autorest.Response{Response: resp}
102 return
103 }
104
105
106 func (client SignedInUserClient) ListOwnedObjects(ctx context.Context) (result DirectoryObjectListResultPage, err error) {
107 if tracing.IsEnabled() {
108 ctx = tracing.StartSpan(ctx, fqdn+"/SignedInUserClient.ListOwnedObjects")
109 defer func() {
110 sc := -1
111 if result.dolr.Response.Response != nil {
112 sc = result.dolr.Response.Response.StatusCode
113 }
114 tracing.EndSpan(ctx, sc, err)
115 }()
116 }
117 result.fn = func(ctx context.Context, lastResult DirectoryObjectListResult) (DirectoryObjectListResult, error) {
118 if lastResult.OdataNextLink == nil || len(to.String(lastResult.OdataNextLink)) < 1 {
119 return DirectoryObjectListResult{}, nil
120 }
121 return client.ListOwnedObjectsNext(ctx, *lastResult.OdataNextLink)
122 }
123 req, err := client.ListOwnedObjectsPreparer(ctx)
124 if err != nil {
125 err = autorest.NewErrorWithError(err, "graphrbac.SignedInUserClient", "ListOwnedObjects", nil, "Failure preparing request")
126 return
127 }
128
129 resp, err := client.ListOwnedObjectsSender(req)
130 if err != nil {
131 result.dolr.Response = autorest.Response{Response: resp}
132 err = autorest.NewErrorWithError(err, "graphrbac.SignedInUserClient", "ListOwnedObjects", resp, "Failure sending request")
133 return
134 }
135
136 result.dolr, err = client.ListOwnedObjectsResponder(resp)
137 if err != nil {
138 err = autorest.NewErrorWithError(err, "graphrbac.SignedInUserClient", "ListOwnedObjects", resp, "Failure responding to request")
139 return
140 }
141 if result.dolr.hasNextLink() && result.dolr.IsEmpty() {
142 err = result.NextWithContext(ctx)
143 return
144 }
145
146 return
147 }
148
149
150 func (client SignedInUserClient) ListOwnedObjectsPreparer(ctx context.Context) (*http.Request, error) {
151 pathParameters := map[string]interface{}{
152 "tenantID": autorest.Encode("path", client.TenantID),
153 }
154
155 const APIVersion = "1.6"
156 queryParameters := map[string]interface{}{
157 "api-version": APIVersion,
158 }
159
160 preparer := autorest.CreatePreparer(
161 autorest.AsGet(),
162 autorest.WithBaseURL(client.BaseURI),
163 autorest.WithPathParameters("/{tenantID}/me/ownedObjects", pathParameters),
164 autorest.WithQueryParameters(queryParameters))
165 return preparer.Prepare((&http.Request{}).WithContext(ctx))
166 }
167
168
169
170 func (client SignedInUserClient) ListOwnedObjectsSender(req *http.Request) (*http.Response, error) {
171 return client.Send(req, autorest.DoRetryForStatusCodes(client.RetryAttempts, client.RetryDuration, autorest.StatusCodesForRetry...))
172 }
173
174
175
176 func (client SignedInUserClient) ListOwnedObjectsResponder(resp *http.Response) (result DirectoryObjectListResult, err error) {
177 err = autorest.Respond(
178 resp,
179 azure.WithErrorUnlessStatusCode(http.StatusOK),
180 autorest.ByUnmarshallingJSON(&result),
181 autorest.ByClosing())
182 result.Response = autorest.Response{Response: resp}
183 return
184 }
185
186
187 func (client SignedInUserClient) ListOwnedObjectsComplete(ctx context.Context) (result DirectoryObjectListResultIterator, err error) {
188 if tracing.IsEnabled() {
189 ctx = tracing.StartSpan(ctx, fqdn+"/SignedInUserClient.ListOwnedObjects")
190 defer func() {
191 sc := -1
192 if result.Response().Response.Response != nil {
193 sc = result.page.Response().Response.Response.StatusCode
194 }
195 tracing.EndSpan(ctx, sc, err)
196 }()
197 }
198 result.page, err = client.ListOwnedObjects(ctx)
199 return
200 }
201
202
203
204
205 func (client SignedInUserClient) ListOwnedObjectsNext(ctx context.Context, nextLink string) (result DirectoryObjectListResult, err error) {
206 if tracing.IsEnabled() {
207 ctx = tracing.StartSpan(ctx, fqdn+"/SignedInUserClient.ListOwnedObjectsNext")
208 defer func() {
209 sc := -1
210 if result.Response.Response != nil {
211 sc = result.Response.Response.StatusCode
212 }
213 tracing.EndSpan(ctx, sc, err)
214 }()
215 }
216 req, err := client.ListOwnedObjectsNextPreparer(ctx, nextLink)
217 if err != nil {
218 err = autorest.NewErrorWithError(err, "graphrbac.SignedInUserClient", "ListOwnedObjectsNext", nil, "Failure preparing request")
219 return
220 }
221
222 resp, err := client.ListOwnedObjectsNextSender(req)
223 if err != nil {
224 result.Response = autorest.Response{Response: resp}
225 err = autorest.NewErrorWithError(err, "graphrbac.SignedInUserClient", "ListOwnedObjectsNext", resp, "Failure sending request")
226 return
227 }
228
229 result, err = client.ListOwnedObjectsNextResponder(resp)
230 if err != nil {
231 err = autorest.NewErrorWithError(err, "graphrbac.SignedInUserClient", "ListOwnedObjectsNext", resp, "Failure responding to request")
232 return
233 }
234
235 return
236 }
237
238
239 func (client SignedInUserClient) ListOwnedObjectsNextPreparer(ctx context.Context, nextLink string) (*http.Request, error) {
240 pathParameters := map[string]interface{}{
241 "nextLink": nextLink,
242 "tenantID": autorest.Encode("path", client.TenantID),
243 }
244
245 const APIVersion = "1.6"
246 queryParameters := map[string]interface{}{
247 "api-version": APIVersion,
248 }
249
250 preparer := autorest.CreatePreparer(
251 autorest.AsGet(),
252 autorest.WithBaseURL(client.BaseURI),
253 autorest.WithPathParameters("/{tenantID}/{nextLink}", pathParameters),
254 autorest.WithQueryParameters(queryParameters))
255 return preparer.Prepare((&http.Request{}).WithContext(ctx))
256 }
257
258
259
260 func (client SignedInUserClient) ListOwnedObjectsNextSender(req *http.Request) (*http.Response, error) {
261 return client.Send(req, autorest.DoRetryForStatusCodes(client.RetryAttempts, client.RetryDuration, autorest.StatusCodesForRetry...))
262 }
263
264
265
266 func (client SignedInUserClient) ListOwnedObjectsNextResponder(resp *http.Response) (result DirectoryObjectListResult, err error) {
267 err = autorest.Respond(
268 resp,
269 azure.WithErrorUnlessStatusCode(http.StatusOK),
270 autorest.ByUnmarshallingJSON(&result),
271 autorest.ByClosing())
272 result.Response = autorest.Response{Response: resp}
273 return
274 }
275
View as plain text