Implementation of controller example client

Signed-off-by: Jonathan Philip Knoblauch <JonathanPhilip.Knoblauch@bosch-si.com>

examples/hawkbit-example-ddi-client/src/main/java/org/eclipse/hawkbit/ddi/client/ApplicationJsonRequestHeaderInterceptor.java

@@ -22,6 +22,8 @@ public class ApplicationJsonRequestHeaderInterceptor implements RequestIntercept
     @Override
     public void apply(final RequestTemplate template) {
         template.header("Accept", MediaType.APPLICATION_JSON_VALUE);
+        // template.header("Accept",
+        // EnableHypermediaSupport.HypermediaType.HAL);
         template.header("Content-Type", MediaType.APPLICATION_JSON_VALUE);
     }
 

examples/hawkbit-example-ddi-client/src/main/java/org/eclipse/hawkbit/ddi/client/DdiDefaultFeignClient.java

@@ -5,6 +5,10 @@ package org.eclipse.hawkbit.ddi.client;
 
 import org.eclipse.hawkbit.ddi.client.resource.RootControllerResourceClient;
 import org.springframework.cloud.netflix.feign.support.ResponseEntityDecoder;
+import org.springframework.hateoas.hal.Jackson2HalModule;
+
+import com.fasterxml.jackson.databind.DeserializationFeature;
+import com.fasterxml.jackson.databind.ObjectMapper;
 
 import feign.Feign;
 import feign.Feign.Builder;
@@ -26,12 +30,18 @@ public class DdiDefaultFeignClient {
     private final String tenant;
 
     public DdiDefaultFeignClient(final String baseUrl, final String tenant) {
+
+        final ObjectMapper mapper = new ObjectMapper()
+                .configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false)
+                .registerModule(new Jackson2HalModule());
+
         feignBuilder = Feign.builder().contract(new IgnoreMultipleConsumersProducersSpringMvcContract())
                 .requestInterceptor(new ApplicationJsonRequestHeaderInterceptor()).logLevel(Level.FULL)
                 .logger(new Logger.ErrorLogger()).encoder(new JacksonEncoder())
-                .decoder(new ResponseEntityDecoder(new JacksonDecoder()));
+                .decoder(new ResponseEntityDecoder(new JacksonDecoder(mapper)));
         this.baseUrl = baseUrl;
         this.tenant = tenant;
+
     }
 
     public Builder getFeignBuilder() {

examples/hawkbit-example-ddi-client/src/main/java/org/eclipse/hawkbit/ddi/client/DdiExampleClient.java

@@ -3,36 +3,55 @@
  */
 package org.eclipse.hawkbit.ddi.client;
 
-import org.springframework.stereotype.Component;
+import java.util.regex.Pattern;
 
-@Component
-public class DdiExampleClient {
+import org.eclipse.hawkbit.ddi.json.model.DdiControllerBase;
+import org.eclipse.hawkbit.ddi.json.model.DdiDeploymentBase;
+import org.springframework.hateoas.Link;
+import org.springframework.http.ResponseEntity;
+
+//@Component
+public class DdiExampleClient implements Runnable {
 
     private final String controllerId;
-    private final String name;
-    private final String description;
-    private final String baseUrl;
+
     final DdiDefaultFeignClient ddiDefaultFeignClient;
 
-    public DdiExampleClient(final String baseUrl, final String controllerId, final String name,
-            final String description, final String tenant) {
+    public DdiExampleClient(final String baseUrl, final String controllerId, final String tenant) {
         super();
         this.controllerId = controllerId;
-        this.name = name;
-        this.description = description;
-        this.baseUrl = baseUrl;
         ddiDefaultFeignClient = new DdiDefaultFeignClient(baseUrl, tenant);
     }
 
+    @Override
+    public void run() {
+
+        ResponseEntity<DdiControllerBase> response;
+
+        for (int i = 0; i < 20; i++) {
+
+            response = ddiDefaultFeignClient.getRootControllerResourceClient().getControllerBase(controllerId);
+            final DdiControllerBase controllerBase = response.getBody();
+            final Link controllerDeploymentBaseLink = controllerBase.getLink("deploymentBase");
+
+            if (controllerDeploymentBaseLink != null) {
+                // TOD actung download nur einmal starten
+                startDownload(controllerDeploymentBaseLink);
+            }
+
+            try {
+                Thread.sleep(2000);
+            } catch (final InterruptedException e) {
+                // TODO Auto-generated catch block
+                e.printStackTrace();
+            }
+        }
+
+    }
+
     public void startDdiClient() {
 
-        // final ResponseEntity<DdiControllerBase> response =
-
-        ddiDefaultFeignClient.getRootControllerResourceClient().getControllerBase(controllerId);
-
-        // final DdiControllerBase controllerBase = response.getBody();
-
-        System.out.println("test");
+        //
 
         // TODO notify every 10 seconds on the rollout server
 
@@ -42,4 +61,32 @@ public class DdiExampleClient {
 
     }
 
+    private void startDownload(final Link controllerDeploymentBaseLink) {
+
+        // controllerDeploymentBaseLink.
+
+        // final List<String> varibles = controllerDeploymentBaseLink.get
+
+        final String link = controllerDeploymentBaseLink.getHref();
+        final String[] segs = link.split(Pattern.quote("/"));
+        final String[] ending = segs[8].split(Pattern.quote("?"));
+        final String actionId = ending[0];
+        final String resource = ending[1].substring(2);
+
+        final ResponseEntity<DdiDeploymentBase> respone = ddiDefaultFeignClient.getRootControllerResourceClient()
+                .getControllerBasedeploymentAction(controllerId, Long.valueOf(actionId), Integer.valueOf(resource));
+
+        final DdiDeploymentBase ddiDeploymentBase = respone.getBody();
+
+        final Link downloadLink = ddiDeploymentBase.getDeployment().getChunks().get(0).getArtifacts().get(0)
+                .getLink("download");
+
+        System.out.println("download startet ....");
+
+    }
+
+    private void startSimulatedInstalltion() {
+
+    }
+
 }

examples/hawkbit-example-ddi-client/src/main/java/org/eclipse/hawkbit/ddi/client/resource/RootControllerResourceClient.java

@@ -9,6 +9,7 @@ import org.springframework.cloud.netflix.feign.FeignClient;
 /**
  * Client binding for the Rootcontroller resource of the DDI API.
  */
+
 @FeignClient(url = "${hawkbit.url:localhost:8080}/" + RootControllerResourceClient.PATH)
 public interface RootControllerResourceClient extends DdiRootControllerRestApi {
 

examples/hawkbit-example-ddi-client/src/test/java/org/eclipse/hawkbit/example/ddi/client/AppTest.java

@@ -11,9 +11,10 @@ public class AppTest {
     @Test
     public void AppTest() {
 
-        final DdiExampleClient ddiClient = new DdiExampleClient("http://localhost:8080/", "mytest", "mytest", "desc",
-                "DEFAULT");
-        ddiClient.startDdiClient();
+        final DdiExampleClient ddiClient = new DdiExampleClient("http://localhost:8080/", "jktest", "DEFAULT");
+        ddiClient.run();
+
+        System.out.println("next steps........................");
     }
 
 }