/*
    * This file is part of NetPisteur.
    * 
    * Copyright 2001-2002 : Olivier CORNEC, David BOUANCHEAU, Loic LOPEZ,
    *                       Gaetan BOUDARD, Mael LE LANNOU, Julien ROBINEAU
    * 
    * Copyright 2002-2003 : Olivier BRIENS, Simon DEZE, Florence FRIGOULT,
    *                       Olivier JOURNEAULT, Francois MARTINIER, Damien RAUDE-MORVAN
    * 
   * Copyright 2004-2007 : Damien RAUDE-MORVAN
   * 
   * NetPisteur is free software; you can redistribute it and/or modify
   * it under the terms of the GNU General Public License as published by
   * the Free Software Foundation; either version 2 of the License, or
   * (at your option) any later version.
   *
   * NetPisteur is distributed in the hope that it will be useful,
   * but WITHOUT ANY WARRANTY; without even the implied warranty of
   * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   * GNU General Public License for more details.
   *
   * You should have received a copy of the GNU General Public License
   * along with NetPisteur; if not, write to the Free Software
   * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
   */
  package com.drazzib.netpisteur.loader;
  
  import java.io.BufferedReader;
  import java.io.IOException;
  import java.io.InputStream;
  import java.io.InputStreamReader;
  import java.net.URL;
  import java.net.URLConnection;
  
  import org.apache.commons.logging.Log;
  import org.apache.commons.logging.LogFactory;
  
  /**
   * <P>
   * <STRONG>Description </STRONG>
   * <P>
   * Manage the connection local and get the content of the Url
   * 
   * @see com.drazzib.netpisteur.loader.Connexion
   * @version 1.0
   * @since 2002/03/18
   * @author NetPisteurTeam
   */
  
  public class ConnexionLocal extends Connexion {
  	
  	private static Log log = LogFactory.getLog(ConnexionLocal.class);
  
  	// /////////////////////////////////////
  	// attributes
  
  	/**
  	 * Represents the local connection
  	 */
  	private URLConnection connexionLocal;
  
  	private String messageErreur;
  
  	private boolean connecte;
  
  	// ///////////////////////////////////
  	// constructor
  
  	/**
  	 * Creates a ConnexionLocal object using the class UrlConnection
  	 * 
  	 * @param uneUrl
  	 *            URL
  	 */
  	public ConnexionLocal(URL uneUrl) {
  		super(uneUrl);
  		this.connexionLocal = null;
  		this.messageErreur = null;
  		this.connecte = false;
  	} // -----------------------------------------ConnexionLocal()
  
  	// /////////////////////////////////////
  	// accessors
  
  	/**
  	 * Gets the url of the connection
  	 * 
  	 * @return URL : Url of the connection
  	 */
  	public URL getTheUrl() {
  		if (this.connecte) {
  			return this.url;
  
  		}
  		return null;
  
  	} // ----------------------------------------------getTheUrl()
  
  	/**
 	 * Gets the message error of the connection
 	 * 
 	 * @return String : message error of the connection
 	 */
 	public String getMessageErreur() {
 		return this.messageErreur;
 
 	} // ----------------------------------------getMessageErreur()
 
 	/**
 	 * Checks errors and gets the message error of the connection
 	 * 
 	 * @param unTypeErreur
 	 *            code error representing state of the connection
 	 * @return String : message error od a code error
 	 */
 	public String traitementErreur(int unTypeErreur) {
 		return this.messageErreur;
 
 	} // ----------------------------------------traitementErreur()
 
 	/**
 	 * Manages the deconnection
 	 * 
 	 * @return boolean : state of the connection
 	 */
 
 	public boolean deconnexion() {
 		this.connecte = false;
 		return this.connecte;
 
 	} // ---------------------------------------------deconnection()
 
 	/**
 	 * Is the connection made ?
 	 * 
 	 * @return boolean: return false if the connection to this url is impossible
 	 */
 	public boolean getConnecte() {
 		return (this.connecte);
 
 	} // ----------------------------------------------getConnecte()
 
 	// /////////////////////////////////////
 	// operations
 
 	/**
 	 * Opens a connection using a url and checking the error
 	 * 
 	 * @return boolean: state of the connection
 	 */
 
 	public boolean connexion() {
 		// initialisation du message d'erreur
 		this.messageErreur = null;
 
 		try {
 
 			// affectation de l'url
 			this.connexionLocal = (this.url).openConnection();
 
 			// Simule un utilisateur pour les requetes
 			this.connexionLocal.setRequestProperty("User-Agent",
 					"Netpisteur v2");
 
 			this.connexionLocal.connect();
 
 			this.messageErreur = "Connexion  URL locale russie. ";
 			this.connecte = true;
 		} catch (java.io.IOException exWithOpenConnection) {
 			this.messageErreur = "Connexion a l'url : " + getURL()
 					+ " impossible. ";
 		}
 
 		return this.connecte;
 	} // ----------------------------------------------------connexion()
 
 	/**
 	 * Gets the ressource of an url using the file protocol This ressource is
 	 * store in a string
 	 * 
 	 * @return String: The ressource of the url
 	 */
 
 	public String getSourceByString() {
 
 		InputStream fluxEntree = null;
 		InputStreamReader lecteurFlux = null;
 		BufferedReader netIn = null;
 		String reponseServeur = null;
 		String reponseServeurTmp = null;
 
 		try {
 			if (this.connecte) {
 
 				fluxEntree = this.connexionLocal.getInputStream();
 				lecteurFlux = new InputStreamReader(fluxEntree);
 				netIn = new BufferedReader(lecteurFlux);
 				do {
 					reponseServeurTmp = (netIn.readLine());
 					reponseServeur = reponseServeur + reponseServeurTmp;
 				} while (reponseServeurTmp != null);
 
 			} else {
 				reponseServeur = (this.messageErreur);
 
 			}
 
 		} catch (java.io.IOException exWithGetInputStream) {
 			this.messageErreur = "erreur de lecture de flux d'entree dans ConnexionHttp.getSourceByString()";
 		} finally {
 			try {
 				if (netIn != null)
 				{
 					netIn.close();
 				}
 				if (lecteurFlux != null) {
 					lecteurFlux.close();
 				}
 				if (fluxEntree != null) {
 					fluxEntree.close();
 				}
 			} catch (IOException e) {
 				log.error(e);
 			}
 		}
 
 		return reponseServeur;
 
 	} // --------------------------------------------getSourceByString()
 
 	/*
 	 * Gets the ressource of an url using the file protocol This ressource is
 	 * store in a stream
 	 * 
 	 * @return InputStreamReader: The ressource of the url
 	 */
 
 	public InputStreamReader getSourceByReader() {
 
 		InputStreamReader fluxEntree = null;
 
 		try {
 			if (this.connecte) {
 
 				fluxEntree = new InputStreamReader(this.connexionLocal
 						.getInputStream());
 				fluxEntree.close();
 			}
 
 		} catch (java.io.IOException exWithGetInputStream) {
 			this.messageErreur = "erreur de lecture de flux d'entree dans ConnexionHttp.getSourceByStream()";
 		}
 
 		return fluxEntree;
 
 	} // --------------------------------------------getSourceByString()
 } // ------------------------------------------------------------------------------fin
 // ConnexionLocal