#2 - Post results as an artifact for the submission

Author: callmekatootie

package-lock.json

@@ -33,6 +33,7 @@
     "get-parameter-names": "^0.3.0",
     "http-status-codes": "^1.3.2",
     "joi": "^14.3.1",
+    "jszip": "^3.2.2",
     "lodash": "^4.17.11",
     "superagent": "^3.8.3",
     "tc-core-library-js": "appirio-tech/tc-core-library-js.git",

package.json

@@ -93,8 +93,26 @@ const reqToSubmissionAPI = async (reqType, path, reqBody) => {
   }
 }
 
+/**
+ * Function to send request to V5 API with file
+ * @param {Object} config Configuration object
+ * @param (String) path Complete path of the API URL
+ * @param {Object} formData multiple part form data
+ * @param {String} the file field name in formData
+ * @returns {Promise}
+ */
+const reqToV5APIWithFile = async (path, formData, fileFieldName) => {
+  const token = await getM2Mtoken()
+  return request
+    .post(path)
+    .set('Authorization', `Bearer ${token}`)
+    .field(_.omit(formData, fileFieldName))
+    .attach(fileFieldName, formData[fileFieldName].data, formData[fileFieldName].name)
+}
+
 module.exports = {
   wrapExpress,
   autoWrapExpress,
-  reqToSubmissionAPI
+  reqToSubmissionAPI,
+  reqToV5APIWithFile
 }

src/common/helper.js

@@ -7,6 +7,10 @@ const helper = require('../common/helper')
 const logger = require('../common/logger')
 const uuid = require('uuid/v4')
 const config = require('config')
+const JSZip = require('jszip')
+
+const resultFileName = 'SonarQubeResults'
+const typeId = 'c56a4180-65aa-42ec-a945-5fd21dec0501'
 
 /**
  * Process the scan results received via Webhook from Sonarqube Server
@@ -21,9 +25,21 @@ const processScanResults = async (body) => {
     reviewerId: randomId,
     submissionId: body.project.key,
     scoreCardId: randomId,
-    typeId: 'c56a4180-65aa-42ec-a945-5fd21dec0501' // Request will fail if we don't use existing review type id
+    typeId // Request will fail if we don't use existing review type id
+  }
+  await helper.reqToSubmissionAPI('POST', `${config.SUBMISSION_API_URL}/reviews`, payload)
+
+  const zip = new JSZip()
+  zip.file(`${resultFileName}.json`, JSON.stringify(body, null, 2))
+  const content = await zip.generateAsync({ type: 'nodebuffer' })
+  const artifactPayload = {
+    artifact: {
+      name: `${resultFileName}.zip`,
+      data: content
+    },
+    typeId
   }
-  helper.reqToSubmissionAPI('POST', `${config.SUBMISSION_API_URL}/reviews`, payload)
+  await helper.reqToV5APIWithFile(`${config.SUBMISSION_API_URL}/submissions/${body.project.key}/artifacts`, artifactPayload, 'artifact')
 }
 
 processScanResults.schema = {

src/services/WebhookService.js

@@ -12,10 +12,13 @@ const URL = require('url')
 
 const authUrl = URL.parse(config.AUTH0_URL)
 const subApiUrl = URL.parse(`${config.SUBMISSION_API_URL}/reviews`)
+const artifactUrl = URL.parse(`${config.SUBMISSION_API_URL}/submissions/a34e1158-2c27-4d38-b079-5e5cca1bdcf7/artifacts`)
 
 nock(/\//)
   .persist()
   .post(authUrl.path)
-  .reply(200, { access_token: 'test' })
+  .reply(200, { access_token: 'eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJyb2xlcyI6WyJUb3Bjb2RlciBVc2VyIiwiQ29ubmVjdCBTdXBwb3J0IiwiYWRtaW5pc3RyYXRvciIsInRlc3RSb2xlIiwiYWFhIiwidG9ueV90ZXN0XzEiLCJDb25uZWN0IE1hbmFnZXIiLCJDb25uZWN0IEFkbWluIiwiY29waWxvdCIsIkNvbm5lY3QgQ29waWxvdCBNYW5hZ2VyIl0sImlzcyI6Imh0dHBzOi8vYXBpLnRvcGNvZGVyLWRldi5jb20iLCJoYW5kbGUiOiJUb255SiIsImV4cCI6MTU2NTY4MTkyMCwidXNlcklkIjoiODU0Nzg5OSIsImlhdCI6MTU1NTY4MTMyMCwiZW1haWwiOiJhamVmdHNAdG9wY29kZXIuY29tIiwianRpIjoiMTlhMDkzNzAtMjk4OC00N2I4LTkxODktMGRhODVjNjM0ZWQyIn0.V8nsQpbzQ_4iEd0dAbuYsfeydnhSAEQ95AKKwl8RONw' })
   .post(subApiUrl.path)
   .reply(200)
+  .post(artifactUrl.path)
+  .reply(200)