Post-process recovered proxies by specprovider

Author: LEDfan

src/main/java/eu/openanalytics/containerproxy/model/runtime/Proxy.java

@@ -16,7 +16,7 @@
  * Apache License for more details.
  *
  * You should have received a copy of the Apache License
- * along with this program.  If not, see http://www.apache.org/licenses/>
+ * along with this program.  If not, see <http://www.apache.org/licenses/>
  */
 package eu.openanalytics.containerproxy.model.runtime;
 

src/main/java/eu/openanalytics/containerproxy/service/AppRecoveryService.java

@@ -20,7 +20,6 @@
  */
 package eu.openanalytics.containerproxy.service;
 
-import com.spotify.docker.client.messages.ContainerInfo;
 import eu.openanalytics.containerproxy.backend.IContainerBackend;
 import eu.openanalytics.containerproxy.model.runtime.Container;
 import eu.openanalytics.containerproxy.model.runtime.ExistingContainerInfo;
@@ -56,7 +55,7 @@ public class AppRecoveryService {
 
 	protected static final String PROPERTY_RECOVER_RUNNING_APPS = "proxy.recover_running_apps";
 
-	private Logger log = LogManager.getLogger(AppRecoveryService.class);
+	private final Logger log = LogManager.getLogger(AppRecoveryService.class);
 
 	@Inject
 	private Environment environment;
@@ -122,11 +121,13 @@ public void recoverRunningApps() throws Exception {
 				proxy.setStatus(ProxyStatus.Up);
 
 				setupPortMapping(proxy, container, containerInfo);
+
+				proxySpecProvider.postProcessRecoveredProxy(proxy);
 			}
 
 			for (Proxy proxy: proxies.values()) {
 				proxyService.addExistingProxy(proxy);
-				heartbeatService.heartbeatReceived(proxy.getId());
+				heartbeatService.heartbeatReceived(proxy);
 			}
 
 		} else {

src/main/java/eu/openanalytics/containerproxy/spec/IProxySpecProvider.java

@@ -22,6 +22,7 @@
 
 import java.util.List;
 
+import eu.openanalytics.containerproxy.model.runtime.Proxy;
 import eu.openanalytics.containerproxy.model.spec.ProxySpec;
 
 /**
@@ -33,4 +34,8 @@ public interface IProxySpecProvider {
 
 	public ProxySpec getSpec(String id);
 
+	default public void postProcessRecoveredProxy(Proxy proxy) {
+		// no-op
+	}
+
 }