shared lock among all rbac operations

Author: nikhilsinhaparseable

src/handlers/http/modal/ingest/ingestor_rbac.rs

@@ -19,10 +19,12 @@
 use std::collections::HashSet;
 
 use actix_web::{Responder, web};
-use tokio::sync::Mutex;
 
 use crate::{
-    handlers::http::{modal::utils::rbac_utils::get_metadata, rbac::RBACError},
+    handlers::http::{
+        modal::utils::rbac_utils::get_metadata,
+        rbac::{RBACError, UPDATE_LOCK},
+    },
     rbac::{
         Users,
         map::roles,
@@ -31,9 +33,6 @@ use crate::{
     storage,
 };
 
-// async aware lock for updating storage metadata and user map atomicically
-static UPDATE_LOCK: Mutex<()> = Mutex::const_new(());
-
 // Handler for POST /api/v1/user/{username}
 // Creates a new user by username if it does not exists
 pub async fn post_user(

src/handlers/http/modal/query/querier_rbac.rs

@@ -19,7 +19,6 @@
 use std::collections::HashSet;
 
 use actix_web::{Responder, web};
-use tokio::sync::Mutex;
 
 use crate::{
     handlers::http::{
@@ -28,7 +27,7 @@ use crate::{
             sync_user_deletion_with_ingestors, sync_users_with_roles_with_ingestors,
         },
         modal::utils::rbac_utils::{get_metadata, put_metadata},
-        rbac::RBACError,
+        rbac::{RBACError, UPDATE_LOCK},
     },
     rbac::{
         Users,
@@ -38,9 +37,6 @@ use crate::{
     validator,
 };
 
-// async aware lock for updating storage metadata and user map atomically
-static UPDATE_LOCK: Mutex<()> = Mutex::const_new(());
-
 // Handler for POST /api/v1/user/{username}
 // Creates a new user by username if it does not exists
 pub async fn post_user(

src/handlers/http/rbac.rs

@@ -43,7 +43,7 @@ use tokio::sync::Mutex;
 use super::modal::utils::rbac_utils::{get_metadata, put_metadata};
 
 // async aware lock for updating storage metadata and user map atomically
-static UPDATE_LOCK: Mutex<()> = Mutex::const_new(());
+pub(crate) static UPDATE_LOCK: Mutex<()> = Mutex::const_new(());
 
 #[derive(serde::Serialize)]
 struct User {