Added doc_name to Registry.

src/action/message.rs

@@ -39,6 +39,7 @@ impl MessageAction for MsgAction {
             Self::OnUpdate(data) => data.doc_name(),
             Self::Query(data) => data.doc_name(),
             Self::Records(data) => data.doc_name(),
+            Self::Register(data) => data.doc_name(),
             _ => &NameType::None,
         }
     }

src/document/definition.rs

@@ -372,11 +372,7 @@ impl DocDef {
     }
 }
 
-impl MessageAction for DocDef {
-    fn doc_name(&self) -> &NameType {
-        &NameType::None
-    }
-}
+impl MessageAction for DocDef {}
 
 #[cfg(test)]
 mod docdefs {

src/message.rs

@@ -3,5 +3,7 @@ pub mod wrapper;
 use crate::name::NameType;
 
 pub trait MessageAction {
-    fn doc_name(&self) -> &NameType;
+    fn doc_name(&self) -> &NameType {
+        &NameType::None
+    }
 }

src/queue/data_director.rs

@@ -1,6 +1,6 @@
 use crate::{
     action::{Action, MsgAction},
-    message::wrapper::Message,
+    message::{wrapper::Message, MessageAction},
     mtterror::MTTError,
     name::{Name, NameType, Names},
     queue::router::Queue,
@@ -89,6 +89,32 @@ impl Register {
     }
 }
 
+impl MessageAction for Register {}
+
+#[cfg(test)]
+mod registries {
+    use super::*;
+
+    #[test]
+    fn does_registry_store_data() {
+        let id = Uuid::new_v4();
+        let inputs = [
+            RegMsg::DocumentNameID(id.clone()),
+            RegMsg::RemoveSender(id.clone()),
+        ];
+        for regmsg in inputs.iter() {
+            let sender_id = Uuid::new_v4();
+            let reg = Register::new(sender_id.clone(), regmsg.clone());
+            assert_eq!(reg.doc_name(), &NameType::None);
+            assert_eq!(reg.get_sender_id(), &sender_id);
+            match reg.get_msg() {
+                RegMsg::DocumentNameID(data) | RegMsg::RemoveSender(data) => assert_eq!(data, &id),
+                _ => unreachable!("should have been one of the inputs"),
+            }
+        }
+    }
+}
+
 #[derive(Clone, Debug)]
 pub struct Path {
     pub msg_id: Include<Uuid>,