mirror of
https://github.com/Cameri/nostream.git
synced 2025-08-03 19:22:12 +02:00
fix: don't send expiration data to buff (#207)
* fix: remove code casting string to buffer
This commit is contained in:
@@ -184,10 +184,10 @@ export class EventRepository implements IEventRepository {
|
|||||||
remote_address: path([ContextMetadataKey as any, 'remoteAddress', 'address']),
|
remote_address: path([ContextMetadataKey as any, 'remoteAddress', 'address']),
|
||||||
expires_at: ifElse(
|
expires_at: ifElse(
|
||||||
propSatisfies(is(Number), EventExpirationTimeMetadataKey),
|
propSatisfies(is(Number), EventExpirationTimeMetadataKey),
|
||||||
pipe(prop(EventExpirationTimeMetadataKey as any), toBuffer),
|
prop(EventExpirationTimeMetadataKey as any),
|
||||||
always(null),
|
always(null),
|
||||||
),
|
),
|
||||||
|
|
||||||
})(event)
|
})(event)
|
||||||
|
|
||||||
return this.masterDbClient('events')
|
return this.masterDbClient('events')
|
||||||
@@ -222,7 +222,7 @@ export class EventRepository implements IEventRepository {
|
|||||||
remote_address: path([ContextMetadataKey as any, 'remoteAddress', 'address']),
|
remote_address: path([ContextMetadataKey as any, 'remoteAddress', 'address']),
|
||||||
expires_at: ifElse(
|
expires_at: ifElse(
|
||||||
propSatisfies(is(Number), EventExpirationTimeMetadataKey),
|
propSatisfies(is(Number), EventExpirationTimeMetadataKey),
|
||||||
pipe(prop(EventExpirationTimeMetadataKey as any), toBuffer),
|
prop(EventExpirationTimeMetadataKey as any),
|
||||||
always(null),
|
always(null),
|
||||||
),
|
),
|
||||||
})(event)
|
})(event)
|
||||||
|
Reference in New Issue
Block a user