fix: reuse HTTP client in push_source_data and fix plugin file path

- Share a single reqwest::Client via Axum Extension layer instead of
  creating a new client on every push_source_data request, avoiding
  repeated connection pool allocation.
- Fix StartupPluginRecord.file_path to use the actual plugin file path
  instead of the containing directory path.

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>

Author: agentofreality

src/api/shared/handlers/source_handlers.rs

@@ -453,6 +453,7 @@ pub async fn stop_source(
 /// This handler reads the source's configured host/port and forwards the request.
 pub async fn push_source_data(
     Extension(core): Extension<Arc<DrasiLib>>,
+    Extension(http_client): Extension<reqwest::Client>,
     Path(id): Path<String>,
     Json(body): Json<serde_json::Value>,
 ) -> Result<Json<ApiResponse<serde_json::Value>>, ErrorResponse> {
@@ -478,8 +479,7 @@ pub async fn push_source_data(
     let effective_host = if host == "0.0.0.0" { "127.0.0.1" } else { host };
     let url = format!("http://{effective_host}:{port}{base}/sources/{id}/events");
 
-    let client = reqwest::Client::new();
-    match client.post(&url).json(&body).send().await {
+    match http_client.post(&url).json(&body).send().await {
         Ok(resp) if resp.status().is_success() => {
             let resp_body: serde_json::Value = resp
                 .json()

src/api/v1/handlers/source_handlers.rs

@@ -413,12 +413,19 @@ pub async fn stop_source(
 )]
 pub async fn push_source_data(
     Extension(registry): Extension<InstanceRegistry>,
+    Extension(http_client): Extension<reqwest::Client>,
     Path(ResourcePath { instance_id, id }): Path<ResourcePath>,
     Json(body): Json<serde_json::Value>,
 ) -> Result<Json<ApiResponse<serde_json::Value>>, ErrorResponse> {
     let core = registry
         .get(&instance_id)
         .await
         .ok_or_else(|| ErrorResponse::new(error_codes::INTERNAL_ERROR, "Instance not found"))?;
-    shared::push_source_data(Extension(core), Path(id), Json(body)).await
+    shared::push_source_data(
+        Extension(core),
+        Extension(http_client),
+        Path(id),
+        Json(body),
+    )
+    .await
 }

src/api/v1/routes.rs

@@ -68,6 +68,7 @@ pub fn build_v1_router(
         .layer(Extension(config_persistence))
         .layer(Extension(plugin_registry))
         .layer(Extension(solutions_dir))
+        .layer(Extension(reqwest::Client::new()))
 }
 
 /// Build routes for dynamic instance resources.

src/dynamic_loading.rs

@@ -226,7 +226,7 @@ pub fn load_plugins(
 
         stats.loaded_plugins.push(StartupPluginRecord {
             plugin_id: derived_plugin_id,
-            file_path: dir.to_path_buf(),
+            file_path: plugin.file_path.clone(),
             kinds: plugin_kinds,
             generation,
             plugin_version,