git.js

const { execFile } = require('child_process');

let _logger = null;

function setLogger(fn) {
  _logger = fn;
}

// Run a git command safely. Only execFile (no shell), arguments as array.
function run(repoPath, args) {
  const command = `git ${args.join(' ')}`;
  if (_logger) _logger({ type: 'cmd', timestamp: new Date().toISOString(), cwd: repoPath, command });

  return new Promise((resolve, reject) => {
    execFile('git', args, { cwd: repoPath, timeout: 30000 }, (err, stdout, stderr) => {
      if (err) {
        if (_logger) _logger({ type: 'error', timestamp: new Date().toISOString(), command, text: stderr.trim() || err.message });
        reject(new Error(stderr.trim() || err.message));
      } else {
        if (_logger && stdout.trim()) _logger({ type: 'output', timestamp: new Date().toISOString(), command, text: stdout.trim() });
        resolve(stdout.trim());
      }
    });
  });
}

// Check if git is available on PATH
async function gitVersion() {
  const command = 'git --version';
  if (_logger) _logger({ type: 'cmd', timestamp: new Date().toISOString(), cwd: null, command });
  return new Promise((resolve, reject) => {
    execFile('git', ['--version'], { timeout: 5000 }, (err, stdout) => {
      if (err) {
        if (_logger) _logger({ type: 'error', timestamp: new Date().toISOString(), command, text: 'Git is not installed or not on PATH' });
        reject(new Error('Git is not installed or not on PATH'));
      } else {
        if (_logger && stdout.trim()) _logger({ type: 'output', timestamp: new Date().toISOString(), command, text: stdout.trim() });
        resolve(stdout.trim());
      }
    });
  });
}

async function gitFetch(repoPath) {
  return run(repoPath, ['fetch', '--all']);
}

async function gitCheckout(repoPath, branch) {
  return run(repoPath, ['checkout', branch]);
}

async function gitPull(repoPath) {
  return run(repoPath, ['pull']);
}

// Returns raw porcelain output. Empty string = clean.
async function gitStatus(repoPath) {
  return run(repoPath, ['status', '--porcelain']);
}

async function gitCurrentBranch(repoPath) {
  return run(repoPath, ['rev-parse', '--abbrev-ref', 'HEAD']);
}

async function gitRemoteUrl(repoPath) {
  return run(repoPath, ['remote', 'get-url', 'origin']);
}

async function gitBranchList(repoPath) {
  const output = await run(repoPath, ['branch', '-a']);
  return output.split('\n').map(b => b.replace('*', '').trim()).filter(Boolean);
}

// Parse org/repo from a remote URL
// Supports: https://github.com/org/repo.git, git@github.com:org/repo.git
function parseRepoId(remoteUrl) {
  // HTTPS format
  let match = remoteUrl.match(/github\.com\/([^/]+\/[^/]+?)(?:\.git)?$/);
  if (match) return match[1];
  // SSH format
  match = remoteUrl.match(/github\.com:([^/]+\/[^/]+?)(?:\.git)?$/);
  if (match) return match[1];
  // Generic: take last two path segments
  match = remoteUrl.match(/\/([^/]+\/[^/]+?)(?:\.git)?$/);
  if (match) return match[1];
  return null;
}

module.exports = {
  setLogger,
  gitVersion,
  gitFetch,
  gitCheckout,
  gitPull,
  gitStatus,
  gitCurrentBranch,
  gitRemoteUrl,
  gitBranchList,
  parseRepoId,
};