larryh/corso
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Added error trace reading for query calls. (#575)

Browse Source 
Added error tracing that gives more details for failed GraphQuery reading for query calls.
This commit is contained in:
Danny 2022-08-17 09:07:53 -04:00 committed by GitHub
parent 24b40cf601
commit 41f22ad9a4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/internal/connector/graph_connector.go
View File

@ -126,7 +126,12 @@ func (gc *GraphConnector) setTenantUsers() error {
} }
response, err := gc.Client().Users().GetWithRequestConfigurationAndResponseHandler(options, nil) response, err := gc.Client().Users().GetWithRequestConfigurationAndResponseHandler(options, nil)
if err != nil { if err != nil {
return err return errors.Wrapf(
err,
"tenant %s M365 query: %s",
gc.tenant,
support.ConnectorStackErrorTrace(err),
)
} }
if response == nil { if response == nil {
err = support.WrapAndAppend("general access", errors.New("connector failed: No access"), err) err = support.WrapAndAppend("general access", errors.New("connector failed: No access"), err)
@ -138,7 +143,7 @@ func (gc *GraphConnector) setTenantUsers() error {
models.CreateUserCollectionResponseFromDiscriminatorValue, models.CreateUserCollectionResponseFromDiscriminatorValue,
) )
if err != nil { if err != nil {
return err return errors.Wrap(err, support.ConnectorStackErrorTrace(err))
} }
var iterateError error var iterateError error
callbackFunc := func(userItem interface{}) bool { callbackFunc := func(userItem interface{}) bool {
@ -318,7 +323,10 @@ func (gc *GraphConnector) createCollections(
} }
response, err := query(&gc.graphService, user) response, err := query(&gc.graphService, user)
if err != nil { if err != nil {
return nil, err return nil, errors.Wrapf(
err,
"user %s M365 query: %s",
user, support.ConnectorStackErrorTrace(err))
} }
pageIterator, err := msgraphgocore.NewPageIterator(response, &gc.graphService.adapter, transformer) pageIterator, err := msgraphgocore.NewPageIterator(response, &gc.graphService.adapter, transformer)
if err != nil { if err != nil {