-
Notifications
You must be signed in to change notification settings - Fork 32
[FSSDK-11170] update: decision service methods for cmab #583
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
base: master
Are you sure you want to change the base?
[FSSDK-11170] update: decision service methods for cmab #583
Conversation
…e to support CMAB UUID handling
…and include CMAB UUIDs in responses
…ils for CMAB configuration
…ations over CMAB service decisions in DecisionService
…tly verify error state
…izely and DecisionService
…text and related fetcher classes
muzahidul-opti
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Changes look good to me. Added few comments.
core-api/src/main/java/com/optimizely/ab/optimizelydecision/DecisionResponse.java
Show resolved
Hide resolved
core-api/src/main/java/com/optimizely/ab/bucketing/Bucketer.java
Outdated
Show resolved
Hide resolved
core-api/src/main/java/com/optimizely/ab/bucketing/Bucketer.java
Outdated
Show resolved
Hide resolved
core-api/src/main/java/com/optimizely/ab/optimizelydecision/AsyncDecisionsFetcher.java
Outdated
Show resolved
Hide resolved
…ecision responses
…ent key retrieval
…eation in CMAB client
…hance decision handling
core-api/src/main/java/com/optimizely/ab/bucketing/DecisionService.java
Outdated
Show resolved
Hide resolved
… backward compatibility for mobile apps
… decisions in OptimizelyUserContext
…rContextTest for consistency
…od for consistency
jaeopt
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
A few more suggestions at the top level.
core-api/src/main/java/com/optimizely/ab/OptimizelyUserContext.java
Outdated
Show resolved
Hide resolved
core-api/src/main/java/com/optimizely/ab/OptimizelyUserContext.java
Outdated
Show resolved
Hide resolved
core-api/src/main/java/com/optimizely/ab/OptimizelyUserContext.java
Outdated
Show resolved
Hide resolved
Co-authored-by: Jae Kim <45045038+jaeopt@users.noreply.github.com>
…larity and maintainability
Co-authored-by: Jae Kim <45045038+jaeopt@users.noreply.github.com>
Co-authored-by: Jae Kim <45045038+jaeopt@users.noreply.github.com>
…ckage-private and add copyright notice to DecisionPath
…and OptimizelyUserContext with corresponding tests
…ndency and adjust related tests
…and enhance builder methods for cache configuration
jaeopt
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I see it's now more aligned with android-sdk. I added more comments. Let's discuss.
core-api/src/main/java/com/optimizely/ab/bucketing/DecisionService.java
Outdated
Show resolved
Hide resolved
|
|
||
| if (decision != null) { | ||
| decisions.add(new DecisionResponse(decision, reasons)); | ||
| decisions.add(new DecisionResponse(decision, reasons, error, decision.cmabUUID)); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Do we have any case we need pass cmabUUID separately though it's already in decision?
core-api/src/main/java/com/optimizely/ab/bucketing/DecisionService.java
Outdated
Show resolved
Hide resolved
core-httpclient-impl/src/main/java/com/optimizely/ab/cmab/DefaultCmabClient.java
Outdated
Show resolved
Hide resolved
core-httpclient-impl/src/main/java/com/optimizely/ab/OptimizelyFactory.java
Outdated
Show resolved
Hide resolved
core-httpclient-impl/src/main/java/com/optimizely/ab/OptimizelyFactory.java
Outdated
Show resolved
Hide resolved
core-api/src/main/java/com/optimizely/ab/cmab/service/DefaultCmabService.java
Outdated
Show resolved
Hide resolved
…nService and adjust tests accordingly
…ervice to utilize it
…djust instance creation logic
…on and enhance cache handling logging
jaeopt
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Bucket cleaning up looks good! A few more changes suggested.
core-api/src/test/java/com/optimizely/ab/OptimizelyUserContextTest.java
Outdated
Show resolved
Hide resolved
core-api/src/main/java/com/optimizely/ab/internal/CacheWithRemove.java
Outdated
Show resolved
Hide resolved
core-api/src/main/java/com/optimizely/ab/cmab/service/DefaultCmabService.java
Outdated
Show resolved
Hide resolved
core-api/src/main/java/com/optimizely/ab/cmab/service/DefaultCmabService.java
Outdated
Show resolved
Hide resolved
core-api/src/main/java/com/optimizely/ab/cmab/service/DefaultCmabService.java
Outdated
Show resolved
Hide resolved
core-api/src/main/java/com/optimizely/ab/cmab/service/DefaultCmabService.java
Outdated
Show resolved
Hide resolved
…ache size and timeout, and remove CacheWithRemove interface
…in OptimizelyFactory
…in newDefaultInstance method of OptimizelyFactory
jaeopt
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
All changes look good to me!
Added a few suggestions - it must be the final round :)
|
|
||
| // If no cmabService provided, create default one | ||
| if (cmabService == null) { | ||
| DefaultCmabClient defaultCmabClient = new DefaultCmabClient(CmabClientConfig.withDefaultRetry()); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Can we change the DefaultCmabClient to use defaultRetry by default, so we can use simpler
| DefaultCmabClient defaultCmabClient = new DefaultCmabClient(CmabClientConfig.withDefaultRetry()); | |
| DefaultCmabClient defaultCmabClient = new DefaultCmabClient(); |
| @@ -0,0 +1,32 @@ | |||
| /** | |||
| * Copyright 2024, Optimizely and contributors | |||
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
| * Copyright 2024, Optimizely and contributors | |
| * Copyright 2025, Optimizely and contributors |
| // This mirrors how the sync methods handle errors | ||
| return OptimizelyDecision.newErrorDecision(key, userContext, "Async decision error: " + errorMessage); | ||
| } | ||
| } No newline at end of file |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I see this "no-new-line-at-the-end" in several places. Can we clean them up?
| } | ||
|
|
||
| /** | ||
| * Creates a default RetryConfig with 3 retries and exponential backoff. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
| * Creates a default RetryConfig with 3 retries and exponential backoff. | |
| * Creates a default RetryConfig with 1 retry and exponential backoff. |
| import java.util.regex.Pattern; | ||
|
|
||
| public class CmabClientHelper { | ||
| public static final String CMAB_PREDICTION_ENDPOINT = "https://prediction.cmab.optimizely.com/predict/%s"; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
remove "final" so that they can override it.
Do you allow it configurable in other way?
| /** | ||
| * Creates a config with default retry settings. | ||
| * | ||
| * @return A default cmab client config |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
We can have this as default.
| @Nonnull ErrorHandler errorHandler, | ||
| @Nullable UserProfileService userProfileService) { | ||
| @Nullable UserProfileService userProfileService, | ||
| @Nonnull CmabService cmabService) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Don't we need to support old constructor for backward compatibility?
DecisionService(bucketer, errorHandler, userProfileService)
| Map<String, OptimizelyDecision> decisionMap = new HashMap<>(); | ||
|
|
||
| ProjectConfig projectConfig = getProjectConfig(); | ||
| if (projectConfig == null) { | ||
| logger.error("Optimizely instance is not valid, failing decideAllSync call."); | ||
| return decisionMap; | ||
| } | ||
|
|
||
| List<FeatureFlag> allFlags = projectConfig.getFeatureFlags(); | ||
| List<String> allFlagKeys = new ArrayList<>(); | ||
| for (int i = 0; i < allFlags.size(); i++) allFlagKeys.add(allFlags.get(i).getKey()); | ||
|
|
||
| return decideForKeysSync(user, allFlagKeys, options); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Can't we reuse the code for decideAll - the same logic repeated here.
| ProjectConfig projectConfig = getProjectConfig(); | ||
| if (projectConfig == null) { | ||
| return OptimizelyDecision.newErrorDecision(key, user, DecisionMessage.SDK_NOT_READY.reason()); | ||
| } | ||
|
|
||
| List<OptimizelyDecideOption> allOptions = getAllOptions(options); | ||
| allOptions.remove(OptimizelyDecideOption.ENABLED_FLAGS_ONLY); | ||
|
|
||
| return decideForKeysSync(user, Arrays.asList(key), allOptions, true).get(key); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Same here - Can't we reuse the code for decide - the same logic repeated here.
Summary
Decision Service methods to handle CMAB
Test plan
Added unit tests
Issues
FSSDK-11170