add fix

2025-03-26 20:40:24 +05:00 · 2025-03-26 20:40:24 +05:00 · 0a35dd7d10
commit 0a35dd7d10
parent 4b897baaac
2 changed files with 3 additions and 3 deletions
--- a/internal/model/sql/query.go
+++ b/internal/model/sql/query.go
@ -329,7 +329,7 @@ var DeleteFilteredWordsBatch = `
 DELETE FROM filters_words 
 USING filters 
 WHERE filters.id = filters_words.donat_filter_id
-  AND filters.streamer_id = @streamer_id 
+  AND filters.donat_filter_id = @donat_filter_id 
  AND filters_words.word = ANY(@words);
 `

--- a/internal/repository/donat/donat.go
+++ b/internal/repository/donat/donat.go
@ -553,8 +553,8 @@ func (repoDonat *RepoDonat) RemoveFilteredWords(
 	}

 	args := pgx.NamedArgs{
-		"streamer_id": filterID,
-		"words":       words,
+		"donat_filter_id": filterID,
+		"words":           words,
 	}

 	err := repoDonat.db.Exec(ctx, sql.DeleteFilteredWordsBatch, args)