Use HTTP and remove Athenz injection

11 files changed, 73 insertions, 132 deletions

diff --git a/service-monitor/src/main/java/com/yahoo/vespa/service/monitor/application/ConfigServerApplication.java b/service-monitor/src/main/java/com/yahoo/vespa/service/monitor/application/ConfigServerApplication.java
index ff51b40e4dd..5ad38cebcfc 100644
--- a/service-monitor/src/main/java/com/yahoo/vespa/service/monitor/application/ConfigServerApplication.java
+++ b/service-monitor/src/main/java/com/yahoo/vespa/service/monitor/application/ConfigServerApplication.java
@@ -14,9 +14,9 @@ import com.yahoo.vespa.applicationmodel.ConfigId;
 import com.yahoo.vespa.applicationmodel.ServiceType;
 import com.yahoo.vespa.applicationmodel.TenantId;
 import com.yahoo.vespa.service.monitor.internal.ModelGenerator;
+import com.yahoo.vespa.service.monitor.internal.health.ApplicationHealthMonitor;
 
 import java.util.ArrayList;
-import java.util.Arrays;
 import java.util.Collections;
 import java.util.HashMap;
 import java.util.List;
@@ -49,7 +49,7 @@ public class ConfigServerApplication extends HostedVespaApplication {
         List<ConfigserverConfig.Zookeeperserver> zooKeeperServers = config.zookeeperserver();
         for (int index = 0; index < zooKeeperServers.size(); ++index) {
             String hostname = zooKeeperServers.get(index).hostname();
-            hostInfos.add(makeHostInfo(hostname, index));
+            hostInfos.add(makeHostInfo(hostname, config.httpport(), index));
         }
 
         return new ApplicationInfo(
@@ -58,9 +58,8 @@ public class ConfigServerApplication extends HostedVespaApplication {
                 new HostsModel(hostInfos));
     }
 
-    private static HostInfo makeHostInfo(String hostname, int configIndex) {
-        // /state/v1/health API is available with STATE and either HTTP or HTTPS.
-        PortInfo portInfo = new PortInfo(4443, Arrays.asList("HTTPS", "STATE"));
+    private static HostInfo makeHostInfo(String hostname, int port, int configIndex) {
+        PortInfo portInfo = new PortInfo(port, ApplicationHealthMonitor.PORT_TAGS_HEALTH);
 
         Map<String, String> properties = new HashMap<>();
         properties.put(ModelGenerator.CLUSTER_ID_PROPERTY_NAME, CLUSTER_ID.s());
diff --git a/service-monitor/src/main/java/com/yahoo/vespa/service/monitor/internal/health/ApplicationHealthMonitor.java b/service-monitor/src/main/java/com/yahoo/vespa/service/monitor/internal/health/ApplicationHealthMonitor.java
index e3d35f6d6e9..f241cd04d99 100644
--- a/service-monitor/src/main/java/com/yahoo/vespa/service/monitor/internal/health/ApplicationHealthMonitor.java
+++ b/service-monitor/src/main/java/com/yahoo/vespa/service/monitor/internal/health/ApplicationHealthMonitor.java
@@ -6,35 +6,36 @@ import com.yahoo.config.model.api.HostInfo;
 import com.yahoo.config.model.api.PortInfo;
 import com.yahoo.config.model.api.ServiceInfo;
 import com.yahoo.config.provision.ApplicationId;
+import com.yahoo.config.provision.HostName;
 import com.yahoo.vespa.applicationmodel.ClusterId;
 import com.yahoo.vespa.applicationmodel.ConfigId;
 import com.yahoo.vespa.applicationmodel.ServiceStatus;
 import com.yahoo.vespa.applicationmodel.ServiceType;
-import com.yahoo.vespa.athenz.identity.ServiceIdentityProvider;
 import com.yahoo.vespa.service.monitor.ServiceStatusProvider;
 import com.yahoo.vespa.service.monitor.application.ApplicationInstanceGenerator;
 import com.yahoo.vespa.service.monitor.internal.ServiceId;
 
-import java.net.URL;
-import java.util.Collection;
+import java.util.Arrays;
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
 import java.util.Optional;
 
-import static com.yahoo.yolean.Exceptions.uncheck;
-
 /**
  * Responsible for monitoring a whole application using /state/v1/health.
  *
  * @author hakon
  */
 public class ApplicationHealthMonitor implements ServiceStatusProvider, AutoCloseable {
+    public static final String PORT_TAG_STATE = "STATE";
+    public static final String PORT_TAG_HTTP = "HTTP";
+    /** Port tags implying /state/v1/health is served */
+    public static final List<String> PORT_TAGS_HEALTH = Arrays.asList(PORT_TAG_HTTP, PORT_TAG_STATE);
+
     private final Map<ServiceId, HealthMonitor> healthMonitors;
 
-    public static ApplicationHealthMonitor startMonitoring(
-            ApplicationInfo application,
-            ServiceIdentityProvider identityProvider) {
-        return new ApplicationHealthMonitor(makeHealthMonitors(application, identityProvider));
+    public static ApplicationHealthMonitor startMonitoring(ApplicationInfo application) {
+        return new ApplicationHealthMonitor(makeHealthMonitors(application));
     }
 
     private ApplicationHealthMonitor(Map<ServiceId, HealthMonitor> healthMonitors) {
@@ -61,9 +62,7 @@ public class ApplicationHealthMonitor implements ServiceStatusProvider, AutoClos
         healthMonitors.clear();
     }
 
-    private static Map<ServiceId, HealthMonitor> makeHealthMonitors(
-            ApplicationInfo application,
-            ServiceIdentityProvider identityProvider) {
+    private static Map<ServiceId, HealthMonitor> makeHealthMonitors(ApplicationInfo application) {
         Map<ServiceId, HealthMonitor> healthMonitors = new HashMap<>();
         for (HostInfo hostInfo : application.getModel().getHosts()) {
             for (ServiceInfo serviceInfo : hostInfo.getServices()) {
@@ -72,8 +71,7 @@ public class ApplicationHealthMonitor implements ServiceStatusProvider, AutoClos
                             application,
                             hostInfo,
                             serviceInfo,
-                            portInfo,
-                            identityProvider)
+                            portInfo)
                             .ifPresent(healthMonitor -> healthMonitors.put(
                                     ApplicationInstanceGenerator.getServiceId(application, serviceInfo),
                                     healthMonitor));
@@ -87,24 +85,14 @@ public class ApplicationHealthMonitor implements ServiceStatusProvider, AutoClos
             ApplicationInfo applicationInfo,
             HostInfo hostInfo,
             ServiceInfo serviceInfo,
-            PortInfo portInfo,
-            ServiceIdentityProvider identityProvider) {
-        Collection<String> portTags = portInfo.getTags();
-        if (portTags.contains("STATE")) {
-            if (portTags.contains("HTTPS")) {
-                URL url = uncheck(() -> new URL(
-                        "https",
-                        hostInfo.getHostname(),
-                        portInfo.getPort(),
-                        "/state/v1/health"));
-                // todo: get hostname verifier
-                // "vespa.vespa[.cd].provider_%s_%s" from AthenzProviderServiceConfig
-                // new AthenzIdentityVerifier(Collections.singleton("vespa.vespa[.cd].provider_%s_%s"));
-                // HealthEndpoint healthEndpoint = HealthEndpoint.forHttps(...);
-                // HealthMonitor healthMonitor = new HealthMonitor(url, identityProvider, hostnameVerifier);
-                // healthMonitor.startMonitoring()
-                return Optional.empty();
-            }
+            PortInfo portInfo) {
+        if (portInfo.getTags().containsAll(PORT_TAGS_HEALTH)) {
+            HostName hostname = HostName.from(hostInfo.getHostname());
+            HealthEndpoint endpoint = HealthEndpoint.forHttp(hostname, portInfo.getPort());
+            // todo: make HealthMonitor
+            // HealthMonitor healthMonitor = new HealthMonitor(endpoint);
+            // healthMonitor.startMonitoring();
+            return Optional.empty();
         }
 
         return Optional.empty();
diff --git a/service-monitor/src/main/java/com/yahoo/vespa/service/monitor/internal/health/HealthClient.java b/service-monitor/src/main/java/com/yahoo/vespa/service/monitor/internal/health/HealthClient.java
index 1ecdf432ada..43a02a385be 100644
--- a/service-monitor/src/main/java/com/yahoo/vespa/service/monitor/internal/health/HealthClient.java
+++ b/service-monitor/src/main/java/com/yahoo/vespa/service/monitor/internal/health/HealthClient.java
@@ -2,7 +2,6 @@
 package com.yahoo.vespa.service.monitor.internal.health;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
-import com.yahoo.config.provision.HostName;
 import com.yahoo.vespa.athenz.api.AthenzService;
 import com.yahoo.vespa.athenz.identity.ServiceIdentityProvider;
 import org.apache.http.HttpEntity;
@@ -23,11 +22,7 @@ import org.apache.http.impl.conn.BasicHttpClientConnectionManager;
 import org.apache.http.protocol.HttpContext;
 import org.apache.http.util.EntityUtils;
 
-import javax.net.ssl.HostnameVerifier;
 import javax.net.ssl.SSLContext;
-import java.net.URL;
-
-import static com.yahoo.yolean.Exceptions.uncheck;
 
 /**
  * @author hakon
@@ -51,35 +46,25 @@ public class HealthClient implements AutoCloseable, ServiceIdentityProvider.List
                 }
             };
 
-    private final URL url;
-    private final ServiceIdentityProvider serviceIdentityProvider;
-    private final HostnameVerifier hostnameVerifier;
+    private final HealthEndpoint endpoint;
 
     private volatile CloseableHttpClient httpClient;
 
-    public HealthClient(HostName hostname,
-                        int port,
-                        ServiceIdentityProvider identityProvider,
-                        HostnameVerifier hostnameVerifier) {
-        this(uncheck(() -> new URL("https", hostname.value(), port, "/state/v1/health")),
-                identityProvider,
-                hostnameVerifier);
+    public HealthClient(HealthEndpoint endpoint) {
+        this.endpoint = endpoint;
     }
 
-    public HealthClient(URL stateV1HealthEndpoint,
-                        ServiceIdentityProvider serviceIdentityProvider,
-                        HostnameVerifier hostnameVerifier) {
-        this.url = stateV1HealthEndpoint;
-        this.serviceIdentityProvider = serviceIdentityProvider;
-        this.hostnameVerifier = hostnameVerifier;
-
-        onCredentialsUpdate(serviceIdentityProvider.getIdentitySslContext(), null);
-        serviceIdentityProvider.addIdentityListener(this);
+    public void start() {
+        endpoint.getServiceIdentityProvider().ifPresent(provider -> {
+            onCredentialsUpdate(provider.getIdentitySslContext(), null);
+            provider.addIdentityListener(this);
+        });
     }
 
     @Override
     public void onCredentialsUpdate(SSLContext sslContext, AthenzService ignored) {
-        SSLConnectionSocketFactory socketFactory = new SSLConnectionSocketFactory(sslContext, hostnameVerifier);
+        SSLConnectionSocketFactory socketFactory =
+                new SSLConnectionSocketFactory(sslContext, endpoint.getHostnameVerifier().orElse(null));
 
         Registry<ConnectionSocketFactory> registry = RegistryBuilder.<ConnectionSocketFactory>create()
                 .register("https", socketFactory)
@@ -111,7 +96,7 @@ public class HealthClient implements AutoCloseable, ServiceIdentityProvider.List
 
     @Override
     public void close() {
-        serviceIdentityProvider.removeIdentityListener(this);
+        endpoint.getServiceIdentityProvider().ifPresent(provider -> provider.removeIdentityListener(this));
 
         try {
             httpClient.close();
@@ -122,7 +107,7 @@ public class HealthClient implements AutoCloseable, ServiceIdentityProvider.List
     }
 
     private HealthInfo probeHealth() throws Exception {
-        HttpGet httpget = new HttpGet(url.toString());
+        HttpGet httpget = new HttpGet(endpoint.getStateV1HealthUrl().toString());
         CloseableHttpResponse httpResponse;
 
         CloseableHttpClient httpClient = this.httpClient;
diff --git a/service-monitor/src/main/java/com/yahoo/vespa/service/monitor/internal/health/HealthEndpoint.java b/service-monitor/src/main/java/com/yahoo/vespa/service/monitor/internal/health/HealthEndpoint.java
index d3b81c213dc..e9d17a9ab70 100644
--- a/service-monitor/src/main/java/com/yahoo/vespa/service/monitor/internal/health/HealthEndpoint.java
+++ b/service-monitor/src/main/java/com/yahoo/vespa/service/monitor/internal/health/HealthEndpoint.java
@@ -3,11 +3,13 @@ package com.yahoo.vespa.service.monitor.internal.health;
 
 import com.yahoo.config.provision.HostName;
 import com.yahoo.vespa.athenz.api.AthenzIdentity;
+import com.yahoo.vespa.athenz.identity.ServiceIdentityProvider;
 import com.yahoo.vespa.athenz.tls.AthenzIdentityVerifier;
 
 import javax.net.ssl.HostnameVerifier;
 import java.net.URL;
 import java.util.Collections;
+import java.util.Optional;
 
 import static com.yahoo.yolean.Exceptions.uncheck;
 
@@ -16,16 +18,28 @@ import static com.yahoo.yolean.Exceptions.uncheck;
  */
 class HealthEndpoint {
     private final URL url;
-    private final HostnameVerifier hostnameVerifier;
+    private final Optional<HostnameVerifier> hostnameVerifier;
+    private final Optional<ServiceIdentityProvider> serviceIdentityProvider;
 
-    static HealthEndpoint forHttps(HostName hostname, int port, AthenzIdentity remoteIdentity) {
+    static HealthEndpoint forHttp(HostName hostname, int port) {
+        URL url = uncheck(() -> new URL("http", hostname.value(), port, "/state/v1/health"));
+        return new HealthEndpoint(url, Optional.empty(), Optional.empty());
+    }
+
+    static HealthEndpoint forHttps(HostName hostname,
+                                   int port,
+                                   ServiceIdentityProvider serviceIdentityProvider,
+                                   AthenzIdentity remoteIdentity) {
         URL url = uncheck(() -> new URL("https", hostname.value(), port, "/state/v1/health"));
         HostnameVerifier peerVerifier = new AthenzIdentityVerifier(Collections.singleton(remoteIdentity));
-        return new HealthEndpoint(url, peerVerifier);
+        return new HealthEndpoint(url, Optional.of(serviceIdentityProvider), Optional.of(peerVerifier));
     }
 
-    private HealthEndpoint(URL url, HostnameVerifier hostnameVerifier) {
+    private HealthEndpoint(URL url,
+                           Optional<ServiceIdentityProvider> serviceIdentityProvider,
+                           Optional<HostnameVerifier> hostnameVerifier) {
         this.url = url;
+        this.serviceIdentityProvider = serviceIdentityProvider;
         this.hostnameVerifier = hostnameVerifier;
     }
 
@@ -33,7 +47,11 @@ class HealthEndpoint {
         return url;
     }
 
-    public HostnameVerifier getHostnameVerifier() {
+    public Optional<ServiceIdentityProvider> getServiceIdentityProvider() {
+        return serviceIdentityProvider;
+    }
+
+    public Optional<HostnameVerifier> getHostnameVerifier() {
         return hostnameVerifier;
     }
 }
diff --git a/service-monitor/src/main/java/com/yahoo/vespa/service/monitor/internal/health/HealthMonitor.java b/service-monitor/src/main/java/com/yahoo/vespa/service/monitor/internal/health/HealthMonitor.java
index 2ad623f15cf..fd809b32918 100644
--- a/service-monitor/src/main/java/com/yahoo/vespa/service/monitor/internal/health/HealthMonitor.java
+++ b/service-monitor/src/main/java/com/yahoo/vespa/service/monitor/internal/health/HealthMonitor.java
@@ -3,10 +3,7 @@ package com.yahoo.vespa.service.monitor.internal.health;
 
 import com.yahoo.log.LogLevel;
 import com.yahoo.vespa.applicationmodel.ServiceStatus;
-import com.yahoo.vespa.athenz.identity.ServiceIdentityProvider;
 
-import javax.net.ssl.HostnameVerifier;
-import java.net.URL;
 import java.time.Duration;
 import java.util.Random;
 import java.util.concurrent.ScheduledThreadPoolExecutor;
@@ -29,10 +26,8 @@ public class HealthMonitor implements AutoCloseable {
 
     private volatile HealthInfo lastHealthInfo = HealthInfo.empty();
 
-    public HealthMonitor(URL stateV1HealthEndpoint,
-                         ServiceIdentityProvider identityProvider,
-                         HostnameVerifier hostnameVerifier) {
-        this.healthClient = new HealthClient(stateV1HealthEndpoint, identityProvider, hostnameVerifier);
+    public HealthMonitor(HealthEndpoint stateV1HealthEndpoint) {
+        this.healthClient = new HealthClient(stateV1HealthEndpoint);
     }
 
     /** For testing. */
@@ -41,6 +36,7 @@ public class HealthMonitor implements AutoCloseable {
     }
 
     public void startMonitoring() {
+        healthClient.start();
         executor.scheduleWithFixedDelay(
                 this::updateSynchronously,
                 initialDelayInSeconds(DELAY.getSeconds()),
diff --git a/service-monitor/src/main/java/com/yahoo/vespa/service/monitor/internal/health/HealthMonitorManager.java b/service-monitor/src/main/java/com/yahoo/vespa/service/monitor/internal/health/HealthMonitorManager.java
index 54d26798ad2..473ef5e3a94 100644
--- a/service-monitor/src/main/java/com/yahoo/vespa/service/monitor/internal/health/HealthMonitorManager.java
+++ b/service-monitor/src/main/java/com/yahoo/vespa/service/monitor/internal/health/HealthMonitorManager.java
@@ -9,7 +9,6 @@ import com.yahoo.vespa.applicationmodel.ClusterId;
 import com.yahoo.vespa.applicationmodel.ConfigId;
 import com.yahoo.vespa.applicationmodel.ServiceStatus;
 import com.yahoo.vespa.applicationmodel.ServiceType;
-import com.yahoo.vespa.athenz.identity.ServiceIdentityProvider;
 import com.yahoo.vespa.service.monitor.application.ZoneApplication;
 import com.yahoo.vespa.service.monitor.internal.MonitorManager;
 
@@ -22,20 +21,17 @@ import java.util.Map;
 public class HealthMonitorManager implements MonitorManager {
     private final Map<ApplicationId, ApplicationHealthMonitor> healthMonitors = new HashMap<>();
     private final ConfigserverConfig configserverConfig;
-    private final ServiceIdentityProvider serviceIdentityProvider;
 
     @Inject
-    public HealthMonitorManager(ConfigserverConfig configserverConfig,
-                                ServiceIdentityProvider serviceIdentityProvider) {
+    public HealthMonitorManager(ConfigserverConfig configserverConfig) {
         this.configserverConfig = configserverConfig;
-        this.serviceIdentityProvider = serviceIdentityProvider;
     }
 
     @Override
     public void applicationActivated(ApplicationInfo application) {
         if (applicationMonitored(application.getApplicationId())) {
             ApplicationHealthMonitor monitor =
-                    ApplicationHealthMonitor.startMonitoring(application, serviceIdentityProvider);
+                    ApplicationHealthMonitor.startMonitoring(application);
             healthMonitors.put(application.getApplicationId(), monitor);
         }
     }
diff --git a/service-monitor/src/test/java/com/yahoo/vespa/service/monitor/application/ApplicationInstanceGeneratorTest.java b/service-monitor/src/test/java/com/yahoo/vespa/service/monitor/application/ApplicationInstanceGeneratorTest.java
index 899cc59bb34..e1d9b728bf8 100644
--- a/service-monitor/src/test/java/com/yahoo/vespa/service/monitor/application/ApplicationInstanceGeneratorTest.java
+++ b/service-monitor/src/test/java/com/yahoo/vespa/service/monitor/application/ApplicationInstanceGeneratorTest.java
@@ -37,7 +37,6 @@ public class ApplicationInstanceGeneratorTest {
         when(statusProvider.getStatus(any(), any(), any(), any())).thenReturn(ServiceStatus.NOT_CHECKED);
         ConfigserverConfig config = ConfigserverUtil.create(
                 true,
-                true,
                 configServer1,
                 configServer2,
                 configServer3);
diff --git a/service-monitor/src/test/java/com/yahoo/vespa/service/monitor/internal/ConfigserverUtil.java b/service-monitor/src/test/java/com/yahoo/vespa/service/monitor/internal/ConfigserverUtil.java
index 8ad153ba8e7..68a55d41b19 100644
--- a/service-monitor/src/test/java/com/yahoo/vespa/service/monitor/internal/ConfigserverUtil.java
+++ b/service-monitor/src/test/java/com/yahoo/vespa/service/monitor/internal/ConfigserverUtil.java
@@ -11,14 +11,12 @@ import com.yahoo.vespa.service.monitor.application.ConfigServerApplication;
 public class ConfigserverUtil {
     /** Create a ConfigserverConfig with the given settings. */
     public static ConfigserverConfig create(
-            boolean hostedVespa,
             boolean nodeAdminInContainer,
             String configServerHostname1,
             String configServerHostname2,
             String configServerHostname3) {
         return new ConfigserverConfig(
                 new ConfigserverConfig.Builder()
-                        .hostedVespa(hostedVespa)
                         .nodeAdminInContainer(nodeAdminInContainer)
                         .zookeeperserver(new ConfigserverConfig.Zookeeperserver.Builder().hostname(configServerHostname1).port(1))
                         .zookeeperserver(new ConfigserverConfig.Zookeeperserver.Builder().hostname(configServerHostname2).port(2))
@@ -26,16 +24,14 @@ public class ConfigserverUtil {
     }
 
     public static ConfigserverConfig createExampleConfigserverConfig(boolean nodeAdminInContainer) {
-        return create(true, nodeAdminInContainer, "cfg1", "cfg2", "cfg3");
+        return create(nodeAdminInContainer, "cfg1", "cfg2", "cfg3");
     }
 
     public static ApplicationInfo makeConfigServerApplicationInfo(
-            boolean hostedVespa,
             String configServerHostname1,
             String configServerHostname2,
             String configServerHostname3) {
         return ConfigServerApplication.CONFIG_SERVER_APPLICATION.makeApplicationInfo(create(
-                hostedVespa,
                 true,
                 configServerHostname1,
                 configServerHostname2,
@@ -43,6 +39,6 @@ public class ConfigserverUtil {
     }
 
     public static ApplicationInfo makeExampleConfigServer() {
-        return makeConfigServerApplicationInfo(true, "cfg1", "cfg2", "cfg3");
+        return makeConfigServerApplicationInfo("cfg1", "cfg2", "cfg3");
     }
 }
diff --git a/service-monitor/src/test/java/com/yahoo/vespa/service/monitor/internal/ModelGeneratorTest.java b/service-monitor/src/test/java/com/yahoo/vespa/service/monitor/internal/ModelGeneratorTest.java
index 72326c7352a..07cfa124434 100644
--- a/service-monitor/src/test/java/com/yahoo/vespa/service/monitor/internal/ModelGeneratorTest.java
+++ b/service-monitor/src/test/java/com/yahoo/vespa/service/monitor/internal/ModelGeneratorTest.java
@@ -32,12 +32,11 @@ public class ModelGeneratorTest {
     private final int PORT = 2;
 
     @Test
-    public void toApplicationModelWithConfigServerApplication() throws Exception {
-        SuperModel superModel =
-                ExampleModel.createExampleSuperModelWithOneRpcPort(HOSTNAME, PORT);
+    public void toApplicationModel() throws Exception {
+        SuperModel superModel = ExampleModel.createExampleSuperModelWithOneRpcPort(HOSTNAME, PORT);
 
         ConfigserverConfig config = ConfigserverUtil.create(
-                true, true, "cfg1", "cfg2", "cfg3");
+                true, "cfg1", "cfg2", "cfg3");
         DuperModel duperModel = new DuperModel(config);
         ModelGenerator modelGenerator = new ModelGenerator();
 
@@ -76,32 +75,6 @@ public class ModelGeneratorTest {
         }
     }
 
-    @Test
-    public void toApplicationModel() throws Exception {
-        SuperModel superModel = ExampleModel.createExampleSuperModelWithOneRpcPort(HOSTNAME, PORT);
-        ConfigserverConfig config = ConfigserverUtil.create(
-                false, true, "cfg1", "cfg2", "cfg3");
-        DuperModel duperModel = new DuperModel(config);
-        ModelGenerator modelGenerator = new ModelGenerator();
-
-        Zone zone = new Zone(Environment.from(ENVIRONMENT), RegionName.from(REGION));
-
-        SlobrokMonitorManagerImpl slobrokMonitorManager = mock(SlobrokMonitorManagerImpl.class);
-        when(slobrokMonitorManager.getStatus(any(), any(), any(), any()))
-                .thenReturn(ServiceStatus.UP);
-
-        ServiceModel serviceModel = modelGenerator.toServiceModel(
-                duperModel.getApplicationInfos(superModel),
-                zone,
-                slobrokMonitorManager);
-
-        Map<ApplicationInstanceReference, ApplicationInstance> applicationInstances =
-                serviceModel.getAllApplicationInstances();
-
-        assertEquals(1, applicationInstances.size());
-        verifyOtherApplication(applicationInstances.values().iterator().next());
-    }
-
     private void verifyOtherApplication(ApplicationInstance applicationInstance) {
         assertEquals(String.format("%s:%s:%s:%s:%s",
                 ExampleModel.TENANT,
diff --git a/service-monitor/src/test/java/com/yahoo/vespa/service/monitor/internal/health/ApplicationHealthMonitorTest.java b/service-monitor/src/test/java/com/yahoo/vespa/service/monitor/internal/health/ApplicationHealthMonitorTest.java
index fd96b519649..51b0503565f 100644
--- a/service-monitor/src/test/java/com/yahoo/vespa/service/monitor/internal/health/ApplicationHealthMonitorTest.java
+++ b/service-monitor/src/test/java/com/yahoo/vespa/service/monitor/internal/health/ApplicationHealthMonitorTest.java
@@ -2,22 +2,18 @@
 package com.yahoo.vespa.service.monitor.internal.health;
 
 import com.yahoo.vespa.applicationmodel.ServiceStatus;
-import com.yahoo.vespa.athenz.identity.ServiceIdentityProvider;
 import com.yahoo.vespa.service.monitor.application.ConfigServerApplication;
 import com.yahoo.vespa.service.monitor.internal.ConfigserverUtil;
 import org.junit.Test;
 
 import static com.yahoo.vespa.applicationmodel.ServiceStatus.NOT_CHECKED;
 import static org.junit.Assert.assertEquals;
-import static org.mockito.Mockito.mock;
 
 public class ApplicationHealthMonitorTest {
     @Test
     public void sanityCheck() {
-        ServiceIdentityProvider provider = mock(ServiceIdentityProvider.class);
         ApplicationHealthMonitor monitor = ApplicationHealthMonitor.startMonitoring(
-                ConfigserverUtil.makeExampleConfigServer(),
-                provider);
+                ConfigserverUtil.makeExampleConfigServer());
         ServiceStatus status = monitor.getStatus(
                 ConfigServerApplication.CONFIG_SERVER_APPLICATION.getApplicationId(),
                 ConfigServerApplication.CLUSTER_ID,
diff --git a/service-monitor/src/test/java/com/yahoo/vespa/service/monitor/internal/health/HealthMonitorManagerTest.java b/service-monitor/src/test/java/com/yahoo/vespa/service/monitor/internal/health/HealthMonitorManagerTest.java
index b416e3f6f2a..97963393268 100644
--- a/service-monitor/src/test/java/com/yahoo/vespa/service/monitor/internal/health/HealthMonitorManagerTest.java
+++ b/service-monitor/src/test/java/com/yahoo/vespa/service/monitor/internal/health/HealthMonitorManagerTest.java
@@ -7,20 +7,17 @@ import com.yahoo.vespa.applicationmodel.ClusterId;
 import com.yahoo.vespa.applicationmodel.ConfigId;
 import com.yahoo.vespa.applicationmodel.ServiceStatus;
 import com.yahoo.vespa.applicationmodel.ServiceType;
-import com.yahoo.vespa.athenz.identity.ServiceIdentityProvider;
 import com.yahoo.vespa.service.monitor.application.ZoneApplication;
 import com.yahoo.vespa.service.monitor.internal.ConfigserverUtil;
 import org.junit.Test;
 
 import static org.junit.Assert.assertEquals;
-import static org.mockito.Mockito.mock;
 
 public class HealthMonitorManagerTest {
     @Test
     public void addRemove() {
         ConfigserverConfig config = ConfigserverUtil.createExampleConfigserverConfig(true);
-        ServiceIdentityProvider provider = mock(ServiceIdentityProvider.class);
-        HealthMonitorManager manager = new HealthMonitorManager(config, provider);
+        HealthMonitorManager manager = new HealthMonitorManager(config);
         ApplicationInfo applicationInfo = ConfigserverUtil.makeExampleConfigServer();
         manager.applicationActivated(applicationInfo);
         manager.applicationRemoved(applicationInfo.getApplicationId());
@@ -29,8 +26,7 @@ public class HealthMonitorManagerTest {
     @Test
     public void withNodeAdmin() {
         ConfigserverConfig config = ConfigserverUtil.createExampleConfigserverConfig(true);
-        ServiceIdentityProvider provider = mock(ServiceIdentityProvider.class);
-        HealthMonitorManager manager = new HealthMonitorManager(config, provider);
+        HealthMonitorManager manager = new HealthMonitorManager(config);
         ServiceStatus status = manager.getStatus(
                 ZoneApplication.ZONE_APPLICATION_ID,
                 ClusterId.NODE_ADMIN,
@@ -42,8 +38,7 @@ public class HealthMonitorManagerTest {
     @Test
     public void withHostAdmin() {
         ConfigserverConfig config = ConfigserverUtil.createExampleConfigserverConfig(false);
-        ServiceIdentityProvider provider = mock(ServiceIdentityProvider.class);
-        HealthMonitorManager manager = new HealthMonitorManager(config, provider);
+        HealthMonitorManager manager = new HealthMonitorManager(config);
         ServiceStatus status = manager.getStatus(
                 ZoneApplication.ZONE_APPLICATION_ID,
                 ClusterId.NODE_ADMIN,