Skip to content

Commit 2397fd0

Browse files
committed
Fix build
1 parent 9cdbc01 commit 2397fd0

File tree

2 files changed

+4
-124
lines changed

2 files changed

+4
-124
lines changed

operator/src/main/java/oracle/kubernetes/operator/DomainProcessorImpl.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -990,6 +990,7 @@ private static Step[] bringAdminServerUpSteps(DomainPresenceInfo info, Step next
990990
resources.add(PodHelper.createAdminPodStep(null));
991991
resources.add(new BeforeAdminServiceStep(null));
992992

993+
Domain dom = info.getDomain();
993994
if (dom.getSpec().getAdminServer().getAdminService() != null) {
994995
resources.add(ServiceHelper.createForAdminServiceStep(null));
995996
}

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

Lines changed: 3 additions & 124 deletions
Original file line numberDiff line numberDiff line change
@@ -45,25 +45,23 @@
4545
import io.kubernetes.client.models.V1ServiceSpec;
4646
import io.kubernetes.client.models.V1Status;
4747
import java.net.HttpURLConnection;
48-
import java.util.*;
48+
import java.util.ArrayList;
49+
import java.util.Collections;
50+
import java.util.List;
4951
import java.util.logging.Level;
5052
import java.util.logging.LogRecord;
5153
import oracle.kubernetes.TestUtils;
5254
import oracle.kubernetes.operator.ProcessingConstants;
5355
import oracle.kubernetes.operator.VersionConstants;
5456
import oracle.kubernetes.operator.utils.WlsDomainConfigSupport;
5557
import oracle.kubernetes.operator.wlsconfig.NetworkAccessPoint;
56-
import oracle.kubernetes.operator.wlsconfig.WlsDomainConfig;
57-
import oracle.kubernetes.operator.wlsconfig.WlsServerConfig;
5858
import oracle.kubernetes.operator.work.Step;
5959
import oracle.kubernetes.operator.work.TerminalStep;
6060
import oracle.kubernetes.weblogic.domain.AdminServerConfigurator;
6161
import oracle.kubernetes.weblogic.domain.DomainConfigurator;
6262
import oracle.kubernetes.weblogic.domain.DomainConfiguratorFactory;
63-
import oracle.kubernetes.weblogic.domain.v2.Channel;
6463
import oracle.kubernetes.weblogic.domain.v2.Domain;
6564
import oracle.kubernetes.weblogic.domain.v2.DomainSpec;
66-
import org.joda.time.DateTime;
6765
import org.junit.After;
6866
import org.junit.Before;
6967
import org.junit.Test;
@@ -127,7 +125,6 @@ public void setUp() throws Exception {
127125
.addToPacket(PORT, TEST_PORT)
128126
.addToPacket(ProcessingConstants.DOMAIN_TOPOLOGY, configSupport.createDomainConfig())
129127
.addDomainPresenceInfo(domainPresenceInfo);
130-
registerWlsDomainConfigScan();
131128
}
132129

133130
@After
@@ -702,122 +699,4 @@ private V1ServiceSpec createExternalChannelServiceSpec() {
702699
private CallTestSupport.CannedResponse expectReadService(String serviceName) {
703700
return testSupport.createCannedResponse("readService").withNamespace(NS).withName(serviceName);
704701
}
705-
706-
@Test
707-
public void onAdminServiceStepRunWithNoService_createIt() {
708-
configAdminService();
709-
V1Service newService = createAdminService();
710-
initializeAdminServiceFromRecord(null);
711-
expectCreateService(newService).returning(newService);
712-
713-
testSupport.addToPacket(SERVER_NAME, domainPresenceInfo.getDomain().getAsName());
714-
testSupport.runSteps(ServiceHelper.createForAdminServiceStep(terminalStep));
715-
716-
assertThat(logRecords, containsInfo(ADMIN_SERVICE_CREATED));
717-
}
718-
719-
@Test
720-
public void onAdminServiceStepRunWithNoService_retryOnFailure() {
721-
configAdminService();
722-
testSupport.addRetryStrategy(retryStrategy);
723-
V1Service newService = createAdminService();
724-
initializeAdminServiceFromRecord(null);
725-
expectCreateService(newService).failingWithStatus(401);
726-
727-
testSupport.addToPacket(SERVER_NAME, domainPresenceInfo.getDomain().getAsName());
728-
testSupport.runSteps(ServiceHelper.createForAdminServiceStep(terminalStep));
729-
730-
testSupport.verifyCompletionThrowable(ApiException.class);
731-
}
732-
733-
@Test
734-
public void onAdminServiceStepRunWitBadVersion_replaceIt() {
735-
verifyAdminServiceReplaced(this::withBadVersion);
736-
}
737-
738-
private void verifyAdminServiceReplaced(ServiceMutator mutator) {
739-
configAdminService();
740-
V1Service newService = createAdminService();
741-
initializeAdminServiceFromRecord(mutator.change(createAdminService()));
742-
expectDeleteServiceSuccessful(getAdminServiceName());
743-
expectSuccessfulCreateService(newService);
744-
745-
testSupport.addToPacket(SERVER_NAME, domainPresenceInfo.getDomain().getAsName());
746-
testSupport.runSteps(ServiceHelper.createForAdminServiceStep(terminalStep));
747-
748-
assertThat(logRecords, containsInfo(ADMIN_SERVICE_REPLACED));
749-
}
750-
751-
@Test
752-
public void onAdminServiceStepRunWithMatchingService_addToSko() {
753-
configAdminService();
754-
V1Service newService = createAdminService();
755-
initializeAdminServiceFromRecord(newService);
756-
757-
testSupport.addToPacket(SERVER_NAME, domainPresenceInfo.getDomain().getAsName());
758-
testSupport.runSteps(ServiceHelper.createForAdminServiceStep(terminalStep));
759-
760-
assertThat(logRecords, containsFine(ADMIN_SERVICE_EXISTS));
761-
}
762-
763-
private V1Service createAdminService() {
764-
return new V1Service()
765-
.spec(createAdminServiceSpec())
766-
.metadata(
767-
new V1ObjectMeta()
768-
.name(getAdminServiceName())
769-
.namespace(NS)
770-
.putLabelsItem(RESOURCE_VERSION_LABEL, VersionConstants.DOMAIN_V2)
771-
.putLabelsItem(DOMAINUID_LABEL, UID)
772-
.putLabelsItem(DOMAINNAME_LABEL, DOMAIN_NAME)
773-
.putLabelsItem(SERVERNAME_LABEL, domainPresenceInfo.getDomain().getAsName())
774-
.putLabelsItem(CREATEDBYOPERATOR_LABEL, "true"));
775-
}
776-
777-
private V1ServiceSpec createAdminServiceSpec() {
778-
return new V1ServiceSpec()
779-
.putSelectorItem(DOMAINUID_LABEL, UID)
780-
.putSelectorItem(SERVERNAME_LABEL, domainPresenceInfo.getDomain().getAsName())
781-
.putSelectorItem(CREATEDBYOPERATOR_LABEL, "true")
782-
.type("NodePort")
783-
.ports(createPorts());
784-
}
785-
786-
private String getAdminServiceName() {
787-
return LegalNames.toAdminServiceName(UID, domainPresenceInfo.getDomain().getAsName());
788-
}
789-
790-
private List<V1ServicePort> createPorts() {
791-
List<V1ServicePort> ports = new ArrayList<>();
792-
ports.add(new V1ServicePort().port(TEST_PORT).nodePort(TEST_NODE_PORT).name("default"));
793-
return ports;
794-
}
795-
796-
private void configAdminService() {
797-
configureAdminServer()
798-
.configureAdminService()
799-
.addChannel("default", new Channel(TEST_NODE_PORT));
800-
}
801-
802-
private void initializeAdminServiceFromRecord(V1Service service) {
803-
domainPresenceInfo.getServers().put(ADMIN_SERVER, createSko(service));
804-
}
805-
806-
private void registerWlsDomainConfigScan() {
807-
ScanCache.INSTANCE.registerScan(
808-
domainPresenceInfo.getNamespace(),
809-
domainPresenceInfo.getDomainUID(),
810-
new Scan(createWlsDomainConfig(), new DateTime()));
811-
}
812-
813-
private WlsDomainConfig createWlsDomainConfig() {
814-
Map<String, WlsServerConfig> wlsServerConfigs = new HashMap<>();
815-
wlsServerConfigs.put(
816-
ADMIN_SERVER, new WlsServerConfig(ADMIN_SERVER, TEST_PORT, null, null, false, null, null));
817-
818-
WlsDomainConfig wlsDomainConfig =
819-
new WlsDomainConfig(DOMAIN_NAME, new HashMap<>(), wlsServerConfigs, null, null);
820-
wlsDomainConfig.setAdminServerName(ADMIN_SERVER);
821-
return wlsDomainConfig;
822-
}
823702
}

0 commit comments

Comments
 (0)