Infrastructure SDK for building
distributed systems in Rust

use encore::storage::postgres::Database;

static DB: Database = Database::new("users").migrations("./migrations");

async fn user_name(id: i64) -> Result<String, encore::Error> {
    let row = DB
        .query_one("SELECT name FROM users WHERE id = $1", &[&id])
        .await?;
    Ok(row.get("name"))
}

use encore::pubsub::{Message, Subscription, Topic};
use serde::{Deserialize, Serialize};

#[derive(Serialize, Deserialize)]
struct SignupEvent {
    user_id: String,
    email: String,
}

static SIGNUPS: Topic<SignupEvent> = Topic::new("signups");

#[encore::pubsub::register]
static WELCOME: Subscription<SignupEvent> =
    Subscription::new(&SIGNUPS, "send-welcome", send_welcome);

async fn send_welcome(msg: Message<SignupEvent>) -> Result<(), encore::Error> {
    send_email(&msg.data.email).await
}

use encore::objects::Bucket;

static AVATARS: Bucket = Bucket::new("avatars").public();

async fn save_avatar(user_id: &str, image: Vec<u8>) -> Result<String, encore::Error> {
    let key = format!("{user_id}.png");
    AVATARS.upload(&key, image).await?;
    AVATARS.public_url(&key)
}

use encore::cron;

// Encore calls POST /internal/welcome-emails every 2 hours.
static WELCOME_EMAILS: cron::Job = cron::Job::new(
    "welcome-email",
    "/internal/welcome-emails",
    cron::Schedule::Every("2h"),
)
.title("Send welcome emails");

let app = Router::new()
    .route(WELCOME_EMAILS.path(), post(send_welcome_emails));

use encore::secrets::Secret;

static STRIPE_KEY: Secret = Secret::new("StripeSecretKey");

// Read the value at runtime, no .env files to manage
let client = StripeClient::new(&*STRIPE_KEY.value()?);

use encore::storage::redis;

static SESSIONS: redis::Database = redis::Database::new("sessions");

async fn track_visit(page: &str) -> Result<i64, encore::Error> {
    SESSIONS.string().incr(format!("visits:{page}"), 1).await
}

use encore::metrics::{Counter, Histogram};

static ORDERS_PLACED: Counter = Counter::new("orders_placed");
static CHECKOUT_TIME: Histogram = Histogram::new("checkout_duration").unit("seconds");

ORDERS_PLACED.increment();
CHECKOUT_TIME.observe(0.42);