source: trunk/src/main/java/omq/common/util/Serializers/GsonImp.java @ 49

package omq.common.util.Serializers;

import java.util.List;

import omq.common.event.Event;
import omq.common.message.Request;
import omq.common.message.Response;
import omq.exception.OmqException;
import omq.exception.SerializerException;
import omq.server.RemoteObject;

import com.google.gson.Gson;
import com.google.gson.JsonArray;
import com.google.gson.JsonElement;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;

public class GsonImp implements ISerializer {
        private final Gson gson = new Gson();

        @Override
        public byte[] serialize(Object obj) throws SerializerException {
                String json = gson.toJson(obj);
                return json.getBytes();
        }

        @Override
        public Request deserializeRequest(byte[] bytes, RemoteObject obj) throws SerializerException {
                String json = new String(bytes);

                JsonParser parser = new JsonParser();
                JsonObject jsonObj = parser.parse(json).getAsJsonObject();

                String id = jsonObj.get("id").getAsString();
                String method = jsonObj.get("method").getAsString();

                List<Class<?>> types = obj.getParams(method);

                try {
                        JsonArray jsonArgs = (JsonArray) jsonObj.get("params");

                        // TODO: if (jsonArgs.size() == types.size())
                        int length = jsonArgs.size();
                        Object[] arguments = new Object[length];

                        int i = 0;
                        for (JsonElement element : jsonArgs) {
                                arguments[i] = gson.fromJson(element, types.get(i));
                                i++;
                        }

                        return new Request(id, method, arguments);
                } catch (NullPointerException e) {
                        return new Request(id, method, null);
                }
        }

        @Override
        public Response deserializeResponse(byte[] bytes, Class<?> type) throws SerializerException {
                String json = new String(bytes);

                JsonParser parser = new JsonParser();
                JsonObject jsonObj = parser.parse(json).getAsJsonObject();

                String id = jsonObj.get("id").getAsString();
                String idOmq = jsonObj.get("idOmq").getAsString();

                JsonElement jsonElement = jsonObj.get("result");
                Object result = gson.fromJson(jsonElement, type);

                JsonElement jsonError = jsonObj.get("error");
                OmqException error = gson.fromJson(jsonError, OmqException.class);

                return new Response(id, idOmq, result, error);
        }

        @Override
        public Event deserializeEvent(byte[] bytes) throws SerializerException {
                try {
                        String json = new String(bytes);
                        System.out.println(json);

                        JsonParser parser = new JsonParser();
                        JsonObject jsonObj = parser.parse(json).getAsJsonObject();

                        String type = jsonObj.get("type").getAsString();

                        JsonElement jsonElement = jsonObj.get("event");
                        Event event;

                        event = (Event) gson.fromJson(jsonElement, Class.forName(type));

                        return event;
                } catch (Exception e) {
                        throw new SerializerException("Deserialize event", e.getCause());
                }
        }

}