Rust (Beta)

[dependencies]
sailhouse = { version = "0.1" }

# Just for the examples below
tokio = { version = "1", features = ["full"] }

use std::{collections::HashMap, env};
use sailhouse::SailhouseClient;

fn main() {
    let token = match env::var("SAILHOUSE_TOKEN") {
        Ok(value) => value,
        Err(error) => {
            eprintln!("Failed to read SAILHOUSE_TOKEN: {}", error);
            return;
        }
    };

    let client = SailhouseClient::new(token);
    let mut data = HashMap::new();
    data.insert("message", "Hello world!");

    let publish_future = client.publish("example-topic", data);
    let _ = tokio::runtime::Runtime::new().unwrap().block_on(publish_future);
}

let token = match env::var("SAILHOUSE_TOKEN") {
    Ok(value) => value,
    Err(error) => {
        eprintln!("Failed to read SAILHOUSE_TOKEN: {}", error);
        return;
    }
};

let client = SailhouseClient::new(token);

use sailhouse::{SailhouseClient, Filter, ComplexFilter, FilterCondition};
use std::collections::HashMap;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let client = SailhouseClient::new(token);
    
    // Basic push subscription
    client.admin().register_push_subscription(
        "user-events",
        "welcome-email",
        "https://api.example.com/webhooks/welcome",
        None,
        None,
        None,
    ).await?;
    
    // With simple filter
    let simple_filter = Filter {
        path: "user.type".to_string(),
        value: "premium".to_string(),
    };
    
    client.admin().register_push_subscription(
        "user-events",
        "premium-users", 
        "https://api.example.com/webhooks/premium",
        Some(simple_filter),
        None,
        None,
    ).await?;
    
    // With advanced filter
    let complex_filter = ComplexFilter {
        filters: vec![
            FilterCondition {
                path: "user.type".to_string(),
                condition: "equals".to_string(),
                value: "premium".to_string(),
            },
            FilterCondition {
                path: "user.status".to_string(), 
                condition: "not_equals".to_string(),
                value: "inactive".to_string(),
            },
        ],
        operator: "and".to_string(),
    };
    
    client.admin().register_push_subscription(
        "user-events",
        "active-premium-users",
        "https://api.example.com/webhooks/active-premium", 
        Some(Filter::Complex(complex_filter)),
        Some("100/h".to_string()),
        Some("5m".to_string()),
    ).await?;
    
    Ok(())
}