Fix transport type to schema mapping and add interval field

- Map transport types to URI schemes (http/https->grpc, http1/https1->http1, dns->dns)
- Error if URI already contains query parameters
- Add optional interval field to TransportConfig
- Build proper URIs with schemes and query parameters

Co-authored-by: Hulto <hulto@users.noreply.github.com>

Author: github-actions[bot]

implants/lib/pb/build.rs

@@ -11,6 +11,8 @@ struct TransportConfig {
     #[serde(rename = "type")]
     transport_type: String,
     extra: String,
+    #[serde(default)]
+    interval: Option<u64>,
 }
 
 #[derive(Debug, Deserialize)]
@@ -65,8 +67,8 @@ fn parse_yaml_config() -> Result<bool, Box<dyn std::error::Error>> {
     for transport in &config.transports {
         // Validate transport type
         let transport_type_lower = transport.transport_type.to_lowercase();
-        if !["grpc", "http1", "dns"].contains(&transport_type_lower.as_str()) {
-            return Err(format!("Invalid transport type '{}'. Must be one of: GRPC, http1, DNS", transport.transport_type).into());
+        if !["grpc", "http1", "dns", "http", "https", "https1"].contains(&transport_type_lower.as_str()) {
+            return Err(format!("Invalid transport type '{}'. Must be one of: GRPC, http, https, http1, https1, DNS", transport.transport_type).into());
         }
 
         // Validate that extra is valid JSON
@@ -75,19 +77,39 @@ fn parse_yaml_config() -> Result<bool, Box<dyn std::error::Error>> {
                 .map_err(|e| format!("Invalid JSON in 'extra' field for transport '{}': {}", transport.uri, e))?;
         }
 
-        // Build DSN part with query parameters
-        let mut dsn_part = transport.uri.clone();
+        // Map transport type to URI scheme
+        let scheme = match transport_type_lower.as_str() {
+            "http" | "https" => "grpc",
+            "http1" | "https1" => "http1",
+            "dns" => "dns",
+            "grpc" => "grpc",
+            _ => return Err(format!("Unhandled transport type '{}'", transport.transport_type).into()),
+        };
+
+        // Parse URI and check if it already has query parameters
+        let uri = &transport.uri;
+        if uri.contains('?') {
+            return Err(format!("URI '{}' already contains query parameters. Query parameters should not be in the URI field.", uri).into());
+        }
+
+        // Build DSN with scheme and query parameters
+        let mut dsn_part = format!("{}://{}", scheme, uri);
 
-        // Check if URI already has query parameters
-        let separator = if dsn_part.contains('?') { "&" } else { "?" };
+        // Start query parameters
+        dsn_part.push('?');
 
-        // Add transport type as query parameter
-        dsn_part.push_str(&format!("{}transport={}", separator, transport_type_lower));
+        // Add interval as query parameter if present
+        if let Some(interval) = transport.interval {
+            dsn_part.push_str(&format!("interval={}", interval));
+        }
 
         // Add extra as query parameter if not empty
         if !transport.extra.is_empty() {
+            if transport.interval.is_some() {
+                dsn_part.push('&');
+            }
             let encoded_extra = urlencoding::encode(&transport.extra);
-            dsn_part.push_str(&format!("&extra={}", encoded_extra));
+            dsn_part.push_str(&format!("extra={}", encoded_extra));
         }
 
         dsn_parts.push(dsn_part);