// 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];
    // Only use filter_agents if agentId is a number or numeric string
    if (agentId && !isNaN(Number(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
};