refactor: rename RoleApi::get_ownerships to list_ownerships

Author: drmingdrmer

src/query/management/src/role/role_api.rs

@@ -32,7 +32,7 @@ pub trait RoleApi: Sync + Send {
 
     async fn get_raw_meta_roles(&self) -> Result<ListKVReply>;
 
-    async fn get_ownerships(&self) -> Result<Vec<SeqV<OwnershipInfo>>>;
+    async fn list_ownerships(&self) -> Result<Vec<SeqV<OwnershipInfo>>>;
 
     /// General role update.
     ///

src/query/management/src/role/role_mgr.rs

@@ -211,7 +211,7 @@ impl RoleApi for RoleMgr {
 
     #[async_backtrace::framed]
     #[fastrace::trace]
-    async fn get_ownerships(&self) -> Result<Vec<SeqV<OwnershipInfo>>, ErrorCode> {
+    async fn list_ownerships(&self) -> Result<Vec<SeqV<OwnershipInfo>>, ErrorCode> {
         let object_owner_prefix = self.ownership_object_prefix();
         let values = self
             .kv_api
@@ -229,7 +229,7 @@ impl RoleApi for RoleMgr {
                 // After rollback the old version, deserialize will return Err Ownership can not be none.
                 // But get ownerships should try to ensure success because in this version.
                 Err(err) => error!(
-                    "deserialize key {} Got err {} while (get_ownerships)",
+                    "deserialize key {} Got err {} while (list_ownerships)",
                     &key, err
                 ),
             }
@@ -270,11 +270,11 @@ impl RoleApi for RoleMgr {
 
     /// Only drop role will call transfer.
     ///
-    /// If a role is dropped, but the owner object is exists,
+    /// If a role is dropped, but the owner object is existing,
     ///
     /// The owner role need to update to account_admin.
     ///
-    /// get_ownerships use prefix_list_kv that will generate once meta call
+    /// list_ownerships use prefix_list_kv that will generate once meta call
     ///
     /// According to Txn reduce meta call. If role own n objects, will generate once meta call.
     #[async_backtrace::framed]
@@ -288,7 +288,7 @@ impl RoleApi for RoleMgr {
             trials.next().unwrap().map_err(AppError::from)?.await;
             let mut if_then = vec![];
             let mut condition = vec![];
-            let seq_owns = self.get_ownerships().await.map_err(|e| {
+            let seq_owns = self.list_ownerships().await.map_err(|e| {
                 e.add_message_back("(while in transfer_ownership_to_admin get ownerships).")
             })?;
             let mut need_transfer = false;

src/query/service/src/interpreters/access/privilege_access.rs

@@ -765,7 +765,7 @@ impl AccessChecker for PrivilegeAccess {
                         let user_api = UserApiProvider::instance();
                         let ownerships = user_api
                             .role_api(&tenant)
-                            .get_ownerships()
+                            .list_ownerships()
                             .await?;
                         let roles = self.ctx.get_all_effective_roles().await?;
                         let roles_name: Vec<String> = roles.iter().map(|role| role.name.to_string()).collect();
@@ -783,7 +783,7 @@ impl AccessChecker for PrivilegeAccess {
                         let user_api = UserApiProvider::instance();
                         let ownerships = user_api
                             .role_api(&tenant)
-                            .get_ownerships()
+                            .list_ownerships()
                             .await?;
                         let roles = self.ctx.get_all_effective_roles().await?;
                         let roles_name: Vec<String> = roles.iter().map(|role| role.name.to_string()).collect();
@@ -938,7 +938,7 @@ impl AccessChecker for PrivilegeAccess {
                 let user_api = UserApiProvider::instance();
                 let ownerships = user_api
                     .role_api(&tenant)
-                    .get_ownerships()
+                    .list_ownerships()
                     .await?;
                 let roles = self.ctx.get_all_effective_roles().await?;
                 let roles_name: Vec<String> = roles.iter().map(|role| role.name.to_string()).collect();

src/query/service/src/sessions/session_privilege_mgr.rs

@@ -397,7 +397,7 @@ impl SessionPrivilegeManager for SessionPrivilegeManagerImpl<'_> {
                 let user_api = UserApiProvider::instance();
                 let ownerships = user_api
                     .role_api(&self.session_ctx.get_current_tenant())
-                    .get_ownerships()
+                    .list_ownerships()
                     .await?;
                 let mut ownership_objects = vec![];
                 for ownership in ownerships {

src/query/service/src/table_functions/show_grants/show_grants_table.rs

@@ -495,7 +495,7 @@ async fn show_account_grants(
         // 2. not expand roles
         // So no need to get ownerships.
         if !roles.is_empty() {
-            let ownerships = user_api.role_api(&tenant).get_ownerships().await?;
+            let ownerships = user_api.role_api(&tenant).list_ownerships().await?;
             for ownership in ownerships {
                 if roles.contains(&ownership.data.role) {
                     match ownership.data.object {
@@ -807,7 +807,7 @@ async fn show_object_grant(
         }
     }
 
-    let ownerships = user_api.role_api(&tenant).get_ownerships().await?;
+    let ownerships = user_api.role_api(&tenant).list_ownerships().await?;
     for ownership in ownerships {
         if ownership.data.object == owner_object {
             privileges.push("OWNERSHIP".to_string());

src/query/storages/system/src/streams_table.rs

@@ -157,7 +157,7 @@ impl<const T: bool> AsyncSystemTable for StreamsTable<T> {
                 .collect::<Vec<_>>();
 
             let ownership = if T {
-                user_api.get_ownerships(&tenant).await.unwrap_or_default()
+                user_api.list_ownerships(&tenant).await.unwrap_or_default()
             } else {
                 HashMap::new()
             };

src/query/storages/system/src/tables_table.rs

@@ -543,7 +543,7 @@ where TablesTable<WITH_HISTORY, WITHOUT_VIEW>: HistoryAware
                 dbs.clear();
 
                 let ownership = if get_ownership {
-                    user_api.get_ownerships(&tenant).await.unwrap_or_default()
+                    user_api.list_ownerships(&tenant).await.unwrap_or_default()
                 } else {
                     HashMap::new()
                 };

src/query/users/src/role_mgr.rs

@@ -84,13 +84,13 @@ impl UserApiProvider {
     }
 
     #[async_backtrace::framed]
-    pub async fn get_ownerships(
+    pub async fn list_ownerships(
         &self,
         tenant: &Tenant,
     ) -> Result<HashMap<OwnershipObject, String>> {
         let seq_owns = self
             .role_api(tenant)
-            .get_ownerships()
+            .list_ownerships()
             .await
             .map_err(|e| e.add_message_back("(while get ownerships)."))?;
 
@@ -172,7 +172,7 @@ impl UserApiProvider {
         if let Some(owner) = ownership {
             // if object has ownership, but the owner role is not exists, set owner role to ACCOUNT_ADMIN,
             // only account_admin can access this object.
-            // Note: get_ownerships no need to do this check.
+            // Note: list_ownerships no need to do this check.
             // Because this can cause system.table queries to slow down
             // The intention is that the account admin can grant ownership.
             // So system.tables will display dropped role. It's by design.

src/query/users/src/user_api.rs

@@ -65,6 +65,7 @@ impl UserApiProvider {
     ) -> Result<()> {
         GlobalInstance::set(Self::try_create(conf, builtin, tenant).await?);
         let user_mgr = UserApiProvider::instance();
+
         if let Some(q) = quota {
             let i = user_mgr.tenant_quota_api(tenant);
             let res = i.get_quota(MatchSeq::GE(0)).await?;