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());
	}
}