make check_program_auth async too

Author: sivukhin

libsql-server/src/connection/libsql.rs

@@ -415,7 +415,8 @@ where
 
         PROGRAM_EXEC_COUNT.increment(1);
 
-        check_program_auth(&ctx, &pgm, &self.inner.lock().config_store.get())?;
+        let config = self.inner.lock().config_store.get();
+        check_program_auth(&ctx, &pgm, &config).await?;
 
         // create the bomb right before spawning the blocking task.
         let mut bomb = Bomb {

libsql-server/src/connection/program.rs

@@ -341,7 +341,7 @@ fn value_size(val: &rusqlite::types::ValueRef) -> usize {
     }
 }
 
-pub fn check_program_auth(
+pub async fn check_program_auth(
     ctx: &RequestContext,
     pgm: &Program,
     config: &DatabaseConfig,
@@ -363,15 +363,11 @@ pub fn check_program_auth(
             }
             StmtKind::Attach(ref ns) => {
                 ctx.auth.has_right(ns, Permission::AttachRead)?;
-                return tokio::runtime::Handle::current().block_on(async {
-                    if !ctx.meta_store.handle(ns.clone()).await.get().allow_attach {
-                        return Err(Error::NotAuthorized(format!(
-                            "Namespace `{ns}` doesn't allow attach"
-                        )));
-                    } else {
-                        Ok(())
-                    }
-                });
+                if !ctx.meta_store.handle(ns.clone()).await.get().allow_attach {
+                    return Err(Error::NotAuthorized(format!(
+                        "Namespace `{ns}` doesn't allow attach"
+                    )));
+                }
             }
             StmtKind::Detach => (),
         }

libsql-server/src/database/schema.rs

@@ -50,7 +50,7 @@ impl crate::connection::Connection for SchemaConnection {
 
             res
         } else {
-            check_program_auth(&ctx, &migration, &self.config.get())?;
+            check_program_auth(&ctx, &migration, &self.config.get()).await?;
             let connection = self.connection.clone();
             validate_migration(&mut migration)?;
             let migration = Arc::new(migration);