node.js - 主体错误: Implementing ngx-soap client in Angular 4

Question

我正在尝试在我的 Angular 4 应用程序中实现 ngx-soap 包 here。我正在使用 Node 服务器，并尝试使用此包 here 创建 SOAP 客户端和服务器文件，并在我从这里获得的帮助下成功实现。现在我想在前端创建客户端。我已经定义了主体，但不确定这是否正确。

import {Component, OnInit} from '@angular/core';
import {SOAPService, Client} from 'ngx-soap';
import {Http} from '@angular/http';

@Component({
  selector: 'app-root',
  templateUrl: './app.component.html'
})
export class AppComponent implements OnInit {

  jsonResponse: any;
  xmlResponse: string;
  loading: boolean;
  message: string;
  private client: Client;

  constructor(private http: Http, private soap: SOAPService) {}

  ngOnInit() {
    this.http.get('/assets/check_username.wsdl').subscribe(response => {
      if (response && response.text()) {
        this.soap.createClient(response.text()).then((client: Client) => {
          this.client = client;
        });
      }
    });
  }

  client_wsdl() {
    this.clear();
    this.loading = true;

   let body = {
         userName:"TEST_USER"
    };

    this.client.operation('checkUserName', body)
      .then(operation => {
        if (operation.error) {
          console.log('Operation error', operation.error);
          return;
        }

        let url = operation.url.replace("http://www.examples.com/", "/CheckUserName");

        this.http.post(url, operation.xml, {
          headers: operation.headers
        }).subscribe(
          response => {
            this.xmlResponse = response.text();
            this.jsonResponse = this.client.parseResponseBody(response.text());

            try {
              this.message = this.jsonResponse.Body.CheckUserNameResponse;
            } catch (error) {}
            this.loading = false;
          },
          err => {
            console.log("Error calling ws", err);
            this.loading = false;
          }
        );
      })
      .catch(err => console.log('Error', err));
  }

}

在 Node 中，我有一个服务器文件，我试图从 arangodb 访问查询，一旦我运行客户端文件，我就可以在控制台中打印出结果信封。我想做同样的事情，但是从 Angular 进行4.

server.js

var soap = require('strong-soap').soap;
var http = require('http');

var myService = {
  CheckUserName_Service: {
    CheckUserName_Port: {
      checkUserName: function(args, soapCallback) {

        console.log('checkUserName: Entering function..');
        db.query(aqlQuery `
                LET startVertex = (FOR doc IN spec
                FILTER doc.serial_no == '"123456abcde"'
                LIMIT 2
                RETURN doc
                )[0]

                FOR v IN 1 ANY startVertex belongs_to
                RETURN v.ip`, {
            bindVar1: 'value',
            bindVar2: 'value',
          }).then(function(response) {
            console.log(`Retrieved documents.`, response._result);
            soapCallback(JSON.stringify(response._result));
          })
          .catch(function(error) {
            console.error('Error getting document', error);
            soapCallback('Error getting document' + error.message);
          });
      }
    }
  }
};
var xml = require('fs').readFileSync('check_username.wsdl', 'utf8');

var server = http.createServer(function(request, response) {
  response.end("404: Not Found: " + request.url);
});

var port = 8000;
server.listen(port);

var soapServer = soap.listen(server, '/test', myService, xml);
soapServer.log = function(type, data) {
  console.log('Type: ' + type + ' data: ' + data);
};

console.log('SOAP service listening on port ' + port);

因为我是后端服务的新手。我无法解决基本错误。我没有掌握它的正确窍门。例如如何处理它？<​​/p>

错误

Answer 1

首先为了解决..，我重新编辑了问题中更新的代码。然后就出现了跨域错误。这可以通过在代码中添加插件或 header 来解决。

然后我使用了下面的函数。

function dbQuery() {
          var response = db.query(aqlQuery`
                 LET startVertex = (FOR doc IN spec
                 FILTER doc.serial_no == '"123456abcde"'
                 LIMIT 2
                 RETURN doc
                 )[0]

                FOR v IN 1 ANY startVertex belongs_to
                RETURN v.ip`,
                {
                bindVar1: 'value',
                bindVar2: 'value',
                });
console.log("response is "+ response);
    return response;
}

//usage inside another async function

function main2() {
        var result2 = dbQuery();

        return result2.then(function(test){

                console.log("test is "+JSON.stringify(test._result));
                var IP = test._result.filter(Boolean);
                console.log("Ip is "+IP);
});
}
main2();