948017836

Build Type

push

github

Committed by leibale

Commit Message

<a href="https://github.com/NodeRedis/node-redis/commit/93938b4b9">add missing file from commit </a><a class="double-link" href="https://github.com/NodeRedis/node-redis/commit/53de279af">53de279af</a>

Run Details

396 of 511 branches covered (77.5%)

Branch coverage included in aggregate %.

18 of 18 new or added lines in 1 file covered. (100.0%)

1576 of 1772 relevant lines covered (88.94%)

32.29 hits per line

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

70.59

/lib/commands/generic-transformers.ts

export function transformReplyNumber(reply: number): number {
    return reply;
}

export function transformReplyString(reply: string): string {
    return reply;
}

export function transformReplyStringArray(reply: Array<string>): Array<string> {
    return reply;
}

export function transformReplyBoolean(reply: number): boolean {
    return reply === 1;
}

export function transformReplyBooleanArray(reply: Array<number>): Array<boolean> {
    return reply.map(transformReplyBoolean);
}

export interface ScanOptions {
    MATCH?: string;
    COUNT?: number;
}

export function transformScanArguments(cursor: number, options?: ScanOptions): Array<string> {
    const args = [cursor.toString()];

    if (options?.MATCH) {
        args.push('MATCH', options.MATCH);
    }

    if (options?.COUNT) {
        args.push('COUNT', options.COUNT.toString());
    }
    
    return args;
}

export interface ScanReply {
    cursor: number;
    keys: Array<string>;
}

export function transformScanReply([cursor, keys]: [string, Array<string>]): ScanReply {
    return {
        cursor: Number(cursor),
        keys
    };
}

export function transformReplyNumberInfinity(reply: string): number {
    switch (reply) {
        case '+inf':
            return Infinity;
        
        case '-inf':
            return -Infinity;

        default:
            return Number(reply);
    }
}

export function transformReplyNumberInfinityArray(reply: Array<string>): Array<number | null> {
    return reply.map(transformReplyNumberInfinity);
}

export function transformReplyNumberInfinityNull(reply: string | null): number | null {
    if (reply === null) return null;

    return transformReplyNumberInfinity(reply);
}

export function transformReplyNumberInfinityNullArray(reply: Array<string | null>): Array<number | null> {
    return reply.map(transformReplyNumberInfinityNull);
}

export function transformArgumentNumberInfinity(num: number): string {
    switch (num) {
        case Infinity:
            return '+inf';
        
        case -Infinity:
            return '-inf';

        default:
            return num.toString();
    }
}

export interface StreamMessage {
    [field: string]: string;
}

export function transformReplyStreamMessage(reply: Array<string>): StreamMessage {
    const message = Object.create(null);

    for (let i = 0; i < reply.length; i += 2) {
        message[reply[i]] = reply[i + 1];
    }

    return message;
}

export interface StreamMessageReply {
    id: string;
    message: StreamMessage;
}

export type StreamMessagesReply = Array<StreamMessageReply>;

export function transformReplyStreamMessages(reply: Array<any>): StreamMessagesReply {
    const messages = [];

    for (let i = 0; i < reply.length; i += 2) {
        messages.push({
            id: reply[i],
            message: transformReplyStreamMessage(reply[i + 1])
        });
    }

    return messages;
}

export type StreamsMessagesReply = Array<{
    name: string;
    messages: StreamMessagesReply;
}>;

export function transformReplyStreamsMessages(reply: Array<any>): StreamsMessagesReply {
    const streams = [];

    for (let i = 0; i < reply.length; i+= 2) {
        streams.push({
            name: reply[i],
            messages: transformReplyStreamMessages(reply[i + 1])
        });
    }

    return streams
}

export function transformReplyStreamsMessagesNull(reply: Array<any> | null): StreamsMessagesReply | null {
    if (reply === null) return null;

    return transformReplyStreamsMessages(reply);
}

1	export function transformReplyNumber(reply: number): number {	1✔
2	return reply;	45✔
3	}
4
5	export function transformReplyString(reply: string): string {	1✔
6	return reply;	292✔
7	}
8
9	export function transformReplyStringArray(reply: Array<string>): Array<string> {	1✔
10	return reply;	15✔
11	}
12
13	export function transformReplyBoolean(reply: number): boolean {	1✔
14	return reply === 1;	24✔
15	}
16
17	export function transformReplyBooleanArray(reply: Array<number>): Array<boolean> {	1✔
18	return reply.map(transformReplyBoolean);	1✔
19	}
20
21	export interface ScanOptions {
22	MATCH?: string;
23	COUNT?: number;
24	}
25
26	export function transformScanArguments(cursor: number, options?: ScanOptions): Array<string> {	1✔
27	const args = [cursor.toString()];	18✔
28
29	if (options?.MATCH) {	18✔
30	args.push('MATCH', options.MATCH);	2✔
31	}
32
33	if (options?.COUNT) {	18✔
34	args.push('COUNT', options.COUNT.toString());	2✔
35	}
36
37	return args;	18✔
38	}
39
40	export interface ScanReply {
41	cursor: number;
42	keys: Array<string>;
43	}
44
45	export function transformScanReply([cursor, keys]: [string, Array<string>]): ScanReply {	1✔
46	return {	14✔
47	cursor: Number(cursor),
48	keys
49	};
50	}
51
52	export function transformReplyNumberInfinity(reply: string): number {	1✔
53	switch (reply) {	107✔
54	case '+inf':	107!
55	return Infinity;	×
56
57	case '-inf':
58	return -Infinity;	×
59
60	default:
61	return Number(reply);	107✔
62	}
63	}
64
65	export function transformReplyNumberInfinityArray(reply: Array<string>): Array<number \| null> {	1✔
66	return reply.map(transformReplyNumberInfinity);	×
67	}
68
69	export function transformReplyNumberInfinityNull(reply: string \| null): number \| null {	1✔
70	if (reply === null) return null;	2!
71
72	return transformReplyNumberInfinity(reply);	×
73	}
74
75	export function transformReplyNumberInfinityNullArray(reply: Array<string \| null>): Array<number \| null> {	1✔
76	return reply.map(transformReplyNumberInfinityNull);	1✔
77	}
78
79	export function transformArgumentNumberInfinity(num: number): string {	1✔
80	switch (num) {	147✔
81	case Infinity:	147!
82	return '+inf';	×
83
84	case -Infinity:
85	return '-inf';	×
86
87	default:
88	return num.toString();	147✔
89	}
90	}
91
92	export interface StreamMessage {
93	[field: string]: string;
94	}
95
96	export function transformReplyStreamMessage(reply: Array<string>): StreamMessage {	1✔
97	const message = Object.create(null);	2✔
98
99	for (let i = 0; i < reply.length; i += 2) {	2✔
100	message[reply[i]] = reply[i + 1];	2✔
101	}
102
103	return message;	2✔
104	}
105
106	export interface StreamMessageReply {
107	id: string;
108	message: StreamMessage;
109	}
110
111	export type StreamMessagesReply = Array<StreamMessageReply>;
112
113	export function transformReplyStreamMessages(reply: Array<any>): StreamMessagesReply {	1✔
114	const messages = [];	6✔
115
116	for (let i = 0; i < reply.length; i += 2) {	6✔
117	messages.push({	×
118	id: reply[i],
119	message: transformReplyStreamMessage(reply[i + 1])
120	});
121	}
122
123	return messages;	6✔
124	}
125
126	export type StreamsMessagesReply = Array<{
127	name: string;
128	messages: StreamMessagesReply;
129	}>;
130
131	export function transformReplyStreamsMessages(reply: Array<any>): StreamsMessagesReply {	1✔
132	const streams = [];	×
133
134	for (let i = 0; i < reply.length; i+= 2) {	×
135	streams.push({	×
136	name: reply[i],
137	messages: transformReplyStreamMessages(reply[i + 1])
138	});
139	}
140
141	return streams	×
142	}
143
144	export function transformReplyStreamsMessagesNull(reply: Array<any> \| null): StreamsMessagesReply \| null {	1✔
145	if (reply === null) return null;	×
146
147	return transformReplyStreamsMessages(reply);	×
148	}

NodeRedis / node-redis / 948017836

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