fabric-platform 0.5.0

Rust client SDK for the Fabric platform
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
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119

# fabric-platform

Rust client SDK for the [Fabric](https://github.com/tinylabscom/fabric) AI workflow platform.

## Installation

```toml
[dependencies]
fabric-platform = "0.1"
tokio = { version = "1", features = ["rt", "macros"] }
```

## Quick Start

```rust
use fabric_sdk::FabricClient;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // API key auth
    let client = FabricClient::new("https://gofabric.dev", "fab_your_key")?;

    // Get the current principal
    let me = client.get_me().await?;
    println!("Logged in as: {:?}", me);

    // List organizations
    let orgs = client.get_my_organizations().await?;
    for org in &orgs {
        println!("Org: {}", org);
    }

    // Check a permission
    let allowed = client
        .check_permission("read", Some("organization:<org-id>"))
        .await?;
    println!("Allowed: {}", allowed);

    Ok(())
}
```

## Features

- **Identity** — `get_me`, `get_my_organizations`, `get_my_teams`, `get_my_permissions`
- **Organizations & teams** — create, list, update, member management
- **Workflows** — register, run, wait for completion, list runs
- **Jobs** — submit and track single-node jobs
- **Authorization** — `check_permission`, `check_permissions` (batch)
- **API keys** — create, list, rotate, disable
- **Providers** — list, execute, estimate cost
- **Streaming** — Server-Sent Events for live workflow updates

## Authentication

The SDK supports two auth modes:

```rust
// API key (server-to-server)
let client = FabricClient::new("https://gofabric.dev", "fab_your_key")?;

// Bearer token (e.g. from /v1/auth/login)
let client = FabricClient::with_token("https://gofabric.dev", "jwt-token")?;
```

## Authorization

Check permissions using the compound resource format (`"type:id"`):

```rust
// Single check
let allowed = client
    .check_permission("owner", Some(&format!("team:{team_id}")))
    .await?;

// Batch check (more efficient for multiple checks)
let results = client
    .check_permissions(vec![
        serde_json::json!({ "resource": format!("team:{team_id}"), "action": "owner" }),
        serde_json::json!({ "resource": format!("team:{team_id}"), "action": "admin" }),
        serde_json::json!({ "resource": format!("team:{team_id}"), "action": "read" }),
    ])
    .await?;
```

## Workflows

```rust
// Register a workflow definition
let wf_id = client
    .upsert_workflow(
        "transcribe-and-summarize",
        serde_json::json!({
            "nodes": [
                {"key": "transcribe", "operation": "audio.transcribe"},
                {"key": "summarize", "operation": "ai.generate", "depends_on": ["transcribe"]}
            ]
        }),
    )
    .await?;

// Run it
let run_id = client
    .run_workflow(wf_id, serde_json::json!({ "audio": { "url": "..." } }))
    .await?;

// Wait for completion
let result = client.wait_for_run(run_id).await?;
```

## Documentation

- Full docs: [gofabric.dev/docs](https://gofabric.dev/docs)
- API reference: [gofabric.dev/reference/api-endpoints](https://gofabric.dev/reference/api-endpoints)
- Repository: [github.com/tinylabscom/fabric](https://github.com/tinylabscom/fabric)

## License

MIT