n8n/packages/cli/test/integration/runners/task-runner-server.test.ts

import { setupBrokerTestServer } from '@test-integration/utils/task-broker-test-server';

describe('TaskRunnerServer', () => {
	const { agent, server } = setupBrokerTestServer({
		authToken: 'token',
		mode: 'external',
	});

	beforeAll(async () => {
		await server.start();
	});

	afterAll(async () => {
		await server.stop();
	});

	describe('/healthz', () => {
		it('should return 200', async () => {
			await agent.get('/healthz').expect(200);
		});
	});

	describe('/runners/_ws', () => {
		it('should return 429 when too many requests are made', async () => {
			await agent.post('/runners/_ws').send({}).expect(401);
			await agent.post('/runners/_ws').send({}).expect(401);
			await agent.post('/runners/_ws').send({}).expect(401);
			await agent.post('/runners/_ws').send({}).expect(401);
			await agent.post('/runners/_ws').send({}).expect(401);
			await agent.post('/runners/_ws').send({}).expect(429);
		});
	});

	describe('/runners/auth', () => {
		it('should return 429 when too many requests are made', async () => {
			await agent.post('/runners/auth').send({ token: 'invalid' }).expect(403);
			await agent.post('/runners/auth').send({ token: 'invalid' }).expect(403);
			await agent.post('/runners/auth').send({ token: 'invalid' }).expect(403);
			await agent.post('/runners/auth').send({ token: 'invalid' }).expect(403);
			await agent.post('/runners/auth').send({ token: 'invalid' }).expect(403);
			await agent.post('/runners/auth').send({ token: 'invalid' }).expect(429);
		});
	});
});