1 files changed, 77 insertions, 0 deletions
diff --git a/champ-lib/champ-core/src/main/java/org/onap/aai/champcore/Formatter.java b/champ-lib/champ-core/src/main/java/org/onap/aai/champcore/Formatter.java
new file mode 100644
index 0000000..a6292f3
--- /dev/null
+++ b/champ-lib/champ-core/src/main/java/org/onap/aai/champcore/Formatter.java
@@ -0,0 +1,77 @@
+/**
+ * ============LICENSE_START==========================================
+ * org.onap.aai
+ * ===================================================================
+ * Copyright © 2017 AT&T Intellectual Property. All rights reserved.
+ * Copyright © 2017 Amdocs
+ * ===================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *        http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END============================================
+ * ECOMP is a trademark and service mark of AT&T Intellectual Property.
+ */
+package org.onap.aai.champcore;
+
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
+import com.google.gson.JsonArray;
+import com.google.gson.JsonElement;
+import com.google.gson.JsonObject;
+import com.google.gson.JsonParser;
+import java.util.List;
+import java.util.Optional;
+import java.util.stream.Stream;
+
+public class Formatter {
+
+    private static final EELFLogger LOGGER = EELFManager.getInstance().getLogger(Formatter.class);
+    protected JsonParser parser = new JsonParser();
+    protected final FormatMapper format;
+
+    public Formatter(FormatMapper format) {
+        this.format = format;
+    }
+
+    public JsonObject output(List<Object> vertices) {
+        Stream<Object> stream = null;
+        JsonObject result = new JsonObject();
+        JsonArray body = new JsonArray();
+        if (vertices.size() >= this.format.parallelThreshold()) {
+            stream = vertices.parallelStream();
+        } else {
+            stream = vertices.stream();
+        }
+
+        boolean isParallel = stream.isParallel();
+        stream.map((v) -> {
+            try {
+                return Optional.of(this.format.formatObject(v));
+            } catch (Exception var3) {
+                LOGGER.warn("Failed to format vertex, returning a partial list", var3);
+                return Optional.empty();
+            }
+        }).forEach((obj) -> {
+            if (obj.isPresent()) {
+                if (isParallel) {
+                    synchronized(body) {
+                        body.add((JsonElement)obj.get());
+                    }
+                } else {
+                    body.add((JsonElement)obj.get());
+                }
+            }
+
+        });
+        result.add("results", body);
+        return result.getAsJsonObject();
+    }
+}
+\ No newline at end of file