source: trunk/objectmq/src/omq/common/util/Serializers/GsonImp.java @ 14

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.SerializerException;
import omq.server.remote.request.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);
                System.out.println(json);
                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("arguments");

                        // 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);

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

        @Override
        public Event deserializeEvent(byte[] unZippedBytes) throws SerializerException {
                // TODO deserializeEvent class<?> ¿?
                return null;
        }
        
        

}