Progress on JSON

[lgpl/argeo-commons.git] / server / runtime / org.argeo.server.json / src / main / java / org / argeo / server / json / JsonObjectFactoryImpl.java

diff --git a/server/runtime/org.argeo.server.json/src/main/java/org/argeo/server/json/JsonObjectFactoryImpl.java b/server/runtime/org.argeo.server.json/src/main/java/org/argeo/server/json/JsonObjectFactoryImpl.java
new file mode 100644 (file)
index 0000000..cd6c00e
--- /dev/null
+++ b/server/runtime/org.argeo.server.json/src/main/java/org/argeo/server/json/JsonObjectFactoryImpl.java
@@ -0,0 +1,113 @@
+package org.argeo.server.json;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.argeo.server.ArgeoServerException;
+import org.codehaus.jackson.map.ObjectMapper;
+import org.osgi.framework.BundleContext;
+import org.springframework.beans.factory.InitializingBean;
+import org.springframework.osgi.context.BundleContextAware;
+import org.springframework.osgi.util.BundleDelegatingClassLoader;
+
+public class JsonObjectFactoryImpl implements JsonObjectFactory,
+               BundleContextAware, InitializingBean {
+       private final static Log log = LogFactory
+                       .getLog(JsonObjectFactoryImpl.class);
+
+       private BundleContext bundleContext;
+       private BundleDelegatingClassLoader classLoader;
+
+       private ObjectMapper objectMapper = new ObjectMapper();
+       private Map<String, Class> supportedTypes = new HashMap<String, Class>();
+
+       public Boolean supports(String type) {
+               if (supportedTypes.containsKey(type))
+                       return true;
+
+               return loadClass(type) != null ? true : false;
+               // try {
+               // // Class.forName(type);
+               // Thread.currentThread().getContextClassLoader().loadClass(type);
+               // return true;
+               // } catch (ClassNotFoundException e) {
+               // return false;
+               // }
+       }
+
+       public <T> T readValue(String type, String str) {
+               final Class clss;
+               if (supportedTypes.containsKey(type))
+                       clss = supportedTypes.get(type);
+               else {
+                       clss = loadClass(type);
+                       if (clss == null)
+                               throw new ArgeoServerException("Cannot find type " + type);
+                       // try {
+                       // // clss = Class.forName(type);
+                       // clss = Thread.currentThread().getContextClassLoader()
+                       // .loadClass(type);
+                       // } catch (ClassNotFoundException e) {
+                       // throw new ArgeoServerException("Cannot find type " + type, e);
+                       // }
+               }
+
+               try {
+                       return (T) objectMapper.readValue(str, clss);
+               } catch (Exception e) {
+                       throw new ArgeoServerException("Cannot deserialize " + str
+                                       + " (type=" + type + ")", e);
+               }
+       }
+
+       public void setSupportedTypes(Map<String, Class> supportedTypes) {
+               this.supportedTypes = supportedTypes;
+       }
+
+       protected Class loadClass(String type) {
+               Class clss;
+//             try {
+//                     return Class.forName(type);
+//             } catch (ClassNotFoundException e) {
+//                     if (log.isDebugEnabled())
+//                             log.debug("Class.forName failed: " + e);
+//             }
+//
+//             try {
+//                     return Thread.currentThread().getContextClassLoader().loadClass(
+//                                     type);
+//             } catch (ClassNotFoundException e) {
+//                     if (log.isDebugEnabled())
+//                             log
+//                                             .debug("Thread.currentThread().getContextClassLoader().loadClass failed: "
+//                                                             + e);
+//             }
+//
+//             try {
+//                     return getClass().getClassLoader().loadClass(type);
+//             } catch (ClassNotFoundException e) {
+//                     if (log.isDebugEnabled())
+//                             log.debug("getClass().getClassLoader().loadClass failed: " + e);
+//             }
+//
+               try {
+                       return classLoader.loadClass(type);
+               } catch (ClassNotFoundException e) {
+                       if (log.isDebugEnabled())
+                               log.debug("BundleDelegatingClassLoader.loadClass failed: " + e);
+               }
+
+               return null;
+       }
+
+       public void setBundleContext(BundleContext bundleContext) {
+               this.bundleContext = bundleContext;
+       }
+
+       public void afterPropertiesSet() throws Exception {
+               classLoader = BundleDelegatingClassLoader
+                               .createBundleClassLoaderFor(bundleContext.getBundle());
+       }
+}