hightower-client 0.1.5

Hightower client library
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

use hightower_client::HightowerConnection;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let auth_token = std::env::var("HT_AUTH_TOKEN")
        .expect("HT_AUTH_TOKEN environment variable must be set");
    let gateway_url = std::env::var("HT_GATEWAY_URL")
        .unwrap_or_else(|_| "http://127.0.0.1:8008".to_string());

    println!("=== Storage Modes Demo ===\n");
    println!("Gateway: {}\n", gateway_url);

    // Mode 1: Default - uses ~/.hightower/gateway/<gateway>/
    println!("1. Default mode (persistent storage):");
    let conn1 = HightowerConnection::connect(&gateway_url, &auth_token).await?;
    println!("   Node ID: {}", conn1.node_id());
    println!("   Storage: ~/.hightower/gateway/<sanitized-gateway>/");
    conn1.disconnect().await?;

    // Mode 2: Ephemeral - no storage, always fresh
    println!("\n2. Ephemeral mode (no storage, always fresh):");
    let conn2 = HightowerConnection::connect_ephemeral(
        &gateway_url,
        &auth_token
    ).await?;
    println!("   Node ID: {}", conn2.node_id());
    println!("   Storage: none (ephemeral)");
    conn2.disconnect().await?;

    // Mode 3: Custom storage directory
    println!("\n3. Custom storage directory:");
    let custom_dir = std::env::temp_dir().join("my-app-connections");
    let conn3 = HightowerConnection::connect_with_storage(
        &gateway_url,
        &auth_token,
        &custom_dir
    ).await?;
    println!("   Node ID: {}", conn3.node_id());
    println!("   Storage: {}", custom_dir.display());
    conn3.disconnect().await?;

    // Mode 4: Force fresh - bypass any stored connection
    println!("\n4. Force fresh registration (ignores stored connection):");
    let conn4 = HightowerConnection::connect_fresh(
        &gateway_url,
        &auth_token
    ).await?;
    println!("   Node ID: {}", conn4.node_id());
    println!("   (This is a brand new registration even if one was stored)");
    conn4.disconnect().await?;

    println!("\n=== Demo Complete ===");

    Ok(())
}