redis/node-redis
1
0
Fork 0
mirror of https://github.com/redis/node-redis.git synced 2025-12-12 21:21:15 +03:00
Code Activity

fix(xreadgroup): dont parse number props (#3133)

Browse Source 
Initially, there was a bug in the server where the two additional props were
returned as string instead of number. This should now be fixed in the GA, so
no need to parse to Number anymore.
This commit is contained in:
Nikolay Karadzhov
2025-11-19 14:16:52 +02:00
committed by GitHub
parent ff91ecef81
commit a245ef4494
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
packages/client/lib/commands/generic-transformers.ts
View File

@@ -522,8 +522,8 @@ export type StreamMessageRawReply = TuplesReply<[
export type StreamMessageReply = { export type StreamMessageReply = {
id: BlobStringReply, id: BlobStringReply,
message: MapReply<BlobStringReply | string, BlobStringReply>, message: MapReply<BlobStringReply | string, BlobStringReply>,
millisElapsedFromDelivery?: number millisElapsedFromDelivery?: NumberReply
deliveriesCounter?: number deliveriesCounter?: NumberReply
}; };
export function transformStreamMessageReply(typeMapping: TypeMapping | undefined, reply: StreamMessageRawReply): StreamMessageReply { export function transformStreamMessageReply(typeMapping: TypeMapping | undefined, reply: StreamMessageRawReply): StreamMessageReply {
@@ -531,8 +531,8 @@ export function transformStreamMessageReply(typeMapping: TypeMapping | undefined
return { return {
id: id, id: id,
message: transformTuplesReply(message, undefined, typeMapping), message: transformTuplesReply(message, undefined, typeMapping),
...(millisElapsedFromDelivery !== undefined ? { millisElapsedFromDelivery: Number(millisElapsedFromDelivery) } : {}), ...(millisElapsedFromDelivery !== undefined ? { millisElapsedFromDelivery } : {}),
...(deliveriesCounter !== undefined ? { deliveriesCounter: Number(deliveriesCounter) } : {}) ...(deliveriesCounter !== undefined ? { deliveriesCounter } : {})
}; };
} }