-
Notifications
You must be signed in to change notification settings - Fork 0
/
integration.js
69 lines (58 loc) · 1.98 KB
/
integration.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
'use strict';
const { setLogger } = require('./src/logger');
const { parseErrorToReadableJSON, ApiRequestError } = require('./src/errors');
const polarityRequest = require('./src/polarity-request');
const { createResultObject } = require('./src/create-result-object')
const SUCCESS_CODES = [200, 404];
let Logger = null;
const startup = (logger) => {
Logger = logger;
setLogger(Logger);
};
/**
* forEach entity
* MakeNetworkRequest1 -- Makes the network request, handles network errors only, returns raw network response
* HandleAPIErrors -- handles error handling of the API response
* CreateResultObject -- Handles any processing of the raw network response, creates a resultObject or resultMissObject
*
* @param entities
* @param options
* @param cb
* @returns {Promise<void>}
*/
const doLookup = async (entities, options, cb) => {
try {
Logger.trace({ entities }, 'doLookup');
const lookupResults = await Promise.all(
entities.map(async (entity) => {
// Make network request
const apiResponse = await polarityRequest.request({
uri: `https://internetdb.shodan.io/${entity.value}`
});
Logger.trace({ apiResponse }, 'Lookup API Response');
// Handle API errors
if (!SUCCESS_CODES.includes(apiResponse.statusCode)) {
throw new ApiRequestError(
`Unexpected status code ${apiResponse.statusCode} received when making request to Shodan Context API`,
{
statusCode: apiResponse.statusCode,
requestOptions: apiResponse.requestOptions
}
);
}
// Create the Result Object
return createResultObject(entity, apiResponse);
})
);
Logger.trace({ lookupResults }, 'Lookup Results');
cb(null, lookupResults);
} catch (error) {
const errorAsPojo = parseErrorToReadableJSON(error);
Logger.error({ error: errorAsPojo }, 'Error in doLookup');
cb(error);
}
};
module.exports = {
startup,
doLookup
};