diff --git a/src/action.rs b/src/action.rs index 276f418..32ceec7 100644 --- a/src/action.rs +++ b/src/action.rs @@ -1,6 +1,7 @@ mod action_type; mod addition; mod calculation; +mod client; mod delete; mod message; mod query; @@ -8,12 +9,12 @@ mod reply; mod request_data; mod show; mod update; -mod user; pub use crate::document::{DocDef, DocFuncType, Field, FieldType, IndexType, Record, Records}; pub use action_type::Action; pub use addition::Addition; pub use calculation::{CalcValue, Calculation, Operand}; +pub use client::ClientAction; pub use delete::Delete; pub use message::MsgAction; pub use query::Query; @@ -21,4 +22,3 @@ pub use reply::Reply; use request_data::RequestData; pub use show::Show; pub use update::Update; -pub use user::UserAction; diff --git a/src/action/user.rs b/src/action/client.rs similarity index 79% rename from src/action/user.rs rename to src/action/client.rs index 317ef02..8dc8ada 100644 --- a/src/action/user.rs +++ b/src/action/client.rs @@ -2,38 +2,38 @@ use super::{Addition, Delete, DocDef, FieldType, Query, Update}; use crate::{message::MessageAction, name::NameType}; #[derive(Clone, Debug)] -pub enum UserAction { +pub enum ClientAction { Addition(Addition), Delete(Delete), Query(Query), Update(Update), } -impl From for UserAction { +impl From for ClientAction { fn from(value: Addition) -> Self { Self::Addition(value) } } -impl From for UserAction { +impl From for ClientAction { fn from(value: Delete) -> Self { Self::Delete(value) } } -impl From for UserAction { +impl From for ClientAction { fn from(value: Query) -> Self { Self::Query(value) } } -impl From for UserAction { +impl From for ClientAction { fn from(value: Update) -> Self { Self::Update(value) } } -impl MessageAction for UserAction { +impl MessageAction for ClientAction { fn doc_name(&self) -> &NameType { match self { Self::Addition(data) => data.doc_name(), diff --git a/src/action/message.rs b/src/action/message.rs index 0f8499a..cfe1f4e 100644 --- a/src/action/message.rs +++ b/src/action/message.rs @@ -1,4 +1,4 @@ -use super::{Addition, Delete, DocDef, Query, Records, Reply, Show, Update, UserAction}; +use super::{Addition, ClientAction, Delete, DocDef, Query, Records, Reply, Show, Update}; use crate::{ message::MessageAction, mtterror::MTTError, name::NameType, queue::data_director::Register, }; @@ -98,13 +98,13 @@ impl From for MsgAction { } } -impl From for MsgAction { - fn from(value: UserAction) -> Self { +impl From for MsgAction { + fn from(value: ClientAction) -> Self { match value { - UserAction::Addition(data) => Self::Addition(data), - UserAction::Delete(data) => Self::Delete(data), - UserAction::Query(data) => Self::Query(data), - UserAction::Update(data) => Self::Update(data), + ClientAction::Addition(data) => Self::Addition(data), + ClientAction::Delete(data) => Self::Delete(data), + ClientAction::Query(data) => Self::Query(data), + ClientAction::Update(data) => Self::Update(data), } } } diff --git a/src/lib.rs b/src/lib.rs index f9e319c..0a1b3a7 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -55,13 +55,13 @@ impl MoreThanText { output } - fn new_session() -> UserAction { + fn new_session() -> ClientAction { Addition::new(Session::doc_names()[0].clone()).into() } fn recursive_message_request(&mut self, action: UA) -> Uuid where - UA: Into, + UA: Into, { match self.records(action) { Ok(data) => { @@ -100,7 +100,7 @@ impl MoreThanText { pub fn records(&mut self, request: UA) -> Result where - UA: Into, + UA: Into, { let req = request.into(); let (tx, rx) = channel(); diff --git a/tests/document_test.rs b/tests/document_test.rs index eb7316b..f8c9350 100644 --- a/tests/document_test.rs +++ b/tests/document_test.rs @@ -28,7 +28,7 @@ fn are_errors_produced_for_duplicate_names() { fn does_document_respond_to() { let mut mtt = MoreThanText::new(); let doc_name = random_name(); - let mut requests: Vec = Vec::new(); + let mut requests: Vec = Vec::new(); requests.push(Addition::new(doc_name.clone()).into()); requests.push(Delete::new(doc_name.clone()).into()); requests.push(Query::new(doc_name.clone()).into()); @@ -55,7 +55,7 @@ fn does_document_ignore_other_document_requests() { Include::All, )]; test_env.register_channel(paths); - let mut requests: Vec = Vec::new(); + let mut requests: Vec = Vec::new(); requests.push(Addition::new(alt.clone()).into()); requests.push(Delete::new(alt.clone()).into()); requests.push(Query::new(alt.clone()).into());