rust_supabase_sdk 0.3.1

Async Rust client for Supabase — PostgREST, Auth, Storage, Edge Functions, and Realtime. Builder-pattern API mirroring `supabase-js`, with a `cargo supabase` codegen for typed row structs.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74


#[cfg(test)]
#[allow(deprecated)] // Legacy integration tests pinned to the pre-builder API.
mod tests {
    use dotenv::dotenv;
    use serde_json::json;
    use rust_supabase_sdk::SupabaseClient;

    #[tokio::test]
    async fn can_initialise_supabase_client() {
        dotenv().ok(); // Load environment variables from .env file
        SupabaseClient::new(
            std::env::var("SUPABASE_URL").unwrap(),
            std::env::var("SUPABASE_API_KEY").unwrap(),
            None
        );
    }

    #[tokio::test]
    async fn can_create_get_update_and_remove() {
        dotenv().ok(); // Load environment variables from .env file
        let supabase_client = SupabaseClient::new(
            std::env::var("SUPABASE_URL").unwrap(),
            std::env::var("SUPABASE_API_KEY").unwrap(),
            None
        );

        let record_id = supabase_client.insert("organisations", json!({
            "name": "Test Organisation"
        })).await.unwrap();

        let record = supabase_client.get_by_id("organisations", &record_id).await.unwrap();
        assert_eq!(record["name"], "Test Organisation");

        supabase_client.update("organisations", &record_id, json!({
            "name": "Updated Organisation"
        })).await.unwrap();

        let record = supabase_client.get_by_id("organisations", &record_id).await.unwrap();
        assert_eq!(record["name"], "Updated Organisation");

        supabase_client.delete("organisations", &record_id).await.unwrap();

        let record = supabase_client.get_by_id("organisations", &record_id).await;
        assert!(record.is_err());
    }

    #[tokio::test]
    async fn can_upsert() {
        dotenv().ok(); // Load environment variables from .env file
        let supabase_client = SupabaseClient::new(
            std::env::var("SUPABASE_URL").unwrap(),
            std::env::var("SUPABASE_API_KEY").unwrap(),
            None
        );

        let record_id = supabase_client.upsert("organisations", json!({
            "name": "Test Organisation"
        })).await.unwrap();

        let record = supabase_client.get_by_id("organisations", &record_id).await.unwrap();
        assert_eq!(record["name"], "Test Organisation");

        supabase_client.upsert("organisations", json!({
            "id": record_id,
            "name": "Updated Organisation"
        })).await.unwrap();

        let record = supabase_client.get_by_id("organisations", &record_id).await.unwrap();
        assert_eq!(record["name"], "Updated Organisation");

        supabase_client.delete("organisations", &record_id).await.unwrap();
    }
}