diff --git a/src/internal/m365/collection/exchange/contacts_container_cache.go b/src/internal/m365/collection/exchange/contacts_container_cache.go index 857ccf9df..52a762f43 100644 --- a/src/internal/m365/collection/exchange/contacts_container_cache.go +++ b/src/internal/m365/collection/exchange/contacts_container_cache.go @@ -2,12 +2,14 @@ package exchange import ( "context" + "time" "github.com/alcionai/clues" "github.com/microsoftgraph/msgraph-sdk-go/models" "github.com/alcionai/corso/src/internal/common/ptr" "github.com/alcionai/corso/src/pkg/fault" + "github.com/alcionai/corso/src/pkg/logger" "github.com/alcionai/corso/src/pkg/path" "github.com/alcionai/corso/src/pkg/services/m365/api/graph" ) @@ -93,6 +95,10 @@ func (cfc *contactContainerCache) Populate( baseID string, baseContainerPath ...string, ) error { + start := time.Now() + + logger.Ctx(ctx).Info("populating container cache") + if err := cfc.init(ctx, baseID, baseContainerPath); err != nil { return clues.Wrap(err, "initializing") } @@ -104,8 +110,10 @@ func (cfc *contactContainerCache) Populate( cfc.userID, baseID, false) + ctx = clues.Add(ctx, "num_enumerated_containers", len(containers)) + if err != nil { - return clues.Wrap(err, "enumerating containers") + return clues.WrapWC(ctx, err, "enumerating containers") } for _, c := range containers { @@ -127,5 +135,9 @@ func (cfc *contactContainerCache) Populate( return clues.Wrap(err, "populating paths") } + logger.Ctx(ctx).Infow( + "done populating container cache", + "duration", time.Since(start)) + return el.Failure() } diff --git a/src/internal/m365/collection/exchange/events_container_cache.go b/src/internal/m365/collection/exchange/events_container_cache.go index dd1d9e280..e6a9ce3e4 100644 --- a/src/internal/m365/collection/exchange/events_container_cache.go +++ b/src/internal/m365/collection/exchange/events_container_cache.go @@ -2,12 +2,14 @@ package exchange import ( "context" + "time" "github.com/alcionai/clues" "github.com/microsoftgraph/msgraph-sdk-go/models" "github.com/alcionai/corso/src/internal/common/ptr" "github.com/alcionai/corso/src/pkg/fault" + "github.com/alcionai/corso/src/pkg/logger" "github.com/alcionai/corso/src/pkg/path" "github.com/alcionai/corso/src/pkg/services/m365/api" "github.com/alcionai/corso/src/pkg/services/m365/api/graph" @@ -67,6 +69,10 @@ func (ecc *eventContainerCache) Populate( baseID string, baseContainerPath ...string, ) error { + start := time.Now() + + logger.Ctx(ctx).Info("populating container cache") + if err := ecc.init(ctx); err != nil { return clues.Wrap(err, "initializing") } @@ -78,8 +84,10 @@ func (ecc *eventContainerCache) Populate( ecc.userID, "", false) + ctx = clues.Add(ctx, "num_enumerated_containers", len(containers)) + if err != nil { - return clues.Wrap(err, "enumerating containers") + return clues.WrapWC(ctx, err, "enumerating containers") } for _, c := range containers { @@ -104,6 +112,10 @@ func (ecc *eventContainerCache) Populate( return clues.Wrap(err, "populating paths") } + logger.Ctx(ctx).Infow( + "done populating container cache", + "duration", time.Since(start)) + return el.Failure() } diff --git a/src/internal/m365/collection/exchange/mail_container_cache.go b/src/internal/m365/collection/exchange/mail_container_cache.go index b3b9c054b..aa205b258 100644 --- a/src/internal/m365/collection/exchange/mail_container_cache.go +++ b/src/internal/m365/collection/exchange/mail_container_cache.go @@ -2,11 +2,13 @@ package exchange import ( "context" + "time" "github.com/alcionai/clues" "github.com/microsoftgraph/msgraph-sdk-go/models" "github.com/alcionai/corso/src/pkg/fault" + "github.com/alcionai/corso/src/pkg/logger" "github.com/alcionai/corso/src/pkg/path" "github.com/alcionai/corso/src/pkg/services/m365/api" "github.com/alcionai/corso/src/pkg/services/m365/api/graph" @@ -97,6 +99,10 @@ func (mc *mailContainerCache) Populate( baseID string, baseContainerPath ...string, ) error { + start := time.Now() + + logger.Ctx(ctx).Info("populating container cache") + if err := mc.init(ctx); err != nil { return clues.Wrap(err, "initializing") } @@ -108,8 +114,10 @@ func (mc *mailContainerCache) Populate( mc.userID, "", false) + ctx = clues.Add(ctx, "num_enumerated_containers", len(containers)) + if err != nil { - return clues.Wrap(err, "enumerating containers") + return clues.WrapWC(ctx, err, "enumerating containers") } for _, c := range containers { @@ -131,5 +139,9 @@ func (mc *mailContainerCache) Populate( return clues.Wrap(err, "populating paths") } + logger.Ctx(ctx).Infow( + "done populating container cache", + "duration", time.Since(start)) + return el.Failure() }