Fix for ONOS-4621. If any errors in parsing the configurations, continue with th…

…e next config key and return the list of subjectClass, subject, config failures

Change-Id: I4883342b4920aa4d6d641a17a395e5f6e4f27d6a

@@ -73,13 +73,14 @@ public class NetworkConfigLoader {
 
 
                 populateConfigurations();
                 populateConfigurations();
 
 
-                applyConfigurations();
-
+                if (applyConfigurations()) {
                     log.info("Loaded initial network configuration from {}", CFG_FILE);
                     log.info("Loaded initial network configuration from {}", CFG_FILE);
+                } else {
+                    log.error("Partially loaded initial network configuration from {}", CFG_FILE);
+                }
             }
             }
         } catch (Exception e) {
         } catch (Exception e) {
-            log.warn("Unable to load initial network configuration from {}",
-                    CFG_FILE, e);
+            log.warn("Unable to load initial network configuration from {}", CFG_FILE, e);
         }
         }
     }
     }
 
 
@@ -185,8 +186,10 @@ public class NetworkConfigLoader {
     /**
     /**
      * Apply the configurations associated with all of the config classes that
      * Apply the configurations associated with all of the config classes that
      * are imported and have not yet been applied.
      * are imported and have not yet been applied.
+     *
+     * @return false if any of the configuration parsing fails
      */
      */
-    private void applyConfigurations() {
+    private boolean applyConfigurations() {
         Iterator<Map.Entry<InnerConfigPosition, JsonNode>> iter = jsons.entrySet().iterator();
         Iterator<Map.Entry<InnerConfigPosition, JsonNode>> iter = jsons.entrySet().iterator();
 
 
         Map.Entry<InnerConfigPosition, JsonNode> entry;
         Map.Entry<InnerConfigPosition, JsonNode> entry;
@@ -195,7 +198,7 @@ public class NetworkConfigLoader {
         String subjectKey;
         String subjectKey;
         String subjectString;
         String subjectString;
         String configKey;
         String configKey;
-
+        boolean isSuccess = true;
         while (iter.hasNext()) {
         while (iter.hasNext()) {
             entry = iter.next();
             entry = iter.next();
             node = entry.getValue();
             node = entry.getValue();
@@ -212,13 +215,19 @@ public class NetworkConfigLoader {
                 Object subject = networkConfigService.getSubjectFactory(subjectKey).
                 Object subject = networkConfigService.getSubjectFactory(subjectKey).
                         createSubject(subjectString);
                         createSubject(subjectString);
 
 
+                try {
                     //Apply the configuration
                     //Apply the configuration
                     networkConfigService.applyConfig(subject, configClass, node);
                     networkConfigService.applyConfig(subject, configClass, node);
+                } catch (IllegalArgumentException e) {
+                    log.warn("Error parsing config " + subjectKey + "/" + subject + "/" + configKey);
+                    isSuccess = false;
+                }
 
 
                 //Now that it has been applied the corresponding JSON entry is no longer needed
                 //Now that it has been applied the corresponding JSON entry is no longer needed
                 iter.remove();
                 iter.remove();
             }
             }
         }
         }
+        return isSuccess;
    }
    }
 
 
 }
 }

@@ -17,6 +17,8 @@ package org.onosproject.rest.resources;
 
 
 import java.io.IOException;
 import java.io.IOException;
 import java.io.InputStream;
 import java.io.InputStream;
+import java.util.ArrayList;
+import java.util.List;
 import java.util.Set;
 import java.util.Set;
 
 
 import javax.ws.rs.Consumes;
 import javax.ws.rs.Consumes;
@@ -34,6 +36,7 @@ import org.onosproject.net.config.NetworkConfigService;
 import org.onosproject.net.config.SubjectFactory;
 import org.onosproject.net.config.SubjectFactory;
 import org.onosproject.rest.AbstractWebResource;
 import org.onosproject.rest.AbstractWebResource;
 
 
+import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.node.ObjectNode;
 import com.fasterxml.jackson.databind.node.ObjectNode;
 
 
 import static org.onlab.util.Tools.emptyIsNotFound;
 import static org.onlab.util.Tools.emptyIsNotFound;
@@ -45,6 +48,8 @@ import static org.onlab.util.Tools.nullIsNotFound;
 @Path("network/configuration")
 @Path("network/configuration")
 public class NetworkConfigWebResource extends AbstractWebResource {
 public class NetworkConfigWebResource extends AbstractWebResource {
 
 
+    //FIX ME not found Multi status error code 207 in jaxrs Response Status.
+    private static final int  MULTI_STATUS_RESPONE = 207;
 
 
     private String subjectClassNotFoundErrorString(String subjectClassKey) {
     private String subjectClassNotFoundErrorString(String subjectClassKey) {
         return "Config for '" + subjectClassKey + "' not found";
         return "Config for '" + subjectClassKey + "' not found";
@@ -194,9 +199,16 @@ public class NetworkConfigWebResource extends AbstractWebResource {
     public Response upload(InputStream request) throws IOException {
     public Response upload(InputStream request) throws IOException {
         NetworkConfigService service = get(NetworkConfigService.class);
         NetworkConfigService service = get(NetworkConfigService.class);
         ObjectNode root = (ObjectNode) mapper().readTree(request);
         ObjectNode root = (ObjectNode) mapper().readTree(request);
+        List<String> errorMsgs = new ArrayList<String>();
         root.fieldNames()
         root.fieldNames()
-                .forEachRemaining(sk -> consumeJson(service, (ObjectNode) root.path(sk),
+                .forEachRemaining(sk ->
+                {
+                    errorMsgs.addAll(consumeJson(service, (ObjectNode) root.path(sk),
                                                  service.getSubjectFactory(sk)));
                                                  service.getSubjectFactory(sk)));
+                });
+        if (errorMsgs.toString().length() > 0) {
+            return Response.status(MULTI_STATUS_RESPONE).entity(produceErrorJson(errorMsgs)).build();
+        }
         return Response.ok().build();
         return Response.ok().build();
     }
     }
 
 
@@ -216,7 +228,10 @@ public class NetworkConfigWebResource extends AbstractWebResource {
                            InputStream request) throws IOException {
                            InputStream request) throws IOException {
         NetworkConfigService service = get(NetworkConfigService.class);
         NetworkConfigService service = get(NetworkConfigService.class);
         ObjectNode root = (ObjectNode) mapper().readTree(request);
         ObjectNode root = (ObjectNode) mapper().readTree(request);
-        consumeJson(service, root, service.getSubjectFactory(subjectClassKey));
+        List<String> errorMsgs = consumeJson(service, root, service.getSubjectFactory(subjectClassKey));
+        if (errorMsgs.toString().length() > 0) {
+            return Response.status(MULTI_STATUS_RESPONE).entity(produceErrorJson(errorMsgs)).build();
+        }
         return Response.ok().build();
         return Response.ok().build();
     }
     }
 
 
@@ -238,9 +253,12 @@ public class NetworkConfigWebResource extends AbstractWebResource {
                            InputStream request) throws IOException {
                            InputStream request) throws IOException {
         NetworkConfigService service = get(NetworkConfigService.class);
         NetworkConfigService service = get(NetworkConfigService.class);
         ObjectNode root = (ObjectNode) mapper().readTree(request);
         ObjectNode root = (ObjectNode) mapper().readTree(request);
-        consumeSubjectJson(service, root,
+        List<String> errorMsgs = consumeSubjectJson(service, root,
                                  service.getSubjectFactory(subjectClassKey).createSubject(subjectKey),
                                  service.getSubjectFactory(subjectClassKey).createSubject(subjectKey),
                                  subjectClassKey);
                                  subjectClassKey);
+        if (errorMsgs.size() > 0) {
+            return Response.status(MULTI_STATUS_RESPONE).entity(produceErrorJson(errorMsgs)).build();
+        }
         return Response.ok().build();
         return Response.ok().build();
     }
     }
 
 
@@ -270,21 +288,37 @@ public class NetworkConfigWebResource extends AbstractWebResource {
         return Response.ok().build();
         return Response.ok().build();
     }
     }
 
 
-    private void consumeJson(NetworkConfigService service, ObjectNode classNode,
+    private List<String> consumeJson(NetworkConfigService service, ObjectNode classNode,
                              SubjectFactory subjectFactory) {
                              SubjectFactory subjectFactory) {
-        classNode.fieldNames().forEachRemaining(s ->
-            consumeSubjectJson(service, (ObjectNode) classNode.path(s),
+        List<String> errorMsgs = new ArrayList<String>();
+        classNode.fieldNames().forEachRemaining(s -> {
+            List<String> error = consumeSubjectJson(service, (ObjectNode) classNode.path(s),
                                                     subjectFactory.createSubject(s),
                                                     subjectFactory.createSubject(s),
-                               subjectFactory.subjectClassKey()));
+                                                    subjectFactory.subjectClassKey());
+            errorMsgs.addAll(error);
+        });
+        return errorMsgs;
     }
     }
 
 
-    private void consumeSubjectJson(NetworkConfigService service,
+    private List<String> consumeSubjectJson(NetworkConfigService service,
                                     ObjectNode subjectNode, Object subject,
                                     ObjectNode subjectNode, Object subject,
                                     String subjectClassKey) {
                                     String subjectClassKey) {
-        subjectNode.fieldNames().forEachRemaining(configKey ->
-            service.applyConfig(subjectClassKey, subject, configKey, subjectNode.path(configKey)));
+        List<String> errorMsgs = new ArrayList<String>();
+        subjectNode.fieldNames().forEachRemaining(configKey -> {
+            try {
+                service.applyConfig(subjectClassKey, subject, configKey, subjectNode.path(configKey));
+            } catch (IllegalArgumentException e) {
+                errorMsgs.add("Error parsing config " + subjectClassKey + "/" + subject + "/" + configKey);
+            }
+        });
+        return errorMsgs;
     }
     }
 
 
+    private ObjectNode produceErrorJson(List<String> errorMsgs) {
+        ObjectMapper mapper = new ObjectMapper();
+        ObjectNode result = mapper.createObjectNode().put("code", 207).putPOJO("message", errorMsgs);
+        return result;
+    }
 
 
     // FIXME: Refactor to allow queued configs to be removed
     // FIXME: Refactor to allow queued configs to be removed