14968700743

Committed 12 May 2025 09:27AM UTC coverage: 72.351% (-0.4%) from 72.779%

Build # 14968700743

Build Type

push

github

Committed by

web-flow

Commit Message

Merge pull request #138 from Nikorag/save-search-history

Save search history

Run Details

354 of 581 branches covered (60.93%)

Branch coverage included in aggregate %.

13 of 25 new or added lines in 4 files covered. (52.0%)

1428 of 1882 relevant lines covered (75.88%)

8.97 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

20.0

/src/types/utils/RedisFIFOQueue.ts

import { redis } from '../../service/redisService'
import { AbstractFIFOQueue } from './AbstractFIFOQueue';

export class RedisFIFOQueue<T> implements AbstractFIFOQueue<T> {
    private key: string;
    private maxSize: number;

    constructor(key: string, maxSize: number) {
        this.key = key;
        this.maxSize = maxSize;
    }

    async enqueue(item: T): Promise<void> {
        const serialized = JSON.stringify(item);
        await redis.lpush(this.key, serialized);
        await redis.ltrim(this.key, 0, this.maxSize - 1);
    }

    async dequeue(): Promise<T | undefined> {
        const item = await redis.rpop(this.key);
        return item ? (JSON.parse(item) as T) : undefined;
    }

    async peek(): Promise<T | undefined> {
        const item = await redis.lindex(this.key, -1);
        return item ? (JSON.parse(item) as T) : undefined;
    }

    async size(): Promise<number> {
        return redis.llen(this.key);
    }

    async isEmpty(): Promise<boolean> {
        return (await this.size()) === 0;
    }

    async getItems(): Promise<T[]> {
        const items = await redis.lrange(this.key, 0, -1);
        return items.map((item) => JSON.parse(item) as T);
    }

    async clear(): Promise<void> {
        await redis.del(this.key);
    }
}

1	import { redis } from '../../service/redisService'	4✔
2	import { AbstractFIFOQueue } from './AbstractFIFOQueue';
3
4	export class RedisFIFOQueue<T> implements AbstractFIFOQueue<T> {	4✔
5	private key: string;
6	private maxSize: number;
7
8	constructor(key: string, maxSize: number) {
9	this.key = key;	4✔
10	this.maxSize = maxSize;	4✔
11	}
12
13	async enqueue(item: T): Promise<void> {
NEW 14	const serialized = JSON.stringify(item);	×
NEW 15	await redis.lpush(this.key, serialized);	×
NEW 16	await redis.ltrim(this.key, 0, this.maxSize - 1);	×
17	}
18
19	async dequeue(): Promise<T \| undefined> {
NEW 20	const item = await redis.rpop(this.key);	×
NEW 21	return item ? (JSON.parse(item) as T) : undefined;	×
22	}
23
24	async peek(): Promise<T \| undefined> {
NEW 25	const item = await redis.lindex(this.key, -1);	×
NEW 26	return item ? (JSON.parse(item) as T) : undefined;	×
27	}
28
29	async size(): Promise<number> {
NEW 30	return redis.llen(this.key);	×
31	}
32
33	async isEmpty(): Promise<boolean> {
NEW 34	return (await this.size()) === 0;	×
35	}
36
37	async getItems(): Promise<T[]> {
NEW 38	const items = await redis.lrange(this.key, 0, -1);	×
NEW 39	return items.map((item) => JSON.parse(item) as T);	×
40	}
41
42	async clear(): Promise<void> {
NEW 43	await redis.del(this.key);	×
44	}
45	}

Nikorag / iplayarr / 14968700743

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous