Skip to content

Commit

Permalink
Add test for setting queue rate limit
Browse files Browse the repository at this point in the history
  • Loading branch information
jasrusable committed Jun 29, 2020
1 parent b5f445b commit 218c257
Showing 1 changed file with 43 additions and 0 deletions.
43 changes: 43 additions & 0 deletions src/tests/actions/set-queue-rate-limit.test.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,43 @@
import { Redis } from 'ioredis';
import {
flushAll,
quit,
createClientAndLoadLuaScripts,
} from '../../utils/redis';
import { createUuid } from '../../utils/general';
import { redisConfig } from '../config';
import { setQueueRateLimit } from '../../actions/set-queue-rate-limit';
import { getQueueRateLimitConfig } from '../../actions/get-queue-rate-limit-config';

describe('setQueueRateLimit', () => {
const queue = createUuid();
let client: Redis;

beforeAll(() => {
client = createClientAndLoadLuaScripts(redisConfig);
});

beforeEach(async () => {
await flushAll({ client });
});

afterAll(async () => {
await quit({ client });
});

it('setQueueRateLimit sets queue rate limit', async () => {
const rateLimitConfig = { points: 100, duration: 60 };
await setQueueRateLimit({
points: rateLimitConfig.points,
duration: rateLimitConfig.duration,
queue,
client,
});
const fetchedRateLimitConfig = await getQueueRateLimitConfig({
queue,
client,
});
expect(fetchedRateLimitConfig?.duration).toBe(rateLimitConfig.duration);
expect(fetchedRateLimitConfig?.points).toBe(rateLimitConfig.points);
});
});

0 comments on commit 218c257

Please sign in to comment.