Skip to content

Commit 9163c48

Browse files
Fix typos
1 parent 3b99e8a commit 9163c48

File tree

3 files changed

+10
-10
lines changed

3 files changed

+10
-10
lines changed

src/sync/streaming/SSEHandler/index.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ export function SSEHandlerFactory(log: ILogger, pushEmitter: IPushEventEmitter,
2525
const code = error.parsedData.code;
2626
telemetryTracker.streamingEvent(ABLY_ERROR, code);
2727

28-
// 401 errors due to invalid or expired token (e.g., if refresh token coudn't be executed)
28+
// 401 errors due to invalid or expired token (e.g., if refresh token couldn't be executed)
2929
if (40140 <= code && code <= 40149) return true;
3030
// Others 4XX errors (e.g., bad request from the SDK)
3131
if (40000 <= code && code <= 49999) return false;

src/sync/submitters/telemetrySubmitter.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,7 @@ export function telemetrySubmitterFactory(params: ISdkFactoryContextSync) {
119119
if (!telemetry || !now) return; // No submitter created if telemetry cache is not defined
120120

121121
const { settings, settings: { log, scheduler: { telemetryRefreshRate } }, splitApi, readiness, sdkReadinessManager } = params;
122-
const startTime = timer(now);
122+
const stopTimer = timer(now);
123123

124124
const submitter = firstPushWindowDecorator(
125125
submitterFactory(
@@ -131,12 +131,12 @@ export function telemetrySubmitterFactory(params: ISdkFactoryContextSync) {
131131
);
132132

133133
readiness.gate.once(SDK_READY_FROM_CACHE, () => {
134-
telemetry.recordTimeUntilReadyFromCache(startTime());
134+
telemetry.recordTimeUntilReadyFromCache(stopTimer());
135135
});
136136

137137
sdkReadinessManager.incInternalReadyCbCount();
138138
readiness.gate.once(SDK_READY, () => {
139-
telemetry.recordTimeUntilReady(startTime());
139+
telemetry.recordTimeUntilReady(stopTimer());
140140

141141
// Post config data when the SDK is ready and if the telemetry submitter was started
142142
if (submitter.isRunning()) {

src/trackers/telemetryTracker.ts

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -11,11 +11,11 @@ export function telemetryTrackerFactory(
1111
): ITelemetryTracker {
1212

1313
if (telemetryCache && now) {
14-
const startTime = timer(now);
14+
const sessionTimer = timer(now);
1515

1616
return {
1717
trackEval(method) {
18-
const evalTime = timer(now);
18+
const evalTimer = timer(now);
1919

2020
return (label) => {
2121
switch (label) {
@@ -25,20 +25,20 @@ export function telemetryTrackerFactory(
2525
case SDK_NOT_READY: // @ts-ignore ITelemetryCacheAsync doesn't implement the method
2626
if (telemetryCache.recordNonReadyUsage) telemetryCache.recordNonReadyUsage();
2727
}
28-
telemetryCache.recordLatency(method, evalTime());
28+
telemetryCache.recordLatency(method, evalTimer());
2929
};
3030
},
3131
trackHttp(operation) {
32-
const httpTime = timer(now);
32+
const httpTimer = timer(now);
3333

3434
return (error) => {
35-
(telemetryCache as ITelemetryCacheSync).recordHttpLatency(operation, httpTime());
35+
(telemetryCache as ITelemetryCacheSync).recordHttpLatency(operation, httpTimer());
3636
if (error && error.statusCode) (telemetryCache as ITelemetryCacheSync).recordHttpError(operation, error.statusCode);
3737
else (telemetryCache as ITelemetryCacheSync).recordSuccessfulSync(operation, Date.now());
3838
};
3939
},
4040
sessionLength() { // @ts-ignore ITelemetryCacheAsync doesn't implement the method
41-
if (telemetryCache.recordSessionLength) telemetryCache.recordSessionLength(startTime());
41+
if (telemetryCache.recordSessionLength) telemetryCache.recordSessionLength(sessionTimer());
4242
},
4343
streamingEvent(e, d) {
4444
if (e === AUTH_REJECTION) {

0 commit comments

Comments
 (0)