/** ------------------------------------
    * SweetDEV RIA library
    * Copyright [2006 - 2010] [Ideo Technologies]
    * ------------------------------------
    *
    * Licensed under the Apache License, Version 2.0 (the "License");
    * you may not use this file except in compliance with the License.
    * You may obtain a copy of the License at
    *
   * 		http://www.apache.org/licenses/LICENSE-2.0
   *
   * Unless required by applicable law or agreed to in writing, software
   * distributed under the License is distributed on an "AS IS" BASIS,
   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
   * See the License for the specific language governing permissions and
   * limitations under the License.
   *
   *
   * For more information, please contact us at:
   *         Ideo Technologies S.A
   *        124 rue de Verdun
   *        92800 Puteaux - France
   *
   *      France & Europe Phone : +33 1.46.25.09.60
   *
   *
   *        web : http://www.ideotechnologies.com
   *        email : SweetDEV-RIA@ideotechnologies.com
   *
   *
   * @version ${pom.version}
   * @author Ideo Technologies
   */
  package com.ideo.sweetdevria.taglib.reader.provider;
  
  import java.io.InputStreamReader;
  import java.io.Serializable;
  import java.net.HttpURLConnection;
  import java.net.URL;
  import java.util.ArrayList;
  import java.util.HashMap;
  import java.util.Iterator;
  import java.util.List;
  import java.util.Map;
  
  import org.apache.commons.logging.Log;
  import org.apache.commons.logging.LogFactory;
  
  import com.ideo.sweetdevria.taglib.reader.model.AbstractDataReaderModel;
  import com.ideo.sweetdevria.taglib.reader.model.ReaderCategoryModel;
  import com.ideo.sweetdevria.taglib.reader.model.ReaderItemModel;
  import com.sun.syndication.feed.synd.SyndEntry;
  import com.sun.syndication.feed.synd.SyndFeed;
  import com.sun.syndication.io.SyndFeedInput;
  
  public class ReaderDataProvider implements Serializable {
  
  	private static final Log LOG = LogFactory.getLog(ReaderDataProvider.class);
  
  	private static final long serialVersionUID = 3813519359771011395L;
  
  	private List data;
  
  	private String rssUrl;
  
  	private Map idMap;
  
  	private int maxDepth = -1;
  
  	public ReaderDataProvider(List data) {
  		idMap = new HashMap();
  		this.data = data;
  		Iterator it = data.iterator();
  		while (it.hasNext()) {
  			AbstractDataReaderModel node = (AbstractDataReaderModel) it.next();
  			registerNode(node);
  		}
  	}
  
  	public ReaderDataProvider(String readerId, String rssFeed,
  			Integer articlesFetched) {
  
  		idMap = new HashMap();
  		rssUrl = rssFeed;
  		SyndFeedInput sfi = null;
  		List entries = new ArrayList();
  
  		try {
  			sfi = new SyndFeedInput();
  		} catch (NoClassDefFoundError e) {
  			LOG.error("Can't create SyndFeedInput : " + e.getMessage(), e);
  		}
  
  		if (sfi != null) {
  			try {
  				URL uri = new URL(rssUrl);
  
  				HttpURLConnection con = (HttpURLConnection) uri
  						.openConnection();
 
 				/**
 				 * Les variables http.proxyHost, http.proxyPort,
 				 * http.proxyUserId, http.proxyUserPwd doivent etre definies
 				 * dans la JVM (System.setProperty) si vous souahitez utiliser
 				 * un proxy afin d'acceder a une url web
 				 */
 				String userId = System.getProperty("http.proxyUserId");
 				String userPwd = System.getProperty("http.proxyUserPwd");
 
 				if (userId != null && userPwd != null) {
 					sun.misc.BASE64Encoder encoder = new sun.misc.BASE64Encoder();
 					String encodedUserPwd = encoder
 							.encode((userId + ":" + userPwd).getBytes());
 					con.setRequestProperty("Proxy-Authorization", "Basic "
 							+ encodedUserPwd);
 				}
 
 				// DEBUT SWTRIA-998
 				String contentType = con.getContentType();
 				String encoding = null;
 				InputStreamReader inStream = null;
 
 				try {
 					if (contentType != null) {
 
 						if (con.getContentType().lastIndexOf('=') > -1) {
 							encoding = contentType.substring(con
 									.getContentType().lastIndexOf('=') + 1, con
 									.getContentType().length());
 							inStream = new InputStreamReader(con
 									.getInputStream(), encoding);
 						} else {
 							inStream = new InputStreamReader(con
 									.getInputStream());
 						}
 					} else {
 						inStream = new InputStreamReader(con.getInputStream());
 					}
 
 					SyndFeed feed = sfi.build(inStream);
 					// FIN SWTRIA-998
 					entries = feed.getEntries();
 				} finally {
 					if (inStream == null) {
 						inStream.close();
 					}
 				}
 			} catch (Exception e) {
 				LOG.error(e.getMessage(), e);
 			}
 		}
 
 		data = new ArrayList();
 
 		Iterator it = entries.iterator();
 		int cpt = 1;
 		while (it.hasNext() && cpt <= articlesFetched.intValue()) {
 			SyndEntry entry = (SyndEntry) it.next();
 
 			AbstractDataReaderModel node = new ReaderItemModel(readerId + "_"
 					+ String.valueOf(cpt++), washHtmlString(entry.getTitle()),
 					washHtmlString(entry.getDescription().getValue()));
 
 			data.add(node);
 			registerNode(node);
 		}
 	}
 
 	private String washHtmlString(String code) {
 		String result = code;
 
 		result = result.replaceAll("\n", "<br/>");
 		result = result.replaceAll("\"", "'");
 
 		return result;
 	}
 
 	public void registerNode(AbstractDataReaderModel node) {
 		idMap.put(node.getId(), node);
 
 		if (node instanceof ReaderCategoryModel) {
 			Iterator it = ((ReaderCategoryModel) node).getChildrenIterator();
 			while (it != null && it.hasNext()) {
 				AbstractDataReaderModel child = (AbstractDataReaderModel) it
 						.next();
 
 				registerNode(child);
 			}
 		}
 	}
 
 	public AbstractDataReaderModel getNodeById(String id) {
 		return (AbstractDataReaderModel) idMap.get(id);
 	}
 
 	public List getData() {
 		return data;
 	}
 
 	public void setData(List data) {
 		this.data = data;
 	}
 
 	public int getSize() {
 		return data.size();
 	}
 
 	public void setMaxDepth(int maxDepth) {
 		this.maxDepth = maxDepth;
 	}
 
 	public String getJSONString(int from, int to) {
 		// System.out.println(from+":"+to);
 		if (from > getSize())
 			return "[]";
 
 		String result = "[";
 
 		for (int i = from; i < to && i < getSize(); i++) {
 			if (i != from) {
 				result += ",";
 			}
 			result += ((AbstractDataReaderModel) (data.get(i)))
 					.getJSONString(maxDepth);
 		}
 
 		return result + "]";
 	}
 
 	public String getNodeContentJSONString(String id) {
 		AbstractDataReaderModel node = getNodeById(id);
 
 		String result = "";
 
 		if (node instanceof ReaderCategoryModel) {
 			result = "[";
 
 			Iterator it = ((ReaderCategoryModel) node).getChildrenIterator();
 			while (it != null && it.hasNext()) {
 				result += ((AbstractDataReaderModel) it.next())
 						.getJSONString(0)
 						+ (it.hasNext() ? "," : "");
 			}
 
 			return result + "]";
 		} else {
 			result = "{\"result\":\"" + ((ReaderItemModel) node).getContent()
 					+ "\"}";
 		}
 
 		return "";
 	}
 
 }