feat(video): add configurable VIDEO_JOB_TIMEOUT_MS
Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com>
This commit is contained in:
@@ -22,6 +22,7 @@ export function loadConfig() {
|
|||||||
workerPollIntervalMs: Number(process.env.WORKER_POLL_INTERVAL_MS ?? 1500),
|
workerPollIntervalMs: Number(process.env.WORKER_POLL_INTERVAL_MS ?? 1500),
|
||||||
workerConcurrency: Number(process.env.WORKER_CONCURRENCY ?? 3),
|
workerConcurrency: Number(process.env.WORKER_CONCURRENCY ?? 3),
|
||||||
ebookJobTimeoutMs: Number(process.env.EBOOK_JOB_TIMEOUT_MS ?? 180000),
|
ebookJobTimeoutMs: Number(process.env.EBOOK_JOB_TIMEOUT_MS ?? 180000),
|
||||||
|
videoJobTimeoutMs: Number(process.env.VIDEO_JOB_TIMEOUT_MS ?? 300000),
|
||||||
rateLimitMaxJobs: Number(process.env.RATE_LIMIT_MAX_JOBS ?? 20),
|
rateLimitMaxJobs: Number(process.env.RATE_LIMIT_MAX_JOBS ?? 20),
|
||||||
rateLimitWindowMinutes: Number(process.env.RATE_LIMIT_WINDOW_MINUTES ?? 10),
|
rateLimitWindowMinutes: Number(process.env.RATE_LIMIT_WINDOW_MINUTES ?? 10),
|
||||||
};
|
};
|
||||||
|
|||||||
@@ -63,6 +63,20 @@ describe('loadConfig', () => {
|
|||||||
expect(loadConfig().ebookJobTimeoutMs).toBe(240000);
|
expect(loadConfig().ebookJobTimeoutMs).toBe(240000);
|
||||||
});
|
});
|
||||||
|
|
||||||
|
it('defaults videoJobTimeoutMs to 300000ms and reads VIDEO_JOB_TIMEOUT_MS when set', () => {
|
||||||
|
process.env.STORAGE_DIR = './storage';
|
||||||
|
process.env.DB_HOST = 'localhost';
|
||||||
|
process.env.DB_USER = 'user';
|
||||||
|
process.env.DB_PASSWORD = 'pass';
|
||||||
|
process.env.DB_NAME = 'db';
|
||||||
|
delete process.env.VIDEO_JOB_TIMEOUT_MS;
|
||||||
|
|
||||||
|
expect(loadConfig().videoJobTimeoutMs).toBe(300000);
|
||||||
|
|
||||||
|
process.env.VIDEO_JOB_TIMEOUT_MS = '400000';
|
||||||
|
expect(loadConfig().videoJobTimeoutMs).toBe(400000);
|
||||||
|
});
|
||||||
|
|
||||||
it('throws listing every missing required variable', () => {
|
it('throws listing every missing required variable', () => {
|
||||||
for (const key of REQUIRED_VARS) delete process.env[key];
|
for (const key of REQUIRED_VARS) delete process.env[key];
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user