Moved Records into the document module.

src/action.rs

@@ -6,10 +6,7 @@ mod query;
 mod request_data;
 mod user;
 
-pub use crate::document::{
-    definition::DocDef,
-    field::{Field, FieldType},
-};
+pub use crate::document::{DocDef, Field, FieldType, Records};
 pub use action_type::Action;
 pub use addition::Addition;
 pub use calculation::{CalcValue, Calculation, Operand};

src/action/message.rs

@@ -1,7 +1,7 @@
-use super::{Addition, DocDef, Query, UserAction};
+use super::{Addition, DocDef, Query, Records, UserAction};
 use crate::{
     message::{
-        wrapper::{Delete, Records, Reply, Update},
+        wrapper::{Delete, Reply, Update},
         MessageAction,
     },
     mtterror::MTTError,
@@ -33,6 +33,7 @@ impl MessageAction for MsgAction {
             Self::Addition(data) => data.doc_name(),
             Self::Query(data) => data.doc_name(),
             Self::Create(data) => data.doc_name(),
+            Self::Error(data) => data.doc_name(),
             _ => &NameType::None,
         }
     }

src/action/user.rs

@@ -1,5 +1,4 @@
-use super::Query;
-use crate::document::{definition::DocDef, field::FieldType};
+use super::{DocDef, FieldType, Query};
 
 pub enum UserAction {
     CreateDocument(DocDef),

src/document.rs

@@ -1,5 +1,13 @@
-pub mod clock;
-pub mod create;
-pub mod definition;
-pub mod field;
-pub mod session;
+mod clock;
+mod create;
+mod definition;
+mod field;
+mod record;
+mod session;
+
+pub use clock::Clock;
+pub use create::CreateDoc;
+pub use definition::DocDef;
+pub use field::{Field, FieldType};
+pub use record::Records;
+pub use session::Session;

src/document/clock.rs

@@ -1,6 +1,6 @@
 use crate::{
-    action::{Action, MsgAction},
-    message::wrapper::{Message, Records},
+    action::{Action, MsgAction, Records},
+    message::wrapper::Message,
     name::{Name, NameType, Names},
     queue::{
         data_director::{Include, Path, RegMsg, Register},

src/document/create.rs

@@ -1,10 +1,10 @@
 use crate::{
-    action::{Action, CalcValue, Calculation, MsgAction, Query},
+    action::{Action, CalcValue, Calculation, MsgAction, Query, Records},
     document::{
         definition::{DocDef, DocFuncType},
         field::Field,
     },
-    message::wrapper::{InternalRecord, InternalRecords, Message, Oid, Records, Reply, Update},
+    message::wrapper::{InternalRecord, InternalRecords, Message, Oid, Reply, Update},
     mtterror::{ErrorID, MTTError},
     name::NameType,
     queue::{

src/document/record.rs

@@ -0,0 +1,67 @@
+use crate::{
+    message::wrapper::{InternalRecord, InternalRecords, Oid, Record},
+    name::{Name, Names},
+};
+
+#[derive(Clone, Debug)]
+pub struct Records {
+    names: Names,
+    data: InternalRecords,
+}
+
+impl Records {
+    pub fn new(names: Names) -> Self {
+        Self {
+            names: names,
+            data: InternalRecords::new(),
+        }
+    }
+
+    pub fn with_data(names: Names, records: InternalRecords) -> Self {
+        Self {
+            names: names,
+            data: records,
+        }
+    }
+
+    pub fn insert(&mut self, oid: Oid, record: InternalRecord) -> Option<InternalRecord> {
+        self.data.insert(oid, record)
+    }
+
+    pub fn len(&self) -> usize {
+        self.data.len()
+    }
+
+    pub fn iter(&self) -> impl Iterator<Item = Record> {
+        RecordIter::new(self)
+    }
+
+    pub fn get_internal_records(&self) -> &InternalRecords {
+        &self.data
+    }
+}
+
+struct RecordIter {
+    names: Names,
+    recs: Vec<InternalRecord>,
+}
+
+impl RecordIter {
+    fn new(records: &Records) -> Self {
+        Self {
+            names: records.names.clone(),
+            recs: records.data.values().cloned().collect(),
+        }
+    }
+}
+
+impl Iterator for RecordIter {
+    type Item = Record;
+
+    fn next(&mut self) -> Option<Self::Item> {
+        match self.recs.pop() {
+            Some(rec) => Some(Record::with_data(self.names.clone(), rec.clone())),
+            None => None,
+        }
+    }
+}

src/document/session.rs

@@ -85,13 +85,12 @@ impl Session {
 mod sessions {
     use super::*;
     use crate::{
-        action::{Addition, MsgAction, Query},
+        action::{Addition, MsgAction, Query, Records},
         document::{
             clock::{clock_test_support::gen_clock_message, Clock},
             create::CreateDoc,
             field::Field,
         },
-        message::wrapper::Records,
         mtterror::{ErrorID, MTTError},
         name::{Name, NameType, Names},
         queue::data_director::{Include, Path, RegMsg, Register},

src/lib.rs

@@ -9,7 +9,7 @@ use action::{
     Action, Addition, CalcValue, Calculation, DocDef, Field, FieldType, MsgAction, Operand, Query,
     UserAction,
 };
-use document::{clock::Clock, create::CreateDoc, session::Session};
+use document::{Clock, CreateDoc, Session};
 use message::{wrapper::Message, MessageAction};
 use queue::{
     data_director::{Include, Path, RegMsg, Register},

src/message/wrapper.rs

@@ -1,6 +1,5 @@
 use crate::{
-    action::{CalcValue, MsgAction, Operand, Query},
-    document::field::{Field, FieldType},
+    action::{CalcValue, Field, FieldType, MsgAction, Operand, Query},
     mtterror::{ErrorID, MTTError},
     name::{NameType, Names},
     queue::data_director::{Include, Path, Route},
@@ -88,7 +87,7 @@ impl Message {
 #[cfg(test)]
 mod messages {
     use super::*;
-    use crate::{document::definition::DocDef, name::Name};
+    use crate::{action::DocDef, name::Name};
 
     #[test]
     fn can_the_document_be_a_named_reference() {
@@ -429,7 +428,7 @@ impl InternalRecords {
         self.data.keys()
     }
 
-    fn values(&self) -> impl Iterator<Item = &InternalRecord> {
+    pub fn values(&self) -> impl Iterator<Item = &InternalRecord> {
         self.data.values()
     }
 
@@ -437,7 +436,7 @@ impl InternalRecords {
         self.data.contains_key(oid)
     }
 
-    fn len(&self) -> usize {
+    pub fn len(&self) -> usize {
         self.data.len()
     }
 }
@@ -449,7 +448,7 @@ pub struct Record {
 }
 
 impl Record {
-    fn with_data(names: Names, rec: InternalRecord) -> Self {
+    pub fn with_data(names: Names, rec: InternalRecord) -> Self {
         Self {
             names: names,
             data: rec,
@@ -471,6 +470,7 @@ impl Record {
     }
 }
 
+/*
 #[derive(Clone, Debug)]
 pub struct Records {
     names: Names,
@@ -533,6 +533,7 @@ impl Iterator for RecordIter {
         }
     }
 }
+*/
 
 #[derive(Clone, Debug)]
 pub struct Document {

src/mtterror.rs

@@ -1,5 +1,5 @@
 use crate::{
-    document::field::{Field, FieldType},
+    action::{Field, FieldType},
     message::MessageAction,
     name::{Name, NameType},
 };

src/queue/data_director.rs

@@ -121,7 +121,7 @@ impl Path {
 mod paths {
     use super::*;
     use crate::{
-        message::wrapper::Records,
+        action::Records,
         name::{Name, Names},
     };