add axios testing

index.js

@@ -1,4 +1,5 @@
 'use strict'
+const axios = require('axios')
 
 function streamToString (stream) {
   const chunks = [];
@@ -60,25 +61,16 @@ exports.hook_queue = async function (next, connection) {
   }
 
   const options = {
-    method: "POST",
-    headers: customHeaders,
-    body: postData
+    headers: customHeaders
   }
 
   try {
-    const response = await fetch(url, options)
-    const text = await response.text();
-
-    // network error in the 4xx–5xx range
-    // ok is in the range of 200-299
-    if (! response.ok) {
-      plugin.logdebug(text);
-      throw new Error(`${response.status} ${response.statusText}`);
-    }
-
+    const response = await axios.post(url, data, options)
   }
   catch (err) {
-    plugin.logdebug(err);
+    if (err.response) {
+      plugin.logdebug(JSON.encode(err.response));
+    }
 
     // blackhole this message as deny
     return next(DENYSOFT, '458 – Unable to queue messages for node resque');

package.json

@@ -27,9 +27,14 @@
   },
   "homepage": "https://github.com/niiknow/haraka-plugin-resque#readme",
   "devDependencies": {
+    "chai": "^5.0.0",
     "eslint": "^8.55.0",
     "eslint-plugin-haraka": "*",
     "haraka-test-fixtures": "*",
-    "mocha": "^10.2.0"
+    "mocha": "^10.2.0",
+    "nock": "^13.4.0"
+  },
+  "dependencies": {
+    "axios": "^1.6.5"
   }
 }

test/index.js

@@ -4,10 +4,15 @@ const assert   = require('assert')
 
 // npm modules
 const fixtures = require('haraka-test-fixtures')
+const nock = require('nock')
+const axios = require('axios')
 
 // start of tests
 //    assert: https://nodejs.org/api/assert.html
 //    mocha: http://mochajs.org
+const host = 'http://localhost';
+axios.defaults.host = host;
+axios.defaults.baseURL = host;
 
 beforeEach(function (done) {
   this.plugin = new fixtures.plugin('resque')
@@ -17,7 +22,16 @@ beforeEach(function (done) {
 describe('resque', function () {
   it('loads', function (done) {
     assert.ok(this.plugin)
-    done()
+    nock(host)
+      .get('/test')
+      .reply(200, 'test data');
+
+    axios.get('/test').then(response => {
+      assert.ok(response.data == 'test data');
+      // console.log(response.data);
+      done();
+    });
+    // done()
   })
 })