URLNotificationJSONConverter.java

  1. package gov.usgs.earthquake.distribution;

  3. import gov.usgs.earthquake.product.ProductId;
  4. import gov.usgs.util.XmlUtils;

  6. import java.io.InputStream;
  7. import java.net.URL;
  8. import java.util.Date;
  9. import javax.json.Json;
  10. import javax.json.JsonObject;
  11. import javax.json.JsonReader;

  13. public class URLNotificationJSONConverter {

  15.   /** attribute for product id */
  16.   public static final String ATTRIBUTE_PRODUCT_ID = "id";
  17.   /** attribute for source */
  18.   public static final String ATTRIBUTE_SOURCE = "source";
  19.   /** attribute for type */
  20.   public static final String ATTRIBUTE_TYPE = "type";
  21.   /** attribute for code */
  22.   public static final String ATTRIBUTE_CODE = "code";
  23.   /** attribute for updatetime */
  24.   public static final String ATTRIBUTE_UPDATE_TIME = "updatetime";
  25.   /** attribute for trackerURL */
  26.   public static final String ATTRIBUTE_TRACKER_URL = "trackerURL";
  27.   /** attribute for expires */
  28.   public static final String ATTRIBUTE_EXPIRES = "expires";
  29.   /** attribute for url */
  30.   public static final String ATTRIBUTE_URL = "url";

  32.   /**
  33.    * Converts a URLNotification into a JSON string
  34.    * @param notification URLNotification to convert
  35.    * @return JSON string
  36.    */
  37.   public static String toJSON(final URLNotification notification) {
  38.     //id
  39.     ProductId id = notification.getProductId();

  41.     JsonObject json = Json.createObjectBuilder()
  42.       .add(ATTRIBUTE_PRODUCT_ID,Json.createObjectBuilder()
  43.         .add(ATTRIBUTE_SOURCE,id.getSource())
  44.         .add(ATTRIBUTE_TYPE,id.getType())
  45.         .add(ATTRIBUTE_CODE,id.getCode())
  46.         .add(ATTRIBUTE_UPDATE_TIME, XmlUtils.formatDate(id.getUpdateTime())))
  47.       .add(ATTRIBUTE_TRACKER_URL,notification.getTrackerURL().toString())
  48.       .add(ATTRIBUTE_EXPIRES,XmlUtils.formatDate(notification.getExpirationDate()))
  49.       .add(ATTRIBUTE_URL,notification.getProductURL().toString())
  50.       .build();

  52.     return json.toString();
  53.   }

  55.   /**
  56.    * parse a message from the input stream
  57.    * @param message InputStream message
  58.    * @return URLNotification
  59.    * @throws Exception if error occurs
  60.    */
  61.   public static URLNotification parseJSON(final InputStream message) throws Exception{
  62.     JsonReader jsonReader = Json.createReader(message);
  63.     JsonObject json = jsonReader.readObject();
  64.     jsonReader.close();

  66.     return parseJSON(json);
  67.   }

  69.   /**
  70.    * Parse a JsonObject
  71.    * @param json JsonObject
  72.    * @return URLNotification
  73.    * @throws Exception if error occurs
  74.    */
  75.   public static URLNotification parseJSON(final JsonObject json) throws Exception{
  76.     JsonObject idJson = json.getJsonObject(ATTRIBUTE_PRODUCT_ID);

  78.     ProductId id = new ProductId(
  79.             idJson.getString(ATTRIBUTE_SOURCE),
  80.             idJson.getString(ATTRIBUTE_TYPE),
  81.             idJson.getString(ATTRIBUTE_CODE),
  82.             XmlUtils.getDate(idJson.getString(ATTRIBUTE_UPDATE_TIME)));

  84.     return new URLNotification(
  85.             id,
  86.             XmlUtils.getDate(json.getString(ATTRIBUTE_EXPIRES)),
  87.             new URL(json.getString(ATTRIBUTE_TRACKER_URL)),
  88.             new URL(json.getString(ATTRIBUTE_URL)));
  89.   }

  91.   /**
  92.    * Main function to run a test JSON-ifying a URLnotification
  93.    * @param args arguments
  94.    * @throws Exception if error occurs
  95.    */
  96.   public static void main(String[] args) throws Exception{
  97.     URLNotification testNotification = new URLNotification(new ProductId("testSource","testType","testCode"), new Date(),
  98.             new URL("http://localhost/tracker/"), new URL("http://localhost/product/"));

  100.     String JSON = toJSON(testNotification);

  102.     System.out.println(JSON);
  103.   }

  105. }
Created with JaCoCo 0.8.8.202204050719