diff --git a/backend/sqlx-data.json b/backend/sqlx-data.json index c8530eda47..248c2b464b 100644 --- a/backend/sqlx-data.json +++ b/backend/sqlx-data.json @@ -1007,6 +1007,27 @@ ] } }, + "5b7a1d16d8109a65479ab33d411c60d14ea91d870fdff8606d7aa4ad39f0ba00": { + "query": "SELECT email FROM usr WHERE username = $1 AND workspace_id = $2", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "email", + "type_info": "Varchar" + } + ], + "parameters": { + "Left": [ + "Text", + "Text" + ] + }, + "nullable": [ + false + ] + } + }, "5b9b58612ca0f703a5d154a76fab82ac2329aef965fa937bfab2810b6e1336a4": { "query": "DELETE FROM group_ WHERE name = $1 AND workspace_id = $2", "describe": { diff --git a/backend/src/jobs.rs b/backend/src/jobs.rs index 7159b3b409..f27f138872 100644 --- a/backend/src/jobs.rs +++ b/backend/src/jobs.rs @@ -1057,25 +1057,34 @@ pub async fn push<'c>( Some(language), ) } - JobPayload::ScriptHub { path } => ( - None, - Some(path.clone()), - Some( - get_hub_script_by_path( - Authed { - email: Some("".to_string()), - username: user.to_string(), - is_admin: false, - groups: vec![], - }, - Path(StripPath(path)), - ) - .await?, - ), - JobKind::Script_Hub, - None, - Some(ScriptLang::Deno), - ), + JobPayload::ScriptHub { path } => { + let email = sqlx::query_scalar!( + "SELECT email FROM usr WHERE username = $1 AND workspace_id = $2", + user, + workspace_id + ) + .fetch_optional(&mut tx) + .await?; + ( + None, + Some(path.clone()), + Some( + get_hub_script_by_path( + Authed { + email, + username: user.to_string(), + is_admin: false, + groups: vec![], + }, + Path(StripPath(path)), + ) + .await?, + ), + JobKind::Script_Hub, + None, + Some(ScriptLang::Deno), + ) + } JobPayload::Code(RawCode { content, path,