Improve handling of request timeout

src/fetcher/dns.js

@@ -15,12 +15,14 @@ limitations under the License.
 */
 const dns = require('dns')
 
-module.exports = async (data, opts) => {
+module.exports.timeout = 5000
+
+module.exports.fn = async (data, opts) => {
   let timeoutHandle
   const timeoutPromise = new Promise((resolve, reject) => {
     timeoutHandle = setTimeout(
       () => reject(new Error('Request was timed out')),
-      5000
+      data.fetcherTimeout ? data.fetcherTimeout : module.exports.timeout
     )
   })
 

src/fetcher/gitlab.js

@@ -16,12 +16,14 @@ limitations under the License.
 const bent = require('bent')
 const req = bent('GET')
 
-module.exports = async (data, opts) => {
+module.exports.timeout = 5000
+
+module.exports.fn = async (data, opts) => {
   let timeoutHandle
   const timeoutPromise = new Promise((resolve, reject) => {
     timeoutHandle = setTimeout(
       () => reject(new Error('Request was timed out')),
-      5000
+      data.fetcherTimeout ? data.fetcherTimeout : module.exports.timeout
     )
   })
 

src/fetcher/http.js

@@ -17,12 +17,14 @@ const bent = require('bent')
 const req = bent('GET')
 const E = require('../enums')
 
-module.exports = async (data, opts) => {
+module.exports.timeout = 5000
+
+module.exports.fn = async (data, opts) => {
   let timeoutHandle
   const timeoutPromise = new Promise((resolve, reject) => {
     timeoutHandle = setTimeout(
       () => reject(new Error('Request was timed out')),
-      5000
+      data.fetcherTimeout ? data.fetcherTimeout : module.exports.timeout
     )
   })
 

src/fetcher/irc.js

@@ -16,12 +16,14 @@ limitations under the License.
 const irc = require('irc-upd')
 const validator = require('validator')
 
-module.exports = async (data, opts) => {
+module.exports.timeout = 20000
+
+module.exports.fn = async (data, opts) => {
   let timeoutHandle
   const timeoutPromise = new Promise((resolve, reject) => {
     timeoutHandle = setTimeout(
       () => reject(new Error('Request was timed out')),
-      20000
+      data.fetcherTimeout ? data.fetcherTimeout : module.exports.timeout
     )
   })
 

src/fetcher/matrix.js

@@ -17,12 +17,14 @@ const bent = require('bent')
 const bentReq = bent('GET')
 const validator = require('validator')
 
-module.exports = async (data, opts) => {
+module.exports.timeout = 5000
+
+module.exports.fn = async (data, opts) => {
   let timeoutHandle
   const timeoutPromise = new Promise((resolve, reject) => {
     timeoutHandle = setTimeout(
       () => reject(new Error('Request was timed out')),
-      5000
+      data.fetcherTimeout ? data.fetcherTimeout : module.exports.timeout
     )
   })
 

src/fetcher/twitter.js

@@ -17,12 +17,14 @@ const bent = require('bent')
 const bentReq = bent('GET')
 const validator = require('validator')
 
-module.exports = async (data, opts) => {
+module.exports.timeout = 5000
+
+module.exports.fn = async (data, opts) => {
   let timeoutHandle
   const timeoutPromise = new Promise((resolve, reject) => {
     timeoutHandle = setTimeout(
       () => reject(new Error('Request was timed out')),
-      5000
+      data.fetcherTimeout ? data.fetcherTimeout : module.exports.timeout
     )
   })
 

src/fetcher/xmpp.js

@@ -18,6 +18,8 @@ const { client, xml } = require('@xmpp/client')
 const debug = require('@xmpp/debug')
 const validator = require('validator')
 
+module.exports.timeout = 5000
+
 let xmpp = null,
   iqCaller = null
 
@@ -43,12 +45,12 @@ const xmppStart = async (service, username, password) => {
   })
 }
 
-module.exports = async (data, opts) => {
+module.exports.fn = async (data, opts) => {
   let timeoutHandle
   const timeoutPromise = new Promise((resolve, reject) => {
     timeoutHandle = setTimeout(
       () => reject(new Error('Request was timed out')),
-      5000
+      data.fetcherTimeout ? data.fetcherTimeout : module.exports.timeout
     )
   })