From 5db1001a8b7bd3389053325ad4a937153d291fa6 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Jonas=20Dre=C3=9Fler?= <verdre@v0yd.nl>
Date: Sun, 8 Dec 2024 12:23:40 +0100
Subject: [PATCH] Send text updates to p2panda

---
 src/application.rs | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/src/application.rs b/src/application.rs
index 68c79f6..2ba0853 100644
--- a/src/application.rs
+++ b/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,6 +41,8 @@ mod imp {
     pub struct AardvarkApplication {
         automerge: RefCell<AutoCommit>,
         root: ObjId,
+        tx: mpsc::Sender<Vec<u8>>,
+        rx: mpsc::Receiver<Vec<u8>>,
     }
 
     impl AardvarkApplication {
@@ -47,6 +50,7 @@ mod imp {
             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();
         }