fix (#53)

* fix

* f

* f

* remove dev

Author: davydova-oleksandra

CHANGELOG.md

@@ -1,3 +1,6 @@
+## 2.2.2 (September 22, 2025)
+* Removed `elasticio-node` library from deprecated action and trigger to fix the bug introduced in version 2.2.1.
+
 ## 2.2.1 (September 19, 2025)
 * Improved Error Handling Policy description
 * Updated `component-commons-library` to version 4.0.0

component.json

@@ -1,6 +1,6 @@
 {
   "title": "REST API V2",
-  "version": "2.2.1",
+  "version": "2.2.2",
   "description": "A generic connector for accessing HTTP and REST APIs .",
   "authClientTypes": [
     "oauth2",

lib/utils.js

@@ -2,7 +2,6 @@
 
 const { JsonataTransform } = require('@elastic.io/component-commons-library');
 const request = require('request-promise');
-const { messages } = require('elasticio-node');
 const xml2js = require('xml2js-es6-promise');
 const uuidv1 = require('uuid').v1;
 
@@ -23,6 +22,11 @@ const methodsMap = {
   PUT: 'put',
 };
 
+module.exports.messages = {
+  newMessageWithBody: (body) => ({ body, headers: {} }),
+  newEmptyMessage: () => ({ body: {}, headers: {} }),
+};
+
 const bodyEncodings = {
   FORM_DATA: 'form-data',
   RAW: 'raw',
@@ -228,7 +232,7 @@ module.exports.processMethod = async function (msg, cfg) {
             // Walk through chain of promises: https://stackoverflow.com/questions/30445543/execute-native-js-promise-in-series
             // eslint-disable-next-line no-restricted-syntax
             for (const item of result.body) {
-              const output = messages.newMessageWithBody({
+              const output = module.exports.messages.newMessageWithBody({
                 headers: result.headers,
                 body: item,
                 statusCode: result.statusCode,
@@ -239,7 +243,7 @@ module.exports.processMethod = async function (msg, cfg) {
               await emitter.emit('data', output);
             }
           } else {
-            const output = messages.newMessageWithBody(result);
+            const output = module.exports.messages.newMessageWithBody(result);
             output.attachments = msg.attachments;
             await emitter.emit('data', output);
           }
@@ -371,7 +375,7 @@ module.exports.processMethod = async function (msg, cfg) {
         errorMessage: e.message,
         errorStack: e.stack,
       };
-      await emitter.emit('data', messages.newMessageWithBody(output));
+      await emitter.emit('data', output);
       await rateLimit(emitter.logger, rateLimitDelay);
       await emitter.emit('end');
     } else {

test/httpRequestAction.spec.js

@@ -5,9 +5,9 @@ const sinon = require('sinon');
 const { expect } = require('chai');
 const nock = require('nock');
 const fs = require('fs');
-const { messages } = require('elasticio-node');
 const logger = require('@elastic.io/component-logger')();
 const client = require('elasticio-rest-node')();
+const { messages } = require('../lib/utils');
 
 const { stub } = sinon;