Send text updates to p2panda

src/application.rs

@@ -32,6 +32,7 @@ use automerge::transaction::Transactable;
 use automerge::ObjType;
 use std::cell::RefCell;
 use automerge::ObjId;
+use tokio::sync::mpsc;
 
 mod imp {
     use super::*;
@@ -40,13 +41,16 @@ mod imp {
     pub struct AardvarkApplication {
         automerge: RefCell<AutoCommit>,
         root: ObjId,
+        tx: mpsc::Sender<Vec<u8>>,
+        rx: mpsc::Receiver<Vec<u8>>,
     }
 
     impl AardvarkApplication {
         fn update_text(&self, text: &str) {
             println!("app: {}", text);
             let mut doc = self.automerge.borrow_mut();
             doc.update_text(&self.root, text).unwrap();
+            self.tx.send(doc.save());
         }
     }
 
@@ -60,9 +64,12 @@ mod imp {
             let mut am = AutoCommit::new();
             let root = am.put_object(automerge::ROOT, "root", ObjType::Text).unwrap();
             let automerge = RefCell::new(am);
+            let (tx, rx) = network::run().expect("running p2p backend");
             AardvarkApplication {
                 automerge,
                 root,
+                tx,
+                rx,
             }
         }
     }
@@ -97,8 +104,6 @@ mod imp {
                 window.upcast()
             });
 
-            network::run().expect("running p2p backend");
-
             // Ask the window manager/compositor to present the window
             window.present();
         }