Started to document service.

src/document.rs

@@ -0,0 +1,50 @@
+use crate::{
+    field::Field,
+    queue::{Message, MsgType, Queue},
+};
+use std::{
+    sync::mpsc::{channel, Receiver},
+    thread::spawn,
+};
+
+const RESPONDS_TO: [MsgType; 1] = [MsgType::DocumentRequest];
+
+struct Document {
+    queue: Queue,
+    rx: Receiver<Message>,
+}
+
+impl Document {
+    fn new(queue: Queue, rx: Receiver<Message>) -> Self {
+        Self {
+            queue: queue,
+            rx: rx,
+        }
+    }
+
+    pub fn start(queue: Queue) {
+        let (tx, rx) = channel();
+        let mut document = Document::new(queue, rx);
+        document.queue.add(tx, RESPONDS_TO.to_vec());
+        spawn(move || {
+            document.listen();
+        });
+    }
+
+    fn listen(&mut self) {
+        loop {
+            let msg = self.rx.recv().unwrap();
+        }
+    }
+}
+
+#[cfg(test)]
+mod documents {
+    use super::*;
+
+    #[test]
+    fn start_service() {
+        let queue = Queue::new();
+        Document::start(queue);
+    }
+}

src/lib.rs

@@ -1,5 +1,6 @@
 mod client;
 mod clock;
+mod document;
 mod field;
 mod queue;
 mod session;

src/queue.rs

@@ -8,6 +8,8 @@ use uuid::Uuid;
 #[derive(Clone, Debug, Eq, Hash, PartialEq)]
 pub enum MsgType {
     ClientRequest,
+    ClientDoc,
+    DocumentRequest,
     SessionValidate,
     Session,
     Time,