Comparing Twilio SendGrid's Activity feed and Email Logs, and checking CSV and JSON

/* sendgrid-tools.js */
const dotenv = require("dotenv");

dotenv.config();

function requireEnv(name) {
  const v = process.env[name];
  if (!v) {
    throw new Error(`${name} is not set. Please check your .env file.`);
  }
  return v;
}

function parseArgs(argv) {
  const args = { _: [] };
  for (let i = 0; i < argv.length; i += 1) {
    const a = argv[i];
    if (a.startsWith("--")) {
      const key = a.slice(2);
      const next = argv[i + 1];
      if (!next || next.startsWith("--")) {
        args[key] = true;
      } else {
        args[key] = next;
        i += 1;
      }
    } else {
      args._.push(a);
    }
  }
  return args;
}

async function sgFetch(url, { method, bodyObj } = {}) {
  const apiKey = requireEnv("SENDGRID_API_KEY");

  const res = await fetch(url, {
    method: method ?? "GET",
    headers: {
      Authorization: `Bearer ${apiKey}`,
      "Content-Type": "application/json",
    },
    body: bodyObj ? JSON.stringify(bodyObj) : undefined,
  });

  const text = await res.text();
  const xMessageId = res.headers.get("x-message-id");

  return {
    ok: res.ok,
    status: res.status,
    headers: {
      "x-message-id": xMessageId ?? "",
    },
    text,
    json: (() => {
      try {
        return text ? JSON.parse(text) : null;
      } catch {
        return null;
      }
    })(),
  };
}

function buildDefaultQuery() {
  const subject = requireEnv("SUBJECT");
  const toEmail = requireEnv("TO_EMAIL");
  return `subject = '${subject}' AND to_email = '${toEmail}'`;
}

async function cmdSend() {
  const toEmail = requireEnv("TO_EMAIL");
  const fromEmail = requireEnv("FROM_EMAIL");
  const subject = requireEnv("SUBJECT");

  const body = {
    personalizations: [
      {
        to: [{ email: toEmail }],
      },
    ],
    from: { email: fromEmail },
    subject,
    content: [{ type: "text/plain", value: "SendGrid logs test." }],
  };

  const r = await sgFetch("https://api.sendgrid.com/v3/mail/send", {
    method: "POST",
    bodyObj: body,
  });

  const out = {
    status: r.status,
    ok: r.ok,
    "x-message-id": r.headers["x-message-id"],
  };
  console.log(JSON.stringify(out, null, 2));

  if (!r.ok) {
    console.error(r.text);
    process.exitCode = 1;
  }
}

async function cmdSearch(args) {
  const limitRaw = args.limit ?? "10";
  const limit = Number(limitRaw);
  if (!Number.isFinite(limit) || limit < 1 || limit > 1000) {
    throw new Error("--limit must be specified in the range from 1 to 1000.");
  }

  const query = args.query ? String(args.query) : buildDefaultQuery();

  const r = await sgFetch("https://api.sendgrid.com/v3/logs", {
    method: "POST",
    bodyObj: { query, limit },
  });

  const out = r.json ?? { status: r.status, ok: r.ok, raw: r.text };
  console.log(JSON.stringify(out, null, 2));

  if (!r.ok) {
    process.exitCode = 1;
  }
}

async function cmdDetail(args) {
  const sgMessageId = args._[0];
  if (!sgMessageId) {
    throw new Error("Please specify sg_message_id. Example: node sendgrid-tools.js detail <sg_message_id>");
  }

  const url = `https://api.sendgrid.com/v3/logs/${encodeURIComponent(sgMessageId)}`;
  const r = await sgFetch(url);

  const out = r.json ?? { status: r.status, ok: r.ok, raw: r.text };
  console.log(JSON.stringify(out, null, 2));

  if (!r.ok) {
    process.exitCode = 1;
  }
}

async function main() {
  const argv = process.argv.slice(2);
  const sub = argv[0];
  const args = parseArgs(argv.slice(1));

  try {
    if (sub === "send") {
      await cmdSend();
      return;
    }
    if (sub === "search") {
      await cmdSearch(args);
      return;
    }
    if (sub === "detail") {
      await cmdDetail(args);
      return;
    }

    console.log(
      [
        "Usage:",
        "  node sendgrid-tools.js send",
        "  node sendgrid-tools.js search --limit 10",
        "  node sendgrid-tools.js search --query \"subject = '...' AND to_email = '...'\"",
        "  node sendgrid-tools.js detail <sg_message_id>",
      ].join("\n"),
    );
    process.exitCode = 2;
  } catch (e) {
    console.error(e?.message ?? e);
    process.exitCode = 1;
  }
}

main();