Fix create filter API (#342)
parent
bb8dcb09a1
commit
19a716e7da
|
@ -92,11 +92,11 @@ func (s *filterStatements) insertFilter(
|
||||||
// Check if filter already exists in the database
|
// Check if filter already exists in the database
|
||||||
err = s.selectFilterIDByContentStmt.QueryRowContext(ctx,
|
err = s.selectFilterIDByContentStmt.QueryRowContext(ctx,
|
||||||
localpart, filterJSON).Scan(&existingFilterID)
|
localpart, filterJSON).Scan(&existingFilterID)
|
||||||
if err != nil {
|
if err != nil && err != sql.ErrNoRows {
|
||||||
return "", err
|
return "", err
|
||||||
}
|
}
|
||||||
// If it does, return the existing ID
|
// If it does, return the existing ID
|
||||||
if len(existingFilterID) != 0 {
|
if existingFilterID != "" {
|
||||||
return existingFilterID, err
|
return existingFilterID, err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue