fix transport type

shivam-rawat-akto · shivam-rawat-akto · commit 9f410d87bd1a · 2025-10-03T13:45:13.000+05:30
diff --git a/apps/mini-runtime/src/main/java/com/akto/hybrid_runtime/McpToolsSyncJobExecutor.java b/apps/mini-runtime/src/main/java/com/akto/hybrid_runtime/McpToolsSyncJobExecutor.java
@@ -375,14 +375,14 @@ private String detectAndSetTransportType(OriginalHttpRequest request, ApiCollect
             } catch (Exception sseException) {
                 logger.info("SSE transport failed, falling back to HTTP transport: {}", sseException.getMessage());
                 // Fall back to HTTP - no need to test, just store it
-                dataActor.updateTransportType(apiCollection.getId(), TRANSPORT_SSE);
+                dataActor.updateTransportType(apiCollection.getId(), TRANSPORT_HTTP);
                 return TRANSPORT_HTTP;
             }
         }
 
         // Default to HTTP if no sseCallbackUrl
         logger.info("No SSE callback URL found, using HTTP transport for: {}", apiCollection.getHostName());
-        dataActor.updateTransportType(apiCollection.getId(), TRANSPORT_SSE);
+        dataActor.updateTransportType(apiCollection.getId(), TRANSPORT_HTTP);
         return TRANSPORT_HTTP;
     }
     private String sendRequest(OriginalHttpRequest request, ApiCollection apiCollection) throws Exception {

Original file line number	Diff line number	Diff line change
`@@ -375,14 +375,14 @@ private String detectAndSetTransportType(OriginalHttpRequest request, ApiCollect`
`375`	`375`	`} catch (Exception sseException) {`
`376`	`376`	`logger.info("SSE transport failed, falling back to HTTP transport: {}", sseException.getMessage());`
`377`	`377`	`// Fall back to HTTP - no need to test, just store it`
`378`		`- dataActor.updateTransportType(apiCollection.getId(), TRANSPORT_SSE);`
	`378`	`+ dataActor.updateTransportType(apiCollection.getId(), TRANSPORT_HTTP);`
`379`	`379`	`return TRANSPORT_HTTP;`
`380`	`380`	`}`
`381`	`381`	`}`
`382`	`382`
`383`	`383`	`// Default to HTTP if no sseCallbackUrl`
`384`	`384`	`logger.info("No SSE callback URL found, using HTTP transport for: {}", apiCollection.getHostName());`
`385`		`- dataActor.updateTransportType(apiCollection.getId(), TRANSPORT_SSE);`
	`385`	`+ dataActor.updateTransportType(apiCollection.getId(), TRANSPORT_HTTP);`
`386`	`386`	`return TRANSPORT_HTTP;`
`387`	`387`	`}`
`388`	`388`	`private String sendRequest(OriginalHttpRequest request, ApiCollection apiCollection) throws Exception {`