refactor(gateway): introduce SourcePlugin trait for uniform source dispatch

Eliminates the per-source iteration repeated between `http.rs::mount_sources`
and `streams.rs::provision` by introducing a gateway-internal `SourcePlugin`
trait. Each webhook source has a unit-struct plugin (GithubPlugin,
SlackPlugin, ..., MicrosoftGraphPlugin) that owns both its JetStream
provisioning loop and its HTTP route mounting loop, including any per-source
edge cases.

Two dispatch entry points -- `provision_webhook_sources` and
`mount_webhook_sources` -- replace the repeated source-by-source dispatch
blocks. Adding a new webhook source now touches one file (source_plugin.rs)
instead of two.

SlackPlugin's `mount` skips socket-mode-only integrations (no webhook
config) since their HTTP route would never receive traffic; the runner is
spawned in main.rs. Discord is intentionally excluded from `SourcePlugin`
because its primary path is a WebSocket gateway runner, not a webhook
receiver -- streams.rs still provisions it inline.

All 579 gateway tests pass; full workspace tests pass.

Signed-off-by: Erik Nilsen <enilsen16@live.com>

Author: enilsen16

rsworkspace/crates/trogon-gateway/src/http.rs

@@ -1,15 +1,15 @@
 use axum::Router;
-use tracing::info;
 use trogon_nats::jetstream::{ClaimCheckPublisher, JetStreamPublisher, ObjectStorePut};
 
-use crate::config::{ResolvedConfig, SourceIntegration};
+use crate::config::ResolvedConfig;
+use crate::source_plugin;
 
 pub(crate) fn mount_sources<P, S>(config: ResolvedConfig, publisher: ClaimCheckPublisher<P, S>) -> Router
 where
     P: JetStreamPublisher,
     S: ObjectStorePut,
 {
-    let mut app = Router::new()
+    let app = Router::new()
         .route(
             "/-/liveness",
             axum::routing::get(|| async { axum::http::StatusCode::OK }),
@@ -19,119 +19,7 @@ where
             axum::routing::get(|| async { axum::http::StatusCode::OK }),
         );
 
-    app = mount_webhook_integrations(
-        app,
-        "github",
-        "/sources/github",
-        &config.github,
-        publisher.clone(),
-        |p, cfg| crate::source::github::router(p, cfg),
-    );
-    for integration in &config.slack {
-        if integration.config.webhook().is_none() {
-            continue;
-        }
-        let path = format!("/sources/slack/{}", integration.id);
-        app = app.nest(
-            &path,
-            crate::source::slack::router(publisher.clone(), &integration.config),
-        );
-        let integration_id = integration.id.as_str();
-        info!(
-            source = "slack",
-            integration = integration_id,
-            path,
-            "mounted source integration"
-        );
-    }
-    app = mount_webhook_integrations(
-        app,
-        "telegram",
-        "/sources/telegram",
-        &config.telegram,
-        publisher.clone(),
-        |p, cfg| crate::source::telegram::router(p, cfg),
-    );
-    app = mount_webhook_integrations(
-        app,
-        "twitter",
-        "/sources/twitter",
-        &config.twitter,
-        publisher.clone(),
-        |p, cfg| crate::source::twitter::router(p, cfg),
-    );
-    app = mount_webhook_integrations(
-        app,
-        "gitlab",
-        "/sources/gitlab",
-        &config.gitlab,
-        publisher.clone(),
-        |p, cfg| crate::source::gitlab::router(p, cfg),
-    );
-    app = mount_webhook_integrations(
-        app,
-        "incidentio",
-        "/sources/incidentio",
-        &config.incidentio,
-        publisher.clone(),
-        |p, cfg| crate::source::incidentio::router(p, cfg),
-    );
-    app = mount_webhook_integrations(
-        app,
-        "linear",
-        "/sources/linear",
-        &config.linear,
-        publisher.clone(),
-        |p, cfg| crate::source::linear::router(p, cfg),
-    );
-    app = mount_webhook_integrations(
-        app,
-        "microsoft-graph",
-        "/sources/microsoft-graph",
-        &config.microsoft_graph,
-        publisher.clone(),
-        |p, cfg| crate::source::microsoft_graph::router(p, cfg),
-    );
-    app = mount_webhook_integrations(
-        app,
-        "notion",
-        "/sources/notion",
-        &config.notion,
-        publisher.clone(),
-        |p, cfg| crate::source::notion::router(p, cfg),
-    );
-    app = mount_webhook_integrations(app, "sentry", "/sources/sentry", &config.sentry, publisher, |p, cfg| {
-        crate::source::sentry::router(p, cfg)
-    });
-
-    app
-}
-
-fn mount_webhook_integrations<P, S, C, F>(
-    mut app: Router,
-    source: &'static str,
-    source_path: &'static str,
-    integrations: &[SourceIntegration<C>],
-    publisher: ClaimCheckPublisher<P, S>,
-    router: F,
-) -> Router
-where
-    P: JetStreamPublisher,
-    S: ObjectStorePut,
-    F: Fn(ClaimCheckPublisher<P, S>, &C) -> Router,
-{
-    for integration in integrations {
-        let path = format!("{}/{}", source_path, integration.id);
-        app = app.nest(&path, router(publisher.clone(), &integration.config));
-        info!(
-            source,
-            integration = integration.id.as_str(),
-            path,
-            "mounted source integration"
-        );
-    }
-
-    app
+    source_plugin::mount_webhook_sources(app, publisher, &config)
 }
 
 #[cfg(test)]

rsworkspace/crates/trogon-gateway/src/main.rs

@@ -11,6 +11,8 @@ mod source;
 #[cfg_attr(coverage, allow(dead_code))]
 mod source_integration_id;
 #[cfg_attr(coverage, allow(dead_code))]
+mod source_plugin;
+#[cfg_attr(coverage, allow(dead_code))]
 mod source_status;
 #[cfg_attr(coverage, allow(dead_code))]
 mod streams;