Fix sync filter map reading

v1adhope · Apr 21, 2023 · 5aee365 · 5aee365
1 parent 6f18182
commit 5aee365
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/.bin/app b/.bin/app
diff --git a/internal/usecase/repository/filter.go b/internal/usecase/repository/filter.go
@@ -3,6 +3,7 @@ package repository
 import (
 	"fmt"
 	"strings"
+	"sync"
 
 	"github.com/v1adhope/crypto-diary/internal/entity"
 )
@@ -20,16 +21,21 @@ type filterBuilderDeps struct {
 }
 
 func BuildFilterString(deps filterBuilderDeps) (string, []string) {
-	var filterRaw strings.Builder
+	var (
+		filterRaw strings.Builder
+		mu        sync.RWMutex
+	)
 
 	args, argsCounter := make([]string, 0), deps.QueryPlaceholderCount+1
 
 	for fieldKey, fieldVal := range deps.Filter.Fields {
+		mu.RLock()
 		if realFilterName, ok := allowedFilters[fieldKey]; ok {
 			fmt.Fprintf(&filterRaw, "AND %s = $%d ", realFilterName, argsCounter)
 			args = append(args, fieldVal)
 			argsCounter++
 		}
+		mu.RUnlock()
 	}
 
 	fmt.Fprintf(&filterRaw, "ORDER by position_id ASC LIMIT $%d", argsCounter)