Hot-fix attachments processing (v3.1.2)

Author: EmptyInfinity

.circleci/config.yml

@@ -0,0 +1,125 @@
+version: 2.1
+parameters:
+  node-version:
+    type: string
+    default: "16.13.2"
+orbs:
+  node: circleci/node@5.0.0
+  slack: circleci/slack@4.5.3
+commands:
+  notify_on_failure:
+    steps:
+      - slack/notify:
+          event: fail
+          custom: |
+            {
+            	"blocks": [
+            		{
+            			"type": "section",
+            			"fields": [
+            				{
+            					"type": "mrkdwn",
+            					"text": ":red_circle: *$CIRCLE_PROJECT_REPONAME*:*$CIRCLE_TAG* build failed"
+            				}
+            			]
+            		},
+            		{
+            			"type": "actions",
+            			"elements": [
+            				{
+            					"type": "button",
+            					"text": {
+            						"type": "plain_text",
+            						"text": "View Job"
+            					},
+            					"url": "${CIRCLE_BUILD_URL}"
+            				}
+            			]
+            		}
+            	]
+            }
+  notify_on_pass:
+    steps:
+      - slack/notify:
+          event: pass
+          custom: |
+            {
+            	"blocks": [
+            		{
+            			"type": "section",
+            			"fields": [
+            				{
+            					"type": "mrkdwn",
+            					"text": ":tada: *$CIRCLE_PROJECT_REPONAME*:*$CIRCLE_TAG* was successfully built and published"
+            				}
+            			]
+            		},
+            		{
+            			"type": "actions",
+            			"elements": [
+            				{
+            					"type": "button",
+            					"text": {
+            						"type": "plain_text",
+            						"text": "View Job"
+            					},
+            					"url": "${CIRCLE_BUILD_URL}"
+            				}
+            			]
+            		}
+            	]
+            }
+jobs:
+  test:
+    docker:
+      - image: circleci/node:14-stretch
+    steps:
+      - checkout
+      - node/install:
+          node-version: << pipeline.parameters.node-version >>
+      - run:
+          name: Audit Dependencies
+          command: npm audit --audit-level=high
+      - node/install-packages:
+          cache-path: ./node_modules
+          override-ci-command: npm install
+      - run:
+          name: Running Mocha Tests
+          command: npm test
+  build:
+    docker:
+      - image: circleci/node:14-stretch
+        user: root
+    steps:
+      - checkout
+      - node/install:
+          node-version: << pipeline.parameters.node-version >>
+      - setup_remote_docker:
+          version: 19.03.13
+          docker_layer_caching: true
+      # build and push Docker image
+      - run:
+          name: Install component-build-helper lib
+          command: npm install -g @elastic.io/component-build-helper
+      - run:
+          name: Build and publish docker image
+          command: build_component_docker
+      - notify_on_failure
+      - notify_on_pass
+workflows:
+  test:
+    jobs:
+      - test:
+          name: "Running tests"
+          filters:
+            tags:
+              ignore: /.*/
+  publish_release:
+    jobs:
+      - build:
+          name: "Build and publish docker image"
+          filters:
+            branches:
+              ignore: /.*/
+            tags:
+              only: /^([0-9]+)\.([0-9]+)\.([0-9]+)(?:-([0-9A-Za-z-]+(?:\.[0-9A-Za-z-]+)*))?(?:\+[0-9A-Za-z-]+)?$/

CHANGELOG.md

@@ -1,3 +1,8 @@
+## 3.1.2 (April 13, 2022)
+* Update `component-commons-library` to read and upload attachments through `Maester`
+* Update `elasticio-sailor-nodejs` to v2.6.27
+* Fix dependencies
+
 ## 3.1.1 (March 15, 2022)
 * Added component pusher build script
 

component.json

@@ -2,7 +2,7 @@
   "title": "CSV",
   "description": "A comma-separated values (CSV) file stores tabular data (numbers and text) in plain-text form",
   "docsUrl": "https://github.com/elasticio/csv-component",
-  "version": "3.1.1",
+  "version": "3.1.2",
   "actions": {
     "read_action": {
       "main": "./lib/actions/read.js",
@@ -85,4 +85,4 @@
       "dynamicMetadata": true
     }
   }
-}
+}

lib/actions/write.js

@@ -45,15 +45,16 @@ async function proceedData(data, cfg) {
   }
 
   const attachmentProcessor = new AttachmentProcessor()
-  let attachment
+  let uploadResult
   try {
-    attachment = await attachmentProcessor.uploadAttachment(csvString)
+    uploadResult = await attachmentProcessor.uploadAttachment(csvString, 'stream')
   } catch (err) {
     this.logger.error(`Upload attachment failed: ${err}`)
     this.emit('error', `Upload attachment failed: ${err}`)
   }
+  const attachmentUrl = `${uploadResult.config.url}${uploadResult.data.objectId}?storage_type=maester`;
   const body = {
-    attachmentUrl: attachment.config.url,
+    attachmentUrl,
     type: '.csv',
     size: Buffer.byteLength(csvString),
     attachmentCreationTime: new Date(),