emgauwa/common
Watch
2
0
Fork
You've already forked common
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Fix delete_by_uid (database) for controllers and schedules

Browse source
This commit is contained in:
Tobias Reisinger 2026-09-02 00:41:23 +02:00
commit ff4d3b9768
Signed by: serguzim
GPG key ID: 13AD60C237A28DFE
2 changed files with 8 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

7
src/db/controllers.rs
View file

@ -79,11 +79,12 @@ impl DbController {
conn: &mut PoolConnection<Sqlite>, conn: &mut PoolConnection<Sqlite>,
filter_uid: EmgauwaUid, filter_uid: EmgauwaUid,
) -> Result<(), DatabaseError> { ) -> Result<(), DatabaseError> {
if sqlx::query_scalar!("SELECT EXISTS (SELECT 1 FROM controllers WHERE uid = ?)", filter_uid) let exists = sqlx::query_scalar!("SELECT EXISTS (SELECT 1 FROM controllers WHERE uid = ?)", filter_uid)
.fetch_optional(conn.deref_mut()) .fetch_optional(conn.deref_mut())
.await? .await?
.is_none() .unwrap_or(0);
{
if exists == 0 {
return Err(DatabaseError::NotFound); return Err(DatabaseError::NotFound);
} }

7
src/db/schedules.rs
View file

@ -78,11 +78,12 @@ impl DbSchedule {
ScheduleUid::Any(_) => Ok(filter_uid), ScheduleUid::Any(_) => Ok(filter_uid),
}?; }?;
if sqlx::query_scalar!("SELECT EXISTS (SELECT 1 FROM schedules WHERE uid = ?)", filter_uid) let exists = sqlx::query_scalar!("SELECT EXISTS (SELECT 1 FROM schedules WHERE uid = ?)", filter_uid)
.fetch_optional(conn.deref_mut()) .fetch_optional(conn.deref_mut())
.await? .await?
.is_none() .unwrap_or(0);
{
if exists == 0 {
return Err(DatabaseError::NotFound); return Err(DatabaseError::NotFound);
} }