Rust Axum and Tower

epode_artifact="$(mktemp -d)/agent-feedback-rust-0.5.28.tar.gz" &&
curl -fsSL https://app.tryintents.com/static/agent-feedback-rust-0.5.28.tar.gz -o "$epode_artifact" &&
printf '%s  %s\n' 'dea703c2637b810a57bf9b696503b8a88bc25fbf53e3cba92601198709bcb608' "$epode_artifact" \
  | shasum -a 256 -c - &&
mkdir -p vendor/agent-feedback-rust-0.5.28 &&
tar -xzf "$epode_artifact" -C vendor/agent-feedback-rust-0.5.28

[dependencies]
agent-feedback = { path = "vendor/agent-feedback-rust-0.5.28" }

use agent_feedback::{buffered_response, AgentFeedbackLayer, Options};
use axum::{middleware, routing::get, Router};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let feedback = AgentFeedbackLayer::new(
        Options::new(std::env::var("AGENT_FEEDBACK_KEY")?)
            .include(["/search", "/docs/**"])
            .account_ref(|request| authenticated_account_id(request))
            .user_ref(|request| authenticated_user_id(request))
            .anonymous_ref(|request| first_party_visitor_id(request))
            .customer_ref(|request| authenticated_account_id(request)) // durable Ask once compatibility
            .session_ref(|request| product_journey_id(request)), // optional server-issued journey
    )?;

    let app = Router::new()
        .route("/search", get(search_handler))
        .layer(feedback.clone())
        .layer(middleware::from_fn(authenticate_product_request));

    // Start Axum, then call feedback.shutdown().await during graceful shutdown.
    Ok(())
}