/* Pi-hole: A black hole for Internet advertisements
 *  (c) 2017 Pi-hole, LLC (https://pi-hole.net)
 *  Network-wide ad blocking via your own hardware.
 *
 *  This file is copyright under the latest version of the EUPL.
 *  Please see LICENSE file for your rights under this license. */

"use strict";

function eventsource() {
  const alInfo = $("#alInfo");
  const alSuccess = $("#alSuccess");
  const ta = $("#output");

  ta.html("");
  ta.show();
  alInfo.show();
  alSuccess.hide();

  fetch(document.body.dataset.apiurl + "/action/gravity", {
    method: "POST",
    headers: { "X-CSRF-TOKEN": $('meta[name="csrf-token"]').attr("content") },
  })
    // Retrieve its body as ReadableStream
    .then(response => {
      const reader = response.body.getReader();
      return new ReadableStream({
        start(controller) {
          return pump();
          function pump() {
            return reader.read().then(({ done, value }) => {
              // When no more data needs to be consumed, close the stream
              if (done) {
                controller.close();
                alInfo.hide();
                $("#gravityBtn").prop("disabled", false);
                return;
              }

              // Enqueue the next data chunk into our target stream
              controller.enqueue(value);
              const string = new TextDecoder().decode(value);
              parseLines(ta, string);

              if (string.includes("Done.")) {
                alSuccess.show();
              }

              return pump();
            });
          }
        },
      });
    })
    .catch(error => console.error(error)); // eslint-disable-line no-console
}

$("#gravityBtn").on("click", () => {
  $("#gravityBtn").prop("disabled", true);
  eventsource();
});

// Handle hiding of alerts
$(() => {
  $("[data-hide]").on("click", function () {
    $(this)
      .closest("." + $(this).attr("data-hide"))
      .hide();
  });
});

function parseLines(ta, str) {
  // str can contain multiple lines.
  // We want to split the text before an "OVER" escape sequence to allow overwriting previous line when needed

  // Splitting the text on "\r"
  const lines = str.split(/(?=\r)/g);

  for (let line of lines) {
    if (line[0] === "\r") {
      // This line starts with the "OVER" sequence. Replace them with "\n" before print
      line = line.replaceAll("\r", "\n").replaceAll("\r", "\n");

      // Last line from the textarea will be overwritten, so we remove it
      ta.html(ta.html().substring(0, ta.html().lastIndexOf("\n")));
    }

    // Track the number of opening spans
    let spanCount = 0;

    // Replace ANSI escape codes with HTML tags and count opening spans
    /* eslint-disable prettier/prettier */
    line = line.replaceAll("", () => { spanCount++; return '<span class="text-bold">'; }); //COL_BOLD
    line = line.replaceAll("", () => { spanCount++; return '<span class="log-gray">'; }); //COL_GRAY
    line = line.replaceAll("", () => { spanCount++; return '<span class="log-red">'; }); //COL_RED
    line = line.replaceAll("", () => { spanCount++; return '<span class="log-green">'; }); //COL_GREEN
    line = line.replaceAll("", () => { spanCount++; return '<span class="log-yellow">'; }); //COL_YELLOW
    line = line.replaceAll("", () => { spanCount++; return '<span class="log-blue">'; }); //COL_BLUE
    line = line.replaceAll("", () => { spanCount++; return '<span class="log-purple">'; }); //COL_PURPLE
    line = line.replaceAll("", () => { spanCount++; return '<span class="log-cyan">'; }); //COL_CYAN
    /* eslint-enable prettier/prettier */

    // Replace [0m with the appropriate number of closing spans
    line = line.replaceAll("", "</span>".repeat(spanCount)); //COL_NC

    // Append the new text to the end of the output
    ta.append(line);
  }
}