keep tcp connections open if possible

vtfk · Sep 22, 2023 · fb6683f · fb6683f
1 parent d8c6f8e
commit fb6683f
Show file tree

Hide file tree

Showing 4 changed files with 22 additions and 4 deletions.
diff --git a/lib/archive.js b/lib/archive.js
@@ -1,5 +1,5 @@
 const { logger } = require('@vtfk/logger')
-const axios = require('axios').default
+const axios = require('./axios-instance')()
 const { fromBuffer } = require('file-type')
 const path = require('path')
 const { ARCHIVE_URL, ARCHIVE_KEY, FILE_FORMATS } = require('../config')
@@ -48,11 +48,11 @@ const callArchive = async (payload, e18JobId, e18TaskId, endpoint) => {
       },
       maxBodyLength
     }
-
     const { data } = await axios.post(`${ARCHIVE_URL}/${endpoint}`, payload, headers)
     logger('info', ['archive', 'callArchive', 'data found'])
     return data
   } catch (error) {
+    console.log(error.response?.data || error.stack || error.toString())
     const { status, message, data } = error.response
     if ((status === 404 && endpoint === 'SyncElevmappe') || (data && data.error && data.error === 'VANLIG BOSATT, mangler ADR og ADR1-3')) {
       logger('info', ['archive', 'aiaiaiaiai', status, message || data])

diff --git a/lib/axios-instance.js b/lib/axios-instance.js
@@ -0,0 +1,18 @@
+const axios = require('axios').default
+const https = require('https')
+
+let instance = null
+
+// To avoid TCP port exhaustion on many runs at once
+module.exports = () => {
+  if (!instance) {
+    console.log('instance does not exits - creating')
+    instance = axios.create({
+      httpsAgent: new https.Agent({
+        keepAlive: true,
+        maxSockets: 200
+      })
+    })
+  }
+  return instance
+}
diff --git a/lib/e18.js b/lib/e18.js
@@ -1,4 +1,4 @@
-const axios = require('axios').default
+const axios = require('./axios-instance')()
 const { logger } = require('@vtfk/logger')
 const { E18_URL, E18_KEY, E18: { PROJECT_ID: projectId, SYSTEM: system, TYPE: type } } = require('../config')
 

diff --git a/lib/isi-lokal.js b/lib/isi-lokal.js
@@ -1,5 +1,5 @@
 const { logger } = require('@vtfk/logger')
-const axios = require('axios').default
+const axios = require('./axios-instance')()
 const { parseStringPromise, processors } = require('xml2js')
 
 const { ISI: { URL, GET_DOCUMENTS, SET_STATUS } } = require('../config')