permutive integration

Author: ChristianPavilonis

crates/common/src/html_processor.rs

@@ -22,7 +22,6 @@ pub struct HtmlProcessorConfig {
     pub request_host: String,
     pub request_scheme: String,
     pub enable_prebid: bool,
-    pub enable_permutive: bool,
     pub integrations: IntegrationRegistry,
     pub nextjs_enabled: bool,
     pub nextjs_attributes: Vec<String>,
@@ -49,7 +48,6 @@ impl HtmlProcessorConfig {
             request_host: request_host.to_string(),
             request_scheme: request_scheme.to_string(),
             enable_prebid: settings.prebid.auto_configure,
-            enable_permutive: settings.permutive.auto_configure,
             integrations: integrations.clone(),
             nextjs_enabled: settings.publisher.nextjs.enabled,
             nextjs_attributes: settings.publisher.nextjs.rewrite_attributes.clone(),
@@ -146,14 +144,6 @@ pub fn create_html_processor(config: HtmlProcessorConfig) -> impl StreamProcesso
         )
     }
 
-    fn is_permutive_sdk_url(url: &str) -> bool {
-        let lower = url.to_ascii_lowercase();
-        // Match: https://*.edge.permutive.app/*-web.js
-        // Match: https://cdn.permutive.com/*-web.js
-        (lower.contains(".edge.permutive.app") || lower.contains("cdn.permutive.com"))
-            && lower.ends_with("-web.js")
-    }
-
     let mut element_content_handlers = vec![
         element!("head", {
             let injected_tsjs = injected_tsjs.clone();
@@ -179,15 +169,12 @@ pub fn create_html_processor(config: HtmlProcessorConfig) -> impl StreamProcesso
         element!("[href]", {
             let patterns = patterns.clone();
             let rewrite_prebid = config.enable_prebid;
-            let rewrite_permutive = config.enable_permutive;
             let integrations = integration_registry.clone();
             move |el| {
                 if let Some(mut href) = el.get_attribute("href") {
                     let original_href = href.clone();
                     if rewrite_prebid && is_prebid_script_url(&href) {
                         href = tsjs::ext_script_src();
-                    } else if rewrite_permutive && is_permutive_sdk_url(&href) {
-                        href = tsjs::permutive_script_src();
                     } else {
                         let new_href = href
                             .replace(&patterns.https_origin(), &patterns.replacement_url())
@@ -220,15 +207,12 @@ pub fn create_html_processor(config: HtmlProcessorConfig) -> impl StreamProcesso
         element!("[src]", {
             let patterns = patterns.clone();
             let rewrite_prebid = config.enable_prebid;
-            let rewrite_permutive = config.enable_permutive;
             let integrations = integration_registry.clone();
             move |el| {
                 if let Some(mut src) = el.get_attribute("src") {
                     let original_src = src.clone();
                     if rewrite_prebid && is_prebid_script_url(&src) {
                         src = tsjs::ext_script_src();
-                    } else if rewrite_permutive && is_permutive_sdk_url(&src) {
-                        src = tsjs::permutive_script_src();
                     } else {
                         let new_src = src
                             .replace(&patterns.https_origin(), &patterns.replacement_url())
@@ -477,7 +461,6 @@ mod tests {
             request_host: "test.example.com".to_string(),
             request_scheme: "https".to_string(),
             enable_prebid: false,
-            enable_permutive: false,
             integrations: IntegrationRegistry::default(),
             nextjs_enabled: false,
             nextjs_attributes: vec!["href".to_string(), "link".to_string(), "url".to_string()],

crates/common/src/integrations/mod.rs

@@ -2,6 +2,7 @@
 
 use crate::settings::Settings;
 
+pub mod permutive;
 mod registry;
 pub mod testlight;
 
@@ -14,5 +15,5 @@ pub use registry::{
 type IntegrationBuilder = fn(&Settings) -> Option<IntegrationRegistration>;
 
 pub(crate) fn builders() -> &'static [IntegrationBuilder] {
-    &[testlight::register]
+    &[permutive::register, testlight::register]
 }