server.js

import { exec } from "child_process";
import { promisify } from "util";
import http from "http";

const execAsync = promisify(exec);

const GITHUB_REPO = process.env.GITHUB_REPO || "Teamtailor/aboard";

let cachedUser = null;

async function getCurrentUser() {
  if (cachedUser) return cachedUser;
  const { stdout } = await execAsync("gh api user --jq .login");
  cachedUser = stdout.trim();
  return cachedUser;
}

const server = http.createServer(async (req, res) => {
  res.setHeader("Access-Control-Allow-Origin", "*");
  res.setHeader("Content-Type", "application/json");

  const url = new URL(req.url, `http://${req.headers.host}`);

  if (url.pathname === "/api/me") {
    try {
      const login = await getCurrentUser();
      res.end(JSON.stringify({ login }));
    } catch (error) {
      res.statusCode = 500;
      res.end(JSON.stringify({ error: error.message }));
    }
  } else if (url.pathname === "/api/prs") {
    try {
      const { stdout } = await execAsync(
        `gh pr list --repo ${GITHUB_REPO} --state merged --limit 1000 --json number,title,url,mergedAt,additions,deletions,author`,
        { maxBuffer: 50 * 1024 * 1024 }
      );
      const prs = JSON.parse(stdout);

      res.end(JSON.stringify({ prs }));
    } catch (error) {
      res.statusCode = 500;
      res.end(JSON.stringify({ error: error.message }));
    }
  } else {
    res.statusCode = 404;
    res.end(JSON.stringify({ error: "Not found" }));
  }
});

server.listen(3002, () => {
  console.log(`API server running on http://localhost:3002`);
  console.log(`Fetching PRs from: ${GITHUB_REPO}`);
});