Add multi_schema tests

Author: soedirgo

tests/multi_schema.rs

@@ -0,0 +1,152 @@
+#[macro_use]
+extern crate json; // array!, object!, value!
+
+use postgrest::Postgrest;
+
+use std::error::Error;
+
+const REST_URL: &str = "http://localhost:3000";
+
+#[tokio::test]
+async fn read_other_schema() -> Result<(), Box<dyn Error>> {
+    let client = Postgrest::new(REST_URL);
+    let resp = client
+        .from("users")
+        .select("username")
+        .eq("username", "leroyjenkins")
+        .execute()
+        .await?;
+    let body = resp.text().await?;
+    let body = json::parse(&body)?;
+
+    assert_eq!(body, array![]);
+
+    let other_client = Postgrest::new(REST_URL).schema("personal");
+    let other_resp = other_client
+        .from("users")
+        .select("username")
+        .eq("username", "leroyjenkins")
+        .execute()
+        .await?;
+    let other_body = other_resp.text().await?;
+    let other_body = json::parse(&other_body)?;
+
+    assert_eq!(other_body, array![{"username": "leroyjenkins"}]);
+
+    Ok(())
+}
+
+#[tokio::test]
+async fn write_other_schema() -> Result<(), Box<dyn Error>> {
+    let client = Postgrest::new(REST_URL);
+    let resp = client
+        .from("users")
+        .select("status")
+        .eq("username", "dragarcia")
+        .execute()
+        .await?;
+    let body = resp.text().await?;
+    let body = json::parse(&body)?;
+
+    assert_eq!(body[0]["status"], "ONLINE");
+
+    let other_client = Postgrest::new(REST_URL).schema("personal");
+    let other_resp = other_client
+        .from("users")
+        .update("{\"status\": \"OFFLINE\"}")
+        .eq("username", "dragarcia")
+        .execute()
+        .await?;
+    let other_body = other_resp.text().await?;
+    let other_body = json::parse(&other_body)?;
+
+    assert_eq!(other_body[0]["status"], "OFFLINE");
+
+    Ok(())
+}
+
+#[tokio::test]
+async fn read_nonexisting_schema() -> Result<(), Box<dyn Error>> {
+    let client = Postgrest::new(REST_URL).schema("private");
+    let resp = client.from("channels").select("*").execute().await?;
+    let body = resp.text().await?;
+    let body = json::parse(&body)?;
+
+    assert_eq!(
+        body["message"],
+        "The schema must be one of the following: public, personal"
+    );
+
+    Ok(())
+}
+
+#[tokio::test]
+async fn write_nonexisting_schema() -> Result<(), Box<dyn Error>> {
+    let client = Postgrest::new(REST_URL).schema("private");
+    let resp = client
+        .from("channels")
+        .update("{\"slug\": \"private\"}")
+        .eq("slug", "random")
+        .execute()
+        .await?;
+    let body = resp.text().await?;
+    let body = json::parse(&body)?;
+
+    assert_eq!(
+        body["message"],
+        "The schema must be one of the following: public, personal"
+    );
+
+    Ok(())
+}
+
+#[tokio::test]
+async fn other_schema_rpc() -> Result<(), Box<dyn Error>> {
+    let client = Postgrest::new(REST_URL).schema("personal");
+    let resp = client
+        .rpc("get_status", "{\"name_param\": \"leroyjenkins\"}")
+        .execute()
+        .await?;
+    let body = resp.text().await?;
+    let body = json::parse(&body)?;
+
+    assert_eq!(body, "ONLINE");
+
+    Ok(())
+}
+
+#[tokio::test]
+async fn nonexisting_rpc_in_schema() -> Result<(), Box<dyn Error>> {
+    let client = Postgrest::new(REST_URL).schema("personal");
+    let resp = client
+        .rpc("nonexistent_procedure", "{\"param\": 0}")
+        .execute()
+        .await?;
+    let body = resp.text().await?;
+    let body = json::parse(&body)?;
+
+    assert_eq!(
+        body["message"],
+        "function personal.nonexistent_procedure(param => text) does not exist"
+    );
+
+    Ok(())
+}
+
+#[tokio::test]
+async fn nonexisting_schema_for_rpc() -> Result<(), Box<dyn Error>> {
+    let client = Postgrest::new(REST_URL).schema("private");
+    let resp = client
+        .rpc("get_status", "{\"name_param\": \"leroyjenkins\"}")
+        .execute()
+        .await?;
+    let body = resp.text().await?;
+    let body = json::parse(&body)?;
+
+    assert_eq!(
+        body["message"],
+        "The schema must be one of the following: public, personal"
+    );
+
+    Ok(())
+}