From c8ff19befd55066579518d7b4e0edfc3a4822731 Mon Sep 17 00:00:00 2001 From: Ruben Fiszel Date: Thu, 25 May 2023 17:45:17 +0200 Subject: [PATCH] add logs around connecting to database --- backend/src/main.rs | 2 ++ backend/windmill-api/src/users.rs | 25 +++++++++++++++++++++++++ 2 files changed, 27 insertions(+) diff --git a/backend/src/main.rs b/backend/src/main.rs index c0dbd6a26d..f2f5706c16 100644 --- a/backend/src/main.rs +++ b/backend/src/main.rs @@ -86,7 +86,9 @@ async fn main() -> anyhow::Result<()> { config }); + tracing::info!("Connecting to database..."); let db = windmill_common::connect_db(server_mode).await?; + tracing::info!("Database connected"); let rsmq = if let Some(config) = rsmq_config { let mut rsmq = rsmq_async::MultiplexedRsmq::new(config).await.unwrap(); diff --git a/backend/windmill-api/src/users.rs b/backend/windmill-api/src/users.rs index 989e9c0309..c22b2788d7 100644 --- a/backend/windmill-api/src/users.rs +++ b/backend/windmill-api/src/users.rs @@ -1891,6 +1891,31 @@ async fn leave_workspace( Ok(format!("left workspace {w_id}")) } +#[derive(Serialize)] +struct Runnable { + workspace: String, + endpoint: String, + summary: String, + description: String, + schema: Option, +} + +async fn get_all_runnables( + Extension(db): Extension, + authed: Authed, +) -> JsonResult> { + let mut tx = db.begin(&authed).await?; + let mut runnables = Vec::new(); + // sqlx::query!( + // "SELECT * FROM usr WHERE workspace_id = $1 AND username = $2", + // username + // ) + // .execute(&mut tx) + // .await?; + + Ok(Json(runnables)) +} + pub async fn delete_expired_items_perdiodically( db: &DB, mut rx: tokio::sync::broadcast::Receiver<()>,