@POST @Path("save") @Consumes(MediaType.APPLICATION_JSON) @Produces(MediaType.APPLICATION_JSON) public Response save(String json) throws Exception { JsonStreamParser jsonStreamParser = new JsonStreamParser(json); if (!jsonStreamParser.hasNext()) { return Response.status(Status.BAD_REQUEST).build(); } JsonObject saveObject = jsonStreamParser.next().getAsJsonObject(); // get navigation MCRNavigation newNavigation = MCRWCMSNavigationManager.fromJSON(saveObject); // save navigation MCRWCMSNavigationManager.save(newNavigation); // save content JsonArray items = saveObject.get(MCRWCMSNavigationProvider.JSON_ITEMS).getAsJsonArray(); getContentManager().save(items); return Response.ok().build(); }
public static HashMap<MCRCategoryID, String> getCategoryIDMap(String json) { HashMap<MCRCategoryID, String> categories = new HashMap<>(); JsonStreamParser jsonStreamParser = new JsonStreamParser(json); if (jsonStreamParser.hasNext()) { JsonArray saveObjArray = jsonStreamParser.next().getAsJsonArray(); for (JsonElement jsonElement : saveObjArray) { //jsonObject.item.id.rootid JsonObject root = jsonElement.getAsJsonObject(); String rootId = root.getAsJsonObject("item").getAsJsonObject("id").getAsJsonPrimitive("rootid") .getAsString(); String state = root.getAsJsonPrimitive("state").getAsString(); JsonElement parentIdJSON = root.get("parentId"); if (parentIdJSON != null && parentIdJSON.isJsonPrimitive() && "_placeboid_".equals(parentIdJSON.getAsString())) { state = "new"; } categories.put(MCRCategoryID.rootID(rootId), state); } } else { return null; } return categories; }
@Test(timeout = 1000) public void testReadWriteTwoStrings_add1417() throws IOException { fr.inria.diversify.testamplification.logger.Logger.writeTestStart(Thread.currentThread(),this, "testReadWriteTwoStrings_add1417"); Gson gson = new Gson(); CharArrayWriter writer = new CharArrayWriter(); writer.write(gson.toJson("one").toCharArray()); writer.write(gson.toJson("one").toCharArray()); writer.write(gson.toJson("two").toCharArray()); CharArrayReader reader = new CharArrayReader(writer.toCharArray()); JsonStreamParser parser = new JsonStreamParser(reader); String actualOne = gson.fromJson(parser.next(), String.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2395,actualOne); String actualTwo = gson.fromJson(parser.next(), String.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2396,actualTwo); fr.inria.diversify.testamplification.logger.Logger.writeTestFinish(Thread.currentThread()); }
@Test(timeout = 1000) public void testReadWriteTwoStrings_add1418() throws IOException { fr.inria.diversify.testamplification.logger.Logger.writeTestStart(Thread.currentThread(),this, "testReadWriteTwoStrings_add1418"); Gson gson = new Gson(); CharArrayWriter writer = new CharArrayWriter(); writer.write(gson.toJson("one").toCharArray()); writer.write(gson.toJson("two").toCharArray()); writer.write(gson.toJson("two").toCharArray()); CharArrayReader reader = new CharArrayReader(writer.toCharArray()); JsonStreamParser parser = new JsonStreamParser(reader); String actualOne = gson.fromJson(parser.next(), String.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2395,actualOne); String actualTwo = gson.fromJson(parser.next(), String.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2396,actualTwo); fr.inria.diversify.testamplification.logger.Logger.writeTestFinish(Thread.currentThread()); }
@Test(timeout = 1000) public void testReadWriteTwoObjects_add1415() throws IOException { fr.inria.diversify.testamplification.logger.Logger.writeTestStart(Thread.currentThread(),this, "testReadWriteTwoObjects_add1415"); Gson gson = new Gson(); CharArrayWriter writer = new CharArrayWriter(); TestTypes.BagOfPrimitives expectedOne = new TestTypes.BagOfPrimitives(1 , 1 , true , "one"); writer.write(gson.toJson(expectedOne).toCharArray()); writer.write(gson.toJson(expectedOne).toCharArray()); TestTypes.BagOfPrimitives expectedTwo = new TestTypes.BagOfPrimitives(2 , 2 , false , "two"); writer.write(gson.toJson(expectedTwo).toCharArray()); CharArrayReader reader = new CharArrayReader(writer.toCharArray()); JsonStreamParser parser = new JsonStreamParser(reader); TestTypes.BagOfPrimitives actualOne = gson.fromJson(parser.next(), TestTypes.BagOfPrimitives.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2391,actualOne.stringValue); TestTypes.BagOfPrimitives actualTwo = gson.fromJson(parser.next(), TestTypes.BagOfPrimitives.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2392,actualTwo.stringValue); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2394,parser,2393,parser.hasNext()); fr.inria.diversify.testamplification.logger.Logger.writeTestFinish(Thread.currentThread()); }
@Test(timeout = 1000) public void testReadWriteTwoObjects_add1416() throws IOException { fr.inria.diversify.testamplification.logger.Logger.writeTestStart(Thread.currentThread(),this, "testReadWriteTwoObjects_add1416"); Gson gson = new Gson(); CharArrayWriter writer = new CharArrayWriter(); TestTypes.BagOfPrimitives expectedOne = new TestTypes.BagOfPrimitives(1 , 1 , true , "one"); writer.write(gson.toJson(expectedOne).toCharArray()); TestTypes.BagOfPrimitives expectedTwo = new TestTypes.BagOfPrimitives(2 , 2 , false , "two"); writer.write(gson.toJson(expectedTwo).toCharArray()); writer.write(gson.toJson(expectedTwo).toCharArray()); CharArrayReader reader = new CharArrayReader(writer.toCharArray()); JsonStreamParser parser = new JsonStreamParser(reader); TestTypes.BagOfPrimitives actualOne = gson.fromJson(parser.next(), TestTypes.BagOfPrimitives.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2391,actualOne.stringValue); TestTypes.BagOfPrimitives actualTwo = gson.fromJson(parser.next(), TestTypes.BagOfPrimitives.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2392,actualTwo.stringValue); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2394,parser,2393,parser.hasNext()); fr.inria.diversify.testamplification.logger.Logger.writeTestFinish(Thread.currentThread()); }
public void testReadWriteTwoObjects() throws IOException { fr.inria.diversify.testamplification.logger.Logger.writeTestStart(Thread.currentThread(),this, "testReadWriteTwoObjects"); Gson gson = new Gson(); CharArrayWriter writer = new CharArrayWriter(); TestTypes.BagOfPrimitives expectedOne = new TestTypes.BagOfPrimitives(2 , 1 , true , "one"); writer.write(gson.toJson(expectedOne).toCharArray()); TestTypes.BagOfPrimitives expectedTwo = new TestTypes.BagOfPrimitives(2 , 2 , false , "two"); writer.write(gson.toJson(expectedTwo).toCharArray()); CharArrayReader reader = new CharArrayReader(writer.toCharArray()); JsonStreamParser parser = new JsonStreamParser(reader); TestTypes.BagOfPrimitives actualOne = gson.fromJson(parser.next(), TestTypes.BagOfPrimitives.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2391,actualOne.stringValue); TestTypes.BagOfPrimitives actualTwo = gson.fromJson(parser.next(), TestTypes.BagOfPrimitives.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2392,actualTwo.stringValue); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2394,parser,2393,parser.hasNext()); fr.inria.diversify.testamplification.logger.Logger.writeTestFinish(Thread.currentThread()); }
public void testReadWriteTwoObjects_literalMutation1921() throws IOException { fr.inria.diversify.testamplification.logger.Logger.writeTestStart(Thread.currentThread(),this, "testReadWriteTwoObjects_literalMutation1921"); Gson gson = new Gson(); CharArrayWriter writer = new CharArrayWriter(); TestTypes.BagOfPrimitives expectedOne = new TestTypes.BagOfPrimitives(1 , 0 , true , "one"); writer.write(gson.toJson(expectedOne).toCharArray()); TestTypes.BagOfPrimitives expectedTwo = new TestTypes.BagOfPrimitives(2 , 2 , false , "two"); writer.write(gson.toJson(expectedTwo).toCharArray()); CharArrayReader reader = new CharArrayReader(writer.toCharArray()); JsonStreamParser parser = new JsonStreamParser(reader); TestTypes.BagOfPrimitives actualOne = gson.fromJson(parser.next(), TestTypes.BagOfPrimitives.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2391,actualOne.stringValue); TestTypes.BagOfPrimitives actualTwo = gson.fromJson(parser.next(), TestTypes.BagOfPrimitives.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2392,actualTwo.stringValue); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2394,parser,2393,parser.hasNext()); fr.inria.diversify.testamplification.logger.Logger.writeTestFinish(Thread.currentThread()); }
public void testReadWriteTwoObjects_literalMutation1922() throws IOException { fr.inria.diversify.testamplification.logger.Logger.writeTestStart(Thread.currentThread(),this, "testReadWriteTwoObjects_literalMutation1922"); Gson gson = new Gson(); CharArrayWriter writer = new CharArrayWriter(); TestTypes.BagOfPrimitives expectedOne = new TestTypes.BagOfPrimitives(1 , 1 , false , "one"); writer.write(gson.toJson(expectedOne).toCharArray()); TestTypes.BagOfPrimitives expectedTwo = new TestTypes.BagOfPrimitives(2 , 2 , false , "two"); writer.write(gson.toJson(expectedTwo).toCharArray()); CharArrayReader reader = new CharArrayReader(writer.toCharArray()); JsonStreamParser parser = new JsonStreamParser(reader); TestTypes.BagOfPrimitives actualOne = gson.fromJson(parser.next(), TestTypes.BagOfPrimitives.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2391,actualOne.stringValue); TestTypes.BagOfPrimitives actualTwo = gson.fromJson(parser.next(), TestTypes.BagOfPrimitives.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2392,actualTwo.stringValue); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2394,parser,2393,parser.hasNext()); fr.inria.diversify.testamplification.logger.Logger.writeTestFinish(Thread.currentThread()); }
public void testReadWriteTwoObjects_literalMutation1923() throws IOException { fr.inria.diversify.testamplification.logger.Logger.writeTestStart(Thread.currentThread(),this, "testReadWriteTwoObjects_literalMutation1923"); Gson gson = new Gson(); CharArrayWriter writer = new CharArrayWriter(); TestTypes.BagOfPrimitives expectedOne = new TestTypes.BagOfPrimitives(1 , 1 , true , "foo"); writer.write(gson.toJson(expectedOne).toCharArray()); TestTypes.BagOfPrimitives expectedTwo = new TestTypes.BagOfPrimitives(2 , 2 , false , "two"); writer.write(gson.toJson(expectedTwo).toCharArray()); CharArrayReader reader = new CharArrayReader(writer.toCharArray()); JsonStreamParser parser = new JsonStreamParser(reader); TestTypes.BagOfPrimitives actualOne = gson.fromJson(parser.next(), TestTypes.BagOfPrimitives.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2391,actualOne.stringValue); TestTypes.BagOfPrimitives actualTwo = gson.fromJson(parser.next(), TestTypes.BagOfPrimitives.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2392,actualTwo.stringValue); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2394,parser,2393,parser.hasNext()); fr.inria.diversify.testamplification.logger.Logger.writeTestFinish(Thread.currentThread()); }
public void testReadWriteTwoObjects_literalMutation1924() throws IOException { fr.inria.diversify.testamplification.logger.Logger.writeTestStart(Thread.currentThread(),this, "testReadWriteTwoObjects_literalMutation1924"); Gson gson = new Gson(); CharArrayWriter writer = new CharArrayWriter(); TestTypes.BagOfPrimitives expectedOne = new TestTypes.BagOfPrimitives(1 , 1 , true , "one"); writer.write(gson.toJson(expectedOne).toCharArray()); TestTypes.BagOfPrimitives expectedTwo = new TestTypes.BagOfPrimitives(1 , 2 , false , "two"); writer.write(gson.toJson(expectedTwo).toCharArray()); CharArrayReader reader = new CharArrayReader(writer.toCharArray()); JsonStreamParser parser = new JsonStreamParser(reader); TestTypes.BagOfPrimitives actualOne = gson.fromJson(parser.next(), TestTypes.BagOfPrimitives.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2391,actualOne.stringValue); TestTypes.BagOfPrimitives actualTwo = gson.fromJson(parser.next(), TestTypes.BagOfPrimitives.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2392,actualTwo.stringValue); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2394,parser,2393,parser.hasNext()); fr.inria.diversify.testamplification.logger.Logger.writeTestFinish(Thread.currentThread()); }
public void testReadWriteTwoObjects_literalMutation1925() throws IOException { fr.inria.diversify.testamplification.logger.Logger.writeTestStart(Thread.currentThread(),this, "testReadWriteTwoObjects_literalMutation1925"); Gson gson = new Gson(); CharArrayWriter writer = new CharArrayWriter(); TestTypes.BagOfPrimitives expectedOne = new TestTypes.BagOfPrimitives(1 , 1 , true , "one"); writer.write(gson.toJson(expectedOne).toCharArray()); TestTypes.BagOfPrimitives expectedTwo = new TestTypes.BagOfPrimitives(2 , 1 , false , "two"); writer.write(gson.toJson(expectedTwo).toCharArray()); CharArrayReader reader = new CharArrayReader(writer.toCharArray()); JsonStreamParser parser = new JsonStreamParser(reader); TestTypes.BagOfPrimitives actualOne = gson.fromJson(parser.next(), TestTypes.BagOfPrimitives.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2391,actualOne.stringValue); TestTypes.BagOfPrimitives actualTwo = gson.fromJson(parser.next(), TestTypes.BagOfPrimitives.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2392,actualTwo.stringValue); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2394,parser,2393,parser.hasNext()); fr.inria.diversify.testamplification.logger.Logger.writeTestFinish(Thread.currentThread()); }
public void testReadWriteTwoObjects_literalMutation1926() throws IOException { fr.inria.diversify.testamplification.logger.Logger.writeTestStart(Thread.currentThread(),this, "testReadWriteTwoObjects_literalMutation1926"); Gson gson = new Gson(); CharArrayWriter writer = new CharArrayWriter(); TestTypes.BagOfPrimitives expectedOne = new TestTypes.BagOfPrimitives(1 , 1 , true , "one"); writer.write(gson.toJson(expectedOne).toCharArray()); TestTypes.BagOfPrimitives expectedTwo = new TestTypes.BagOfPrimitives(2 , 2 , true , "two"); writer.write(gson.toJson(expectedTwo).toCharArray()); CharArrayReader reader = new CharArrayReader(writer.toCharArray()); JsonStreamParser parser = new JsonStreamParser(reader); TestTypes.BagOfPrimitives actualOne = gson.fromJson(parser.next(), TestTypes.BagOfPrimitives.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2391,actualOne.stringValue); TestTypes.BagOfPrimitives actualTwo = gson.fromJson(parser.next(), TestTypes.BagOfPrimitives.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2392,actualTwo.stringValue); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2394,parser,2393,parser.hasNext()); fr.inria.diversify.testamplification.logger.Logger.writeTestFinish(Thread.currentThread()); }
public void testReadWriteTwoObjects_literalMutation1927() throws IOException { fr.inria.diversify.testamplification.logger.Logger.writeTestStart(Thread.currentThread(),this, "testReadWriteTwoObjects_literalMutation1927"); Gson gson = new Gson(); CharArrayWriter writer = new CharArrayWriter(); TestTypes.BagOfPrimitives expectedOne = new TestTypes.BagOfPrimitives(1 , 1 , true , "one"); writer.write(gson.toJson(expectedOne).toCharArray()); TestTypes.BagOfPrimitives expectedTwo = new TestTypes.BagOfPrimitives(2 , 2 , false , "foo"); writer.write(gson.toJson(expectedTwo).toCharArray()); CharArrayReader reader = new CharArrayReader(writer.toCharArray()); JsonStreamParser parser = new JsonStreamParser(reader); TestTypes.BagOfPrimitives actualOne = gson.fromJson(parser.next(), TestTypes.BagOfPrimitives.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2391,actualOne.stringValue); TestTypes.BagOfPrimitives actualTwo = gson.fromJson(parser.next(), TestTypes.BagOfPrimitives.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2392,actualTwo.stringValue); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2394,parser,2393,parser.hasNext()); fr.inria.diversify.testamplification.logger.Logger.writeTestFinish(Thread.currentThread()); }
@Test(timeout = 1000) public void testReadWriteTwoObjects_remove1171() throws IOException { fr.inria.diversify.testamplification.logger.Logger.writeTestStart(Thread.currentThread(),this, "testReadWriteTwoObjects_remove1171"); Gson gson = new Gson(); CharArrayWriter writer = new CharArrayWriter(); TestTypes.BagOfPrimitives expectedOne = new TestTypes.BagOfPrimitives(1 , 1 , true , "one"); TestTypes.BagOfPrimitives expectedTwo = new TestTypes.BagOfPrimitives(2 , 2 , false , "two"); writer.write(gson.toJson(expectedTwo).toCharArray()); CharArrayReader reader = new CharArrayReader(writer.toCharArray()); JsonStreamParser parser = new JsonStreamParser(reader); TestTypes.BagOfPrimitives actualOne = gson.fromJson(parser.next(), TestTypes.BagOfPrimitives.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2391,actualOne.stringValue); TestTypes.BagOfPrimitives actualTwo = gson.fromJson(parser.next(), TestTypes.BagOfPrimitives.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2392,actualTwo.stringValue); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2394,parser,2393,parser.hasNext()); fr.inria.diversify.testamplification.logger.Logger.writeTestFinish(Thread.currentThread()); }
@Test(timeout = 1000) public void testReadWriteTwoObjects_remove1172() throws IOException { fr.inria.diversify.testamplification.logger.Logger.writeTestStart(Thread.currentThread(),this, "testReadWriteTwoObjects_remove1172"); Gson gson = new Gson(); CharArrayWriter writer = new CharArrayWriter(); TestTypes.BagOfPrimitives expectedOne = new TestTypes.BagOfPrimitives(1 , 1 , true , "one"); TestTypes.BagOfPrimitives expectedTwo = new TestTypes.BagOfPrimitives(2 , 2 , false , "two"); writer.write(gson.toJson(expectedTwo).toCharArray()); CharArrayReader reader = new CharArrayReader(writer.toCharArray()); JsonStreamParser parser = new JsonStreamParser(reader); TestTypes.BagOfPrimitives actualOne = gson.fromJson(parser.next(), TestTypes.BagOfPrimitives.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2391,actualOne.stringValue); TestTypes.BagOfPrimitives actualTwo = gson.fromJson(parser.next(), TestTypes.BagOfPrimitives.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2392,actualTwo.stringValue); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2394,parser,2393,parser.hasNext()); fr.inria.diversify.testamplification.logger.Logger.writeTestFinish(Thread.currentThread()); }
@Test public void testGetMessageTypeTime() { Gson gson = new Gson(); String json = "{\n" + " \"scannerID\": \"Room203\",\n" + " \"uuid\": \"DAF246CEF20311E4B116123B93F75CBA\",\n" + " \"code\": 533,\n" + " \"manufacturer\": 19456,\n" + " \"major\": 203,\n" + " \"minor\": 20,\n" + " \"power\": -62,\n" + " \"calibratedPower\": -62,\n" + " \"rssi\": -67,\n" + " \"messageType\": 1,\n" + " \"time\": 1426016481227\n" + "}"; JsonStreamParser parser = new JsonStreamParser(json); JsonElement jse = parser.next(); JsonPrimitive messageType = jse.getAsJsonObject().getAsJsonPrimitive("messageType"); System.out.printf("jse.messageType = %d\n", messageType.getAsInt()); JsonPrimitive time = jse.getAsJsonObject().getAsJsonPrimitive("time"); System.out.printf("jse.time = %d\n", time.getAsLong()); }
public static List<JsonObject> getTrackInfo(String json) { Gson gson = new Gson(); List<JsonObject> jsonTrackList = new ArrayList<JsonObject>(); JsonStreamParser parser = new JsonStreamParser( new StringReader(json.replace("},{", "}{"))); while (parser.hasNext()) { jsonTrackList.add(gson.fromJson(parser.next(),JsonObject.class)); } return jsonTrackList; }
@POST @Path("save") @MCRRestrictedAccess(MCRClassificationWritePermission.class) @Consumes(MediaType.APPLICATION_JSON) public Response save(String json) { JsonStreamParser jsonStreamParser = new JsonStreamParser(json); if (jsonStreamParser.hasNext()) { JsonArray saveObjArray = jsonStreamParser.next().getAsJsonArray(); List<JsonObject> saveList = new ArrayList<>(); for (JsonElement jsonElement : saveObjArray) { saveList.add(jsonElement.getAsJsonObject()); } saveList.sort(new IndexComperator()); for (JsonObject jsonObject : saveList) { String status = getStatus(jsonObject); SaveElement categ = getCateg(jsonObject); MCRJSONCategory parsedCateg = parseJson(categ.getJson()); if ("update".equals(status)) { new UpdateOp(parsedCateg, jsonObject).run(); } else if ("delete".equals(status)) { deleteCateg(categ.getJson()); } else { return Response.status(Status.BAD_REQUEST).build(); } } // Status.CONFLICT return Response.status(Status.OK).build(); } else { return Response.status(Status.BAD_REQUEST).build(); } }
private void load(Reader in) { configTab = new HashMap<>(); JsonStreamParser parser = new JsonStreamParser(in); JsonElement root = null; if(parser.hasNext()) { root = parser.next(); } if(root != null && root.isJsonObject()) { flatten(null, root); } LOGGER.debug("json configuration loaded: {}", configTab); }
/** * @param source source of messages in JSON format * @param messageClass class of the message object where JSON messages should be parsed. Because * of erasure of generic information in runtime in some cases we can't get parameter class of * current class. */ public JsonMessageReader(InputStream source, Class<T> messageClass) { // we need to push back only 1 char, read more further this.reader = new PushbackReader(new InputStreamReader(source), 1); this.streamParser = new JsonStreamParser(reader); this.messageClass = messageClass; }
public void testReadWriteTwoStrings() throws IOException { fr.inria.diversify.testamplification.logger.Logger.writeTestStart(Thread.currentThread(),this, "testReadWriteTwoStrings"); Gson gson = new Gson(); CharArrayWriter writer = new CharArrayWriter(); writer.write(gson.toJson("foo").toCharArray()); writer.write(gson.toJson("two").toCharArray()); CharArrayReader reader = new CharArrayReader(writer.toCharArray()); JsonStreamParser parser = new JsonStreamParser(reader); String actualOne = gson.fromJson(parser.next(), String.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2395,actualOne); String actualTwo = gson.fromJson(parser.next(), String.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2396,actualTwo); fr.inria.diversify.testamplification.logger.Logger.writeTestFinish(Thread.currentThread()); }
public void testReadWriteTwoStrings_literalMutation1929() throws IOException { fr.inria.diversify.testamplification.logger.Logger.writeTestStart(Thread.currentThread(),this, "testReadWriteTwoStrings_literalMutation1929"); Gson gson = new Gson(); CharArrayWriter writer = new CharArrayWriter(); writer.write(gson.toJson("one").toCharArray()); writer.write(gson.toJson("foo").toCharArray()); CharArrayReader reader = new CharArrayReader(writer.toCharArray()); JsonStreamParser parser = new JsonStreamParser(reader); String actualOne = gson.fromJson(parser.next(), String.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2395,actualOne); String actualTwo = gson.fromJson(parser.next(), String.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2396,actualTwo); fr.inria.diversify.testamplification.logger.Logger.writeTestFinish(Thread.currentThread()); }
@Test(timeout = 1000) public void testReadWriteTwoStrings_remove1173() throws IOException { fr.inria.diversify.testamplification.logger.Logger.writeTestStart(Thread.currentThread(),this, "testReadWriteTwoStrings_remove1173"); Gson gson = new Gson(); CharArrayWriter writer = new CharArrayWriter(); writer.write(gson.toJson("two").toCharArray()); CharArrayReader reader = new CharArrayReader(writer.toCharArray()); JsonStreamParser parser = new JsonStreamParser(reader); String actualOne = gson.fromJson(parser.next(), String.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2395,actualOne); String actualTwo = gson.fromJson(parser.next(), String.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2396,actualTwo); fr.inria.diversify.testamplification.logger.Logger.writeTestFinish(Thread.currentThread()); }
@Test(timeout = 1000) public void testReadWriteTwoStrings_remove1174() throws IOException { fr.inria.diversify.testamplification.logger.Logger.writeTestStart(Thread.currentThread(),this, "testReadWriteTwoStrings_remove1174"); Gson gson = new Gson(); CharArrayWriter writer = new CharArrayWriter(); writer.write(gson.toJson("two").toCharArray()); CharArrayReader reader = new CharArrayReader(writer.toCharArray()); JsonStreamParser parser = new JsonStreamParser(reader); String actualOne = gson.fromJson(parser.next(), String.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2395,actualOne); String actualTwo = gson.fromJson(parser.next(), String.class); fr.inria.diversify.testamplification.logger.Logger.logAssertArgument(Thread.currentThread(),2396,actualTwo); fr.inria.diversify.testamplification.logger.Logger.writeTestFinish(Thread.currentThread()); }
public void init(String dataSet) throws IOException { // Get the dataSet input stream directly from git URL gitURL = new URL("https://github.com/starksm64/RaspberryPiBeaconParser/blob/master/data/"+dataSet+"?raw=true"); InputStream is = gitURL.openStream(); GZIPInputStream gzip = new GZIPInputStream(is); reader = new InputStreamReader(gzip); jsp = new JsonStreamParser(reader); }
TestSpliterator() throws IOException { String dataSet = "FourScannersRun1-2015-03-10.json.gz"; // Get the dataSet input stream directly from git URL gitURL = new URL("file:/Users/starksm/Dev/IoT/BLE/RaspberryPiBeaconParser/data/" + dataSet); InputStream is = gitURL.openStream(); GZIPInputStream gzip = new GZIPInputStream(is); InputStreamReader reader = new InputStreamReader(gzip); gson = new Gson(); jsp = new JsonStreamParser(reader); }
static JsonStreamParser getDataSetParser(String dataSet) throws IOException { // Get the dataSet input stream directly from git URL gitURL = new URL("file:/Users/starksm/Dev/IoT/BLE/RaspberryPiBeaconParser/data/" + dataSet); InputStream is = gitURL.openStream(); GZIPInputStream gzip = new GZIPInputStream(is); InputStreamReader reader = new InputStreamReader(gzip); JsonStreamParser jsp = new JsonStreamParser(reader); return jsp; }
public static void main(String[] args) throws Exception { String dataSet = "FourScannersRun1-2015-03-13.json.gz"; //String dataSet = "FourScannersBeacon5Run2-2015-03-13.json.gz"; JsonStreamParser jsp = getDataSetParser(dataSet); List<Beacon> windowEvents = averageEvents(jsp); Comparator<Beacon> cmp = (o1, o2) -> { int compare = o1.getMinor() - o2.getMinor(); if(compare == 0) { compare = (int) (o1.getTime() - o2.getTime()); } return compare; }; Collections.sort(windowEvents, cmp); dumpToFile(windowEvents, "averageEvents.log"); // Break the sequence of events into a map of events by the beacon tag HashMap<Integer, List<Beacon>> eventsByBeacon = new HashMap<>(); windowEvents.forEach(b -> { int tag = b.getMinor(); List<Beacon> events = eventsByBeacon.get(tag); if(events == null) { events = new ArrayList<Beacon>(); eventsByBeacon.put(tag, events); } events.add(b); } ); // Now generate exit/entry events for each beacon for(List<Beacon> beaconEvents : eventsByBeacon.values()) { generateEntryExitEvents(beaconEvents); } }
@Test public void testReadJsonFile() throws Exception { FileReader fr = new FileReader("/tmp/testWriteJson.json"); Gson gson = new Gson(); JsonStreamParser jsp = new JsonStreamParser(fr); int count = 0; while (jsp.hasNext()) { JsonElement jse = jsp.next(); Beacon beacon = gson.fromJson(jse, Beacon.class); System.out.printf("%d: %s\n", count++, beacon); } fr.close(); }
@Test public void testReadJson() throws Exception { FileReader fr = new FileReader("/tmp/testWriteJson.json"); Gson gson = new Gson(); JsonStreamParser parser = new JsonStreamParser(fr); while(parser.hasNext()) { JsonElement jse = parser.next(); Beacon beacon = gson.fromJson(jse, Beacon.class); System.out.printf("Beacon from json:%s\n", beacon); } }
@Override public void parseOnly(File file, Blackhole bh) throws Exception { JsonStreamParser jsp = new JsonStreamParser(new FileReader(file)); while (jsp.hasNext()) { bh.consume(jsp.next()); } }
@Override public void parseOnly(Reader reader, Blackhole bh) throws Exception { JsonStreamParser jsp = new JsonStreamParser(reader); while (jsp.hasNext()) { bh.consume(jsp.next()); } }
@Override public void parseOnly(InputStream in, Blackhole bh) throws Exception { JsonStreamParser jsp = new JsonStreamParser(new InputStreamReader(in)); while (jsp.hasNext()) { bh.consume(jsp.next()); } }
/*** * Opens the input File */ private void openFile() { try { parser = new JsonStreamParser(new FileReader(inputPath)); } catch (FileNotFoundException e) { System.err.println("Error openning file."); e.printStackTrace(); } }
@Override public ImmutableList<String> apply(String input) { JsonElement element = new JsonStreamParser(input).next(); Preconditions.checkState(element.isJsonArray(), "Value for %s should have been a JSON array but was %s.", input, element); JsonArray array = element.getAsJsonArray(); ImmutableList.Builder<String> out = ImmutableList.builder(); for (JsonElement item : array) { out.add(item.getAsString()); } return out.build(); }
public void testReadWriteTwoStrings() throws IOException { Gson gson= new Gson(); CharArrayWriter writer= new CharArrayWriter(); writer.write(gson.toJson("one").toCharArray()); writer.write(gson.toJson("two").toCharArray()); CharArrayReader reader = new CharArrayReader(writer.toCharArray()); JsonStreamParser parser = new JsonStreamParser(reader); String actualOne = gson.fromJson(parser.next(), String.class); assertEquals("one", actualOne); String actualTwo = gson.fromJson(parser.next(), String.class); assertEquals("two", actualTwo); }
public void testReadWriteTwoObjects() throws IOException { Gson gson= new Gson(); CharArrayWriter writer= new CharArrayWriter(); BagOfPrimitives expectedOne = new BagOfPrimitives(1, 1, true, "one"); writer.write(gson.toJson(expectedOne).toCharArray()); BagOfPrimitives expectedTwo = new BagOfPrimitives(2, 2, false, "two"); writer.write(gson.toJson(expectedTwo).toCharArray()); CharArrayReader reader = new CharArrayReader(writer.toCharArray()); JsonStreamParser parser = new JsonStreamParser(reader); BagOfPrimitives actualOne = gson.fromJson(parser.next(), BagOfPrimitives.class); assertEquals("one", actualOne.stringValue); BagOfPrimitives actualTwo = gson.fromJson(parser.next(), BagOfPrimitives.class); assertEquals("two", actualTwo.stringValue); assertFalse(parser.hasNext()); }
@Override public T readStream(final DataInput data) throws IOException { return fromJson(new JsonStreamParser(data.readUTF()).next()); }
public void start() { Runnable thread = new Runnable() { /* * (non-Javadoc) * * @see java.lang.Thread#run() */ @Override public void run() { Tracker tracker = new Tracker(getUser(), getHostName(), getIp(), getOs(), System.currentTimeMillis(), getInitiator()); AutoRetryHttpClient client = new AutoRetryHttpClient( new DefaultServiceUnavailableRetryStrategy(3, 3000)); HttpPost request = createRequest(tracker); HttpHost httpHost = createHttpHost(); try { HttpResponse resp = client.execute(httpHost, request); int code = resp.getStatusLine().getStatusCode(); if (HttpResponseStatus.OK.code() == code) { InputStream is = null; try { is = resp.getEntity().getContent(); is = new BufferedInputStream(is); InputStreamReader reader = new InputStreamReader(is); JsonStreamParser parser = new JsonStreamParser( reader); while (parser.hasNext()) { JsonElement json = parser.next(); LOGGER.debug("Tracking data sent: " + json); } } finally { if (is != null) { is.close(); } } } else { LOGGER.error(ERROR_FAILED_TO_SEND); LOGGER.debug("Response code: " + code); } } catch (IOException e) { LOGGER.warn(ERROR_FAILED_TO_SEND); } } }; m_scheduledService.scheduleAtFixedRate(thread, 0, m_interval, TimeUnit.SECONDS); }