|
45 | 45 | import io.kubernetes.client.models.V1ServiceSpec; |
46 | 46 | import io.kubernetes.client.models.V1Status; |
47 | 47 | import java.net.HttpURLConnection; |
48 | | -import java.util.*; |
| 48 | +import java.util.ArrayList; |
| 49 | +import java.util.Collections; |
| 50 | +import java.util.List; |
49 | 51 | import java.util.logging.Level; |
50 | 52 | import java.util.logging.LogRecord; |
51 | 53 | import oracle.kubernetes.TestUtils; |
52 | 54 | import oracle.kubernetes.operator.ProcessingConstants; |
53 | 55 | import oracle.kubernetes.operator.VersionConstants; |
54 | 56 | import oracle.kubernetes.operator.utils.WlsDomainConfigSupport; |
55 | 57 | import oracle.kubernetes.operator.wlsconfig.NetworkAccessPoint; |
56 | | -import oracle.kubernetes.operator.wlsconfig.WlsDomainConfig; |
57 | | -import oracle.kubernetes.operator.wlsconfig.WlsServerConfig; |
58 | 58 | import oracle.kubernetes.operator.work.Step; |
59 | 59 | import oracle.kubernetes.operator.work.TerminalStep; |
60 | 60 | import oracle.kubernetes.weblogic.domain.AdminServerConfigurator; |
61 | 61 | import oracle.kubernetes.weblogic.domain.DomainConfigurator; |
62 | 62 | import oracle.kubernetes.weblogic.domain.DomainConfiguratorFactory; |
63 | | -import oracle.kubernetes.weblogic.domain.v2.Channel; |
64 | 63 | import oracle.kubernetes.weblogic.domain.v2.Domain; |
65 | 64 | import oracle.kubernetes.weblogic.domain.v2.DomainSpec; |
66 | | -import org.joda.time.DateTime; |
67 | 65 | import org.junit.After; |
68 | 66 | import org.junit.Before; |
69 | 67 | import org.junit.Test; |
@@ -127,7 +125,6 @@ public void setUp() throws Exception { |
127 | 125 | .addToPacket(PORT, TEST_PORT) |
128 | 126 | .addToPacket(ProcessingConstants.DOMAIN_TOPOLOGY, configSupport.createDomainConfig()) |
129 | 127 | .addDomainPresenceInfo(domainPresenceInfo); |
130 | | - registerWlsDomainConfigScan(); |
131 | 128 | } |
132 | 129 |
|
133 | 130 | @After |
@@ -702,122 +699,4 @@ private V1ServiceSpec createExternalChannelServiceSpec() { |
702 | 699 | private CallTestSupport.CannedResponse expectReadService(String serviceName) { |
703 | 700 | return testSupport.createCannedResponse("readService").withNamespace(NS).withName(serviceName); |
704 | 701 | } |
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 | | - } |
823 | 702 | } |
0 commit comments