Skip to content

Commit

Permalink
refactor: pleasing the sonarqube
Browse files Browse the repository at this point in the history
Signed-off-by: Vincent Boutour <[email protected]>
  • Loading branch information
ViBiOh committed Sep 13, 2022
1 parent b192408 commit e54ae95
Show file tree
Hide file tree
Showing 3 changed files with 10 additions and 14 deletions.
10 changes: 7 additions & 3 deletions pkg/crud/list.go
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,10 @@ import (
"go.opentelemetry.io/otel/trace"
)

func listLogger(pathname string) logger.Provider {
return logger.WithField("fn", "crud.list").WithField("item", pathname)
}

func (a App) list(ctx context.Context, request provider.Request, message renderer.Message, item absto.Item, files []absto.Item) (renderer.Page, error) {
ctx, end := tracer.StartSpan(ctx, a.tracer, "list", trace.WithAttributes(attribute.String("item", item.Pathname)))
defer end()
Expand All @@ -32,7 +36,7 @@ func (a App) list(ctx context.Context, request provider.Request, message rendere

directoryAggregate, err = a.exifApp.GetAggregateFor(ctx, item)
if err != nil && !absto.IsNotExist(err) {
logger.WithField("fn", "crud.list").WithField("item", item.Pathname).Error("get aggregate: %s", err)
listLogger(item.Pathname).Error("get aggregate: %s", err)
}
})

Expand All @@ -42,7 +46,7 @@ func (a App) list(ctx context.Context, request provider.Request, message rendere

aggregates, err = a.exifApp.ListAggregateFor(ctx, files...)
if err != nil {
logger.WithField("fn", "crud.list").WithField("item", item.Pathname).Error("list exifs: %s", err)
listLogger(item.Pathname).Error("list exifs: %s", err)
}
})

Expand All @@ -55,7 +59,7 @@ func (a App) list(ctx context.Context, request provider.Request, message rendere

thumbnails, err = a.thumbnailApp.ListDir(ctx, item)
if err != nil {
logger.WithField("fn", "crud.list").WithField("item", item.Pathname).Error("list thumbnail: %s", err)
listLogger(item.Pathname).Error("list thumbnail: %s", err)
return
}
}()
Expand Down
4 changes: 2 additions & 2 deletions pkg/exif/aggregate.go
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ func (a App) ListExifFor(ctx context.Context, items ...absto.Item) (map[string]e
ctx, end := tracer.StartSpan(ctx, a.tracer, "list_exif")
defer end()

exifs, err := a.exifCacheApp.List(ctx, onExifError, items...)
exifs, err := a.exifCacheApp.List(ctx, onListError, items...)
if err != nil {
return nil, fmt.Errorf("list: %w", err)
}
Expand Down Expand Up @@ -70,7 +70,7 @@ func (a App) ListAggregateFor(ctx context.Context, items ...absto.Item) (map[str
ctx, end := tracer.StartSpan(ctx, a.tracer, "list_aggregate")
defer end()

exifs, err := a.aggregateCacheApp.List(ctx, onAggregateError, items...)
exifs, err := a.aggregateCacheApp.List(ctx, onListError, items...)
if err != nil {
return nil, fmt.Errorf("list: %w", err)
}
Expand Down
10 changes: 1 addition & 9 deletions pkg/exif/error.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,15 +7,7 @@ import (
"github.com/ViBiOh/httputils/v4/pkg/logger"
)

func onExifError(item absto.Item, err error) bool {
if !absto.IsNotExist(err) && !errors.Is(err, errInvalidItemType) {
logger.WithField("item", item.Pathname).Error("load exif: %s", item.Pathname, err)
}

return true
}

func onAggregateError(item absto.Item, err error) bool {
func onListError(item absto.Item, err error) bool {
if !absto.IsNotExist(err) && !errors.Is(err, errInvalidItemType) {
logger.WithField("item", item.Pathname).Error("load exif: %s", item.Pathname, err)
}
Expand Down

0 comments on commit e54ae95

Please sign in to comment.