1313import com .uid2 .admin .legacy .RotatingLegacyClientKeyProvider ;
1414import com .uid2 .admin .managers .KeysetManager ;
1515import com .uid2 .admin .monitoring .DataStoreMetrics ;
16- import com .uid2 .admin .managers .S3KeyManager ;
16+ import com .uid2 .admin .managers .CloudEncryptionKeyManager ;
1717import com .uid2 .admin .secret .*;
1818import com .uid2 .admin .store .*;
1919import com .uid2 .admin .store .reader .RotatingAdminKeysetStore ;
@@ -197,18 +197,18 @@ public void run() {
197197 operatorKeyProvider .loadContent (operatorKeyProvider .getMetadata ());
198198 OperatorKeyStoreWriter operatorKeyStoreWriter = new OperatorKeyStoreWriter (operatorKeyProvider , fileManager , jsonWriter , versionGenerator );
199199
200- CloudPath s3KeyMetadataPath = new CloudPath (config .getString (Const .Config .S3keysMetadataPathProp ));
201- GlobalScope s3KeyGlobalScope = new GlobalScope (s3KeyMetadataPath );
202- RotatingS3KeyProvider s3KeyProvider = new RotatingS3KeyProvider (cloudStorage , s3KeyGlobalScope );
203- S3KeyStoreWriter s3KeyStoreWriter = new S3KeyStoreWriter ( s3KeyProvider , fileManager , jsonWriter , versionGenerator , clock , s3KeyGlobalScope );
200+ CloudPath cloudEncryptionKeyMetadataPath = new CloudPath (config .getString (Const .Config .CloudEncryptionKeysMetadataPathProp ));
201+ GlobalScope cloudEncryptionKeyGlobalScope = new GlobalScope (cloudEncryptionKeyMetadataPath );
202+ RotatingCloudEncryptionKeyProvider RotatingCloudEncryptionKeyProvider = new RotatingCloudEncryptionKeyProvider (cloudStorage , cloudEncryptionKeyGlobalScope );
203+ CloudEncryptionKeyStoreWriter cloudEncryptionKeyStoreWriter = new CloudEncryptionKeyStoreWriter ( RotatingCloudEncryptionKeyProvider , fileManager , jsonWriter , versionGenerator , clock , cloudEncryptionKeyGlobalScope );
204204 IKeyGenerator keyGenerator = new SecureKeyGenerator ();
205- S3KeyManager s3KeyManager = new S3KeyManager ( s3KeyProvider , s3KeyStoreWriter ,keyGenerator );
205+ CloudEncryptionKeyManager cloudEncryptionKeyManager = new CloudEncryptionKeyManager ( RotatingCloudEncryptionKeyProvider , cloudEncryptionKeyStoreWriter ,keyGenerator );
206206 try {
207- s3KeyProvider .loadContent ();
207+ RotatingCloudEncryptionKeyProvider .loadContent ();
208208 } catch (CloudStorageException e ) {
209209 if (e .getMessage ().contains ("The specified key does not exist" )) {
210- s3KeyStoreWriter .upload (new HashMap <>(), null );
211- s3KeyProvider .loadContent ();
210+ cloudEncryptionKeyStoreWriter .upload (new HashMap <>(), null );
211+ RotatingCloudEncryptionKeyProvider .loadContent ();
212212 } else {
213213 throw e ;
214214 }
@@ -255,11 +255,11 @@ public void run() {
255255 clientSideKeypairService ,
256256 new ServiceService (auth , writeLock , serviceStoreWriter , serviceProvider , siteProvider , serviceLinkProvider ),
257257 new ServiceLinkService (auth , writeLock , serviceLinkStoreWriter , serviceLinkProvider , serviceProvider , siteProvider ),
258- new OperatorKeyService (config , auth , writeLock , operatorKeyStoreWriter , operatorKeyProvider , siteProvider , keyGenerator , keyHasher , s3KeyManager ),
258+ new OperatorKeyService (config , auth , writeLock , operatorKeyStoreWriter , operatorKeyProvider , siteProvider , keyGenerator , keyHasher , cloudEncryptionKeyManager ),
259259 new SaltService (auth , writeLock , saltStoreWriter , saltProvider , saltRotation ),
260260 new SiteService (auth , writeLock , siteStoreWriter , siteProvider , clientKeyProvider ),
261261 new PartnerConfigService (auth , writeLock , partnerStoreWriter , partnerConfigProvider ),
262- new PrivateSiteDataRefreshService (auth , jobDispatcher , writeLock , config , s3KeyProvider ),
262+ new PrivateSiteDataRefreshService (auth , jobDispatcher , writeLock , config , RotatingCloudEncryptionKeyProvider ),
263263 new JobDispatcherService (auth , jobDispatcher ),
264264 new SearchService (auth , clientKeyProvider , operatorKeyProvider )
265265 };
@@ -286,8 +286,8 @@ public void run() {
286286 }
287287
288288 synchronized (writeLock ) {
289- s3KeyManager .generateKeysForOperators (operatorKeyProvider .getAll (), config .getLong ("s3_key_activates_in_seconds " ), config .getInteger ("s3_key_count_per_site " ));
290- s3KeyProvider .loadContent ();
289+ cloudEncryptionKeyManager .generateKeysForOperators (operatorKeyProvider .getAll (), config .getLong ("cloud_encryption_key_activates_in_seconds " ), config .getInteger ("cloud_encryption_key_count_per_site " ));
290+ RotatingCloudEncryptionKeyProvider .loadContent ();
291291 }
292292
293293 /*
@@ -336,7 +336,7 @@ public void run() {
336336 CompletableFuture <Boolean > privateSiteDataSyncJobFuture = jobDispatcher .executeNextJob ();
337337 privateSiteDataSyncJobFuture .get ();
338338
339- EncryptedFilesSyncJob encryptedFilesSyncJob = new EncryptedFilesSyncJob (config , writeLock ,s3KeyProvider );
339+ EncryptedFilesSyncJob encryptedFilesSyncJob = new EncryptedFilesSyncJob (config , writeLock ,RotatingCloudEncryptionKeyProvider );
340340 jobDispatcher .enqueue (encryptedFilesSyncJob );
341341 CompletableFuture <Boolean > encryptedFilesSyncJobFuture = jobDispatcher .executeNextJob ();
342342 encryptedFilesSyncJobFuture .get ();
0 commit comments