SentryStr API

REST API server for SentryStr event collection and querying.

Quick Start

use sentrystr_api::create_app;
use sentrystr_collector::EventCollector;
use std::sync::Arc;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let relays = vec!["wss://relay.damus.io".to_string()];
    let collector = Arc::new(EventCollector::new(relays).await?);

    let app = create_app(collector);

    let listener = tokio::net::TcpListener::bind("0.0.0.0:3000").await?;
    println!("SentryStr API server running on http://localhost:3000");

    axum::serve(listener, app).await?;
    Ok(())
}

API Endpoints

GET /events

Query events with optional filters:

curl "http://localhost:3000/events?limit=10&level=error"
curl "http://localhost:3000/events?author=npub1...&since=2024-01-01T00:00:00Z"

GET /events/{author}

Get events by specific author:

curl "http://localhost:3000/events/npub1abc123.../events"

GET /health

Health check endpoint:

curl "http://localhost:3000/health"

With Tracing Integration

use sentrystr_api::create_app;
use sentrystr_collector::EventCollector;
use sentrystr_tracing::SentryStrTracingBuilder;
use tracing::{info, error};
use std::sync::Arc;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // Setup tracing for the API server itself
    SentryStrTracingBuilder::new()
        .with_generated_keys_and_relays(vec!["wss://relay.damus.io".to_string()])
        .init()
        .await?;

    let relays = vec!["wss://relay.damus.io".to_string()];
    let collector = Arc::new(EventCollector::new(relays).await?);
    let app = create_app(collector);

    info!("Starting SentryStr API server");

    let listener = tokio::net::TcpListener::bind("0.0.0.0:3000").await?;
    axum::serve(listener, app).await?;

    Ok(())
}