add create dump test.

Author: MarinPostma

sqld/tests/common/http.rs

@@ -16,6 +16,15 @@ impl Response {
         Ok(v)
     }
 
+    pub async fn json_value(self) -> anyhow::Result<serde_json::Value> {
+        self.json().await
+    }
+
+    pub async fn body_string(self) -> anyhow::Result<String> {
+        let bytes = hyper::body::to_bytes(self.0.into_body()).await?;
+        Ok(String::from_utf8(bytes.to_vec())?)
+    }
+
     pub fn status(&self) -> hyper::http::StatusCode {
         self.0.status()
     }

sqld/tests/namespaces/load_dump.rs

@@ -1,6 +1,7 @@
 use std::convert::Infallible;
 
 use hyper::{service::make_service_fn, Response, Body, StatusCode};
+use insta::assert_snapshot;
 use libsql::{Database, Value};
 use serde_json::json;
 use tempfile::tempdir;
@@ -157,9 +158,10 @@ fn load_namespace_from_no_txn() {
 
     sim.client("client", async move {
         let client = Client::new();
-        let resp = client.post("http://primary:9090/v1/namespaces/foo/create", json!({ "dump_url": format!("file:{}", tmp_path.join("dump.sql").display())})).await.unwrap();
+        let resp = client.post("http://primary:9090/v1/namespaces/foo/create", json!({ "dump_url": format!("file:{}", tmp_path.join("dump.sql").display())})).await?;
         // the dump is malformed
         assert_eq!(resp.status(), StatusCode::BAD_REQUEST, "{}", resp.json::<serde_json::Value>().await.unwrap_or_default());
+        assert_snapshot!(resp.json_value().await.unwrap());
 
         // namespace doesn't exist
         let foo = Database::open_remote_with_connector("http://foo.primary:8080", "", TurmoilConnector)?;
@@ -171,3 +173,34 @@ fn load_namespace_from_no_txn() {
 
     sim.run().unwrap();
 }
+
+#[test]
+fn export_dump() {
+    let mut sim = Builder::new().build();
+    let tmp = tempdir().unwrap();
+
+    make_primary(&mut sim, tmp.path().to_path_buf());
+
+    sim.client("client", async move {
+        let client = Client::new();
+        let resp = client.post("http://primary:9090/v1/namespaces/foo/create", json!({})).await?;
+        assert_eq!(resp.status(), StatusCode::OK);
+        assert_snapshot!(resp.json_value().await.unwrap());
+
+        let foo = Database::open_remote_with_connector("http://foo.primary:8080", "", TurmoilConnector)?;
+        let foo_conn = foo.connect()?;
+        foo_conn.execute("create table test (x)", ()).await?;
+        foo_conn.execute("insert into test values (42)", ()).await?;
+        foo_conn.execute("insert into test values (\"foo\")", ()).await?;
+        foo_conn.execute("insert into test values (\"bar\")", ()).await?;
+
+
+        let resp = client.get("http://foo.primary:8080/dump").await?;
+        assert_eq!(resp.status(), StatusCode::OK);
+        assert_snapshot!(resp.body_string().await?);
+
+        Ok(())
+    });
+
+    sim.run().unwrap();
+}

sqld/tests/namespaces/snapshots/tests__namespaces__load_dump__export_dump.snap

@@ -0,0 +1,13 @@
+---
+source: sqld/tests/namespaces/load_dump.rs
+expression: resp.body_string().await?
+---
+PRAGMA foreign_keys=OFF;
+BEGIN TRANSACTION;
+CREATE TABLE IF NOT EXISTS libsql_wasm_func_table (name text PRIMARY KEY, body text) WITHOUT ROWID;
+CREATE TABLE IF NOT EXISTS test (x);
+INSERT INTO test VALUES(42);
+INSERT INTO test VALUES('foo');
+INSERT INTO test VALUES('bar');
+COMMIT;
+