Skip to content

Commit c4900c1

Browse files
raju-optiraju-opti
committed
wip
1 parent df094ad commit c4900c1

5 files changed

+53
-13
lines changed

‎lib/event_processor/event_processor_factory.browser.ts

+5
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,9 @@ import { LocalStorageCache } from '../utils/cache/local_storage_cache.browser';
3030
import { SyncPrefixCache } from '../utils/cache/cache';
3131
import { EVENT_STORE_PREFIX, FAILED_EVENT_RETRY_INTERVAL } from './event_processor_factory';
3232

33+
export const DEFAULT_EVENT_BATCH_SIZE = 10;
34+
export const DEFAULT_EVENT_FLUSH_INTERVAL = 1_000;
35+
3336
export const createForwardingEventProcessor = (
3437
eventDispatcher: EventDispatcher = defaultEventDispatcher,
3538
): OpaqueEventProcessor => {
@@ -54,6 +57,8 @@ export const createBatchEventProcessor = (
5457
(options.eventDispatcher ? undefined : sendBeaconEventDispatcher),
5558
flushInterval: options.flushInterval,
5659
batchSize: options.batchSize,
60+
defaultFlushInterval: DEFAULT_EVENT_FLUSH_INTERVAL,
61+
defaultBatchSize: DEFAULT_EVENT_BATCH_SIZE,
5762
retryOptions: {
5863
maxRetries: 5,
5964
},

‎lib/event_processor/event_processor_factory.node.ts

+5
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,9 @@ import {
2525
wrapEventProcessor,
2626
} from './event_processor_factory';
2727

28+
export const DEFAULT_EVENT_BATCH_SIZE = 10;
29+
export const DEFAULT_EVENT_FLUSH_INTERVAL = 30_000;
30+
2831
export const createForwardingEventProcessor = (
2932
eventDispatcher: EventDispatcher = defaultEventDispatcher,
3033
): OpaqueEventProcessor => {
@@ -41,6 +44,8 @@ export const createBatchEventProcessor = (
4144
closingEventDispatcher: options.closingEventDispatcher,
4245
flushInterval: options.flushInterval,
4346
batchSize: options.batchSize,
47+
defaultFlushInterval: DEFAULT_EVENT_FLUSH_INTERVAL,
48+
defaultBatchSize: DEFAULT_EVENT_BATCH_SIZE,
4449
retryOptions: {
4550
maxRetries: 10,
4651
},

‎lib/event_processor/event_processor_factory.react_native.ts

+5
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,9 @@ import { AsyncStorageCache } from '../utils/cache/async_storage_cache.react_nati
3131
import { ReactNativeNetInfoEventProcessor } from './batch_event_processor.react_native';
3232
import { isAvailable as isNetInfoAvailable } from '../utils/import.react_native/@react-native-community/netinfo';
3333

34+
export const DEFAULT_EVENT_BATCH_SIZE = 10;
35+
export const DEFAULT_EVENT_FLUSH_INTERVAL = 1_000;
36+
3437
export const createForwardingEventProcessor = (
3538
eventDispatcher: EventDispatcher = defaultEventDispatcher,
3639
): OpaqueEventProcessor => {
@@ -62,6 +65,8 @@ export const createBatchEventProcessor = (
6265
closingEventDispatcher: options.closingEventDispatcher,
6366
flushInterval: options.flushInterval,
6467
batchSize: options.batchSize,
68+
defaultFlushInterval: DEFAULT_EVENT_FLUSH_INTERVAL,
69+
defaultBatchSize: DEFAULT_EVENT_BATCH_SIZE,
6570
retryOptions: {
6671
maxRetries: 5,
6772
},

‎lib/event_processor/event_processor_factory.spec.ts

+27-5
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
*/
1616

1717
import { describe, it, expect, beforeEach, vi, MockInstance } from 'vitest';
18-
import { DEFAULT_EVENT_BATCH_SIZE, DEFAULT_EVENT_FLUSH_INTERVAL, getBatchEventProcessor } from './event_processor_factory';
18+
import { getBatchEventProcessor } from './event_processor_factory';
1919
import { BatchEventProcessor, BatchEventProcessorConfig, EventWithId,DEFAULT_MAX_BACKOFF, DEFAULT_MIN_BACKOFF } from './batch_event_processor';
2020
import { ExponentialBackoff, IntervalRepeater } from '../utils/repeater/repeater';
2121
import { getMockSyncCache } from '../tests/mock/mock_cache';
@@ -44,6 +44,8 @@ describe('getBatchEventProcessor', () => {
4444
it('returns an instane of BatchEventProcessor if no subclass constructor is provided', () => {
4545
const options = {
4646
eventDispatcher: getMockEventDispatcher(),
47+
defaultFlushInterval: 1000,
48+
defaultBatchSize: 10,
4749
};
4850

4951
const processor = getBatchEventProcessor(options);
@@ -60,6 +62,8 @@ describe('getBatchEventProcessor', () => {
6062

6163
const options = {
6264
eventDispatcher: getMockEventDispatcher(),
65+
defaultFlushInterval: 1000,
66+
defaultBatchSize: 10,
6367
};
6468

6569
const processor = getBatchEventProcessor(options, CustomEventProcessor);
@@ -70,6 +74,8 @@ describe('getBatchEventProcessor', () => {
7074
it('does not use retry if retryOptions is not provided', () => {
7175
const options = {
7276
eventDispatcher: getMockEventDispatcher(),
77+
defaultFlushInterval: 1000,
78+
defaultBatchSize: 10,
7379
};
7480

7581
const processor = getBatchEventProcessor(options);
@@ -81,6 +87,8 @@ describe('getBatchEventProcessor', () => {
8187
const options = {
8288
eventDispatcher: getMockEventDispatcher(),
8389
retryOptions: {},
90+
defaultFlushInterval: 1000,
91+
defaultBatchSize: 10,
8492
};
8593

8694
const processor = getBatchEventProcessor(options);
@@ -94,6 +102,8 @@ describe('getBatchEventProcessor', () => {
94102
it('uses the correct maxRetries value when retryOptions is provided', () => {
95103
const options1 = {
96104
eventDispatcher: getMockEventDispatcher(),
105+
defaultFlushInterval: 1000,
106+
defaultBatchSize: 10,
97107
retryOptions: {
98108
maxRetries: 10,
99109
},
@@ -105,6 +115,8 @@ describe('getBatchEventProcessor', () => {
105115

106116
const options2 = {
107117
eventDispatcher: getMockEventDispatcher(),
118+
defaultFlushInterval: 1000,
119+
defaultBatchSize: 10,
108120
retryOptions: {},
109121
};
110122

@@ -117,6 +129,8 @@ describe('getBatchEventProcessor', () => {
117129
it('uses exponential backoff with default parameters when retryOptions is provided without backoff values', () => {
118130
const options = {
119131
eventDispatcher: getMockEventDispatcher(),
132+
defaultFlushInterval: 1000,
133+
defaultBatchSize: 10,
120134
retryOptions: {},
121135
};
122136

@@ -133,6 +147,8 @@ describe('getBatchEventProcessor', () => {
133147
it('uses exponential backoff with provided backoff values in retryOptions', () => {
134148
const options = {
135149
eventDispatcher: getMockEventDispatcher(),
150+
defaultFlushInterval: 1000,
151+
defaultBatchSize: 10,
136152
retryOptions: { minBackoff: 1000, maxBackoff: 2000 },
137153
};
138154

@@ -149,48 +165,54 @@ describe('getBatchEventProcessor', () => {
149165
it('uses a IntervalRepeater with default flush interval and adds a startup log if flushInterval is not provided', () => {
150166
const options = {
151167
eventDispatcher: getMockEventDispatcher(),
168+
defaultFlushInterval: 12345,
169+
defaultBatchSize: 77,
152170
};
153171

154172
const processor = getBatchEventProcessor(options);
155173

156174
expect(Object.is(processor, MockBatchEventProcessor.mock.instances[0])).toBe(true);
157175
const usedRepeater = MockBatchEventProcessor.mock.calls[0][0].dispatchRepeater;
158176
expect(Object.is(usedRepeater, MockIntervalRepeater.mock.instances[0])).toBe(true);
159-
expect(MockIntervalRepeater).toHaveBeenNthCalledWith(1, DEFAULT_EVENT_FLUSH_INTERVAL);
177+
expect(MockIntervalRepeater).toHaveBeenNthCalledWith(1, 12345);
160178

161179
const startupLogs = MockBatchEventProcessor.mock.calls[0][0].startupLogs;
162180
expect(startupLogs).toEqual(expect.arrayContaining([{
163181
level: LogLevel.Warn,
164182
message: 'Invalid flushInterval %s, defaulting to %s',
165-
params: [undefined, DEFAULT_EVENT_FLUSH_INTERVAL],
183+
params: [undefined, 12345],
166184
}]));
167185
});
168186

169187
it('uses default flush interval and adds a startup log if flushInterval is less than 1', () => {
170188
const options = {
171189
eventDispatcher: getMockEventDispatcher(),
172190
flushInterval: -1,
191+
defaultFlushInterval: 12345,
192+
defaultBatchSize: 77,
173193
};
174194

175195
const processor = getBatchEventProcessor(options);
176196

177197
expect(Object.is(processor, MockBatchEventProcessor.mock.instances[0])).toBe(true);
178198
const usedRepeater = MockBatchEventProcessor.mock.calls[0][0].dispatchRepeater;
179199
expect(Object.is(usedRepeater, MockIntervalRepeater.mock.instances[0])).toBe(true);
180-
expect(MockIntervalRepeater).toHaveBeenNthCalledWith(1, DEFAULT_EVENT_FLUSH_INTERVAL);
200+
expect(MockIntervalRepeater).toHaveBeenNthCalledWith(1, 12345);
181201

182202
const startupLogs = MockBatchEventProcessor.mock.calls[0][0].startupLogs;
183203
expect(startupLogs).toEqual(expect.arrayContaining([{
184204
level: LogLevel.Warn,
185205
message: 'Invalid flushInterval %s, defaulting to %s',
186-
params: [-1, DEFAULT_EVENT_FLUSH_INTERVAL],
206+
params: [-1, 12345],
187207
}]));
188208
});
189209

190210
it('uses a IntervalRepeater with provided flushInterval and adds no startup log if provided flushInterval is valid', () => {
191211
const options = {
192212
eventDispatcher: getMockEventDispatcher(),
193213
flushInterval: 12345,
214+
defaultFlushInterval: 1000,
215+
defaultBatchSize: 77,
194216
};
195217

196218
const processor = getBatchEventProcessor(options);

‎lib/event_processor/event_processor_factory.ts

+11-8
Original file line numberDiff line numberDiff line change
@@ -22,9 +22,7 @@ import { EventProcessor } from "./event_processor";
2222
import { BatchEventProcessor, DEFAULT_MAX_BACKOFF, DEFAULT_MIN_BACKOFF, EventWithId, RetryConfig } from "./batch_event_processor";
2323
import { AsyncPrefixCache, Cache, SyncPrefixCache } from "../utils/cache/cache";
2424

25-
export const DEFAULT_EVENT_BATCH_SIZE = 10;
26-
export const DEFAULT_EVENT_FLUSH_INTERVAL = 1000;
27-
export const DEFAULT_EVENT_MAX_QUEUE_SIZE = 10000;
25+
2826
export const FAILED_EVENT_RETRY_INTERVAL = 20 * 1000;
2927
export const EVENT_STORE_PREFIX = 'optly_event:';
3028

@@ -60,9 +58,12 @@ export type BatchEventProcessorOptions = {
6058
eventStore?: Cache<string>;
6159
};
6260

63-
export type BatchEventProcessorFactoryOptions = Omit<BatchEventProcessorOptions, 'eventDispatcher' | 'eventStore'> & {
61+
export type BatchEventProcessorFactoryOptions = Omit<BatchEventProcessorOptions, 'eventDispatcher' | 'eventStore' > & {
6462
eventDispatcher: EventDispatcher;
63+
closingEventDispatcher?: EventDispatcher;
6564
failedEventRetryInterval?: number;
65+
defaultFlushInterval: number;
66+
defaultBatchSize: number;
6667
eventStore?: Cache<EventWithId>;
6768
retryOptions?: {
6869
maxRetries?: number;
@@ -88,23 +89,25 @@ export const getBatchEventProcessor = (
8889

8990
const startupLogs: StartupLog[] = [];
9091

91-
let flushInterval = DEFAULT_EVENT_FLUSH_INTERVAL;
92+
const { defaultFlushInterval, defaultBatchSize } = options;
93+
94+
let flushInterval = defaultFlushInterval;
9295
if (options.flushInterval === undefined || options.flushInterval <= 0) {
9396
startupLogs.push({
9497
level: LogLevel.Warn,
9598
message: 'Invalid flushInterval %s, defaulting to %s',
96-
params: [options.flushInterval, DEFAULT_EVENT_FLUSH_INTERVAL],
99+
params: [options.flushInterval, defaultFlushInterval],
97100
});
98101
} else {
99102
flushInterval = options.flushInterval;
100103
}
101104

102-
let batchSize = DEFAULT_EVENT_BATCH_SIZE;
105+
let batchSize = defaultBatchSize;
103106
if (options.batchSize === undefined || options.batchSize <= 0) {
104107
startupLogs.push({
105108
level: LogLevel.Warn,
106109
message: 'Invalid batchSize %s, defaulting to %s',
107-
params: [options.batchSize, DEFAULT_EVENT_BATCH_SIZE],
110+
params: [options.batchSize, defaultBatchSize],
108111
});
109112
} else {
110113
batchSize = options.batchSize;

0 commit comments

Comments
 (0)