1717/**
1818 * Bucketer API for determining the variation id from the specified parameters
1919 */
20- import { sprintf } from '../../utils/fns' ;
2120import murmurhash from 'murmurhash' ;
2221import { LoggerFacade } from '../../logging/logger' ;
2322import {
@@ -27,8 +26,8 @@ import {
2726 Group ,
2827} from '../../shared_types' ;
2928
30- import { LOG_LEVEL } from '../../utils/enums' ;
3129import { INVALID_BUCKETING_ID , INVALID_GROUP_ID } from '../../error_messages' ;
30+ import { OptimizelyError } from '../../error/optimizly_error' ;
3231
3332export const USER_NOT_IN_ANY_EXPERIMENT = 'User %s is not in any experiment of group %s.' ;
3433export const USER_NOT_BUCKETED_INTO_EXPERIMENT_IN_GROUP = 'User %s is not in experiment %s of group %s.' ;
@@ -39,7 +38,6 @@ export const INVALID_VARIATION_ID = 'Bucketed into an invalid variation ID. Retu
3938const HASH_SEED = 1 ;
4039const MAX_HASH_VALUE = Math . pow ( 2 , 32 ) ;
4140const MAX_TRAFFIC_VALUE = 10000 ;
42- const MODULE_NAME = 'BUCKETER' ;
4341const RANDOM_POLICY = 'random' ;
4442
4543/**
@@ -66,7 +64,7 @@ export const bucket = function(bucketerParams: BucketerParams): DecisionResponse
6664 if ( groupId ) {
6765 const group = bucketerParams . groupIdMap [ groupId ] ;
6866 if ( ! group ) {
69- throw new Error ( sprintf ( INVALID_GROUP_ID , MODULE_NAME , groupId ) ) ;
67+ throw new OptimizelyError ( INVALID_GROUP_ID , groupId ) ;
7068 }
7169 if ( group . policy === RANDOM_POLICY ) {
7270 const bucketedExperimentId = bucketUserIntoExperiment (
@@ -85,7 +83,6 @@ export const bucket = function(bucketerParams: BucketerParams): DecisionResponse
8583 ) ;
8684 decideReasons . push ( [
8785 USER_NOT_IN_ANY_EXPERIMENT ,
88- MODULE_NAME ,
8986 bucketerParams . userId ,
9087 groupId ,
9188 ] ) ;
@@ -105,7 +102,6 @@ export const bucket = function(bucketerParams: BucketerParams): DecisionResponse
105102 ) ;
106103 decideReasons . push ( [
107104 USER_NOT_BUCKETED_INTO_EXPERIMENT_IN_GROUP ,
108- MODULE_NAME ,
109105 bucketerParams . userId ,
110106 bucketerParams . experimentKey ,
111107 groupId ,
@@ -125,7 +121,6 @@ export const bucket = function(bucketerParams: BucketerParams): DecisionResponse
125121 ) ;
126122 decideReasons . push ( [
127123 USER_BUCKETED_INTO_EXPERIMENT_IN_GROUP ,
128- MODULE_NAME ,
129124 bucketerParams . userId ,
130125 bucketerParams . experimentKey ,
131126 groupId ,
@@ -142,7 +137,6 @@ export const bucket = function(bucketerParams: BucketerParams): DecisionResponse
142137 ) ;
143138 decideReasons . push ( [
144139 USER_ASSIGNED_TO_EXPERIMENT_BUCKET ,
145- MODULE_NAME ,
146140 bucketValue ,
147141 bucketerParams . userId ,
148142 ] ) ;
@@ -151,8 +145,8 @@ export const bucket = function(bucketerParams: BucketerParams): DecisionResponse
151145 if ( entityId !== null ) {
152146 if ( ! bucketerParams . variationIdMap [ entityId ] ) {
153147 if ( entityId ) {
154- bucketerParams . logger ?. warn ( INVALID_VARIATION_ID , MODULE_NAME ) ;
155- decideReasons . push ( [ INVALID_VARIATION_ID , MODULE_NAME ] ) ;
148+ bucketerParams . logger ?. warn ( INVALID_VARIATION_ID ) ;
149+ decideReasons . push ( [ INVALID_VARIATION_ID ] ) ;
156150 }
157151 return {
158152 result : null ,
@@ -228,7 +222,7 @@ export const _generateBucketValue = function(bucketingKey: string): number {
228222 const ratio = hashValue / MAX_HASH_VALUE ;
229223 return Math . floor ( ratio * MAX_TRAFFIC_VALUE ) ;
230224 } catch ( ex : any ) {
231- throw new Error ( sprintf ( INVALID_BUCKETING_ID , MODULE_NAME , bucketingKey , ex . message ) ) ;
225+ throw new OptimizelyError ( INVALID_BUCKETING_ID , bucketingKey , ex . message ) ;
232226 }
233227} ;
234228
0 commit comments