refactor(plugins): Consolidate plugins monitor config (#727)

Co-authored-by: Chris Smalley <csmalley@netflix.com>

igor-monitor-plugins/src/main/java/com/netflix/spinnaker/igor/plugins/PluginsBuildMonitor.java

@@ -83,8 +83,10 @@ protected void commitDelta(PluginPollingDelta delta, boolean sendEvents) {
   private void postEvent(PluginRelease release) {
     if (!echoService.isPresent()) {
       log.warn("Cannot send new plugin notification: Echo is not configured");
-      registry.counter(
-          missedNotificationId.withTag("monitor", PluginsBuildMonitor.class.getSimpleName()));
+      registry
+          .counter(
+              missedNotificationId.withTag("monitor", PluginsBuildMonitor.class.getSimpleName()))
+          .increment();
     } else if (release != null) {
       AuthenticatedRequest.allowAnonymous(
           () -> echoService.get().postEvent(new PluginEvent(release)));

igor-web/src/main/groovy/com/netflix/spinnaker/igor/config/PluginMonitorConfig.java

@@ -18,6 +18,7 @@
 
 import com.netflix.discovery.DiscoveryClient;
 import com.netflix.spectator.api.Registry;
+import com.netflix.spinnaker.config.OkHttpClientConfiguration;
 import com.netflix.spinnaker.igor.IgorConfigurationProperties;
 import com.netflix.spinnaker.igor.history.EchoService;
 import com.netflix.spinnaker.igor.plugins.PluginCache;
@@ -27,13 +28,18 @@
 import com.netflix.spinnaker.igor.polling.LockService;
 import com.netflix.spinnaker.kork.dynamicconfig.DynamicConfigService;
 import com.netflix.spinnaker.kork.jedis.RedisClientDelegate;
+import com.netflix.spinnaker.retrofit.Slf4jRetrofitLogger;
+import com.squareup.okhttp.OkHttpClient;
 import java.util.Optional;
-import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import retrofit.Endpoints;
+import retrofit.RestAdapter;
+import retrofit.client.OkClient;
 
 @Configuration
-@ConditionalOnBean(Front50Service.class)
+@ConditionalOnProperty("services.front50.base-url")
 public class PluginMonitorConfig {
 
   @Bean
@@ -43,7 +49,21 @@ public PluginCache pluginCache(
   }
 
   @Bean
-  public PluginReleaseService pluginReleaseService(Front50Service front50Service) {
+  public PluginReleaseService pluginReleaseService(
+      OkHttpClientConfiguration okHttpClientConfiguration, IgorConfigurationProperties properties) {
+    String address = properties.getServices().getFront50().getBaseUrl();
+
+    OkHttpClient client = okHttpClientConfiguration.create();
+
+    Front50Service front50Service =
+        new RestAdapter.Builder()
+            .setEndpoint(Endpoints.newFixedEndpoint(address))
+            .setClient(new OkClient(client))
+            .setLogLevel(RestAdapter.LogLevel.BASIC)
+            .setLog(new Slf4jRetrofitLogger(Front50Service.class))
+            .build()
+            .create(Front50Service.class);
+
     return new PluginReleaseService(front50Service);
   }