Motor de Calidad de Datos

const scriptName = String("MQD - Event Producer Interceptor");
const scriptVersion = String("1.1.0");

try {

    $call.tracer.trace(">Sensedia debug => Custom javascript: Name [ "+scriptName+" ] version [ "+scriptVersion+" ]." );
    $console.debug("responseStatusCode", $call.response.getStatus());

    if ($call.response.getStatus() == 200 && $call.request.getMethod() == "GET") {

        const url = String($call.request.getRequestedUrl().getPath());

        const apiName = extractApiNameByUrl(url);

        $console.debug("apiName", apiName);

        const mqdTopicUrl = String($call.environmentVariables.get('mqd-'+ apiName +'-topic-handler-url'));

        $console.debug("mqdTopicUrl", mqdTopicUrl);

        if(mqdTopicUrl) {

            let jsonResponse = JSON.parse( $call.response.getBody().getString("UTF-8") );

            jsonResponse.mqd = {};
            jsonResponse.mqd.endpointName = substituirPathPorPathId(url);
            jsonResponse.mqd.serverOrgId = $call.request.getHeader("x-organisation-id");
            jsonResponse.mqd.fapiInteractionId = $response.getHeader("x-fapi-interaction-id");

            const response =  $http.post(mqdTopicUrl, $call.response.getHeaders(), $json.stringify(jsonResponse));

            $console.debug("response", response.responseText);
            $console.debug("response status", response.getStatus());

            $call.tracer.trace("Custom javascript: Name [ "+scriptName+" ] version [ "+scriptVersion+" ].Envio para MQD Finalizado." );

        } else {
            $call.tracer.trace("Custom javascript: Name [ "+scriptName+" ] version [ "+scriptVersion+" ]. ATENCIÓN!  environmentVariable >'mqd-"+ apiName +"-topic-handler-url'< no configurada! Ignorando envío al tópico MQD." );
        }
    }
} catch (exception) {
    $call.tracer.trace("Exception message => " + exception.message + " <= in line => " + exception.stack);
    $console.debug(">sensedia => Exception", exception);
}


function substituirPathPorPathId(urlSearch) {

  function substituir(match, pathAnterior) {
      // Remover el último carácter "s" del path anterior
      const pathId = pathAnterior.slice(0, -1) + 'Id';
      // Retornar el pathId entre llaves
      return '/' + pathAnterior + '/{'+pathId+'}';
  }
  //regex uuid estándar para los recursos api de datos
  let regex = /\/([^\/]+)\/([a-f0-9-]+)(?=\/|$)/g;

  //si es api consents el regex será diferente
  if(apiName === "consents"){
    regex = /\/([^\/]+)\/(urn:[a-zA-Z0-9-]+:[a-f0-9-]+)(?=\/|$)/g;
  }

  // Sustituir el nombre del path anterior más "Id" por el string dentro de las llaves
  const nuevaUrl = urlSearch.replace(regex, substituir);

  return nuevaUrl.match(/open-banking(.+)/)[1];
}

function extractApiNameByUrl(url) {
  const start = "open-banking/";
  const startIndex = url.indexOf(start);

  if (startIndex === -1) {
    return "";
  }

  const endIndex = url.indexOf("/", startIndex + start.length);
  if (endIndex === -1) {
    return url.substring(startIndex + start.length);
  }

  return url.substring(startIndex + start.length, endIndex);
}