improved end-to-end integration tests, cleanup unused js package

Author: carlsverre

demo/frontend/package.json

@@ -15,7 +15,6 @@
     "@mantine/core": "^7.1.5",
     "@mantine/form": "^7.1.5",
     "@mantine/hooks": "^7.1.5",
-    "@mantine/vanilla-extract": "^7.1.5",
     "@orbitinghail/sqlsync-react": "workspace:*",
     "@orbitinghail/sqlsync-worker": "workspace:*",
     "@tabler/icons-react": "^2.39.0",

lib/sqlsync/examples/end-to-end-local-net.rs

@@ -305,21 +305,23 @@ fn start_client(
 }
 
 fn main() -> anyhow::Result<()> {
-    // seed a random number generater from the command line
-    // or use a random seed
-    let mut rng = std::env::args()
-        .nth(1)
-        .map(|seed| {
-            let seed = seed.parse::<u64>().unwrap();
-            StdRng::seed_from_u64(seed)
-        })
-        .unwrap_or_else(|| StdRng::from_entropy());
-
     simple_logger::SimpleLogger::new()
         .with_level(log::LevelFilter::Debug)
+        .without_timestamps()
         .env()
         .init()?;
 
+    // seed a random number generater from the command line
+    // or use a random seed
+    let rng_seed: u64 = std::env::args()
+        .nth(1)
+        .map(|seed| seed.parse().unwrap())
+        .unwrap_or_else(|| rand::thread_rng().gen());
+
+    log::info!("using rng seed: {}", rng_seed);
+
+    let mut rng = StdRng::seed_from_u64(rng_seed);
+
     let addr = "127.0.0.1:8080";
     let listener = TcpListener::bind(addr)?;
     let doc_id = JournalId::new256(&mut rng);

lib/sqlsync/examples/end-to-end-local.rs

@@ -4,7 +4,7 @@
 ///
 use std::{collections::BTreeMap, format, io};
 
-use rand::{rngs::StdRng, SeedableRng};
+use rand::{rngs::StdRng, Rng, SeedableRng};
 use serde::{Deserialize, Serialize};
 use sqlsync::{
     coordinator::CoordinatorDocument,
@@ -14,7 +14,7 @@ use sqlsync::{
     JournalId, MemoryJournal, MemoryJournalFactory, Reducer,
 };
 
-#[derive(Debug)]
+#[derive(Debug, PartialEq)]
 #[allow(dead_code)]
 struct Task {
     id: i64,
@@ -71,22 +71,23 @@ enum Mutation {
 }
 
 fn main() -> anyhow::Result<()> {
-    // seed a random number generater from the command line
-    // or use a random seed
-    let mut rng = std::env::args()
-        .nth(1)
-        .map(|seed| {
-            let seed = seed.parse::<u64>().unwrap();
-            StdRng::seed_from_u64(seed)
-        })
-        .unwrap_or_else(|| StdRng::from_entropy());
-
     simple_logger::SimpleLogger::new()
         .with_level(log::LevelFilter::Debug)
         .without_timestamps()
         .env()
         .init()?;
 
+    // seed a random number generater from the command line
+    // or use a random seed
+    let rng_seed: u64 = std::env::args()
+        .nth(1)
+        .map(|seed| seed.parse().unwrap())
+        .unwrap_or_else(|| rand::thread_rng().gen());
+
+    log::info!("using rng seed: {}", rng_seed);
+
+    let mut rng = StdRng::seed_from_u64(rng_seed);
+
     let doc_id = JournalId::new128(&mut rng);
     // build task_reducer.wasm using: `cargo build --target wasm32-unknown-unknown --example task-reducer`
     let wasm_bytes =
@@ -333,6 +334,16 @@ fn main() -> anyhow::Result<()> {
     print_tasks!(local)?;
     print_tasks!(local2)?;
 
+    // get both sets of tasks and make sure they are the same
+    let tasks1 = local.query(|conn| query_tasks(conn))?;
+    let tasks2 = local2.query(|conn| query_tasks(conn))?;
+
+    // compare the two Vec<Task> objects
+    assert_eq!(tasks1.len(), tasks2.len(), "different number of tasks",);
+    for (i, task) in tasks1.iter().enumerate() {
+        assert_eq!(task, &tasks2[i], "tasks differ at index {}", i);
+    }
+
     log::info!("DONE");
 
     Ok(())