Skip to content

Commit af06f64

Browse files
chnaged date imps events
1 parent 388ab2f commit af06f64

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

packages/service-core/src/routes/endpoints/socket-route.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,7 @@ export const syncStreamReactive: SocketRouteGenerator = (router) =>
9898
metricsEngine.getUpDownCounter(APIMetric.CONCURRENT_CONNECTIONS).add(1);
9999
service_context.emitterEngine.emit(event_types.EmitterEngineEvents.SDK_CONNECT_EVENT, {
100100
...sdkData,
101-
connect_at: streamStart
101+
connect_at: new Date(streamStart)
102102
});
103103
const tracker = new sync.RequestTracker(metricsEngine);
104104
try {
@@ -181,7 +181,7 @@ export const syncStreamReactive: SocketRouteGenerator = (router) =>
181181
metricsEngine.getUpDownCounter(APIMetric.CONCURRENT_CONNECTIONS).add(-1);
182182
service_context.emitterEngine.emit(event_types.EmitterEngineEvents.SDK_DISCONNECT_EVENT, {
183183
...sdkData,
184-
disconnect_at: Date.now()
184+
disconnect_at: new Date()
185185
});
186186
}
187187
}

packages/service-core/src/routes/endpoints/sync-stream.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,7 @@ export const syncStreamed = routeDefinition({
7272
metricsEngine.getUpDownCounter(APIMetric.CONCURRENT_CONNECTIONS).add(1);
7373
service_context.emitterEngine.emit(event_types.EmitterEngineEvents.SDK_CONNECT_EVENT, {
7474
...sdkData,
75-
connect_at: streamStart
75+
connect_at: new Date(streamStart)
7676
});
7777
const stream = Readable.from(
7878
sync.transformToBytesTracked(
@@ -138,7 +138,7 @@ export const syncStreamed = routeDefinition({
138138
metricsEngine.getUpDownCounter(APIMetric.CONCURRENT_CONNECTIONS).add(-1);
139139
service_context.emitterEngine.emit(event_types.EmitterEngineEvents.SDK_DISCONNECT_EVENT, {
140140
...sdkData,
141-
disconnect_at: Date.now()
141+
disconnect_at: new Date()
142142
});
143143
logger.info(`Sync stream complete`, {
144144
...tracker.getLogMeta(),
@@ -152,7 +152,7 @@ export const syncStreamed = routeDefinition({
152152
metricsEngine.getUpDownCounter(APIMetric.CONCURRENT_CONNECTIONS).add(-1);
153153
service_context.emitterEngine.emit(event_types.EmitterEngineEvents.SDK_DISCONNECT_EVENT, {
154154
...sdkData,
155-
disconnect_at: Date.now()
155+
disconnect_at: new Date()
156156
});
157157
}
158158
}

0 commit comments

Comments
 (0)