import * as http from "node:http";

let messages = new Map<string, any>();

export function startSink() {
  const hostname = "127.0.0.1";
  const port = 3030;

  const server = http.createServer((req, res) => {
    console.log("Sink received message: ");
    let body = "";
    req.on("data", (chunk) => {
      body += chunk;
    });

    req.on("end", () => {
      console.log(body);
      const data = JSON.parse(body);
      messages.set(data.contextInfo.recipientEmailAddress, data.args.code);
      res.statusCode = 200;
      res.setHeader("Content-Type", "text/plain");
      res.write("OK");
      res.end();
    });
  });

  server.listen(port, hostname, () => {
    console.log(`Sink running at http://${hostname}:${port}/`);
  });
  return server;
}