[server] Add db user actions to cluster #1396

agdb/src/query.rs

@@ -56,7 +56,7 @@ use crate::{
 #[cfg(any(feature = "serde", feature = "openapi"))]
 #[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
 #[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
-#[derive(Debug, PartialEq)]
+#[derive(Clone, Debug, PartialEq)]
 #[expect(clippy::large_enum_variant)]
 pub enum QueryType {
     InsertAlias(InsertAliasesQuery),

agdb/src/query/insert_aliases_query.rs

@@ -15,7 +15,7 @@ use crate::StorageData;
 /// The result will contain number of aliases inserted/updated but no elements.
 #[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
 #[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
-#[derive(Debug, PartialEq)]
+#[derive(Clone, Debug, PartialEq)]
 pub struct InsertAliasesQuery {
     /// Ids to be aliased
     pub ids: QueryIds,

agdb/src/query/insert_edges_query.rs

@@ -28,7 +28,7 @@ use crate::StorageData;
 /// with their ids, origin and destination, but no properties.
 #[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
 #[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
-#[derive(Debug, PartialEq)]
+#[derive(Clone, Debug, PartialEq)]
 pub struct InsertEdgesQuery {
     /// Origins
     pub from: QueryIds,

agdb/src/query/insert_index_query.rs

@@ -9,7 +9,7 @@ use crate::StorageData;
 /// a given key.
 #[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
 #[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
-#[derive(Debug, PartialEq)]
+#[derive(Clone, Debug, PartialEq)]
 pub struct InsertIndexQuery(pub DbValue);
 
 impl QueryMut for InsertIndexQuery {

agdb/src/query/insert_nodes_query.rs

@@ -27,7 +27,7 @@ use crate::StorageData;
 /// with their ids but no properties.
 #[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
 #[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
-#[derive(Debug, PartialEq)]
+#[derive(Clone, Debug, PartialEq)]
 pub struct InsertNodesQuery {
     /// Number of nodes to be inserted.
     pub count: u64,

agdb/src/query/insert_values_query.rs

@@ -24,7 +24,7 @@ use crate::StorageData;
 /// NOTE: The result is NOT number of affected elements but individual properties.
 #[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
 #[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
-#[derive(Debug, PartialEq)]
+#[derive(Clone, Debug, PartialEq)]
 pub struct InsertValuesQuery {
     /// Ids whose properties should be updated
     pub ids: QueryIds,

agdb/src/query/query_values.rs

@@ -5,7 +5,7 @@ use crate::DbUserValue;
 /// and multiple (`Multi`) values in database queries.
 #[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
 #[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
-#[derive(Debug, PartialEq)]
+#[derive(Clone, Debug, PartialEq)]
 pub enum QueryValues {
     /// Single list of properties (key-value pairs)
     /// to be applied to all elements in a query.

agdb/src/query/remove_aliases_query.rs

@@ -12,7 +12,7 @@ use crate::StorageData;
 /// many aliases have been actually removed.
 #[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
 #[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
-#[derive(Debug, PartialEq)]
+#[derive(Clone, Debug, PartialEq)]
 pub struct RemoveAliasesQuery(pub Vec<String>);
 
 impl QueryMut for RemoveAliasesQuery {

agdb/src/query/remove_index_query.rs

@@ -9,7 +9,7 @@ use crate::StorageData;
 /// a given key.
 #[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
 #[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
-#[derive(Debug, PartialEq)]
+#[derive(Clone, Debug, PartialEq)]
 pub struct RemoveIndexQuery(pub DbValue);
 
 impl QueryMut for RemoveIndexQuery {

agdb/src/query/remove_query.rs

@@ -16,7 +16,7 @@ use crate::StorageData;
 /// also removed along with their properties.
 #[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
 #[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
-#[derive(Debug, PartialEq)]
+#[derive(Clone, Debug, PartialEq)]
 pub struct RemoveQuery(pub QueryIds);
 
 impl QueryMut for RemoveQuery {

agdb/src/query/remove_values_query.rs

@@ -15,7 +15,7 @@ use crate::StorageData;
 /// do not exist on any of the elements).
 #[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
 #[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
-#[derive(Debug, PartialEq)]
+#[derive(Clone, Debug, PartialEq)]
 pub struct RemoveValuesQuery(pub SelectValuesQuery);
 
 impl QueryMut for RemoveValuesQuery {

agdb/src/query/select_aliases_query.rs

@@ -17,7 +17,7 @@ use crate::StorageData;
 /// the value `String`.
 #[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
 #[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
-#[derive(Debug, PartialEq)]
+#[derive(Clone, Debug, PartialEq)]
 pub struct SelectAliasesQuery(pub QueryIds);
 
 impl Query for SelectAliasesQuery {

agdb/src/query/select_all_aliases_query.rs

@@ -12,7 +12,7 @@ use crate::StorageData;
 /// the value `String`.
 #[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
 #[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
-#[derive(Debug, PartialEq)]
+#[derive(Clone, Debug, PartialEq)]
 pub struct SelectAllAliasesQuery {}
 
 impl Query for SelectAllAliasesQuery {

agdb/src/query/select_edge_count_query.rs

@@ -22,7 +22,7 @@ use crate::StorageData;
 /// might be greater than number of unique db elements.
 #[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
 #[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
-#[derive(Debug, PartialEq)]
+#[derive(Clone, Debug, PartialEq)]
 pub struct SelectEdgeCountQuery {
     /// Ids of the nodes to select edge count for.
     pub ids: QueryIds,

agdb/src/query/select_indexes_query.rs

@@ -14,7 +14,7 @@ use crate::StorageData;
 /// index.
 #[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
 #[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
-#[derive(Debug, PartialEq)]
+#[derive(Clone, Debug, PartialEq)]
 pub struct SelectIndexesQuery {}
 
 impl Query for SelectIndexesQuery {

agdb/src/query/select_key_count_query.rs

@@ -16,7 +16,7 @@ use crate::StorageData;
 /// a value `u64`.
 #[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
 #[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
-#[derive(Debug, PartialEq)]
+#[derive(Clone, Debug, PartialEq)]
 pub struct SelectKeyCountQuery(pub QueryIds);
 
 impl Query for SelectKeyCountQuery {

agdb/src/query/select_keys_query.rs

@@ -15,7 +15,7 @@ use crate::StorageData;
 /// of elements with all properties except all values will be empty.
 #[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
 #[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
-#[derive(Debug, PartialEq)]
+#[derive(Clone, Debug, PartialEq)]
 pub struct SelectKeysQuery(pub QueryIds);
 
 impl Query for SelectKeysQuery {

agdb/src/query/select_node_count.rs

@@ -13,7 +13,7 @@ use crate::StorageData;
 /// a value `u64` represneting number of nodes in teh database.
 #[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
 #[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
-#[derive(Debug, PartialEq)]
+#[derive(Clone, Debug, PartialEq)]
 pub struct SelectNodeCountQuery {}
 
 impl Query for SelectNodeCountQuery {

agdb/src/query/select_values_query.rs

@@ -17,7 +17,7 @@ use crate::StorageData;
 /// list of elements with the requested properties.
 #[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
 #[cfg_attr(feature = "openapi", derive(utoipa::ToSchema))]
-#[derive(Debug, PartialEq)]
+#[derive(Clone, Debug, PartialEq)]
 pub struct SelectValuesQuery {
     pub keys: Vec<DbValue>,
     pub ids: QueryIds,

agdb_api/rust/src/api.rs

@@ -156,7 +156,7 @@ impl<T: HttpClient> AgdbApi<T> {
         &self,
         owner: &str,
         db: &str,
-        queries: &Vec<QueryType>,
+        queries: &[QueryType],
     ) -> AgdbApiResult<(u16, Vec<QueryResult>)> {
         self.client
             .post(

agdb_api/rust/src/api_types.rs

@@ -1,11 +1,10 @@
-use std::fmt::Display;
-
 use agdb::DbError;
 use agdb::DbValue;
 use agdb::QueryResult;
 use agdb::QueryType;
 use serde::Deserialize;
 use serde::Serialize;
+use std::fmt::Display;
 use utoipa::ToSchema;
 
 #[derive(
@@ -70,7 +69,7 @@ pub struct AdminStatus {
     pub size: u64,
 }
 
-#[derive(Deserialize, ToSchema)]
+#[derive(Clone, Deserialize, Serialize, ToSchema)]
 pub struct Queries(pub Vec<QueryType>);
 
 #[derive(Serialize, ToSchema)]
@@ -116,9 +115,20 @@ pub struct UserStatus {
 impl From<&str> for DbType {
     fn from(value: &str) -> Self {
         match value {
-            "mapped" => DbType::Mapped,
-            "file" => DbType::File,
-            _ => DbType::Memory,
+            "mapped" => Self::Mapped,
+            "file" => Self::File,
+            _ => Self::Memory,
+        }
+    }
+}
+
+impl From<&str> for DbResource {
+    fn from(value: &str) -> Self {
+        match value {
+            "db" => Self::Db,
+            "audit" => Self::Audit,
+            "backup" => Self::Backup,
+            _ => Self::All,
         }
     }
 }
@@ -131,12 +141,26 @@ impl TryFrom<DbValue> for DbType {
     }
 }
 
+impl TryFrom<DbValue> for DbResource {
+    type Error = DbError;
+
+    fn try_from(value: DbValue) -> Result<Self, Self::Error> {
+        Ok(Self::from(value.to_string().as_str()))
+    }
+}
+
 impl From<DbType> for DbValue {
     fn from(value: DbType) -> Self {
         value.to_string().into()
     }
 }
 
+impl From<DbResource> for DbValue {
+    fn from(value: DbResource) -> Self {
+        value.to_string().into()
+    }
+}
+
 impl Display for DbType {
     fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
         match self {