Home
last modified time | relevance | path

Searched refs:KAnonMessageEntity (Results 1 – 18 of 18) sorted by relevance

/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/data/kanon/
DKAnonMessageConstants.java21 import com.android.adservices.service.kanon.KAnonMessageEntity;
46 @KAnonMessageEntity.KanonMessageEntityStatus int status) { in fromKAnonMessageEntityStatus()
48 case KAnonMessageEntity.KanonMessageEntityStatus.NOT_PROCESSED: in fromKAnonMessageEntityStatus()
50 case KAnonMessageEntity.KanonMessageEntityStatus.SIGNED: in fromKAnonMessageEntityStatus()
52 case KAnonMessageEntity.KanonMessageEntityStatus.JOINED: in fromKAnonMessageEntityStatus()
54 case KAnonMessageEntity.KanonMessageEntityStatus.FAILED: in fromKAnonMessageEntityStatus()
62 @KAnonMessageEntity.KanonMessageEntityStatus
66 return KAnonMessageEntity.KanonMessageEntityStatus.NOT_PROCESSED; in toKAnonMessageEntityStatus()
68 return KAnonMessageEntity.KanonMessageEntityStatus.SIGNED; in toKAnonMessageEntityStatus()
70 return KAnonMessageEntity.KanonMessageEntityStatus.JOINED; in toKAnonMessageEntityStatus()
[all …]
/packages/modules/AdServices/adservices/tests/unittest/service-core/src/com/android/adservices/service/kanon/
DKAnonSignJoinManagerTest.java75 @Captor private ArgumentCaptor<List<KAnonMessageEntity>> kanonMessageEntityArgumentCaptor;
89 private final KAnonMessageEntity.Builder mKAnonMessageEntityBuilder =
90 KAnonMessageEntity.builder()
93 .setStatus(KAnonMessageEntity.KanonMessageEntityStatus.NOT_PROCESSED);
135 KAnonMessageEntity kAnonMessageEntity = in processNewMessage_immediateJoinValueZero_shouldSaveMessageInDatabase()
137 .setStatus(KAnonMessageEntity.KanonMessageEntityStatus.NOT_PROCESSED) in processNewMessage_immediateJoinValueZero_shouldSaveMessageInDatabase()
139 List<KAnonMessageEntity> newMessages = List.of(kAnonMessageEntity); in processNewMessage_immediateJoinValueZero_shouldSaveMessageInDatabase()
143 List<KAnonMessageEntity> fetchedKAnonEntities = in processNewMessage_immediateJoinValueZero_shouldSaveMessageInDatabase()
162 KAnonMessageEntity kAnonMessageEntity = in processNewMessage_immediateJoinValueHundred_shouldImmediatelyProcessMessage()
164 .setStatus(KAnonMessageEntity.KanonMessageEntityStatus.NOT_PROCESSED) in processNewMessage_immediateJoinValueHundred_shouldImmediatelyProcessMessage()
[all …]
DKAnonMessageManagerTest.java62 private final KAnonMessageEntity mKAnonMessageEntity =
63 KAnonMessageEntity.builder()
66 .setStatus(KAnonMessageEntity.KanonMessageEntityStatus.NOT_PROCESSED)
68 private final KAnonMessageEntity mKAnonMessageEntity2 =
69 KAnonMessageEntity.builder()
72 .setStatus(KAnonMessageEntity.KanonMessageEntityStatus.NOT_PROCESSED)
74 private final KAnonMessageEntity mKAnonMessageEntity3 =
75 KAnonMessageEntity.builder()
78 .setStatus(KAnonMessageEntity.KanonMessageEntityStatus.NOT_PROCESSED)
146 List<KAnonMessageEntity> fetchedKAnonEntities = in testFetchNKAnonMessagesWithStatus_shouldFetchListOfCorrectMessages()
[all …]
DKAnonCallerImplTest.java232 List<KAnonMessageEntity> kanonMessageList = in test_signedJoinedSuccessfully_shouldUpdateKAnonMessageStatusInDB()
234 2, KAnonMessageEntity.KanonMessageEntityStatus.NOT_PROCESSED); in test_signedJoinedSuccessfully_shouldUpdateKAnonMessageStatusInDB()
240 List<KAnonMessageEntity> messagesFromDBAfter = in test_signedJoinedSuccessfully_shouldUpdateKAnonMessageStatusInDB()
242 10, KAnonMessageEntity.KanonMessageEntityStatus.JOINED); in test_signedJoinedSuccessfully_shouldUpdateKAnonMessageStatusInDB()
274 List<KAnonMessageEntity> kanonMessageList = in test_multipleBatches_shouldSignAndJoinMessages()
276 2, KAnonMessageEntity.KanonMessageEntityStatus.NOT_PROCESSED); in test_multipleBatches_shouldSignAndJoinMessages()
282 List<KAnonMessageEntity> messagesFromDBAfter = in test_multipleBatches_shouldSignAndJoinMessages()
284 10, KAnonMessageEntity.KanonMessageEntityStatus.JOINED); in test_multipleBatches_shouldSignAndJoinMessages()
306 List<KAnonMessageEntity> kanonMessageList = in test_signSuccessfulButJoinUnsuccessful_shouldUpdateKAnonMessageStatusToSignedDB()
308 2, KAnonMessageEntity.KanonMessageEntityStatus.NOT_PROCESSED); in test_signSuccessfulButJoinUnsuccessful_shouldUpdateKAnonMessageStatusToSignedDB()
[all …]
DKAnonMessageEntityTest.java23 import com.android.adservices.service.kanon.KAnonMessageEntity.KanonMessageEntityStatus;
42 KAnonMessageEntity kAnonMessageEntity = in testBuilderKAnonMessageEntity_buildsSuccessfully()
43 KAnonMessageEntity.builder() in testBuilderKAnonMessageEntity_buildsSuccessfully()
64 KAnonMessageEntity kAnonMessageEntity = in testBuilderKAnonMessageEntity_withoutMessageId_buildsSuccessfully()
65 KAnonMessageEntity.builder() in testBuilderKAnonMessageEntity_withoutMessageId_buildsSuccessfully()
80 KAnonMessageEntity kAnonMessageEntity = in testBuilderKAnonMessageEntity_withoutClientExpiryInstant_buildsSuccessfully()
81 KAnonMessageEntity.builder() in testBuilderKAnonMessageEntity_withoutClientExpiryInstant_buildsSuccessfully()
97 KAnonMessageEntity.builder() in testBuilderKAnonMessageEntity_withoutHashSet_throwsError()
111 KAnonMessageEntity.builder() in testBuilderKAnonMessageEntity_withoutStatus_throwsError()
DKAnonE2ETest.java495 List<KAnonMessageEntity> kAnonMessageEntityListNotProcessed = in persistAdSelectionData_withKAnonImmediateValueZero_savesTheMessageInDB()
497 10, KAnonMessageEntity.KanonMessageEntityStatus.NOT_PROCESSED); in persistAdSelectionData_withKAnonImmediateValueZero_savesTheMessageInDB()
520 List<KAnonMessageEntity> kAnonMessageEntityListNotProcessed = in persistAdSelectionData_withKAnonFeatureFlagDisabled_doesNothing()
522 10, KAnonMessageEntity.KanonMessageEntityStatus.NOT_PROCESSED); in persistAdSelectionData_withKAnonFeatureFlagDisabled_doesNothing()
523 List<KAnonMessageEntity> kAnonMessageEntityListSigned = in persistAdSelectionData_withKAnonFeatureFlagDisabled_doesNothing()
525 10, KAnonMessageEntity.KanonMessageEntityStatus.SIGNED); in persistAdSelectionData_withKAnonFeatureFlagDisabled_doesNothing()
526 List<KAnonMessageEntity> kAnonMessageEntityListNotJoined = in persistAdSelectionData_withKAnonFeatureFlagDisabled_doesNothing()
528 10, KAnonMessageEntity.KanonMessageEntityStatus.JOINED); in persistAdSelectionData_withKAnonFeatureFlagDisabled_doesNothing()
529 List<KAnonMessageEntity> kAnonMessageEntityListNotFailed = in persistAdSelectionData_withKAnonFeatureFlagDisabled_doesNothing()
531 10, KAnonMessageEntity.KanonMessageEntityStatus.FAILED); in persistAdSelectionData_withKAnonFeatureFlagDisabled_doesNothing()
[all …]
DKAnonCallerImplFullIntegrationTests.java200 List<KAnonMessageEntity> messageEntities = in testKAnonCallerImpl_runsSuccessfully_joinsMessagesCorrectly()
202 10, KAnonMessageEntity.KanonMessageEntityStatus.NOT_PROCESSED); in testKAnonCallerImpl_runsSuccessfully_joinsMessagesCorrectly()
225 List<KAnonMessageEntity> messageEntitiesAfterProcessing = in testKAnonCallerImpl_runsSuccessfully_joinsMessagesCorrectly()
227 10, KAnonMessageEntity.KanonMessageEntityStatus.JOINED); in testKAnonCallerImpl_runsSuccessfully_joinsMessagesCorrectly()
241 List<KAnonMessageEntity> messageEntities = in testKAnonCallerImpl_clientParamsAlreadyPresent_doesntFetchClientParams()
243 10, KAnonMessageEntity.KanonMessageEntityStatus.NOT_PROCESSED); in testKAnonCallerImpl_clientParamsAlreadyPresent_doesntFetchClientParams()
266 List<KAnonMessageEntity> messageEntitiesAfterProcessing = in testKAnonCallerImpl_clientParamsAlreadyPresent_doesntFetchClientParams()
268 10, KAnonMessageEntity.KanonMessageEntityStatus.JOINED); in testKAnonCallerImpl_clientParamsAlreadyPresent_doesntFetchClientParams()
DKAnonSignJoinBackgroundJobWorkerTest.java106 List<KAnonMessageEntity> messageEntityList = in makeSignJoinCalls_nonZeroBackgroundCallBatchSize_makesSignJoinCalls()
108 10, KAnonMessageEntity.KanonMessageEntityStatus.NOT_PROCESSED); in makeSignJoinCalls_nonZeroBackgroundCallBatchSize_makesSignJoinCalls()
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/kanon/
DKAnonMessageManager.java54 public List<KAnonMessageEntity> persistNewAnonMessageEntities( in persistNewAnonMessageEntities()
55 List<KAnonMessageEntity> kAnonMessageEntityList) { in persistNewAnonMessageEntities()
61 List<KAnonMessageEntity> newKAnonMessageEntities = new ArrayList<>(); in persistNewAnonMessageEntities()
63 KAnonMessageEntity currentEntity = kAnonMessageEntityList.get(i); in persistNewAnonMessageEntities()
65 KAnonMessageEntity.builder() in persistNewAnonMessageEntities()
82 public List<KAnonMessageEntity> fetchNKAnonMessagesWithStatus( in fetchNKAnonMessagesWithStatus()
93 public List<KAnonMessageEntity> fetchKAnonMessageEntityWithMessage(String hashSetToSearch) { in fetchKAnonMessageEntityWithMessage()
110 List<KAnonMessageEntity> messageEntities, in updateMessagesStatus()
111 @KAnonMessageEntity.KanonMessageEntityStatus int status) { in updateMessagesStatus()
114 .map(KAnonMessageEntity::getMessageId) in updateMessagesStatus()
[all …]
DKAnonMessageEntity.java33 public abstract class KAnonMessageEntity { class
36 KAnonMessageEntity.KanonMessageEntityStatus.NOT_PROCESSED,
37 KAnonMessageEntity.KanonMessageEntityStatus.SIGNED,
38 KAnonMessageEntity.KanonMessageEntityStatus.JOINED,
39 KAnonMessageEntity.KanonMessageEntityStatus.FAILED
83 public static KAnonMessageEntity.Builder builder() { in builder()
88 public KAnonMessageEntity create( in create()
124 public abstract KAnonMessageEntity build(); in build()
DKAnonSignJoinManager.java77 private boolean filterRequest(KAnonMessageEntity kAnonMessageEntity) { in filterRequest()
82 List<KAnonMessageEntity> messageEntitiesFromDB = in filterRequest()
92 for (KAnonMessageEntity messageInDB : messageEntitiesFromDB) { in filterRequest()
96 != KAnonMessageEntity.KanonMessageEntityStatus.NOT_PROCESSED in filterRequest()
134 public void processNewMessages(List<KAnonMessageEntity> newMessages) { in processNewMessages()
142 List<KAnonMessageEntity> messageAfterFiltering = in processNewMessages()
147 List<KAnonMessageEntity> insertedMessages = in processNewMessages()
166 List<KAnonMessageEntity> messageEntities = in processMessagesFromDatabase()
DKAnonUtil.java57 public static List<KAnonMessageEntity> getKAnonEntitiesFromAuctionResult( in getKAnonEntitiesFromAuctionResult()
61 KAnonMessageEntity kAnonMessageEntity = in getKAnonEntitiesFromAuctionResult()
62 KAnonMessageEntity.builder() in getKAnonEntitiesFromAuctionResult()
63 .setStatus(KAnonMessageEntity.KanonMessageEntityStatus.NOT_PROCESSED) in getKAnonEntitiesFromAuctionResult()
DKAnonCallerImpl.java26 import static com.android.adservices.service.kanon.KAnonMessageEntity.KanonMessageEntityStatus.FAIL…
27 import static com.android.adservices.service.kanon.KAnonMessageEntity.KanonMessageEntityStatus.JOIN…
28 import static com.android.adservices.service.kanon.KAnonMessageEntity.KanonMessageEntityStatus.SIGN…
64 import com.android.adservices.service.kanon.KAnonMessageEntity.KanonMessageEntityStatus;
238 List<KAnonMessageEntity> messageEntities, KAnonCallerSource source) { in signAndJoinMessages()
380 private ListenableFuture<Void> performSignAndJoinInBatches(List<KAnonMessageEntity> messages) { in performSignAndJoinInBatches()
384 List<KAnonMessageEntity> messagesSublist = in performSignAndJoinInBatches()
399 private ListenableFuture<TokensSet> signRequest(List<KAnonMessageEntity> messageEntities) { in signRequest()
453 List<KAnonMessageEntity> messageEntities, TokensSet tokensSet) {
837 List<KAnonMessageEntity> messages, @KanonMessageEntityStatus int status) {
[all …]
DKAnonCaller.java34 void signAndJoinMessages(List<KAnonMessageEntity> messagesToProcess, KAnonCallerSource source); in signAndJoinMessages()
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/adselection/
DAdSelectionRunner.java63 import com.android.adservices.service.kanon.KAnonMessageEntity;
465 List<KAnonMessageEntity> messageEntities = in makeSignJoinCall()
DPersistAdSelectionResultRunner.java61 import com.android.adservices.service.kanon.KAnonMessageEntity;
292 List<KAnonMessageEntity> messageEntities = in makeKAnonSignJoin()
/packages/modules/AdServices/adservices/tests/unittest/service-core/src/com/android/adservices/service/adselection/
DPersistAdSelectionResultRunnerTest.java97 import com.android.adservices.service.kanon.KAnonMessageEntity;
408 @Captor private ArgumentCaptor<List<KAnonMessageEntity>> mKAnonMessageEntitiesCaptor;
1842 List<KAnonMessageEntity> capturedMessageEntity = mKAnonMessageEntitiesCaptor.getValue(); in testRunner_withKAnonEnabled_createsKAnonEntityWithCorrectEncoding()
DOnDeviceAdSelectionRunnerTest.java173 import com.android.adservices.service.kanon.KAnonMessageEntity;
331 @Captor ArgumentCaptor<List<KAnonMessageEntity>> kanonMessageEntitiesCaptor;
4212 List<KAnonMessageEntity> kAnonMessageEntities = kanonMessageEntitiesCaptor.getValue(); in testRunAdSelection_withKAnonSignJoinEnabled_success()
4340 List<KAnonMessageEntity> kAnonMessageEntities = kanonMessageEntitiesCaptor.getValue(); in testRunAdSelection_kAnonSignJoinCrashes_doesntAffectOtherPaths()