opensource/supermq
1
0
Fork 0
mirror of https://github.com/absmach/supermq.git synced 2026-06-23 07:10:19 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

MG-217 - Update the RE update tag repo logic

Browse Source 
Signed-off-by: Dusan Borovcanin <borovcanindusan1@gmail.com>
This commit is contained in:
Dušan Borovčanin
2025-06-20 17:06:10 +02:00
committed by GitHub
parent 184a9161d6
commit 612823b4d2
1 changed files with 11 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
re/postgres/repository.go
+11 -13
View File
@@ -164,20 +164,18 @@ func (repo *PostgresRepository) update(ctx context.Context, r re.Rule, query str
return re.Rule{}, postgres.HandleError(repoerr.ErrUpdateEntity, err)
}
defer row.Close()
var dbRule dbRule
if row.Next() {
if err := row.StructScan(&dbRule); err != nil {
return re.Rule{}, errors.Wrap(repoerr.ErrUpdateEntity, err)
}
rule, err := dbToRule(dbRule)
if err != nil {
return re.Rule{}, errors.Wrap(repoerr.ErrUpdateEntity, err)
}
return rule, nil
if !row.Next() {
return re.Rule{}, repoerr.ErrNotFound
}
return re.Rule{}, repoerr.ErrNotFound
var dbRule dbRule
if err := row.StructScan(&dbRule); err != nil {
return re.Rule{}, errors.Wrap(repoerr.ErrUpdateEntity, err)
}
rule, err := dbToRule(dbRule)
if err != nil {
return re.Rule{}, errors.Wrap(repoerr.ErrUpdateEntity, err)
}
return rule, nil
}
func (repo *PostgresRepository) RemoveRule(ctx context.Context, id string) error {