JsonUtils.java

package com.hwx.ranger;

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.google.common.reflect.TypeToken;
import java.lang.reflect.Type;
import com.google.gson.Gson;
import com.google.gson.JsonElement;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
import com.google.gson.JsonSyntaxException;

public class JsonUtils {

	protected static final Logger logger = LoggerFactory.getLogger(JsonUtils.class);
	
    protected Response parseJSON(String jsonContent)  {
    	 Response inpObject=null;
        if ((jsonContent == null) || jsonContent.isEmpty()) {
          return (Response) Collections.emptyMap();
        } else {
          try {
        	inpObject = new Gson().fromJson(jsonContent, Response.class);
          } 
          catch (JsonSyntaxException e) {
        	  logger.error(e.getMessage());
          }
          return inpObject;
        }

      }
    
    

    protected RangerPolicyResponse parseRangerPolicy(String jsonContent)  {
      	 RangerPolicyResponse inpObject=null;
          if ((jsonContent == null) || jsonContent.isEmpty()) {
            return (RangerPolicyResponse) Collections.emptyMap();
          } else {
            try {
          	inpObject = new Gson().fromJson(jsonContent, RangerPolicyResponse.class);
            } 
            catch (JsonSyntaxException e) {
          	  logger.error(e.getMessage());
            }
            return inpObject;
          }

        }
    protected List<RangerPolicyResponse> parseRangerPolicies(String jsonContent)  {
    	List<RangerPolicyResponse> inpObject=null;
         if ((jsonContent == null) || jsonContent.isEmpty()) {
           return null;
         } else {
           try {
        	Type listType = new TypeToken<ArrayList<RangerPolicyResponse>>(){}.getType();
         	inpObject = new Gson().fromJson(jsonContent, listType);
           } 
           catch (JsonSyntaxException e) {
         	  logger.error(e.getMessage());
           }
           return inpObject;
         }

       }
    
    protected HDFSCheckList parseHDFSCheckList(String jsonContent)  {
    	HDFSCheckList inpObject=null;
         if ((jsonContent == null) || jsonContent.isEmpty()) {
           return null;
         } else {
           try {
         	inpObject = new Gson().fromJson(jsonContent, HDFSCheckList.class);
           } 
           catch (JsonSyntaxException e) {
         	  logger.error(e.getMessage());
           }
           return inpObject;
         }

       }
    
    protected String prettyPrint(String jsonContent)  {
   	 String prettyJsonString=null;
   	String data=null;
       if ((jsonContent == null) || jsonContent.isEmpty()) {
         return "EmptyJson";
       } else {
         try {
    		JsonParser jp = new JsonParser();
    		JsonElement je = jp.parse(jsonContent);
    		
    		if (je.isJsonObject())
    		{
    			JsonObject response = je.getAsJsonObject();
    			data = response.get("data").getAsString();
    		}
    		//prettyJsonString = gson.toJson(data);
    		prettyJsonString = data;
         } 
         catch (JsonSyntaxException e) {
       	  logger.error(e.getMessage());
         }
         return prettyJsonString;
       }

     }
    
}