const { test } = require("tap");
const net = require("net");
const log4js = require("../../lib/log4js");
const vcr = require("../../lib/appenders/recording");
const levels = require("../../lib/levels");
const LoggingEvent = require("../../lib/LoggingEvent");

test("TCP Server", batch => {
  batch.test(
    "should listen for TCP messages and re-send via process.send",
    t => {
      log4js.configure({
        appenders: {
          vcr: { type: "recording" },
          tcp: { type: "tcp-server", port: 5678 }
        },
        categories: {
          default: { appenders: ["vcr"], level: "debug" }
        }
      });
      // give the socket a chance to start up
      setTimeout(() => {
        const socket = net.connect(5678, () => {
          socket.write(
            `${new LoggingEvent(
              "test-category",
              levels.INFO,
              ["something"],
              {}
            ).serialise()}__LOG4JS__${new LoggingEvent(
              "test-category",
              levels.INFO,
              ["something else"],
              {}
            ).serialise()}__LOG4JS__some nonsense__LOG4JS__{"some":"json"}__LOG4JS__`,
            () => {
              socket.end();
              setTimeout(() => {
                log4js.shutdown(() => {
                  const logs = vcr.replay();
                  t.equal(logs.length, 4);
                  t.match(logs[0], {
                    data: ["something"],
                    categoryName: "test-category",
                    level: { levelStr: "INFO" },
                    context: {}
                  });
                  t.match(logs[1], {
                    data: ["something else"],
                    categoryName: "test-category",
                    level: { levelStr: "INFO" },
                    context: {}
                  });
                  t.match(logs[2], {
                    data: [
                      "Unable to parse log:",
                      "some nonsense",
                      "because: ",
                      SyntaxError
                    ],
                    categoryName: "log4js",
                    level: { levelStr: "ERROR" },
                    context: {}
                  });
                  t.match(logs[3], {
                    data: [
                      "Unable to parse log:",
                      '{"some":"json"}',
                      "because: ",
                      TypeError
                    ],
                    categoryName: "log4js",
                    level: { levelStr: "ERROR" },
                    context: {}
                  });
                  t.end();
                });
              }, 100);
            }
          );
        });

        socket.unref();
      }, 100);
    }
  );

  batch.test(
    "sending incomplete messages in chunks",
    t => {
      log4js.configure({
        appenders: {
          vcr: { type: "recording" },
          tcp: { type: "tcp-server" }
        },
        categories: {
          default: { appenders: ["vcr"], level: "debug" }
        }
      });
      // give the socket a chance to start up
      setTimeout(() => {
        const socket = net.connect(5000, () => {
          const syncWrite = (dataArray = [], finalCallback) => {
            if (dataArray === null) {
              dataArray = [];
            } else if (!Array.isArray(dataArray)) {
              dataArray = [dataArray];
            }
            if (typeof finalCallback !== "function") {
              finalCallback = () => {};
            }
            setTimeout(() => {
              if (!dataArray.length) {
                finalCallback();
              } else if (dataArray.length === 1) {
                socket.write(dataArray.shift(), finalCallback);
              } else {
                socket.write(dataArray.shift(), () => { syncWrite(dataArray, finalCallback); });
              }
            }, 100);
          };

          const dataArray = [
            "__LOG4JS__",
            "Hello__LOG4JS__World",
            "__LOG4JS__",
            "testing nonsense",
            `__LOG4JS__more nonsense__LOG4JS__`
          ];

          const finalCallback = () => {
            socket.end();
            setTimeout(() => {
              log4js.shutdown(() => {
                const logs = vcr.replay();
                t.equal(logs.length, 8);
                t.match(logs[4], {
                  data: [
                    "Unable to parse log:",
                    "Hello",
                    "because: ",
                    SyntaxError
                  ],
                  categoryName: "log4js",
                  level: { levelStr: "ERROR" },
                  context: {}
                });
                t.match(logs[5], {
                  data: [
                    "Unable to parse log:",
                    "World",
                    "because: ",
                    SyntaxError
                  ],
                  categoryName: "log4js",
                  level: { levelStr: "ERROR" },
                  context: {}
                });
                t.match(logs[6], {
                  data: [
                    "Unable to parse log:",
                    "testing nonsense",
                    "because: ",
                    SyntaxError
                  ],
                  categoryName: "log4js",
                  level: { levelStr: "ERROR" },
                  context: {}
                });
                t.match(logs[7], {
                  data: [
                    "Unable to parse log:",
                    "more nonsense",
                    "because: ",
                    SyntaxError
                  ],
                  categoryName: "log4js",
                  level: { levelStr: "ERROR" },
                  context: {}
                });
                t.end();
              });
            }, 100);
          };

          syncWrite(dataArray, finalCallback);
        });

        socket.unref();
      }, 100);
    }
  );

  batch.end();
});