wehub-resource-sync
9b395f5cc3
Build Chrome Extension / build (push) Waiting to run
Trigger Website Rebuild (Docs Updated) / dispatch (push) Waiting to run
E2E Headed Chrome / e2e-headed (macos-15) (push) Has been cancelled
E2E Headed Chrome / e2e-headed (ubuntu-latest) (push) Has been cancelled
E2E Headed Chrome / e2e-headed (windows-latest) (push) Has been cancelled
CI / build (macos-latest) (push) Has been cancelled
CI / build (ubuntu-latest) (push) Has been cancelled
CI / build (windows-latest) (push) Has been cancelled
CI / unit-test (push) Has been cancelled
CI / bun-test (push) Has been cancelled
CI / adapter-test (push) Has been cancelled
CI / smoke-test (macos-latest) (push) Has been cancelled
CI / smoke-test (ubuntu-latest) (push) Has been cancelled
Security Audit / audit (push) Has been cancelled
405 lines
18 KiB
JavaScript
405 lines
18 KiB
JavaScript
import { afterEach, describe, expect, it, vi } from 'vitest';
|
|
import { getRegistry } from '@jackwener/opencli/registry';
|
|
import { ArgumentError, CommandExecutionError, EmptyResultError } from '@jackwener/opencli/errors';
|
|
import './hot.js';
|
|
import './search.js';
|
|
import './unanswered.js';
|
|
import './bounties.js';
|
|
import './read.js';
|
|
import './tag.js';
|
|
import './user.js';
|
|
|
|
afterEach(() => {
|
|
vi.unstubAllGlobals();
|
|
vi.restoreAllMocks();
|
|
});
|
|
|
|
describe('stackoverflow listing adapters surface question_id/tags/views/owner', () => {
|
|
it('stackoverflow/hot has the agent-native column shape', () => {
|
|
const cmd = getRegistry().get('stackoverflow/hot');
|
|
expect(cmd?.columns).toEqual([
|
|
'rank', 'id', 'title', 'score', 'answers', 'views',
|
|
'is_answered', 'tags', 'author', 'creation_date', 'url',
|
|
]);
|
|
const mapStep = cmd?.pipeline?.find((step) => step.map);
|
|
expect(mapStep?.map).toMatchObject({
|
|
id: '${{ item.question_id }}',
|
|
views: '${{ item.view_count }}',
|
|
is_answered: '${{ item.is_answered }}',
|
|
author: '${{ item.owner.display_name }}',
|
|
creation_date: '${{ item.creation_date }}',
|
|
});
|
|
});
|
|
|
|
it('stackoverflow/search has the agent-native column shape', () => {
|
|
const cmd = getRegistry().get('stackoverflow/search');
|
|
expect(cmd?.columns).toEqual([
|
|
'rank', 'id', 'title', 'score', 'answers', 'views',
|
|
'is_answered', 'tags', 'author', 'creation_date', 'url',
|
|
]);
|
|
const mapStep = cmd?.pipeline?.find((step) => step.map);
|
|
expect(mapStep?.map).toMatchObject({
|
|
id: '${{ item.question_id }}',
|
|
views: '${{ item.view_count }}',
|
|
});
|
|
});
|
|
|
|
it('stackoverflow/unanswered drops is_answered (always false) but keeps the rest', () => {
|
|
const cmd = getRegistry().get('stackoverflow/unanswered');
|
|
expect(cmd?.columns).toEqual([
|
|
'rank', 'id', 'title', 'score', 'answers', 'views',
|
|
'tags', 'author', 'creation_date', 'url',
|
|
]);
|
|
expect(cmd?.columns).not.toContain('is_answered');
|
|
});
|
|
|
|
it('stackoverflow/bounties keeps the bounty column at the front', () => {
|
|
const cmd = getRegistry().get('stackoverflow/bounties');
|
|
expect(cmd?.columns).toEqual([
|
|
'rank', 'id', 'bounty', 'title', 'score', 'answers', 'views',
|
|
'is_answered', 'tags', 'author', 'creation_date', 'url',
|
|
]);
|
|
const mapStep = cmd?.pipeline?.find((step) => step.map);
|
|
expect(mapStep?.map).toMatchObject({
|
|
id: '${{ item.question_id }}',
|
|
bounty: '${{ item.bounty_amount }}',
|
|
});
|
|
});
|
|
|
|
it('stackoverflow/tag exposes id so rows round-trip into read <id>', async () => {
|
|
const cmd = getRegistry().get('stackoverflow/tag');
|
|
expect(cmd?.columns).toEqual([
|
|
'rank', 'id', 'title', 'score', 'answers', 'views',
|
|
'isAnswered', 'tags', 'author', 'createdAt', 'lastActivityAt', 'url',
|
|
]);
|
|
|
|
vi.stubGlobal('fetch', vi.fn().mockResolvedValue(
|
|
new Response(JSON.stringify({
|
|
items: [{
|
|
question_id: 123,
|
|
title: 'Rust & async',
|
|
score: 5,
|
|
answer_count: 2,
|
|
view_count: 100,
|
|
is_answered: true,
|
|
tags: ['rust', 'async'],
|
|
owner: { display_name: 'Ferris's friend' },
|
|
creation_date: 1700000000,
|
|
last_activity_date: 1700003600,
|
|
link: 'https://stackoverflow.com/questions/123/rust-async',
|
|
}],
|
|
}), { status: 200 }),
|
|
));
|
|
|
|
const rows = await cmd.func({ tag: 'rust', sort: 'activity', limit: 1 });
|
|
|
|
expect(rows).toEqual([expect.objectContaining({
|
|
id: 123,
|
|
title: 'Rust & async',
|
|
author: "Ferris's friend",
|
|
url: 'https://stackoverflow.com/questions/123/rust-async',
|
|
})]);
|
|
expect(rows[0]).not.toHaveProperty('questionId');
|
|
});
|
|
|
|
it('stackoverflow/tag rejects bad sort and limit before fetching', async () => {
|
|
const cmd = getRegistry().get('stackoverflow/tag');
|
|
const fetchMock = vi.fn();
|
|
vi.stubGlobal('fetch', fetchMock);
|
|
|
|
await expect(cmd.func({ tag: 'rust', sort: 'invalid', limit: 1 }))
|
|
.rejects.toThrow(ArgumentError);
|
|
await expect(cmd.func({ tag: 'rust', sort: 'activity', limit: 101 }))
|
|
.rejects.toThrow(ArgumentError);
|
|
expect(fetchMock).not.toHaveBeenCalled();
|
|
});
|
|
|
|
it('stackoverflow/user exposes userId profile rows without pretending they feed read <id>', async () => {
|
|
const cmd = getRegistry().get('stackoverflow/user');
|
|
expect(cmd?.columns).toEqual([
|
|
'userId', 'displayName', 'reputation', 'goldBadges', 'silverBadges',
|
|
'bronzeBadges', 'location', 'createdAt', 'lastAccessAt', 'url',
|
|
]);
|
|
});
|
|
});
|
|
|
|
describe('stackoverflow/read adapter', () => {
|
|
const cmd = getRegistry().get('stackoverflow/read');
|
|
|
|
it('registers the question/answer/comment row shape', () => {
|
|
expect(cmd?.columns).toEqual(['type', 'author', 'score', 'accepted', 'text']);
|
|
});
|
|
|
|
it('takes a positional id plus tunable answers-limit/comments-limit/max-length', () => {
|
|
const argNames = (cmd?.args || []).map((a) => a.name);
|
|
expect(argNames).toEqual(['id', 'answers-limit', 'comments-limit', 'max-length']);
|
|
const idArg = cmd?.args?.find((a) => a.name === 'id');
|
|
expect(idArg?.required).toBe(true);
|
|
expect(idArg?.positional).toBe(true);
|
|
});
|
|
|
|
it('uses the public Stack Exchange API (no browser, public strategy)', () => {
|
|
expect(cmd?.browser).toBe(false);
|
|
expect(cmd?.strategy).toBe('public');
|
|
});
|
|
|
|
it('fails fast with ArgumentError for non-numeric id before fetching', async () => {
|
|
const fetchMock = vi.fn();
|
|
vi.stubGlobal('fetch', fetchMock);
|
|
|
|
await expect(cmd.func({ id: 'not-a-number', 'answers-limit': 10, 'comments-limit': 5, 'max-length': 4000 }))
|
|
.rejects.toThrow(ArgumentError);
|
|
expect(fetchMock).not.toHaveBeenCalled();
|
|
});
|
|
|
|
it('fails fast with ArgumentError for max-length below 100 before fetching', async () => {
|
|
const fetchMock = vi.fn();
|
|
vi.stubGlobal('fetch', fetchMock);
|
|
|
|
await expect(cmd.func({ id: '12345', 'answers-limit': 10, 'comments-limit': 5, 'max-length': 50 }))
|
|
.rejects.toThrow(ArgumentError);
|
|
expect(fetchMock).not.toHaveBeenCalled();
|
|
});
|
|
|
|
it('fails fast with EmptyResultError when the question lookup returns empty items', async () => {
|
|
vi.stubGlobal('fetch', vi.fn().mockResolvedValue(
|
|
new Response(JSON.stringify({ items: [] }), { status: 200 }),
|
|
));
|
|
|
|
await expect(cmd.func({ id: '99999999', 'answers-limit': 10, 'comments-limit': 5, 'max-length': 4000 }))
|
|
.rejects.toThrow(EmptyResultError);
|
|
});
|
|
|
|
it('surfaces Stack Exchange API throttle / quota errors as CommandExecutionError', async () => {
|
|
vi.stubGlobal('fetch', vi.fn().mockResolvedValue(
|
|
new Response(JSON.stringify({ error_id: 502, error_name: 'throttle_violation', error_message: 'too fast' }), { status: 200 }),
|
|
));
|
|
|
|
await expect(cmd.func({ id: '12345', 'answers-limit': 10, 'comments-limit': 5, 'max-length': 4000 }))
|
|
.rejects.toThrow(CommandExecutionError);
|
|
});
|
|
|
|
it('wraps fetch network failures in CommandExecutionError (not raw TypeError)', async () => {
|
|
vi.stubGlobal('fetch', vi.fn().mockRejectedValue(new TypeError('fetch failed')));
|
|
|
|
await expect(cmd.func({ id: '12345', 'answers-limit': 10, 'comments-limit': 5, 'max-length': 4000 }))
|
|
.rejects.toThrow(CommandExecutionError);
|
|
});
|
|
|
|
it('wraps malformed JSON responses in CommandExecutionError (not raw SyntaxError)', async () => {
|
|
vi.stubGlobal('fetch', vi.fn().mockResolvedValue(
|
|
new Response('<!DOCTYPE html><html>maintenance</html>', { status: 200 }),
|
|
));
|
|
|
|
await expect(cmd.func({ id: '12345', 'answers-limit': 10, 'comments-limit': 5, 'max-length': 4000 }))
|
|
.rejects.toThrow(CommandExecutionError);
|
|
});
|
|
|
|
it('coerces and validates string-form numeric args (e.g. "50" not Number(50))', async () => {
|
|
const fetchMock = vi.fn();
|
|
vi.stubGlobal('fetch', fetchMock);
|
|
|
|
// String "50" should still be rejected because it's < 100
|
|
await expect(cmd.func({ id: '12345', 'answers-limit': 10, 'comments-limit': 5, 'max-length': '50' }))
|
|
.rejects.toThrow(ArgumentError);
|
|
expect(fetchMock).not.toHaveBeenCalled();
|
|
|
|
// String "abc" should also be rejected
|
|
await expect(cmd.func({ id: '12345', 'answers-limit': 10, 'comments-limit': 5, 'max-length': 'abc' }))
|
|
.rejects.toThrow(ArgumentError);
|
|
expect(fetchMock).not.toHaveBeenCalled();
|
|
});
|
|
|
|
it('rejects answer/comment limits above Stack Exchange pagesize max before fetching', async () => {
|
|
const fetchMock = vi.fn();
|
|
vi.stubGlobal('fetch', fetchMock);
|
|
|
|
await expect(cmd.func({ id: '12345', 'answers-limit': '101', 'comments-limit': 5, 'max-length': 4000 }))
|
|
.rejects.toThrow(ArgumentError);
|
|
await expect(cmd.func({ id: '12345', 'answers-limit': 10, 'comments-limit': '101', 'max-length': 4000 }))
|
|
.rejects.toThrow(ArgumentError);
|
|
expect(fetchMock).not.toHaveBeenCalled();
|
|
});
|
|
|
|
it('builds POST + Q-COMMENT + ANSWER + A-COMMENT rows, accepted answer first', async () => {
|
|
const question = {
|
|
items: [{
|
|
question_id: 1,
|
|
title: 'Why?',
|
|
body: '<p>Question body</p>',
|
|
score: 10,
|
|
link: 'https://example.com/q/1',
|
|
owner: { display_name: 'asker' },
|
|
}],
|
|
};
|
|
const qComments = {
|
|
items: [
|
|
{ score: 2, owner: { display_name: 'qc1' }, body: '<p>q comment one</p>' },
|
|
{ score: 1, owner: { display_name: 'qc2' }, body: '<p>q comment two</p>' },
|
|
],
|
|
};
|
|
const answers = {
|
|
items: [
|
|
{ answer_id: 100, score: 5, is_accepted: false, owner: { display_name: 'low' }, body: '<p>low score answer</p>' },
|
|
{ answer_id: 200, score: 50, is_accepted: true, owner: { display_name: 'winner' }, body: '<p>accepted answer</p>' },
|
|
],
|
|
};
|
|
const answerComments = {
|
|
items: [
|
|
{ post_id: 200, score: 1, owner: { display_name: 'ac1' }, body: '<p>comment on accepted</p>' },
|
|
{ post_id: 100, score: 0, owner: { display_name: 'ac2' }, body: '<p>comment on low</p>' },
|
|
],
|
|
};
|
|
const fetchMock = vi.fn()
|
|
.mockResolvedValueOnce(new Response(JSON.stringify(question), { status: 200 }))
|
|
.mockResolvedValueOnce(new Response(JSON.stringify(qComments), { status: 200 }))
|
|
.mockResolvedValueOnce(new Response(JSON.stringify(answers), { status: 200 }))
|
|
.mockResolvedValueOnce(new Response(JSON.stringify(answerComments), { status: 200 }));
|
|
vi.stubGlobal('fetch', fetchMock);
|
|
|
|
const rows = await cmd.func({ id: '1', 'answers-limit': 10, 'comments-limit': 5, 'max-length': 4000 });
|
|
|
|
expect(rows.map((r) => [r.type, r.author, r.accepted])).toEqual([
|
|
['POST', 'asker', ''],
|
|
['Q-COMMENT', 'qc1', ''],
|
|
['Q-COMMENT', 'qc2', ''],
|
|
['ANSWER', 'winner', 'true'], // accepted comes FIRST
|
|
['A-COMMENT', 'ac1', ''],
|
|
['ANSWER', 'low', ''],
|
|
['A-COMMENT', 'ac2', ''],
|
|
]);
|
|
|
|
// Verify the answer-comments fetch batched both answer ids
|
|
const ansCommentsCall = fetchMock.mock.calls[3][0];
|
|
expect(ansCommentsCall).toContain('/answers/200;100/comments');
|
|
expect(fetchMock.mock.calls[1][0]).toContain('pagesize=5');
|
|
expect(fetchMock.mock.calls[2][0]).toContain('pagesize=10');
|
|
expect(fetchMock.mock.calls[3][0]).toContain('pagesize=10');
|
|
});
|
|
|
|
it('fetches accepted answer separately when it is missing from the votes page', async () => {
|
|
const question = {
|
|
items: [{
|
|
question_id: 1,
|
|
accepted_answer_id: 999,
|
|
title: 'Why?',
|
|
body: '<p>Question body</p>',
|
|
score: 10,
|
|
link: 'https://example.com/q/1',
|
|
owner: { display_name: 'asker' },
|
|
}],
|
|
};
|
|
const answers = {
|
|
items: [
|
|
{ answer_id: 100, score: 50, is_accepted: false, owner: { display_name: 'top-voted' }, body: '<p>top voted answer</p>' },
|
|
],
|
|
};
|
|
const acceptedAnswer = {
|
|
items: [
|
|
{ answer_id: 999, score: 1, is_accepted: true, owner: { display_name: 'accepted' }, body: '<p>accepted answer</p>' },
|
|
],
|
|
};
|
|
const fetchMock = vi.fn()
|
|
.mockResolvedValueOnce(new Response(JSON.stringify(question), { status: 200 }))
|
|
.mockResolvedValueOnce(new Response(JSON.stringify({ items: [] }), { status: 200 }))
|
|
.mockResolvedValueOnce(new Response(JSON.stringify(answers), { status: 200 }))
|
|
.mockResolvedValueOnce(new Response(JSON.stringify(acceptedAnswer), { status: 200 }))
|
|
.mockResolvedValueOnce(new Response(JSON.stringify({ items: [] }), { status: 200 }));
|
|
vi.stubGlobal('fetch', fetchMock);
|
|
|
|
const rows = await cmd.func({ id: '1', 'answers-limit': 2, 'comments-limit': 5, 'max-length': 4000 });
|
|
|
|
expect(rows.filter((r) => r.type === 'ANSWER').map((r) => [r.author, r.accepted])).toEqual([
|
|
['accepted', 'true'],
|
|
['top-voted', ''],
|
|
]);
|
|
expect(fetchMock.mock.calls[3][0]).toContain('/answers/999?');
|
|
expect(fetchMock.mock.calls[4][0]).toContain('/answers/999;100/comments');
|
|
expect(fetchMock.mock.calls[4][0]).toContain('pagesize=10');
|
|
});
|
|
|
|
it('fails fast when batched answer comments would be partial', async () => {
|
|
const question = {
|
|
items: [{
|
|
question_id: 1,
|
|
title: 'Why?',
|
|
body: '<p>Question body</p>',
|
|
score: 10,
|
|
link: 'https://example.com/q/1',
|
|
owner: { display_name: 'asker' },
|
|
}],
|
|
};
|
|
const answers = {
|
|
items: [
|
|
{ answer_id: 100, score: 50, is_accepted: false, owner: { display_name: 'a1' }, body: '<p>one</p>' },
|
|
{ answer_id: 200, score: 40, is_accepted: false, owner: { display_name: 'a2' }, body: '<p>two</p>' },
|
|
],
|
|
};
|
|
const answerComments = {
|
|
has_more: true,
|
|
items: [
|
|
{ post_id: 100, score: 1, owner: { display_name: 'c1' }, body: '<p>comment on first</p>' },
|
|
],
|
|
};
|
|
const fetchMock = vi.fn()
|
|
.mockResolvedValueOnce(new Response(JSON.stringify(question), { status: 200 }))
|
|
.mockResolvedValueOnce(new Response(JSON.stringify({ items: [] }), { status: 200 }))
|
|
.mockResolvedValueOnce(new Response(JSON.stringify(answers), { status: 200 }))
|
|
.mockResolvedValueOnce(new Response(JSON.stringify(answerComments), { status: 200 }));
|
|
vi.stubGlobal('fetch', fetchMock);
|
|
|
|
await expect(cmd.func({ id: '1', 'answers-limit': 2, 'comments-limit': 1, 'max-length': 4000 }))
|
|
.rejects.toThrow(CommandExecutionError);
|
|
});
|
|
|
|
it('decodes HTML entities in body and display_name (named, decimal, hex)', async () => {
|
|
const question = {
|
|
items: [{
|
|
question_id: 1,
|
|
title: 't',
|
|
body: '<p>price < & … ö 'ok'</p>',
|
|
score: 0,
|
|
link: '',
|
|
owner: { display_name: 'Jonas Kölker' },
|
|
}],
|
|
};
|
|
const fetchMock = vi.fn()
|
|
.mockResolvedValueOnce(new Response(JSON.stringify(question), { status: 200 }))
|
|
.mockResolvedValueOnce(new Response(JSON.stringify({ items: [] }), { status: 200 }))
|
|
.mockResolvedValueOnce(new Response(JSON.stringify({ items: [] }), { status: 200 }));
|
|
vi.stubGlobal('fetch', fetchMock);
|
|
|
|
const rows = await cmd.func({ id: '1', 'answers-limit': 10, 'comments-limit': 5, 'max-length': 4000 });
|
|
|
|
expect(rows[0].author).toBe('Jonas Kölker');
|
|
expect(rows[0].text).toContain('price < & … ö \'ok\'');
|
|
});
|
|
|
|
it('respects answers-limit when there are more answers than the cap', async () => {
|
|
const question = {
|
|
items: [{
|
|
question_id: 1, title: 't', body: '', score: 0, link: '',
|
|
owner: { display_name: 'a' },
|
|
}],
|
|
};
|
|
const answers = {
|
|
items: [
|
|
{ answer_id: 100, score: 5, is_accepted: false, owner: { display_name: 'a1' }, body: '' },
|
|
{ answer_id: 200, score: 4, is_accepted: false, owner: { display_name: 'a2' }, body: '' },
|
|
{ answer_id: 300, score: 3, is_accepted: false, owner: { display_name: 'a3' }, body: '' },
|
|
],
|
|
};
|
|
const fetchMock = vi.fn()
|
|
.mockResolvedValueOnce(new Response(JSON.stringify(question), { status: 200 }))
|
|
.mockResolvedValueOnce(new Response(JSON.stringify({ items: [] }), { status: 200 }))
|
|
.mockResolvedValueOnce(new Response(JSON.stringify(answers), { status: 200 }))
|
|
.mockResolvedValueOnce(new Response(JSON.stringify({ items: [] }), { status: 200 }));
|
|
vi.stubGlobal('fetch', fetchMock);
|
|
|
|
const rows = await cmd.func({ id: '1', 'answers-limit': 2, 'comments-limit': 5, 'max-length': 4000 });
|
|
|
|
const answerRows = rows.filter((r) => r.type === 'ANSWER');
|
|
expect(answerRows.map((r) => r.author)).toEqual(['a1', 'a2']);
|
|
});
|
|
});
|