import { $, path, fs } from 'npm:zx';
import WebUtility from 'npm:web-utility';

const { Second, sleep } = WebUtility;

/**
 * Returns an ISO-8601 timestamp for the start or end (`endOfDay=true`) of a date string.
 */
export const toISOTimestamp = (date: string, endOfDay = false) =>
  endOfDay ? `${date}T23:59:59Z` : `${date}T00:00:00Z`;

export async function resolvePath(
  root: string,
  folder: string,
  file: string,
): Promise<string> {
  const absolutePath = path.isAbsolute(folder)
    ? folder
    : path.resolve(root, folder);

  try {
    const stats = await fs.stat(absolutePath);

    return stats.isDirectory()
      ? path.join(absolutePath, file)
      : absolutePath;
  } catch (error) {
    if ((error as NodeJS.ErrnoException).code === 'ENOENT') return absolutePath;

    throw error;
  }
}

/**
 * Run a GraphQL query via `gh api graphql`.
 */
export async function gql<T = unknown>(
  query: string,
  extraArgs: string[] = [],
): Promise<T> {
  const result = await $`gh api graphql -f query=${query} ${extraArgs}`;

  return (JSON.parse(result.stdout) as { data: T }).data;
}

// ── Rate-limited Search API wrapper ──────────────────────────────────────────

const SEARCH_INTERVAL_S = 2.1;
let _lastSearchAt = 0;

/**
 * Rate-limited wrapper for GitHub Search API (30 requests/min max).
 */
export async function ghSearch<T = unknown>(path: string): Promise<T> {
  const elapsedS = (Date.now() - _lastSearchAt) / Second;

  if (elapsedS < SEARCH_INTERVAL_S) await sleep(SEARCH_INTERVAL_S - elapsedS);

  _lastSearchAt = Date.now();

  const result = await $`gh api ${path}`;

  return JSON.parse(result.stdout) as T;
}