CheapestInference
1aad1e0313
Auto-retry Claude Code sessions when hitting Anthropic subscription rate limits. Uses tmux monitoring + send-keys to detect rate limit messages, wait for reset, and send "continue" automatically. Zero dependencies, zero workflow change. - Shell wrapper intercepts `claude` command transparently - Background monitor polls tmux pane for rate limit patterns - Timezone-aware reset time parsing with DST safety - Safe send-keys with foreground process verification - --print mode: buffers output, retries cleanly for pipes - Config validation prevents bad values from causing crashes - 59 tests, 0 dependencies Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
69 lines
2.9 KiB
JavaScript
69 lines
2.9 KiB
JavaScript
import { describe, it } from 'node:test';
|
|
import assert from 'node:assert/strict';
|
|
import { loadConfig, DEFAULT_CONFIG } from '../src/config.js';
|
|
|
|
describe('DEFAULT_CONFIG', () => {
|
|
it('has expected defaults', () => {
|
|
assert.equal(DEFAULT_CONFIG.maxRetries, 5);
|
|
assert.equal(DEFAULT_CONFIG.pollIntervalSeconds, 5);
|
|
assert.equal(DEFAULT_CONFIG.marginSeconds, 60);
|
|
assert.equal(DEFAULT_CONFIG.fallbackWaitHours, 5);
|
|
assert.equal(typeof DEFAULT_CONFIG.retryMessage, 'string');
|
|
assert.deepEqual(DEFAULT_CONFIG.customPatterns, []);
|
|
});
|
|
});
|
|
|
|
describe('loadConfig', () => {
|
|
it('returns defaults when no config file exists', async () => {
|
|
const config = await loadConfig('/nonexistent/path/.claude-auto-retry.json');
|
|
assert.deepEqual(config, DEFAULT_CONFIG);
|
|
});
|
|
it('merges partial config with defaults', async () => {
|
|
const { writeFile, unlink } = await import('node:fs/promises');
|
|
const { tmpdir } = await import('node:os');
|
|
const { join } = await import('node:path');
|
|
const f = join(tmpdir(), `car-test-${Date.now()}.json`);
|
|
await writeFile(f, JSON.stringify({ maxRetries: 10 }));
|
|
try {
|
|
const config = await loadConfig(f);
|
|
assert.equal(config.maxRetries, 10);
|
|
assert.equal(config.pollIntervalSeconds, 5);
|
|
} finally { await unlink(f); }
|
|
});
|
|
it('returns defaults for invalid JSON', async () => {
|
|
const { writeFile, unlink } = await import('node:fs/promises');
|
|
const { tmpdir } = await import('node:os');
|
|
const { join } = await import('node:path');
|
|
const f = join(tmpdir(), `car-test-${Date.now()}.json`);
|
|
await writeFile(f, 'not json{{{');
|
|
try {
|
|
const config = await loadConfig(f);
|
|
assert.deepEqual(config, DEFAULT_CONFIG);
|
|
} finally { await unlink(f); }
|
|
});
|
|
it('rejects string values and falls back to defaults', async () => {
|
|
const { writeFile, unlink } = await import('node:fs/promises');
|
|
const { tmpdir } = await import('node:os');
|
|
const { join } = await import('node:path');
|
|
const f = join(tmpdir(), `car-test-${Date.now()}.json`);
|
|
await writeFile(f, JSON.stringify({ maxRetries: "never", pollIntervalSeconds: "fast" }));
|
|
try {
|
|
const config = await loadConfig(f);
|
|
assert.equal(config.maxRetries, 5);
|
|
assert.equal(config.pollIntervalSeconds, 5);
|
|
} finally { await unlink(f); }
|
|
});
|
|
it('rejects negative numbers and falls back to defaults', async () => {
|
|
const { writeFile, unlink } = await import('node:fs/promises');
|
|
const { tmpdir } = await import('node:os');
|
|
const { join } = await import('node:path');
|
|
const f = join(tmpdir(), `car-test-${Date.now()}.json`);
|
|
await writeFile(f, JSON.stringify({ maxRetries: -1, marginSeconds: -10 }));
|
|
try {
|
|
const config = await loadConfig(f);
|
|
assert.equal(config.maxRetries, 5);
|
|
assert.equal(config.marginSeconds, 60);
|
|
} finally { await unlink(f); }
|
|
});
|
|
});
|