Anthrove/otter-space-sdk
5
0
Fork 0
Code Issues Pull Requests Actions Projects Releases 9 Activity

SDK v3 #8

Merged
SoXX merged 77 commits from dev/issue-5 into main 2024-08-14 13:27:35 +00:00
Conversation 0 Commits 77 Files Changed 67 +6 -6
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 098ecda869 - Show all commits

12
pkg/database/tagAlias.go
View File

@ -69,10 +69,10 @@ func CreateTagAliasInBatch(ctx context.Context, tagsAliases []models.TagAlias, b
span.SetAttributes( span.SetAttributes(
attribute.Int64("batch_size", int64(batchSize)), attribute.Int64("batch_size", int64(batchSize)),
attribute.Int64("tag_count", int64(len(tagsAliases))), attribute.Int64("tag_aliases_count", int64(len(tagsAliases))),
) )
span.AddEvent("Starting batch tag creation") span.AddEvent("Starting batch tag alias creation")
if client == nil { if client == nil {
return utils.HandleError(ctx, span, logger, nil, &otterError.Database{Reason: otterError.DatabaseIsNotConnected}) return utils.HandleError(ctx, span, logger, nil, &otterError.Database{Reason: otterError.DatabaseIsNotConnected})
@ -87,26 +87,26 @@ func CreateTagAliasInBatch(ctx context.Context, tagsAliases []models.TagAlias, b
} }
logger.WithContext(ctx).WithFields(log.Fields{ logger.WithContext(ctx).WithFields(log.Fields{
"tag_alias_length": len(tagsAliases), "tag_aliases_count": len(tagsAliases),
}).Debug("attempting to create tags aliases") }).Debug("attempting to create tags aliases")
result := client.WithContext(ctx).CreateInBatches(&tagsAliases, batchSize) result := client.WithContext(ctx).CreateInBatches(&tagsAliases, batchSize)
if result.Error != nil { if result.Error != nil {
if errors.Is(result.Error, gorm.ErrDuplicatedKey) { if errors.Is(result.Error, gorm.ErrDuplicatedKey) {
loggerFields := log.Fields{ loggerFields := log.Fields{
"tag_alias_length": len(tagsAliases), "tag_aliases_count": len(tagsAliases),
} }
return utils.HandleError(ctx, span, logger, loggerFields, &otterError.Database{Reason: otterError.DuplicateKey}) return utils.HandleError(ctx, span, logger, loggerFields, &otterError.Database{Reason: otterError.DuplicateKey})
} }
loggerFields := log.Fields{ loggerFields := log.Fields{
"tag_alias_length": len(tagsAliases), "tag_aliases_count": len(tagsAliases),
} }
return utils.HandleError(ctx, span, logger, loggerFields, result.Error) return utils.HandleError(ctx, span, logger, loggerFields, result.Error)
} }
logger.WithContext(ctx).WithFields(log.Fields{ logger.WithContext(ctx).WithFields(log.Fields{
"tag_alias_length": len(tagsAliases), "tag_aliases_count": len(tagsAliases),
}).Debug("batch tags aliases created") }).Debug("batch tags aliases created")
span.AddEvent("Batch tags aliases created successfully") span.AddEvent("Batch tags aliases created successfully")