add wrapper tests

Author: shulkaolka

lib/common.js

@@ -1,3 +1,4 @@
 module.exports.globalConsts = {
   SALESFORCE_API_VERSION: process.env.SALESFORCE_API_VERSION || '46.0',
+  REFRESH_TOKEN_RETRIES: process.env.REFRESH_TOKEN_RETRIES ? parseInt(process.env.REFRESH_TOKEN_RETRIES, 10) : 10,
 };

lib/helpers/wrapper.js

@@ -1,43 +1,47 @@
 /* eslint-disable no-await-in-loop */
 const { SalesForceClient } = require('../salesForceClient');
 const { getCredentials, refreshToken } = require('../helpers/oauth2Helper');
+const { REFRESH_TOKEN_RETRIES } = require('../common.js').globalConsts;
 
 let client;
 
 exports.callJSForceMethod = async function callJSForceMethod(configuration, method, options) {
-  this.logger.trace('Incoming configuration: %j', configuration);
+  this.logger.info('Preparing SalesForce Client...');
   let accessToken;
   let instanceUrl;
   const { secretId } = configuration;
   if (secretId) {
+    this.logger.info('Fetching credentials by secretId');
     const credentials = await getCredentials(this, secretId);
-    this.logger.trace('Fetched credentials: %j', credentials);
     accessToken = credentials.access_token;
     instanceUrl = credentials.instance_url;
   } else {
+    this.logger.info('Fetching credentials from configuration');
     accessToken = configuration.oauth.access_token;
     instanceUrl = configuration.oauth.instance_url;
   }
   let result;
   let isSuccess = false;
-  let iteration = 3;
+  let iteration = REFRESH_TOKEN_RETRIES;
   do {
     iteration -= 1;
     try {
-      this.logger.info('Iteration: %s', iteration);
+      this.logger.info('Iteration: %s', REFRESH_TOKEN_RETRIES - iteration);
       const cfg = {
         ...configuration,
         access_token: accessToken,
         instance_url: instanceUrl,
       };
       if (!client || Object.entries(client.configuration).toString() !== Object.entries(cfg).toString()) {
-        this.logger.info('Try to create connection', iteration);
+        this.logger.info('Try to create SalesForce Client', REFRESH_TOKEN_RETRIES - iteration);
+        this.logger.trace('Creating SalesForce Client with configuration: %j', cfg);
         client = new SalesForceClient(this, cfg);
-        this.logger.info('Connection is created');
+        this.logger.info('SalesForce Client is created');
       }
-      this.logger.info('Trying to call method %s with options: %j', method, options);
+      this.logger.info('Trying to call method %s', method);
+      this.logger.debug('Trying to call method %s with options: %j', method, options);
       result = await client[method](options);
-      this.logger.trace('Execution result: %j', result);
+      this.logger.debug('Execution result: %j', result);
       isSuccess = true;
       this.logger.info('Method is executed successfully');
       break;

spec-integration/helpers/wrapper.spec.js

@@ -0,0 +1,79 @@
+/* eslint-disable no-return-assign */
+const fs = require('fs');
+const logger = require('@elastic.io/component-logger')();
+const { expect } = require('chai');
+const nock = require('nock');
+const { callJSForceMethod } = require('../../lib/helpers/wrapper');
+
+describe('wrapper helper test', async () => {
+  const secretId = 'secretId';
+  let configuration;
+  let secret;
+  let invalidSecret;
+
+  before(async () => {
+    if (fs.existsSync('.env')) {
+      // eslint-disable-next-line global-require
+      require('dotenv').config();
+    }
+    process.env.ELASTICIO_API_URI = 'https://app.example.io';
+    process.env.ELASTICIO_API_USERNAME = 'user';
+    process.env.ELASTICIO_API_KEY = 'apiKey';
+    process.env.ELASTICIO_WORKSPACE_ID = 'workspaceId';
+    secret = {
+      data: {
+        attributes: {
+          credentials: {
+            access_token: process.env.ACCESS_TOKEN,
+            instance_url: process.env.INSTANCE_URL,
+          },
+        },
+      },
+    };
+    invalidSecret = {
+      data: {
+        attributes: {
+          credentials: {
+            access_token: 'access_token',
+            instance_url: process.env.INSTANCE_URL,
+          },
+        },
+      },
+    };
+
+    configuration = {
+      secretId,
+      sobject: 'Contact',
+    };
+  });
+
+  it('should succeed call describe method, credentials from config', async () => {
+    const cfg = {
+      sobject: 'Contact',
+      oauth: {
+        access_token: process.env.ACCESS_TOKEN,
+        instance_url: process.env.INSTANCE_URL,
+      },
+    };
+    const result = await callJSForceMethod.call({ logger }, cfg, 'describe');
+    expect(result.name).to.eql('Contact');
+  });
+
+  it('should succeed call describe method', async () => {
+    nock(process.env.ELASTICIO_API_URI)
+      .get(`/v2/workspaces/${process.env.ELASTICIO_WORKSPACE_ID}/secrets/${secretId}`)
+      .reply(200, secret);
+    const result = await callJSForceMethod.call({ logger }, configuration, 'describe');
+    expect(result.name).to.eql('Contact');
+  });
+
+  it('should refresh token and succeed call describe method', async () => {
+    nock(process.env.ELASTICIO_API_URI)
+      .get(`/v2/workspaces/${process.env.ELASTICIO_WORKSPACE_ID}/secrets/${secretId}`)
+      .reply(200, invalidSecret)
+      .post(`/v2/workspaces/${process.env.ELASTICIO_WORKSPACE_ID}/secrets/${secretId}/refresh`)
+      .reply(200, secret);
+    const result = await callJSForceMethod.call({ logger }, configuration, 'describe');
+    expect(result.name).to.eql('Contact');
+  });
+});