Multi transport builds (#1517)

* Add multi-callback

* Add DSN configuration

* Force lowercase

* Auto grab pubkey with multi-callback using 0th element.

* Update v1

* Update callback rotation

* fmt

* Remove agent callback_uris and idx in favor of config's

* Remove callback_uri from transport init replaced by config

* remove callback_uri direct ref

* fmt

* Cleanup warnings

* Address code review feedback

- Remove unused imports and variables in agent.rs
- Switch to and_then syntax for cleaner Option chaining
- Refactor parse_dsn to return Transport struct directly
- Convert default parameters to const values
- Bubble up errors instead of returning defaults
- Use named enum variants instead of numeric constants in tests
- Update all test cases to use TransportType enum

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-authored-by: Hulto <[email protected]>

* fmt

* Fix test_parse_callback_interval_valid test

The test was failing because parse_callback_interval() now returns
anyhow::Result<u64> instead of u64. Updated the test to properly
unwrap the Result before comparison.

Co-authored-by: Hulto <[email protected]>

* Update enum name

* Fix tests

* Fix tests

* Setup tests

* fix?

---------

Co-authored-by: claude[bot] <41898282+claude[bot]@users.noreply.github.com>
Co-authored-by: Hulto <[email protected]>

Author: hulto

implants/imix/src/agent.rs

@@ -88,17 +88,7 @@ impl<T: Transport + 'static> Agent<T> {
      * Callback once using the configured client to claim new tasks and report available output.
      */
     pub async fn callback(&mut self) -> Result<()> {
-        //TODO: De-dupe this fields - probably just need to pass the config not the callback URI.
-        self.t = T::new(
-            self.cfg
-                .info
-                .clone()
-                .context("failed to get info")?
-                .active_transport
-                .context("failed to get transport")?
-                .uri,
-            self.cfg.clone(),
-        )?;
+        self.t = T::new(self.cfg.clone())?;
         self.claim_tasks(self.t.clone()).await?;
         self.report(self.t.clone()).await?;
         self.t = T::init(); // re-init to make sure no active connections during sleep
@@ -130,13 +120,23 @@ impl<T: Transport + 'static> Agent<T> {
                 return Ok(());
             }
 
-            let interval = match self.cfg.info.clone() {
-                Some(b) => Ok(b
-                    .active_transport
-                    .context("failed to get transport")?
-                    .interval),
-                None => Err(anyhow::anyhow!("beacon info is missing from agent")),
-            }?;
+            let interval = self
+                .cfg
+                .info
+                .clone()
+                .context("beacon info is missing from agent")
+                .and_then(|b| {
+                    b.available_transports
+                        .context("failed to get available transports")
+                })
+                .and_then(|available_transports| {
+                    available_transports
+                        .transports
+                        .get(available_transports.active_index as usize)
+                        .cloned()
+                        .context("active transport index out of bounds")
+                })
+                .map(|active_transport| active_transport.interval)?;
             let delay = match interval.checked_sub(start.elapsed().as_secs()) {
                 Some(secs) => Duration::from_secs(secs),
                 None => Duration::from_secs(0),

implants/imix/src/run.rs

@@ -25,7 +25,8 @@ pub async fn handle_main() {
         let retry_interval = cfg
             .info
             .as_ref()
-            .and_then(|beacon| beacon.active_transport.as_ref())
+            .and_then(|beacon| beacon.available_transports.as_ref())
+            .and_then(|available| available.transports.get(available.active_index as usize))
             .map(|transport| transport.interval)
             .unwrap_or(DEFAULT_RETRY_INTERVAL);