feature/707: improve soap 1.1 capture of proxy request/responses

META-INF/MANIFEST.MF

@@ -0,0 +1,5 @@
+Manifest-Version: 1.0
+Main-Class: io.gatehill.imposter.cmd.ImposterLauncher
+Imposter-Version: 0.0.0-SNAPSHOT
+Multi-Release: true
+

cmd/src/main/java/io/gatehill/imposter/cmd/ImposterLauncher.kt

@@ -117,6 +117,9 @@ class ImposterLauncher(args: Array<String>) {
 
     @Option(name = "--serverFactory", usage = "Fully qualified class for server factory")
     private var serverFactory: String = VertxWebServerFactoryImpl::class.java.canonicalName
+
+    @Option(name = "--soap", usage = "Enable SOAP-aware mode for capturing requests/responses with SOAPAction")
+    private var soapMode: Boolean = false
 
     companion object {
         private val LOGGER = LogManager.getLogger(ImposterLauncher::class.java)
@@ -204,6 +207,11 @@ class ImposterLauncher(args: Array<String>) {
             imposterConfig.configDirs = configDirs
             imposterConfig.plugins = plugins
             imposterConfig.pluginArgs = splitArgs
+            imposterConfig.soapMode = soapMode
+
+            if (soapMode) {
+                LOGGER.info("SOAP-aware mode enabled - requests and responses will be saved with SOAPAction-based filenames")
+            }
         }
 
         LifecycleAwareLauncher().dispatch(originalArgs)

core/api/src/main/java/io/gatehill/imposter/ImposterConfig.kt

@@ -63,8 +63,9 @@ class ImposterConfig {
     var pluginDiscoveryStrategy: PluginDiscoveryStrategy? = null
     var pluginDiscoveryStrategyClass: String? = null
     var useEmbeddedScriptEngine: Boolean = false
+    var soapMode: Boolean = false
 
     override fun toString(): String {
-        return "ImposterConfig(host=$host, listenPort=$listenPort, configDirs=${configDirs.contentToString()}, serverUrl=$serverUrl, isTlsEnabled=$isTlsEnabled, keystorePath=$keystorePath, keystorePassword=$keystorePassword, plugins=${plugins?.contentToString()}, pluginArgs=$pluginArgs, serverFactory=$serverFactory, pluginDiscoveryStrategy=$pluginDiscoveryStrategy, pluginDiscoveryStrategyClass=$pluginDiscoveryStrategyClass, useEmbeddedScriptEngine=$useEmbeddedScriptEngine)"
+        return "ImposterConfig(host=$host, listenPort=$listenPort, configDirs=${configDirs.contentToString()}, serverUrl=$serverUrl, isTlsEnabled=$isTlsEnabled, keystorePath=$keystorePath, keystorePassword=$keystorePassword, plugins=${plugins?.contentToString()}, pluginArgs=$pluginArgs, serverFactory=$serverFactory, pluginDiscoveryStrategy=$pluginDiscoveryStrategy, pluginDiscoveryStrategyClass=$pluginDiscoveryStrategyClass, useEmbeddedScriptEngine=$useEmbeddedScriptEngine, soapMode=$soapMode)"
     }
 }

core/engine/src/main/java/io/gatehill/imposter/inject/EngineModule.kt

@@ -59,6 +59,7 @@ import io.gatehill.imposter.service.ResponseService
 import io.gatehill.imposter.service.ResponseServiceImpl
 import io.gatehill.imposter.service.ScriptedResponseService
 import io.gatehill.imposter.service.SecurityService
+import io.gatehill.imposter.service.SoapAwareUpstreamService
 import io.gatehill.imposter.service.StepService
 import io.gatehill.imposter.service.UpstreamService
 import io.gatehill.imposter.service.script.EmbeddedScriptService
@@ -99,5 +100,6 @@ internal class EngineModule : AbstractModule() {
         bind(RemoteService::class.java).asSingleton()
         bind(StepService::class.java).asSingleton()
         bind(UpstreamService::class.java).asSingleton()
+        bind(SoapAwareUpstreamService::class.java).asSingleton()
     }
 }

core/engine/src/main/java/io/gatehill/imposter/service/HandlerServiceImpl.kt

@@ -81,6 +81,8 @@ class HandlerServiceImpl @Inject constructor(
     private val interceptorService: InterceptorService,
     private val responseService: ResponseService,
     private val upstreamService: UpstreamService,
+    private val soapAwareUpstreamService: SoapAwareUpstreamService,
+    private val imposterConfig: ImposterConfig,
 ) : HandlerService, CoroutineScope by supervisedDefaultCoroutineScope {
 
     private val shouldAddEngineResponseHeaders: Boolean =
@@ -339,11 +341,23 @@ class HandlerServiceImpl @Inject constructor(
         pluginConfig: PluginConfig,
         resourceConfig: BasicResourceConfig,
         httpExchange: HttpExchange,
-    ) = upstreamService.forwardToUpstream(
-        pluginConfig as UpstreamsHolder,
-        resourceConfig as PassthroughResourceConfig,
-        httpExchange
-    )
+    ) = if (imposterConfig.soapMode) {
+        // Use SOAP-aware upstream service if SOAP mode is enabled
+        soapAwareUpstreamService.forwardToUpstream(
+            pluginConfig as UpstreamsHolder,
+            resourceConfig as PassthroughResourceConfig,
+            httpExchange,
+            imposterConfig.configDirs.firstOrNull() ?: ".",
+            imposterConfig.soapMode
+        )
+    } else {
+        // Use standard upstream service
+        upstreamService.forwardToUpstream(
+            pluginConfig as UpstreamsHolder,
+            resourceConfig as PassthroughResourceConfig,
+            httpExchange
+        )
+    }
 
     companion object {
         private val LOGGER = LogManager.getLogger(HandlerServiceImpl::class.java)