relay_server/endpoints/
mod.rs

1//! Web server endpoints.
2//!
3//! This module contains implementations for all supported relay endpoints, as well as a generic
4//! `forward` endpoint that sends unknown requests to the upstream.
5
6mod attachments;
7mod autoscaling;
8mod batch_metrics;
9mod batch_outcomes;
10mod common;
11mod envelope;
12mod forward;
13mod health_check;
14mod integrations;
15mod minidump;
16mod monitor;
17mod nel;
18#[cfg(sentry)]
19mod playstation;
20mod project_configs;
21mod public_keys;
22mod security_report;
23mod statics;
24mod store;
25mod unreal;
26
27use axum::extract::DefaultBodyLimit;
28use axum::routing::{Router, any, get, post};
29use relay_config::Config;
30
31use crate::middlewares;
32use crate::service::ServiceState;
33
34/// Size limit for internal batch endpoints.
35const BATCH_JSON_BODY_LIMIT: usize = 50_000_000; // 50 MB
36
37/// All of Relay's routes.
38///
39/// This includes [`public_routes`] as well as [`internal_routes`].
40pub fn all_routes(config: &Config) -> Router<ServiceState> {
41    public_routes_raw(config).merge(internal_routes(config))
42}
43
44/// Relay's internal routes.
45///
46/// Routes which do not need to be exposed.
47#[rustfmt::skip]
48pub fn internal_routes(_: &Config) -> Router<ServiceState>{
49    Router::new()
50        .route("/api/relay/healthcheck/{kind}/", get(health_check::handle))
51        .route("/api/relay/autoscaling/", get(autoscaling::handle))
52        // Fallback route, but with a name, and just on `/api/relay/*`.
53        .route("/api/relay/{*not_found}", any(statics::not_found))
54}
55
56/// Relay's public routes.
57///
58/// Routes which are public API and must be exposed.
59#[expect(unused, reason = "temporarily unused")]
60pub fn public_routes(config: &Config) -> Router<ServiceState> {
61    // Exclude internal routes, they must be configured separately.
62    public_routes_raw(config).route("/api/relay/{*not_found}", any(statics::not_found))
63}
64
65#[rustfmt::skip]
66fn public_routes_raw(config: &Config) -> Router<ServiceState> {
67    // Sentry Web API routes pointing to /api/0/relays/
68    let web_routes = Router::new()
69        .route("/api/0/relays/projectconfigs/", post(project_configs::handle))
70        .route("/api/0/relays/publickeys/", post(public_keys::handle))
71        // Network connectivity check for downstream Relays, same as the internal health check.
72        .route("/api/0/relays/live/", get(health_check::handle_live))
73        .route_layer(DefaultBodyLimit::max(crate::constants::MAX_JSON_SIZE));
74
75    let batch_routes = Router::new()
76        .route("/api/0/relays/outcomes/", post(batch_outcomes::handle))
77        .route("/api/0/relays/metrics/", post(batch_metrics::handle))
78        .route_layer(DefaultBodyLimit::max(BATCH_JSON_BODY_LIMIT));
79
80    // Ingestion routes pointing to /api/:project_id/
81    let store_routes = Router::new()
82        // Legacy store path that is missing the project parameter.
83        .route("/api/store/", store::route(config))
84        // cron monitor level routes.  These are user facing APIs and as such support trailing slashes.
85        .route("/api/{project_id}/cron/{monitor_slug}/{sentry_key}", monitor::route(config))
86        .route("/api/{project_id}/cron/{monitor_slug}/{sentry_key}/", monitor::route(config))
87        .route("/api/{project_id}/cron/{monitor_slug}", monitor::route(config))
88        .route("/api/{project_id}/cron/{monitor_slug}/", monitor::route(config))
89
90        .route("/api/{project_id}/store/", store::route(config))
91        .route("/api/{project_id}/envelope/", envelope::route(config))
92        .route("/api/{project_id}/security/", security_report::route(config))
93        .route("/api/{project_id}/csp-report/", security_report::route(config))
94        .route("/api/{project_id}/nel/", nel::route(config))
95        // No mandatory trailing slash here because people already use it like this.
96        .route("/api/{project_id}/minidump", minidump::route(config))
97        .route("/api/{project_id}/minidump/", minidump::route(config))
98        .route("/api/{project_id}/events/{event_id}/attachments/", post(attachments::handle))
99        .route("/api/{project_id}/unreal/{sentry_key}/", unreal::route(config));
100
101    #[cfg(sentry)]
102    let store_routes = store_routes.route("/api/{project_id}/playstation/", playstation::route(config));
103    let store_routes = store_routes.route_layer(middlewares::cors());
104
105    // Integration routes.
106    //
107    // For integrations we want to be lenient on trailing `/`, as they are often manually
108    // configured by users or protocols may force a specific variant.
109    let integration_routes = Router::new()
110        .nest("/api/{project_id}/integration/otlp", integrations::otlp::routes(config))
111        .nest("/api/{project_id}/integration/vercel", integrations::vercel::routes(config))
112        .route_layer(middlewares::cors());
113
114    // NOTE: If you add a new (non-experimental) route here, please also list it in
115    // https://github.com/getsentry/sentry-docs/blob/master/docs/product/relay/operating-guidelines.mdx
116
117    Router::new()
118        .merge(web_routes)
119        .merge(batch_routes)
120        .merge(store_routes)
121        .merge(integration_routes)
122        // Forward all other API routes to the upstream. This will 404 for non-API routes.
123        .fallback(forward::forward)
124}
relay_server/endpoints/mod.rs

relay_server/endpoints/
mod.rs
