diff --git a/.sqlx/query-c45fa767d46311a0558110f5d27da6acd355ffe8e1df18d16c19aeb1b162fc8f.json b/.sqlx/query-a3c235bd5df50f80ec93c3d9f6da8db7e17e89788f30c5b6432c582992b6a009.json similarity index 64% rename from .sqlx/query-c45fa767d46311a0558110f5d27da6acd355ffe8e1df18d16c19aeb1b162fc8f.json rename to .sqlx/query-a3c235bd5df50f80ec93c3d9f6da8db7e17e89788f30c5b6432c582992b6a009.json index c704849a..d385fd06 100644 --- a/.sqlx/query-c45fa767d46311a0558110f5d27da6acd355ffe8e1df18d16c19aeb1b162fc8f.json +++ b/.sqlx/query-a3c235bd5df50f80ec93c3d9f6da8db7e17e89788f30c5b6432c582992b6a009.json @@ -1,6 +1,6 @@ { "db_name": "PostgreSQL", - "query": "\n DELETE FROM af_published_collab\n WHERE publish_name = ANY($1::text[])\n RETURNING publish_name\n ", + "query": "\n DELETE FROM af_published_collab\n WHERE workspace_id = $1\n AND publish_name = ANY($2::text[])\n RETURNING publish_name\n ", "describe": { "columns": [ { @@ -11,6 +11,7 @@ ], "parameters": { "Left": [ + "Uuid", "TextArray" ] }, @@ -18,5 +19,5 @@ false ] }, - "hash": "c45fa767d46311a0558110f5d27da6acd355ffe8e1df18d16c19aeb1b162fc8f" + "hash": "a3c235bd5df50f80ec93c3d9f6da8db7e17e89788f30c5b6432c582992b6a009" } diff --git a/libs/database/src/publish.rs b/libs/database/src/publish.rs index a3252c25..0b8fb3be 100644 --- a/libs/database/src/publish.rs +++ b/libs/database/src/publish.rs @@ -237,9 +237,11 @@ pub async fn insert_or_replace_publish_collabs( let delete_publish_names = sqlx::query_scalar!( r#" DELETE FROM af_published_collab - WHERE publish_name = ANY($1::text[]) + WHERE workspace_id = $1 + AND publish_name = ANY($2::text[]) RETURNING publish_name "#, + workspace_id, &publish_names, ) .fetch_all(txn.as_mut())