jackwener--opencli/tests/e2e/public-commands.test.ts

/**
 * E2E tests for public API commands (browser: false).
 * These commands use Node.js fetch directly — no browser needed.
 */

import { describe, expect, it } from 'vitest';
import * as fs from 'node:fs/promises';
import * as os from 'node:os';
import * as path from 'node:path';
import { parseJsonOutput, runCli } from './helpers.js';

function isExpectedChineseSiteRestriction(code: number, stderr: string): boolean {
  if (code === 0) return false;
  // Overseas CI runners may get HTTP errors, geo-blocks, DNS failures,
  // or receive mangled HTML that fails parsing. Some runners also fail
  // without surfacing a useful stderr payload.
  // Exit code 78 (CONFIG_ERROR) covers adapters that migrated to authenticated
  // APIs — credentials won't be available in CI.
  return /Error \[(FETCH_ERROR|PARSE_ERROR|NOT_FOUND)\]/.test(stderr)
    || /fetch failed/.test(stderr)
    || /code: CONFIG/.test(stderr)
    || code === 78
    || stderr.trim() === '';
}

function isExpectedApplePodcastsRestriction(code: number, stderr: string): boolean {
  if (code === 0) return false;
  return /(?:Error \[FETCH_ERROR\]: )?(Charts API HTTP \d+|Unable to reach Apple Podcasts charts)/.test(stderr)
    || stderr === ''; // timeout killed the process before any output
}

function isExpectedGoogleRestriction(code: number, stderr: string): boolean {
  if (code === 0) return false;
  // Network unreachable (DNS/proxy) or HTTP error from Google
  return /fetch failed/.test(stderr) || /Error \[FETCH_ERROR\]: HTTP (403|429|451|503)\b/.test(stderr);
}

// Keep old name as alias for existing tests
const isExpectedXiaoyuzhouRestriction = isExpectedChineseSiteRestriction;

describe('public command restriction detectors', () => {
  it('treats current Apple Podcasts CliError rendering as an expected restriction', () => {
    expect(
      isExpectedApplePodcastsRestriction(
        1,
        '⚠️ Unable to reach Apple Podcasts charts for US\n→ Apple charts may be temporarily unavailable (ECONNRESET). Try again later.\n',
      ),
    ).toBe(true);
  });
});

describe('public commands E2E', () => {
  // ── apple-podcasts ──
  it('apple-podcasts search returns structured podcast results', async () => {
    const { stdout, code } = await runCli(['apple-podcasts', 'search', 'technology', '--limit', '3', '-f', 'json']);
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBeGreaterThanOrEqual(1);
    expect(data[0]).toHaveProperty('id');
    expect(data[0]).toHaveProperty('title');
    expect(data[0]).toHaveProperty('author');
  }, 30_000);

  it('apple-podcasts episodes returns episode list from a known show', async () => {
    const { stdout, code } = await runCli(['apple-podcasts', 'episodes', '275699983', '--limit', '3', '-f', 'json']);
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBeGreaterThanOrEqual(1);
    expect(data[0]).toHaveProperty('title');
    expect(data[0]).toHaveProperty('duration');
    expect(data[0]).toHaveProperty('date');
  }, 30_000);

  it('apple-podcasts top returns ranked podcasts', async () => {
    const { stdout, stderr, code } = await runCli([
      'apple-podcasts',
      'top',
      '--limit',
      '3',
      '--country',
      'us',
      '-f',
      'json',
    ]);
    if (isExpectedApplePodcastsRestriction(code, stderr)) {
      console.warn(`apple-podcasts top skipped: ${stderr.trim()}`);
      return;
    }
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBe(3);
    expect(data[0]).toHaveProperty('rank');
    expect(data[0]).toHaveProperty('title');
    expect(data[0]).toHaveProperty('id');
  }, 30_000);

  it('paperreview submit dry-run validates a local PDF without remote upload', async () => {
    const tempDir = await fs.mkdtemp(path.join(os.tmpdir(), 'opencli-paperreview-'));
    const pdfPath = path.join(tempDir, 'sample.pdf');
    await fs.writeFile(pdfPath, Buffer.concat([Buffer.from('%PDF-1.4\n'), Buffer.alloc(256, 1)]));

    const { stdout, code } = await runCli([
      'paperreview',
      'submit',
      pdfPath,
      '--email',
      'wang2629651228@gmail.com',
      '--venue',
      'RAL',
      '--dry-run',
      'true',
      '-f',
      'json',
    ]);

    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(data).toMatchObject({
      status: 'dry-run',
      file: 'sample.pdf',
      email: 'wang2629651228@gmail.com',
      venue: 'RAL',
    });
  }, 30_000);

  // ── hackernews ──
  it('hackernews top returns structured data', async () => {
    const { stdout, code } = await runCli(['hackernews', 'top', '--limit', '3', '-f', 'json']);
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBe(3);
    expect(data[0]).toHaveProperty('title');
    expect(data[0]).toHaveProperty('score');
    expect(data[0]).toHaveProperty('rank');
  }, 30_000);

  it('hackernews top respects --limit', async () => {
    const { stdout, code } = await runCli(['hackernews', 'top', '--limit', '1', '-f', 'json']);
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(data.length).toBe(1);
  }, 30_000);

  it('hackernews new returns newest stories', async () => {
    const { stdout, code } = await runCli(['hackernews', 'new', '--limit', '3', '-f', 'json']);
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBeGreaterThanOrEqual(1);
    expect(data[0]).toHaveProperty('title');
    expect(data[0]).toHaveProperty('score');
    expect(data[0]).toHaveProperty('rank');
  }, 30_000);

  it('hackernews best returns best stories', async () => {
    const { stdout, code } = await runCli(['hackernews', 'best', '--limit', '3', '-f', 'json']);
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBeGreaterThanOrEqual(1);
    expect(data[0]).toHaveProperty('title');
    expect(data[0]).toHaveProperty('score');
  }, 30_000);

  it('hackernews ask returns Ask HN posts', async () => {
    const { stdout, code } = await runCli(['hackernews', 'ask', '--limit', '3', '-f', 'json']);
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBeGreaterThanOrEqual(1);
    expect(data[0]).toHaveProperty('title');
  }, 30_000);

  it('hackernews show returns Show HN posts', async () => {
    const { stdout, code } = await runCli(['hackernews', 'show', '--limit', '3', '-f', 'json']);
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBeGreaterThanOrEqual(1);
    expect(data[0]).toHaveProperty('title');
  }, 30_000);

  it('hackernews jobs returns job postings', async () => {
    const { stdout, code } = await runCli(['hackernews', 'jobs', '--limit', '3', '-f', 'json']);
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBeGreaterThanOrEqual(1);
    expect(data[0]).toHaveProperty('title');
    expect(data[0]).toHaveProperty('url');
  }, 30_000);

  it('hackernews search returns results for query', async () => {
    const { stdout, code } = await runCli(['hackernews', 'search', 'typescript', '--limit', '3', '-f', 'json']);
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBe(3);
    expect(data[0]).toHaveProperty('title');
    expect(data[0]).toHaveProperty('score');
    expect(data[0]).toHaveProperty('author');
  }, 30_000);

  it('hackernews user returns user profile', async () => {
    const { stdout, code } = await runCli(['hackernews', 'user', 'pg', '-f', 'json']);
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBe(1);
    expect(data[0]).toHaveProperty('username', 'pg');
    expect(data[0]).toHaveProperty('karma');
  }, 30_000);

  // ── v2ex (public API, browser: false) ──
  it('v2ex hot returns topics', async () => {
    const { stdout, code } = await runCli(['v2ex', 'hot', '--limit', '3', '-f', 'json']);
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBeGreaterThanOrEqual(1);
    expect(data[0]).toHaveProperty('title');
  }, 30_000);

  it('v2ex latest returns topics', async () => {
    const { stdout, code } = await runCli(['v2ex', 'latest', '--limit', '3', '-f', 'json']);
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBeGreaterThanOrEqual(1);
  }, 30_000);

  it('v2ex topic returns topic detail', async () => {
    // Topic 1000001 is a well-known V2EX topic
    const { stdout, code } = await runCli(['v2ex', 'topic', '1000001', '-f', 'json']);
    // May fail if V2EX rate-limits, but should return structured data
    if (code === 0) {
      const data = parseJsonOutput(stdout);
      expect(data).toBeDefined();
    }
  }, 30_000);

  it('v2ex node returns topics for a given node', async () => {
    const { stdout, code } = await runCli(['v2ex', 'node', 'python', '--limit', '3', '-f', 'json']);
    // V2EX may rate-limit; only assert when successful
    if (code === 0) {
      const data = parseJsonOutput(stdout);
      expect(Array.isArray(data)).toBe(true);
      expect(data.length).toBeGreaterThanOrEqual(1);
      expect(data.length).toBeLessThanOrEqual(3);
      expect(data[0]).toHaveProperty('title');
      expect(data[0]).toHaveProperty('author');
      expect(data[0]).toHaveProperty('url');
    }
  }, 30_000);

  it('v2ex user returns topics by username', async () => {
    const { stdout, code } = await runCli(['v2ex', 'user', 'Livid', '--limit', '3', '-f', 'json']);
    if (code === 0) {
      const data = parseJsonOutput(stdout);
      expect(Array.isArray(data)).toBe(true);
      expect(data.length).toBeGreaterThanOrEqual(1);
      expect(data.length).toBeLessThanOrEqual(3);
      expect(data[0]).toHaveProperty('title');
      expect(data[0]).toHaveProperty('node');
      expect(data[0]).toHaveProperty('url');
    }
  }, 30_000);

  it('v2ex member returns user profile', async () => {
    const { stdout, code } = await runCli(['v2ex', 'member', 'Livid', '-f', 'json']);
    if (code === 0) {
      const data = parseJsonOutput(stdout);
      expect(Array.isArray(data)).toBe(true);
      expect(data.length).toBe(1);
      expect(data[0].username).toBe('Livid');
    }
  }, 30_000);

  it('v2ex replies returns topic replies', async () => {
    const { stdout, code } = await runCli(['v2ex', 'replies', '1000', '--limit', '3', '-f', 'json']);
    if (code === 0) {
      const data = parseJsonOutput(stdout);
      expect(Array.isArray(data)).toBe(true);
      expect(data.length).toBeGreaterThanOrEqual(1);
      expect(data.length).toBeLessThanOrEqual(3);
      expect(data[0]).toHaveProperty('author');
      expect(data[0]).toHaveProperty('content');
    }
  }, 30_000);

  it('v2ex nodes returns node list sorted by topics', async () => {
    const { stdout, code } = await runCli(['v2ex', 'nodes', '--limit', '5', '-f', 'json']);
    if (code === 0) {
      const data = parseJsonOutput(stdout);
      expect(Array.isArray(data)).toBe(true);
      expect(data.length).toBe(5);
      expect(data[0]).toHaveProperty('name');
      expect(data[0]).toHaveProperty('title');
      expect(data[0]).toHaveProperty('topics');
      // Verify descending sort by topic count
      expect(Number(data[0].topics)).toBeGreaterThanOrEqual(Number(data[data.length - 1].topics));
    }
  }, 30_000);

  // ── xiaoyuzhou (Chinese site — may return empty on overseas CI runners) ──
  it('xiaoyuzhou podcast returns podcast profile', async () => {
    const { stdout, stderr, code } = await runCli(['xiaoyuzhou', 'podcast', '6013f9f58e2f7ee375cf4216', '-f', 'json']);
    if (isExpectedXiaoyuzhouRestriction(code, stderr)) {
      console.warn(`xiaoyuzhou podcast skipped: ${stderr.trim()}`);
      return;
    }
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBe(1);
    expect(data[0]).toHaveProperty('title');
    expect(data[0]).toHaveProperty('subscribers');
    expect(data[0]).toHaveProperty('episodes');
  }, 30_000);

  it('xiaoyuzhou podcast-episodes returns episode list', async () => {
    const { stdout, stderr, code } = await runCli([
      'xiaoyuzhou',
      'podcast-episodes',
      '6013f9f58e2f7ee375cf4216',
      '-f',
      'json',
    ]);
    if (isExpectedXiaoyuzhouRestriction(code, stderr)) {
      console.warn(`xiaoyuzhou podcast-episodes skipped: ${stderr.trim()}`);
      return;
    }
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBeGreaterThanOrEqual(1);
    expect(data[0]).toHaveProperty('eid');
    expect(data[0]).toHaveProperty('title');
    expect(data[0]).toHaveProperty('duration');
  }, 30_000);

  it('xiaoyuzhou episode returns episode detail', async () => {
    const { stdout, stderr, code } = await runCli(['xiaoyuzhou', 'episode', '69b3b675772ac2295bfc01d0', '-f', 'json']);
    if (isExpectedXiaoyuzhouRestriction(code, stderr)) {
      console.warn(`xiaoyuzhou episode skipped: ${stderr.trim()}`);
      return;
    }
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBe(1);
    expect(data[0]).toHaveProperty('title');
    expect(data[0]).toHaveProperty('podcast');
    expect(data[0]).toHaveProperty('plays');
    expect(data[0]).toHaveProperty('comments');
  }, 30_000);

  it('xiaoyuzhou podcast-episodes rejects invalid limit', async () => {
    const { stderr, code } = await runCli([
      'xiaoyuzhou',
      'podcast-episodes',
      '6013f9f58e2f7ee375cf4216',
      '--limit',
      'abc',
      '-f',
      'json',
    ]);
    if (isExpectedXiaoyuzhouRestriction(code, stderr)) {
      console.warn(`xiaoyuzhou invalid-limit skipped: ${stderr.trim()}`);
      return;
    }
    expect(code).not.toBe(0);
    expect(stderr).toMatch(/limit must be a positive integer|Argument "limit" must be a valid number/);
  }, 30_000);

  // ── google suggest (public JSON API) ──
  it('google suggest returns suggestions', async () => {
    const { stdout, stderr, code } = await runCli(['google', 'suggest', 'python', '-f', 'json']);
    if (isExpectedGoogleRestriction(code, stderr)) {
      console.warn(`google suggest skipped: ${stderr.trim()}`);
      return;
    }
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBeGreaterThanOrEqual(1);
    expect(data[0]).toHaveProperty('suggestion');
  }, 30_000);

  // ── google news (public RSS) ──
  it('google news returns headlines', async () => {
    const { stdout, stderr, code } = await runCli(['google', 'news', '--limit', '3', '-f', 'json']);
    if (isExpectedGoogleRestriction(code, stderr)) {
      console.warn(`google news skipped: ${stderr.trim()}`);
      return;
    }
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBeGreaterThanOrEqual(1);
    expect(data[0]).toHaveProperty('title');
    expect(data[0]).toHaveProperty('source');
    expect(data[0]).toHaveProperty('url');
  }, 30_000);

  it('google news search returns results', async () => {
    const { stdout, stderr, code } = await runCli(['google', 'news', 'AI', '--limit', '3', '-f', 'json']);
    if (isExpectedGoogleRestriction(code, stderr)) {
      console.warn(`google news search skipped: ${stderr.trim()}`);
      return;
    }
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBeGreaterThanOrEqual(1);
    expect(data[0]).toHaveProperty('title');
  }, 30_000);

  // ── google trends (public RSS) ──
  it('google trends returns trending searches', async () => {
    const { stdout, stderr, code } = await runCli(['google', 'trends', '--region', 'US', '--limit', '3', '-f', 'json']);
    if (isExpectedGoogleRestriction(code, stderr)) {
      console.warn(`google trends skipped: ${stderr.trim()}`);
      return;
    }
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBeGreaterThanOrEqual(1);
    expect(data[0]).toHaveProperty('title');
    expect(data[0]).toHaveProperty('traffic');
  }, 30_000);

  // ── weread (Chinese site — may return empty on overseas CI runners) ──
  it('weread search returns books', async () => {
    const { stdout, stderr, code } = await runCli(['weread', 'search', 'python', '--limit', '3', '-f', 'json']);
    if (isExpectedChineseSiteRestriction(code, stderr)) {
      console.warn(`weread search skipped: ${stderr.trim()}`);
      return;
    }
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBeGreaterThanOrEqual(1);
    expect(data[0]).toHaveProperty('title');
    expect(data[0]).toHaveProperty('bookId');
  }, 30_000);

  it('weread ranking returns books', async () => {
    const { stdout, stderr, code } = await runCli(['weread', 'ranking', 'all', '--limit', '3', '-f', 'json']);
    if (isExpectedChineseSiteRestriction(code, stderr)) {
      console.warn(`weread ranking skipped: ${stderr.trim()}`);
      return;
    }
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBeGreaterThanOrEqual(1);
    expect(data[0]).toHaveProperty('title');
    expect(data[0]).toHaveProperty('readingCount');
    expect(data[0]).toHaveProperty('bookId');
  }, 30_000);

  // ── yollomi (browser: false, hardcoded data) ──
  it('yollomi models returns model list with all types', async () => {
    const { stdout, code } = await runCli(['yollomi', 'models', '-f', 'json']);
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBeGreaterThan(10);
    expect(data[0]).toHaveProperty('type');
    expect(data[0]).toHaveProperty('model');
    expect(data[0]).toHaveProperty('credits');
    expect(data[0]).toHaveProperty('description');
    const types = new Set(data.map((d: any) => d.type));
    expect(types.has('image')).toBe(true);
    expect(types.has('video')).toBe(true);
    expect(types.has('tool')).toBe(true);
  }, 30_000);

  it('yollomi models --type image filters correctly', async () => {
    const { stdout, code } = await runCli(['yollomi', 'models', '--type', 'image', '-f', 'json']);
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(data.length).toBeGreaterThan(0);
    expect(data.every((d: any) => d.type === 'image')).toBe(true);
  }, 30_000);

  // ── dictionary (public API, browser: false) ──
  it('dictionary search returns word definitions', async () => {
    const { stdout, code } = await runCli(['dictionary', 'search', 'serendipity', '-f', 'json']);
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBeGreaterThanOrEqual(1);
    expect(data[0]).toHaveProperty('word', 'serendipity');
    expect(data[0]).toHaveProperty('phonetic');
    expect(data[0]).toHaveProperty('definition');
  }, 30_000);

  it('dictionary synonyms returns synonyms', async () => {
    const { stdout, code } = await runCli(['dictionary', 'synonyms', 'serendipity', '-f', 'json']);
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBeGreaterThanOrEqual(1);
    expect(data[0]).toHaveProperty('word', 'serendipity');
    expect(data[0]).toHaveProperty('synonyms');
  }, 30_000);

  it('dictionary examples returns examples', async () => {
    const { stdout, code } = await runCli(['dictionary', 'examples', 'perfect', '-f', 'json']);
    expect(code).toBe(0);
    const data = parseJsonOutput(stdout);
    expect(Array.isArray(data)).toBe(true);
    expect(data.length).toBeGreaterThanOrEqual(1);
    expect(data[0]).toHaveProperty('word', 'perfect');
    expect(data[0]).toHaveProperty('example');
  }, 30_000);
});