add attachment tests

Author: shulkaolka

CHANGELOG.md

@@ -1,3 +1,8 @@
+## 2.0.0 (September 11, 2020)
+
+* Component uses new `Auth-client` functionality
+* All deprecated triggers and actions are deleted
+* Code is refactored
 
 ## 1.3.5 (August 21, 2020)
 

lib/helpers/attachment.js

@@ -21,7 +21,6 @@ async function downloadFile(url, headers) {
   return response.body;
 }
 
-// eslint-disable-next-line max-len
 exports.prepareBinaryData = async function prepareBinaryData(msg, configuration, emitter) {
   let binField;
   let attachment;
@@ -63,7 +62,6 @@ exports.prepareBinaryData = async function prepareBinaryData(msg, configuration,
   return binField;
 };
 
-// eslint-disable-next-line max-len
 exports.getAttachment = async function getAttachment(configuration, objectContent, emitter) {
   const objectFields = await callJSForceMethod.call(emitter, configuration, 'getObjectFieldsMetaData');
 

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "salesforce-component",
-  "version": "1.3.5",
+  "version": "2.0.0",
   "description": "elastic.io component that connects to Salesforce API (node.js)",
   "main": "index.js",
   "scripts": {

package.json

@@ -0,0 +1,80 @@
+/* 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 { prepareBinaryData } = require('../../lib/helpers/attachment');
+
+describe('attachment helper test', async () => {
+  const secretId = 'secretId';
+  let configuration;
+  let secret;
+
+  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_WORKSPACE_ID = 'workspaceId';
+    secret = {
+      data: {
+        attributes: {
+          credentials: {
+            access_token: process.env.ACCESS_TOKEN,
+            instance_url: process.env.INSTANCE_URL,
+          },
+        },
+      },
+    };
+
+    configuration = {
+      secretId,
+      sobject: 'Document',
+    };
+  });
+  describe('prepareBinaryData test', async () => {
+    it('should discard attachment utilizeAttachment:false', async () => {
+      nock(process.env.ELASTICIO_API_URI)
+        .get(`/v2/workspaces/${process.env.ELASTICIO_WORKSPACE_ID}/secrets/${secretId}`)
+        .reply(200, secret);
+      const msg = {
+        body: {
+          Name: 'TryTest',
+        },
+        attachments: {
+          'Fox.jpeg': {
+            'content-type': 'image/jpeg',
+            size: 126564,
+            url: 'https://upload.wikimedia.org/wikipedia/commons/thumb/f/f6/Everest_kalapatthar.jpg/800px-Everest_kalapatthar.jpg',
+          },
+        },
+      };
+      await prepareBinaryData(msg, { ...configuration, utilizeAttachment: false }, { logger });
+      expect(msg.body.Name).to.eql('TryTest');
+      expect(Object.prototype.hasOwnProperty.call(msg.body, 'Body')).to.eql(false);
+    });
+
+    it('should upload attachment utilizeAttachment:true', async () => {
+      nock(process.env.ELASTICIO_API_URI)
+        .get(`/v2/workspaces/${process.env.ELASTICIO_WORKSPACE_ID}/secrets/${secretId}`)
+        .reply(200, secret);
+      const msg = {
+        body: {
+          Name: 'TryTest',
+        },
+        attachments: {
+          'Fox.jpeg': {
+            'content-type': 'image/jpeg',
+            size: 126564,
+            url: 'https://upload.wikimedia.org/wikipedia/commons/thumb/f/f6/Everest_kalapatthar.jpg/800px-Everest_kalapatthar.jpg',
+          },
+        },
+      };
+      await prepareBinaryData(msg, { ...configuration, utilizeAttachment: true }, { logger });
+      expect(msg.body.Name).to.eql('TryTest');
+      expect(msg.body.ContentType).to.eql('image/jpeg');
+      expect(Object.prototype.hasOwnProperty.call(msg.body, 'Body')).to.eql(true);
+    });
+  });
+});

spec-integration/helpers/attachment.spec.js

@@ -0,0 +1,92 @@
+const { expect } = require('chai');
+const nock = require('nock');
+const logger = require('@elastic.io/component-logger')();
+const common = require('../../lib/common.js');
+const testCommon = require('../common.js');
+const { prepareBinaryData, getAttachment } = require('../../lib/helpers/attachment');
+
+describe('attachment helper', () => {
+  nock(testCommon.instanceUrl, { encodedQueryParams: true })
+    .get(`/services/data/v${common.globalConsts.SALESFORCE_API_VERSION}/sobjects/Document/describe`)
+    .times(2)
+    .reply(200, {
+      fields: [
+        {
+          name: 'Body',
+          type: 'base64',
+        },
+        {
+          name: 'ContentType',
+        },
+      ],
+    });
+  const configuration = {
+    secretId: testCommon.secretId,
+    sobject: 'Document',
+  };
+
+  describe('prepareBinaryData test', () => {
+    nock(process.env.ELASTICIO_API_URI)
+      .get(`/v2/workspaces/${process.env.ELASTICIO_WORKSPACE_ID}/secrets/${testCommon.secretId}`)
+      .times(2)
+      .reply(200, testCommon.secret);
+
+    it('should upload attachment utilizeAttachment:true', async () => {
+      const msg = {
+        body: {
+          Name: 'Attachment',
+        },
+        attachments: {
+          'Fox.jpeg': {
+            'content-type': 'image/jpeg',
+            size: 126564,
+            url: 'https://upload.wikimedia.org/wikipedia/commons/thumb/f/f6/Everest_kalapatthar.jpg/800px-Everest_kalapatthar.jpg',
+          },
+        },
+      };
+      await prepareBinaryData(msg, { ...configuration, utilizeAttachment: true }, { logger });
+      expect(msg.body.Name).to.eql('Attachment');
+      expect(msg.body.ContentType).to.eql('image/jpeg');
+      expect(Object.prototype.hasOwnProperty.call(msg.body, 'Body')).to.eql(true);
+    });
+
+    it('should discard attachment utilizeAttachment:false', async () => {
+      const msg = {
+        body: {
+          Name: 'Without Attachment',
+        },
+        attachments: {
+          'Fox.jpeg': {
+            'content-type': 'image/jpeg',
+            size: 126564,
+            url: 'https://upload.wikimedia.org/wikipedia/commons/thumb/f/f6/Everest_kalapatthar.jpg/800px-Everest_kalapatthar.jpg',
+          },
+        },
+      };
+      await prepareBinaryData(msg, configuration, { logger });
+      expect(msg.body.Name).to.eql('Without Attachment');
+      expect(Object.prototype.hasOwnProperty.call(msg.body, 'Body')).to.eql(false);
+    });
+  });
+
+  describe('getAttachment test', async () => {
+    it('should getAttachment', async () => {
+      nock(process.env.ELASTICIO_API_URI)
+        .get(`/v2/workspaces/${process.env.ELASTICIO_WORKSPACE_ID}/secrets/${testCommon.secretId}`)
+        .times(2)
+        .reply(200, testCommon.secret);
+      nock(testCommon.instanceUrl)
+        .get('/services/data/v46.0/sobjects/Attachment/00P2R00001DYjNVUA1/Body')
+        .reply(200, { hello: 'world' });
+      const objectContent = {
+        Body: '/services/data/v46.0/sobjects/Attachment/00P2R00001DYjNVUA1/Body',
+      };
+      const result = await getAttachment(configuration, objectContent, { logger });
+      expect(result).to.eql({
+        attachment: {
+          url: 'http://file.storage.server/file',
+        },
+      });
+    });
+  });
+});

spec/helpers/attachment.spec.js

@@ -2,9 +2,10 @@ const { callJSForceMethod } = require('./lib/helpers/wrapper');
 
 module.exports = async function verify(credentials) {
   try {
-    this.logger.info('Incoming credentials: %j', credentials);
+    this.logger.trace('Incoming credentials: %j', credentials);
+    this.logger.info('Going to make request describeGlobal() for verifying credentials...');
     const result = await callJSForceMethod.call(this, credentials, 'describeGlobal');
-    this.logger.info('Credentials are valid, sobjects count: %s', result.sobjects.length);
+    this.logger.info('Credentials are valid, it was found sobjects count: %s', result.sobjects.length);
     return { verified: true };
   } catch (e) {
     this.logger.error(e);