78 lines
3.0 KiB
JavaScript
78 lines
3.0 KiB
JavaScript
// proxy/backoneClientCore.js
|
|
// ─────────────────────────────────────────────────────────────────────────────
|
|
// Core fetch and authentication helpers for BackOne DPI API.
|
|
// ─────────────────────────────────────────────────────────────────────────────
|
|
|
|
const path = require('path');
|
|
require('dotenv').config({ path: path.join(__dirname, '..', '.env.local') });
|
|
const axios = require('axios');
|
|
|
|
const BASE_URL = process.env.BACKONE_INFORMATICS_BASE_URL || 'https://api0.dev.backone.cloud/api/v1';
|
|
const JWT_TOKEN = process.env.BACKONE_TOKEN || process.env.BACKONE_JWT_TOKEN || process.env.BACKONE_API_KEY || process.env.NETIFY_API_KEY;
|
|
const agentMap = {};
|
|
|
|
function getHeaders(siteUuid) {
|
|
const token = process.env.BACKONE_DPI_API_KEY || JWT_TOKEN;
|
|
const headers = { 'x-api-key': token, 'Accept': 'application/json' };
|
|
// siteUuid is explicitly ignored to fetch globally across all sites
|
|
return headers;
|
|
}
|
|
|
|
function fixDates(obj) {
|
|
if (Array.isArray(obj)) {
|
|
for (let i = 0; i < obj.length; i++) fixDates(obj[i]);
|
|
} else if (obj !== null && typeof obj === 'object') {
|
|
for (const key in obj) {
|
|
if ((key === 'first_seen_at' || key === 'last_seen_at' || key.endsWith('_at')) && obj[key] && typeof obj[key].date === 'string') {
|
|
let d = obj[key].date;
|
|
if (d.includes(' ') && !d.endsWith('Z')) obj[key].date = d.replace(' ', 'T') + 'Z';
|
|
else if (!d.endsWith('Z') && !d.includes('+') && d.includes('T')) obj[key].date = d + 'Z';
|
|
} else if (typeof obj[key] === 'object') {
|
|
fixDates(obj[key]);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
async function backoneFetch(endpoint, params = {}, agentUuid = null, siteUuid = null) {
|
|
if (agentUuid) {
|
|
const agentId = agentMap[agentUuid];
|
|
if (agentId) {
|
|
params.filter_agents = `[${agentId}]`;
|
|
} else {
|
|
params.settings_agent = agentUuid;
|
|
}
|
|
}
|
|
|
|
const token = process.env.BACKONE_DPI_API_KEY || JWT_TOKEN;
|
|
if (!token) {
|
|
console.error(`[DpiClient] Missing DPI_API_KEY for endpoint ${endpoint}`);
|
|
return null;
|
|
}
|
|
|
|
try {
|
|
const res = await axios.get(`${BASE_URL}${endpoint}`, {
|
|
headers: getHeaders(siteUuid), params, timeout: 60000,
|
|
});
|
|
const json = res.data;
|
|
|
|
if (json?.status_code !== 0) {
|
|
console.error(`[DpiClient] API Error ${json?.status_code} on ${endpoint}: ${json?.status_message || 'No message'}`);
|
|
return null;
|
|
}
|
|
if (json && json.data) fixDates(json.data);
|
|
return json?.data ?? null;
|
|
} catch (err) {
|
|
const s = err.response?.status;
|
|
const msg = JSON.stringify(err.response?.data ?? err.message);
|
|
console.error(`[DpiClient] ${s ?? 'ERR'} ${endpoint}: ${msg}`);
|
|
return null;
|
|
}
|
|
}
|
|
|
|
module.exports = {
|
|
backoneFetch,
|
|
agentMap,
|
|
BASE_URL
|
|
};
|