feat(soap): auto detection of SOAP namespace, and allow to customize it

.changeset/tangy-moons-post.md

@@ -0,0 +1,27 @@
+---
+'@graphql-mesh/transport-soap': minor
+'@omnigraph/soap': minor
+---
+
+Auto detection of SOAP version to decide SOAP namespace;
+For SOAP 1.1, it is set to `http://schemas.xmlsoap.org/soap/envelope/` and for SOAP 1.2, it is set to `http://www.w3.org/2003/05/soap-envelope`.
+
+If you want to use a custom namespace, you can set it like below;
+
+```ts
+import { defineConfig } from '@graphql-mesh/compose-cli'
+import { loadSOAPSubgraph } from '@omnigraph/soap'
+
+export const composeConfig = defineConfig({
+  subgraphs: [
+    {
+      sourceHandler: loadSOAPSubgraph('CountryInfo', {
+        source:
+          'http://webservices.oorsprong.org/websamples.countryinfo/CountryInfoService.wso?WSDL',
+        soapNamespace: 'http://foo.com/schemas/soap/envelope'
+      })
+    }
+  ]
+})
+```
+

e2e/soap-demo/__snapshots__/soap-demo.test.ts.snap

@@ -92,6 +92,7 @@ directive @soap(
   bodyAlias: String
   soapHeaders: SOAPHeaders
   soapAction: String
+  soapNamespace: String
 ) repeatable on FIELD_DEFINITION
 
 directive @extraSchemaDefinitionDirective(directives: _DirectiveExtensions)  repeatable on OBJECT
@@ -121,34 +122,39 @@ type Query @extraSchemaDefinitionDirective(directives: {transport: [{kind: "soap
     bindingNamespace: "http://tempuri.org"
     endpoint: "http://localhost:<soap-demo_port>/csp/samples/SOAP.Demo.cls"
     subgraph: "soap-demo"
+    soapNamespace: "http://schemas.xmlsoap.org/soap/envelope/"
     soapAction: "http://tempuri.org/SOAP.Demo.FindPerson"
   )
   s0_SOAPDemo_SOAPDemoSoap_GetByName(GetByName: s0_GetByName_Input = {}) : s0_GetByNameResponse @soap(
     elementName: "GetByNameResponse"
     bindingNamespace: "http://tempuri.org"
     endpoint: "http://localhost:<soap-demo_port>/csp/samples/SOAP.Demo.cls"
     subgraph: "soap-demo"
+    soapNamespace: "http://schemas.xmlsoap.org/soap/envelope/"
     soapAction: "http://tempuri.org/SOAP.Demo.GetByName"
   )
   s0_SOAPDemo_SOAPDemoSoap_GetDataSetByName(GetDataSetByName: s0_GetDataSetByName_Input = {}) : s0_GetDataSetByNameResponse @soap(
     elementName: "GetDataSetByNameResponse"
     bindingNamespace: "http://tempuri.org"
     endpoint: "http://localhost:<soap-demo_port>/csp/samples/SOAP.Demo.cls"
     subgraph: "soap-demo"
+    soapNamespace: "http://schemas.xmlsoap.org/soap/envelope/"
     soapAction: "http://tempuri.org/SOAP.Demo.GetDataSetByName"
   )
   s0_SOAPDemo_SOAPDemoSoap_GetListByName(GetListByName: s0_GetListByName_Input = {}) : s0_GetListByNameResponse @soap(
     elementName: "GetListByNameResponse"
     bindingNamespace: "http://tempuri.org"
     endpoint: "http://localhost:<soap-demo_port>/csp/samples/SOAP.Demo.cls"
     subgraph: "soap-demo"
+    soapNamespace: "http://schemas.xmlsoap.org/soap/envelope/"
     soapAction: "http://tempuri.org/SOAP.Demo.GetListByName"
   )
   s0_SOAPDemo_SOAPDemoSoap_QueryByName(QueryByName: s0_QueryByName_Input = {}) : s0_QueryByNameResponse @soap(
     elementName: "QueryByNameResponse"
     bindingNamespace: "http://tempuri.org"
     endpoint: "http://localhost:<soap-demo_port>/csp/samples/SOAP.Demo.cls"
     subgraph: "soap-demo"
+    soapNamespace: "http://schemas.xmlsoap.org/soap/envelope/"
     soapAction: "http://tempuri.org/SOAP.Demo.QueryByName"
   )
 }
@@ -234,27 +240,31 @@ type Mutation @join__type(graph: SOAP_DEMO)  {
     bindingNamespace: "http://tempuri.org"
     endpoint: "http://localhost:<soap-demo_port>/csp/samples/SOAP.Demo.cls"
     subgraph: "soap-demo"
+    soapNamespace: "http://schemas.xmlsoap.org/soap/envelope/"
     soapAction: "http://tempuri.org/SOAP.Demo.AddInteger"
   )
   s0_SOAPDemo_SOAPDemoSoap_DivideInteger(DivideInteger: s0_DivideInteger_Input = {}) : s0_DivideIntegerResponse @soap(
     elementName: "DivideIntegerResponse"
     bindingNamespace: "http://tempuri.org"
     endpoint: "http://localhost:<soap-demo_port>/csp/samples/SOAP.Demo.cls"
     subgraph: "soap-demo"
+    soapNamespace: "http://schemas.xmlsoap.org/soap/envelope/"
     soapAction: "http://tempuri.org/SOAP.Demo.DivideInteger"
   )
   s0_SOAPDemo_SOAPDemoSoap_LookupCity(LookupCity: s0_LookupCity_Input = {}) : s0_LookupCityResponse @soap(
     elementName: "LookupCityResponse"
     bindingNamespace: "http://tempuri.org"
     endpoint: "http://localhost:<soap-demo_port>/csp/samples/SOAP.Demo.cls"
     subgraph: "soap-demo"
+    soapNamespace: "http://schemas.xmlsoap.org/soap/envelope/"
     soapAction: "http://tempuri.org/SOAP.Demo.LookupCity"
   )
   s0_SOAPDemo_SOAPDemoSoap_Mission(Mission: JSON = "") : s0_MissionResponse @soap(
     elementName: "MissionResponse"
     bindingNamespace: "http://tempuri.org"
     endpoint: "http://localhost:<soap-demo_port>/csp/samples/SOAP.Demo.cls"
     subgraph: "soap-demo"
+    soapNamespace: "http://schemas.xmlsoap.org/soap/envelope/"
     soapAction: "http://tempuri.org/SOAP.Demo.Mission"
   )
 }

examples/soap-demo/tests__bak/soap-demo.test.ts.bak

@@ -0,0 +1,40 @@
+import { basename, join } from 'path';
+import { lexicographicSortSchema } from 'graphql';
+import { findAndParseConfig } from '@graphql-mesh/cli';
+import { ProcessedConfig } from '@graphql-mesh/config';
+import { getMesh, MeshInstance } from '@graphql-mesh/runtime';
+import { InMemoryStoreStorageAdapter, MeshStore } from '@graphql-mesh/store';
+import { printSchemaWithDirectives } from '@graphql-tools/utils';
+import { inspect } from 'util';
+
+describe('SOAP Demo', () => {
+  let mesh: MeshInstance;
+  let config: ProcessedConfig;
+  beforeAll(async () => {
+    const store = new MeshStore('soap', new InMemoryStoreStorageAdapter(), {
+      readonly: false,
+      validate: false,
+    });
+    config = await findAndParseConfig({
+      dir: join(__dirname, '..'),
+      store,
+    });
+    mesh = await getMesh(config);
+  });
+  it('should generate correct schema', async () => {
+    expect(printSchemaWithDirectives(lexicographicSortSchema(mesh.schema))).toMatchSnapshot(
+      'soap-demo-schema',
+    );
+  });
+  it('should give correct response for example queries', async () => {
+    for (const source of config.documents) {
+      if (!source.document || !source.location) {
+        throw new Error(`Invalid document config: ${inspect(source)}`);
+      }
+      const result = await mesh.execute(source.document);
+      expect(result.errors).toBeUndefined();
+      expect(result).toMatchSnapshot(basename(source.location) + '-soap-demo-result');
+    }
+  });
+  afterAll(() => mesh?.destroy?.());
+});

packages/loaders/soap/src/SOAPLoader.ts

@@ -77,6 +77,7 @@ export interface SOAPLoaderOptions {
   endpoint?: string;
   cwd?: string;
   bodyAlias?: string;
+  soapNamespace?: string;
 }
 
 export interface SOAPHeaders {
@@ -142,6 +143,9 @@ const soapDirective = new GraphQLDirective({
     soapAction: {
       type: GraphQLString,
     },
+    soapNamespace: {
+      type: GraphQLString,
+    },
   },
 });
 
@@ -196,6 +200,7 @@ export class SOAPLoader {
   private cwd: string;
   private soapHeaders: SOAPHeaders;
   private bodyAlias?: string;
+  private soapNamespace: string;
 
   constructor(options: SOAPLoaderOptions) {
     this.fetchFn = options.fetch || defaultFetchFn;
@@ -208,6 +213,7 @@ export class SOAPLoader {
     this.cwd = options.cwd;
     this.soapHeaders = options.soapHeaders;
     this.bodyAlias = options.bodyAlias;
+    this.soapNamespace = 'http://schemas.xmlsoap.org/soap/envelope/';
   }
 
   loadXMLSchemaNamespace() {
@@ -400,6 +406,9 @@ export class SOAPLoader {
 
   async loadDefinition(definition: WSDLDefinition) {
     this.getNamespaceDefinitions(definition.attributes.targetNamespace).push(definition);
+    if (definition.attributes.soap12) {
+      this.soapNamespace = 'http://www.w3.org/2003/05/soap-envelope';
+    }
     const definitionAliasMap = this.getAliasMapFromAttributes(definition.attributes);
     const definitionNamespace = definition.attributes.targetNamespace;
     const typePrefix =
@@ -509,6 +518,7 @@ export class SOAPLoader {
               bindingNamespace,
               endpoint: this.endpoint,
               subgraph: this.subgraphName,
+              soapNamespace: this.soapNamespace,
             };
             if (!soapAnnotations.endpoint && portObj.address) {
               for (const address of portObj.address) {

packages/loaders/soap/src/index.ts

@@ -34,6 +34,13 @@ export interface SOAPSubgraphLoaderOptions {
    * @default body
    */
   bodyAlias?: string;
+  /**
+   * The namespace of the SOAP envelope
+   * By default, SOAP handler detects the SOAP version and if SOAP version is 1.1,
+   * it uses `http://schemas.xmlsoap.org/soap/envelope/` namespace
+   * If SOAP version is 1.2, it uses `http://www.w3.org/2003/05/soap-envelope` namespace
+   */
+  soapNamespace?: string;
 }
 
 export function loadSOAPSubgraph(subgraphName: string, options: SOAPSubgraphLoaderOptions) {

packages/loaders/soap/src/types.ts

@@ -1,6 +1,7 @@
 export interface WSDLDefinitionAttributes {
   name: string;
   targetNamespace: string;
+  soap12?: string;
 }
 
 export interface WSDLDefinition {

packages/loaders/soap/src/utils.ts

@@ -5,6 +5,7 @@ export interface SoapAnnotations {
   elementName: string;
   bindingNamespace: string;
   endpoint: string;
+  soapNamespace: string;
   bodyAlias?: string;
   soapAction?: string;
   soapHeaders?: {