A minimal library for connecting to Salesforce from Node.js. 

A minimal library for connecting to Salesforce from Node.js

jesperkristensen

node-salesforce-connection

  "description": "A minimal library for connecting to Salesforce from Node.js",

  "repository": "jesperkristensen/node-salesforce-connection",

let urlEncoder = require("./urlencoder");

let querystring = require("querystring");

  soapLogin({hostname, apiVersion, username, password}) {

    let wsdl = this.wsdl(apiVersion, "Partner");

    return this.soap(wsdl, "login", {username, password})

        let {serverUrl, sessionId} = loginResult;

        serverUrl = /https:\/\/(.*)\/services/.exec(serverUrl)[1];

          let err = new Error("Salesforce didn't return a serverUrl and sessionId");

        this.instanceHostname = serverUrl;

    return this.rest("/services/oauth2/token", {method: "POST", body: tokenRequest, bodyType: "urlencoded"})

        let {instance_url, access_token} = token;

        instance_url = instance_url.replace("https://", "");

        if (!instance_url || !access_token) {

          let err = new Error("Salesforce didn't return an instance_url and access_token");

        this.instanceHostname = instance_url;

  rest(path, {method = "GET", api = "normal", body = undefined, bodyType = "json", headers: argHeaders = {}, responseType = "json"} = {}) {

      headers.Accept = "application/json; charset=UTF-8";

      throw new Error("Unknown responseType");

      headers["X-SFDC-Session"] = this.sessionId;

      headers.Authorization = "Bearer " + this.sessionId;

        headers["Content-Type"] = "application/json; charset=UTF-8";

      } else if (bodyType == "urlencoded") {

        body = querystring.stringify(body);

        headers["Content-Type"] = "application/x-www-form-urlencoded; charset=UTF-8";

        throw new Error("Unknown bodyType");

    Object.assign(headers, argHeaders); // argHeaders take priority over headers

    return this._request({host, path, method, headers}, body).then(response => {

      if (response.statusCode >= 200 && response.statusCode < 300) {

          if (response.body.length > 0) {

            return JSON.parse(response.body.toString());

        err.name = "SalesforceRestError";

            err.detail = JSON.parse(response.body.toString());

            err.message = err.detail.map(err => err.errorCode + ": " + err.message).join("\n");

            if (response.body.length > 0) {

              err.message = response.body.toString();

              err.message = "HTTP error " + response.statusCode + " " + response.statusMessage;

        servicePortAddress: "/services/Soap/c/" + apiVersion,

        targetNamespace: "urn:enterprise.soap.sforce.com"

        servicePortAddress: "/services/Soap/u/" + apiVersion,

        targetNamespace: "urn:partner.soap.sforce.com"

        servicePortAddress: "/services/Soap/s/" + apiVersion,

        targetNamespace: "http://soap.sforce.com/2006/08/apex"

        servicePortAddress: "/services/Soap/m/" + apiVersion,

        targetNamespace: "http://soap.sforce.com/2006/04/metadata"

        servicePortAddress: "/services/Soap/T/" + apiVersion,

        targetNamespace: "urn:tooling.soap.sforce.com"

  soap(wsdl, method, args, {headers} = {}) {

      sessionHeader = {SessionHeader: {sessionId: this.sessionId}};

      attributes: ' xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="' + wsdl.targetNamespace + '"',

        "soapenv:Header": Object.assign({}, sessionHeader, headers),

    return this._request(httpsOptions, requestBody).then(response => {

      let resBody = XML.parse(response.body.toString()).value["soapenv:Body"];

		{
		"name": "node-salesforce-connection",
		"version": "2.2.1",
		"version": "2.2.2",
		"description": "A minimal library for connecting to Salesforce from Node.js",
		@@ -5,0 +5,0 @@ "license": "MIT",

		"use strict";
		let https = require("https");
		let urlEncoder = require("./urlencoder");
		let querystring = require("querystring");
		let XML = require("./xml");
		@@ -77,3 +77,3 @@
		} else if (bodyType == "urlencoded") {
		body = urlEncoder(body);
		body = querystring.stringify(body);
		headers["Content-Type"] = "application/x-www-form-urlencoded; charset=UTF-8";
		@@ -80,0 +80,0 @@ } else if (bodyType == "raw") {

Worsened metrics