Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion src/logger/messages/warn.ts
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ export const codesWarn: [number, string][] = codesError.concat([
[c.STREAMING_PARSING_ERROR_FAILS, c.LOG_PREFIX_SYNC_STREAMING + 'Error parsing SSE error notification: %s'],
[c.STREAMING_PARSING_MESSAGE_FAILS, c.LOG_PREFIX_SYNC_STREAMING + 'Error parsing SSE message notification: %s'],
[c.STREAMING_FALLBACK, c.LOG_PREFIX_SYNC_STREAMING + 'Falling back to polling mode. Reason: %s'],
[c.SUBMITTERS_PUSH_FAILS, c.LOG_PREFIX_SYNC_SUBMITTERS + 'Droping %s after retry. Reason: %s.'],
[c.SUBMITTERS_PUSH_FAILS, c.LOG_PREFIX_SYNC_SUBMITTERS + 'Dropping %s after retry. Reason: %s.'],
[c.SUBMITTERS_PUSH_RETRY, c.LOG_PREFIX_SYNC_SUBMITTERS + 'Failed to push %s, keeping data to retry on next iteration. Reason: %s.'],
// client status
[c.CLIENT_NOT_READY, '%s: the SDK is not ready, results may be incorrect. Make sure to wait for SDK readiness before using this method.'],
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ test('EVENTS CACHE IN REDIS / `track`, `count`, `popNWithMetadata` and `drop` me
await Promise.all([cache.track(fakeEvent1), cache.track(fakeEvent2), cache.track(fakeEvent3)]);
expect(await cache.count()).toBe(3);
await cache.drop();
expect(await cache.count()).toBe(0); // storage should be empty after droping it
expect(await cache.count()).toBe(0); // storage should be empty after dropping it

// Clean up then end.
await connection.del(eventsKey, nonListKey);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ describe('IMPRESSIONS CACHE IN REDIS', () => {
await c.track([o1, o2, o3]);
expect(await c.count()).toBe(3);
await c.drop();
expect(await c.count()).toBe(0); // storage should be empty after droping it
expect(await c.count()).toBe(0); // storage should be empty after dropping it

await connection.del(impressionsKey);
await connection.quit();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@ describe('PLUGGABLE EVENTS CACHE', () => {
await Promise.all([cache.track(fakeEvent1), cache.track(fakeEvent2), cache.track(fakeEvent3)]);
expect(await cache.count()).toBe(3);
await cache.drop();
expect(await cache.count()).toBe(0); // storage should be empty after droping it
expect(await cache.count()).toBe(0); // storage should be empty after dropping it

wrapperMock.mockClear();
});
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -86,7 +86,7 @@ describe('PLUGGABLE IMPRESSIONS CACHE', () => {
await cache.track([o1, o2, o3]);
expect(await cache.count()).toBe(3);
await cache.drop();
expect(await cache.count()).toBe(0); // storage should be empty after droping it
expect(await cache.count()).toBe(0); // storage should be empty after dropping it

});

Expand Down