Proxy publisher content

.env.dev

@@ -1,6 +1,9 @@
 # [ad_server]
 TRUSTED_SERVER__AD_SERVER__AD_PARTNER_BACKEND=http://127.0.0.1:10180
 
+# [publisher]
+TRUSTED_SERVER__PUBLISHER__ORIGIN_URL=http://localhost:9090
+
 # [synthetic]
 TRUSTED_SERVER__SYNTHETIC__COUNTER_STORE=counter_store
 TRUSTED_SERVER__SYNTHETIC__OPID_STORE=opid_store

crates/common/Cargo.toml

@@ -9,13 +9,14 @@ publish = false
 license = "Apache-2.0"
 
 [dependencies]
-brotli = "3.3"
+brotli = "8.0"
 chrono = "0.4"
 config = "0.15.11"
 cookie = "0.18.1"
 derive_more = { version = "2.0", features = ["display", "error"] }
 error-stack = "0.5"
 fastly = "0.11.5"
+flate2 = "1.0"
 futures = "0.3"
 handlebars = "6.3.2"
 hex = "0.4.3"
@@ -35,10 +36,11 @@ urlencoding = "2.1"
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0.91"
 config = "0.15.11"
-derive_more = { version = "2.0", features = ["display", "error"] }
+derive_more = { version = "1.0", features = ["display", "error"] }
 error-stack = "0.5"
 http = "1.3.1"
 toml = "0.9.0"
+url = "2.4.1"
 
 [dev-dependencies]
 regex = "1.1.1"

crates/common/src/error.rs

@@ -19,7 +19,15 @@ pub enum TrustedServerError {
     #[display("Configuration error: {message}")]
     Configuration { message: String },
 
+    /// GAM (Google Ad Manager) integration error.
+    #[display("GAM error: {message}")]
+    Gam { message: String },
+    /// GDPR consent handling error.
+    #[display("GDPR consent error: {message}")]
+    GdprConsent { message: String },
+
     /// The synthetic secret key is using the insecure default value.
+
     #[display("Synthetic secret key is set to the default value - this is insecure")]
     InsecureSecretKey,
 
@@ -31,29 +39,26 @@ pub enum TrustedServerError {
     #[display("Invalid HTTP header value: {message}")]
     InvalidHeaderValue { message: String },
 
+    /// Key-value store operation failed.
+    #[display("KV store error: {store_name} - {message}")]
+    KvStore { store_name: String, message: String },
+
+    /// Prebid integration error.
+    #[display("Prebid error: {message}")]
+    Prebid { message: String },
+
+    /// Proxy error.
+    #[display("Proxy error: {message}")]
+    Proxy { message: String },
+
     /// Settings parsing or validation failed.
     #[display("Settings error: {message}")]
     Settings { message: String },
 
-    /// GAM (Google Ad Manager) integration error.
-    #[display("GAM error: {message}")]
-    Gam { message: String },
-    /// GDPR consent handling error.
-    #[display("GDPR consent error: {message}")]
-    GdprConsent { message: String },
-
     /// Synthetic ID generation or validation failed.
     #[display("Synthetic ID error: {message}")]
     SyntheticId { message: String },
 
-    /// Prebid integration error.
-    #[display("Prebid error: {message}")]
-    Prebid { message: String },
-
-    /// Key-value store operation failed.
-    #[display("KV store error: {store_name} - {message}")]
-    KvStore { store_name: String, message: String },
-
     /// Template rendering error.
     #[display("Template error: {message}")]
     Template { message: String },
@@ -75,14 +80,15 @@ impl IntoHttpResponse for TrustedServerError {
     fn status_code(&self) -> StatusCode {
         match self {
             Self::Configuration { .. } | Self::Settings { .. } => StatusCode::INTERNAL_SERVER_ERROR,
-            Self::InsecureSecretKey => StatusCode::INTERNAL_SERVER_ERROR,
-            Self::InvalidUtf8 { .. } => StatusCode::BAD_REQUEST,
-            Self::InvalidHeaderValue { .. } => StatusCode::BAD_REQUEST,
             Self::Gam { .. } => StatusCode::BAD_GATEWAY,
             Self::GdprConsent { .. } => StatusCode::BAD_REQUEST,
-            Self::SyntheticId { .. } => StatusCode::INTERNAL_SERVER_ERROR,
-            Self::Prebid { .. } => StatusCode::BAD_GATEWAY,
+            Self::InsecureSecretKey => StatusCode::INTERNAL_SERVER_ERROR,
+            Self::InvalidHeaderValue { .. } => StatusCode::BAD_REQUEST,
+            Self::InvalidUtf8 { .. } => StatusCode::BAD_REQUEST,
             Self::KvStore { .. } => StatusCode::SERVICE_UNAVAILABLE,
+            Self::Prebid { .. } => StatusCode::BAD_GATEWAY,
+            Self::Proxy { .. } => StatusCode::BAD_GATEWAY,
+            Self::SyntheticId { .. } => StatusCode::INTERNAL_SERVER_ERROR,
             Self::Template { .. } => StatusCode::INTERNAL_SERVER_ERROR,
         }
     }

crates/common/src/lib.rs

@@ -15,6 +15,7 @@
 //! - [`prebid`]: Prebid integration and real-time bidding support
 //! - [`privacy`]: Privacy utilities and helpers
 //! - [`settings`]: Configuration management and validation
+//! - [`streaming_replacer`]: Streaming URL replacement for large responses
 //! - [`synthetic`]: Synthetic ID generation using HMAC
 //! - [`templates`]: Handlebars template handling
 //! - [`test_support`]: Testing utilities and mocks
@@ -33,6 +34,7 @@ pub mod privacy;
 pub mod publisher;
 pub mod settings;
 pub mod settings_data;
+pub mod streaming_replacer;
 pub mod synthetic;
 pub mod templates;
 pub mod test_support;