fix unit test

Author: jshum2479

operator/src/test/java/oracle/kubernetes/operator/helpers/DomainIntrospectorJobTest.java

@@ -137,6 +137,8 @@
 import static oracle.kubernetes.operator.helpers.StepContextConstants.OPSS_WALLETFILE_VOLUME;
 import static oracle.kubernetes.operator.helpers.StepContextConstants.SECRETS_VOLUME;
 import static oracle.kubernetes.operator.helpers.StepContextConstants.WDTCONFIGMAP_MOUNT_PATH;
+import static oracle.kubernetes.operator.helpers.StepContextConstants.WDT_MODEL_ENCRYPTION_PASSPHRASE_MOUNT_PATH;
+import static oracle.kubernetes.operator.helpers.StepContextConstants.WDT_MODEL_ENCRYPTION_PASSPHRASE_VOLUME;
 import static oracle.kubernetes.operator.tuning.TuningParameters.DOMAIN_PRESENCE_RECHECK_INTERVAL_SECONDS;
 import static oracle.kubernetes.weblogic.domain.model.AuxiliaryImage.AUXILIARY_IMAGE_DEFAULT_SOURCE_WDT_INSTALL_HOME;
 import static oracle.kubernetes.weblogic.domain.model.AuxiliaryImage.AUXILIARY_IMAGE_INTERNAL_VOLUME_NAME;
@@ -497,6 +499,24 @@ void whenJobCreatedWithInitializeDomainOnPVDefined_hasSecretsVolumeAndMounts() {
             .mountPath(OPSS_KEY_MOUNT_PATH).readOnly(true)));
   }
 
+  @Test
+  void whenJobCreatedWithInitDomainOnPVWithModelEncryption_hasSecretsVolumeAndMounts() {
+    getConfigurator().withInitializeDomainOnPVModelEncryptionSecret("encryptedSecret");
+    testSupport.defineResources(createSecret("encryptedSecret"));
+
+    List<V1Job> jobs = runStepsAndGetJobs();
+    V1Job job = jobs.get(0);
+
+    assertThat(getJobPodSpec(job).getVolumes(),
+            hasItem(new V1Volume().name(WDT_MODEL_ENCRYPTION_PASSPHRASE_VOLUME).secret(
+                    new V1SecretVolumeSource().secretName("encryptedSecret").optional(true).defaultMode(420))));
+    assertThat(getCreatedPodSpecContainers(jobs).get(0).getVolumeMounts(),
+            hasItem(new V1VolumeMount().name(WDT_MODEL_ENCRYPTION_PASSPHRASE_VOLUME)
+                    .mountPath(WDT_MODEL_ENCRYPTION_PASSPHRASE_MOUNT_PATH).readOnly(true)));
+
+  }
+
+
   private V1Secret createSecret(String name) {
     return new V1Secret().metadata(new V1ObjectMeta().name(name).namespace(NS));
   }

operator/src/test/java/oracle/kubernetes/weblogic/domain/DomainConfigurator.java

@@ -725,5 +725,14 @@ public abstract DomainConfigurator withConfigurationForInitializeDomainOnPV(
    */
   public abstract DomainConfigurator withDomainCreationConfigMap(String cm);
 
+  /**
+   * Add model encryption secret for the domain resource's initializeDomainOnPV.
+   *
+   * @param secret the model encryption file secret
+   * @return this object
+   */
+  public abstract DomainConfigurator withInitializeDomainOnPVModelEncryptionSecret(String secret);
+
+
   public abstract DomainConfigurator withModel(Model model);
 }

operator/src/test/java/oracle/kubernetes/weblogic/domain/model/DomainCommonConfigurator.java

@@ -476,6 +476,12 @@ public DomainConfigurator withInitializeDomainOnPVOpssWalletFileSecret(String se
     return this;
   }
 
+  @Override
+  public DomainConfigurator withInitializeDomainOnPVModelEncryptionSecret(String secret) {
+    getOrCreateInitializeDomainOnPVModelSecret(secret);
+    return this;
+  }
+
   @Override
   public DomainConfigurator withInitializeDomainOnPVType(String type) {
     getOrCreateInitializeDomainOnPVDomain().domainType(type);
@@ -570,6 +576,13 @@ private Opss getOrCreateInitializeDomainOnPVOpss() {
     return domain.getOpss();
   }
 
+  private void getOrCreateInitializeDomainOnPVModelSecret(String secretName) {
+    InitializeDomainOnPV initializeDomainOnPV = getOrCreateInitializeDomainOnPV();
+    if (initializeDomainOnPV.getWdtModelEncryptionPassphraseSecret() == null) {
+      initializeDomainOnPV.wdtModelEncryptionPassphraseSecret(secretName);
+    }
+  }
+
   @Override
   public void setShuttingDown(boolean shuttingDown) {
     configureAdminServer().withServerStartPolicy(shuttingDown ? ServerStartPolicy.NEVER : ServerStartPolicy.ALWAYS);