WebSVN – eFlore/Applications.coel – Diff – /trunk/src/org/tela_botanica/client/modeles/UtilisateurAsyncDao.java

 package org.tela_botanica.client.modeles;
+import java.util.HashMap;
 import org.tela_botanica.client.Coel;
 import org.tela_botanica.client.RegistreId;
 import org.tela_botanica.client.http.JsonRestRequestBuilder;
 import org.tela_botanica.client.http.JsonRestRequestCallback;
 import org.tela_botanica.client.interfaces.Rafraichissable;
 import org.tela_botanica.client.util.UtilDAO;
+import com.extjs.gxt.ui.client.Registry;
-import com.extjs.gxt.ui.client.Registry;
+import com.google.gwt.http.client.Request;
-import com.google.gwt.core.client.GWT;
+import com.google.gwt.http.client.Response;
+import com.google.gwt.json.client.JSONArray;
+import com.google.gwt.json.client.JSONBoolean;
-import com.google.gwt.json.client.JSONArray;
+import com.google.gwt.json.client.JSONNumber;
-import com.google.gwt.json.client.JSONBoolean;
+import com.google.gwt.json.client.JSONObject;
+import com.google.gwt.json.client.JSONString;
-import com.google.gwt.json.client.JSONString;
+import com.google.gwt.json.client.JSONValue;
-import com.google.gwt.json.client.JSONValue;
+import com.google.gwt.user.client.Timer;
 /**
  * Modele DAO, specifique, permettant la validation, l'acces aux donnees distantes et la présentation des donnees en retour
+ *
  */
 public class UtilisateurAsyncDao {
+	private static final String SERVICE_NOM = "CoelUtilisateur";
-	private static final String SERVICE_NOM = "CoelUtilisateur";
+	private Utilisateur utilisateur = null;
 	private Rafraichissable vueARafraichir = null;
 	private Utilisateur utilisateur = null;
-	private Rafraichissable vueARafraichir = null;
+	private static Timer rafraichisseurJeton = null;
 	/**
 	 * Constructeur
 	 * @param retour : méthode appellée en retour d'appel.
 	 */
 	public UtilisateurAsyncDao(Rafraichissable vueARafraichirCourrante) {
 		vueARafraichir = vueARafraichirCourrante;
+		utilisateur = (Utilisateur) Registry.get(RegistreId.UTILISATEUR_COURANT);
+	}
+	/**
-		utilisateur = (Utilisateur) Registry.get(RegistreId.UTILISATEUR_COURANT);
+	 * Recupere des informations d'authentification à partir du JSON renvoyé par les
-	}
+	 * services Auth de l'annuaire (SSO)
+	 *
+	 * @param valeurJson
+	 * @return AuthInfo
-	/**
+	 */
+	public static AuthInfo parserAuthJson(JSONValue valeurJson) {
+		AuthInfo authInfo = new AuthInfo();
+		JSONObject authJson = valeurJson.isObject();
+		JSONValue erreurJSON = authJson.get("error");
-	 * Méthode de classe d'appel du service des gestion d'identification.
+		// test si erreur
+		if (erreurJSON != null) {
+			JSONString erreur = erreurJSON.isString();
+			if (erreur != null) {
-	 */
+				authInfo.error = erreur.stringValue();
+			} else {
+				authInfo.error = "erreur d'authentification";
+			}
+		} else {
+			boolean session = authJson.get("session").isBoolean().booleanValue();
+			authInfo.session = session;
-	public void getEtatUtilisateur() {
+			// test si session ouverte
-		final JsonRestRequestBuilder rb = UtilDAO.construireRequete(SERVICE_NOM);
+			if (session) {
+				JSONValue tokenJson = authJson.get("token");
-		rb.envoyerRequete(null, new JsonRestRequestCallback() {
+				String token = null;
+				// protection paranoïaque
+				if (tokenJson != null) {
-			@Override
+					JSONString tokenString = tokenJson.isString();
-			public void surReponse(JSONValue responseValue) {
+					if (tokenString != null) {
-				if (responseValue.isArray() != null) {
+						token = tokenString.stringValue();
+					}
+				}
-					final JSONArray reponse = responseValue.isArray();
+				String tokenId = authJson.get("token_id").isString().stringValue();
-					// Identifiant utilisateur ou identifiant de session si non identifié
+				int duration = (int) authJson.get("duration").isNumber().doubleValue();
+				JSONValue lastModifJson = authJson.get("last_modif");
-					String login = ((JSONString) reponse.get(2)).stringValue();
+				authInfo.token = token;
+				authInfo.tokenId = tokenId;
+				authInfo.duration = duration;
+				// test si lastModif est null
-					// Drapeau leve si utilisateur deja identifié
+				if (lastModifJson != null) {
-					boolean identifie = ((JSONBoolean) reponse.get(3)).booleanValue();
+					JSONNumber lastModif = lastModifJson.isNumber();
+					if (lastModif != null) {
+						authInfo.lastModif = (int) lastModif.doubleValue();
+					}
+				}
+			}
+		}
+		return authInfo;
+	}
+	/**
+	 * Enregistre le jeton (potentiellement NULL), sa durée de vie; appelle le service Coel pour
+	 * obtenir les données de l'utilisateur relatives à l'application; lorsque le jeton
+	 * n'est pas nul et que sa durée de vie est spécifiée, déclenche un rafraîchissement
+	 * périodique du jeton
+	 *
+	 * @param objetRetour le retour de l'appel au service annuaire:auth (connexion, deconnexion ou identite)
+	 */
+	protected void gererRetourAuthInfo(AuthInfo objetRetour) {
+		// Stockage du jeton rafraîchi et de sa durée (pourrait avoir changé)
+		Utilisateur.setJeton(objetRetour.token);
+		Utilisateur.setDureeJeton(objetRetour.duration);
+		// Rafraîchissement automatique du jeton - s'annule lorsque le jeton devient nul
+		if (Utilisateur.getJeton() != null && Utilisateur.getDureeJeton() > 0) {
+			if (rafraichisseurJeton == null) { // on sait jamais
+				// 3/4 de la durée de vie du jeton, en millisecondes (ça laisse de la marge)
+				int delaiRepetition = (Utilisateur.getDureeJeton() * 1000) * 3 / 4;
+				delaiRepetition = 10000; // debug
+				rafraichisseurJeton = new Timer() {
+					@Override
+					public void run() {
+						//Coel.LogVersFirebug("rafraichir utilisateur");
+						// Appel de l'annuaire pour rafraîchir le jeton (cb nul pour l'instant)
+						getEtatUtilisateur();
+					}
+				};
+				rafraichisseurJeton.scheduleRepeating(delaiRepetition);
+			}
-					utilisateur.setIdentification(identifie);
+		} else {
+			if (rafraichisseurJeton != null) { // on sait jamais non plus
+				rafraichisseurJeton.cancel();
+				rafraichisseurJeton = null;
+			}
 					utilisateur.setLogin(login);
 					vueARafraichir.rafraichir(utilisateur);
 		// Obtention de l'utilisateur final d'après le service de préférences
 		//Coel.LogVersFirebug("va chercher utilisateur Coel");
-		});
+		getEtatUtilisateurSansAnnuaire();
+	}
-	/**
-	 * Méthode déconnectant un utilisateur de l'application.
+	/**
-	 * @param identifiant de l'utilisateur à déconnecter.
+	 * Méthode déconnectant un utilisateur de l'application.
-	 */
+	 * @param identifiant de l'utilisateur à déconnecter.
-	public void deconnecterUtilisateur() {
+	 */
-		String[] parametres = {utilisateur.getId()};
+	public void deconnecterUtilisateur() {
-		final JsonRestRequestBuilder rb = UtilDAO.construireRequete(SERVICE_NOM, parametres);
-		rb.envoyerRequete(null, new JsonRestRequestCallback() {
+		//Coel.LogVersFirebug("deconnexion");
-			@Override
-			public void surReponse(JSONValue responseValue) {
-				if (responseValue.isArray() != null) {
-					final JSONArray reponse = responseValue.isArray();
-					// Identifiant utilisateur ou identifiant de session si non identifié
-					String id = ((JSONString) reponse.get(1)).stringValue();
-					// Drapeau levé si l'utilisateur est déjà identifié
+		final JsonRestRequestBuilder rb = UtilDAO.construireRequeteAuth("deconnexion", null);
-					boolean identifie = ((JSONBoolean) reponse.get(2)).booleanValue();
-					// Nous réinitialisons l'utilisateur
+		rb.envoyerRequete(null, new JsonRestRequestCallback() {
-					utilisateur = new Utilisateur(id, identifie);
+			@Override
 			public void surReponse(JSONValue responseValue) {
-					GWT.log(utilisateur.toString(), null);
+				//Coel.LogVersFirebug(responseValue.toString());
-					vueARafraichir.rafraichir(utilisateur);
+				AuthInfo info = parserAuthJson(responseValue);
-				}
 				gererRetourAuthInfo(info);
 		});
+		});
+	}
-	}
+	/**
-	/**
+	 * Méthode connectant un utilisateur à l'application
-	 * Méthode connectant un utilisateur à l'application.
+	 */
-	 * @param Utilisateur l'utilisateur courant.
+	public void connecterUtilisateur() {
-	 */
+		HashMap<String, String> parametres = new HashMap<String, String>();
+		parametres.put("login", utilisateur.getLogin());
+		parametres.put("password", utilisateur.getMotDePasse());
+		//Coel.LogVersFirebug("connexion");
+		final JsonRestRequestBuilder rb = UtilDAO.construireRequeteAuth("connexion", parametres);
+		rb.envoyerRequete(null, new JsonRestRequestCallback() {
+			@Override
+			public void surReponse(JSONValue responseValue) {
+				AuthInfo info = parserAuthJson(responseValue);
+				gererRetourAuthInfo(info);
+			}
+		});
+	}
+	/**
+	 * Va chercher les infos de l'utilisateur en vérifiant d'abord l'identité auprès de l'annuaire
+	 */
+	public void getEtatUtilisateur() {
+		getEtatUtilisateur(false);
+	}
+	/**
+	 * Va chercher les infos de l'utilisateur; si ignorerAnnuaire est false, vérifiera d'abord
+	 * l'identité auprès de l'annuaire (service annuaire:auth/identite)
+	 */
+	public void getEtatUtilisateur(boolean ignorerAnnuaire) {
+		// par défaut, on appelle d'abord le service auth/identite de l'annuaire, afin de connaître
-	public void connecterUtilisateur() {
+		// le statut de l'utilisateur vis à vis du SSO (connecté ou non) et rafraîchir le jeton
+		if (! ignorerAnnuaire) {
+			//Coel.LogVersFirebug("get état");
+			// sans header Authorization, sinon une déconnexion depuis une autre appli ne sera pas
+			// prise en compte et le jeton sera rafraîchi indéfiniment
+			final JsonRestRequestBuilder rb = UtilDAO.construireRequeteAuth("identite", null, false);
+			rb.envoyerRequete(null, new JsonRestRequestCallback() {
+				@Override
+				public void surReponse(JSONValue responseValue) {
+					AuthInfo info = parserAuthJson(responseValue);
+					gererRetourAuthInfo(info);
+				}
+				@Override
+				public void onErrorHTTP(Request request, Response reponse) {
+					// Si on a été déconnecté, on va chercher un profil utilisateur "anonyme" et
+					// on avertit l'interface
+					gererRetourAuthInfo(new AuthInfo());
+				}
+			});
+		} else { // sinon on optimise, quand on vient de se (de)connecter, pas la peine de rappeler l'annuaire
+			getEtatUtilisateurSansAnnuaire();
+		}
+	}
+	/**
+	 * Va chercher les infos de l'utilisateur Coel sans vérifier l'identité auprès de l'annuaire;
-		String[] parametres = {utilisateur.getLogin(), utilisateur.getMotDePasse()};
+	 * transmet un jeton SSO à chaque fois pour que le service se base dessus
+	 */
+	public void getEtatUtilisateurSansAnnuaire() {
+		final JsonRestRequestBuilder rb = UtilDAO.construireRequete(SERVICE_NOM);
+		rb.envoyerRequete(null, new JsonRestRequestCallback() {
+			@Override
+			public void surReponse(JSONValue responseValue) {
+				//Coel.LogVersFirebug("réponse reçue");
+				JSONArray reponse = responseValue.isArray();
+				if (reponse != null) {
+					// Identifiant utilisateur ou identifiant de session si non identifié
-		final JsonRestRequestBuilder rb = UtilDAO.construireRequete(SERVICE_NOM, parametres);
+					String login = ((JSONString) reponse.get(1)).stringValue();
-		rb.envoyerRequete(null, new JsonRestRequestCallback() {
+					// Drapeau leve si utilisateur deja identifié
-			@Override
+					boolean identifie = ((JSONBoolean) reponse.get(2)).booleanValue();
 			public void surReponse(JSONValue responseValue) {
-				if (responseValue.isArray() != null) {
+					utilisateur.setIdentification(identifie);
-					final JSONArray reponse = responseValue.isArray();
+					utilisateur.setLogin(login);
+					//Ajout des informations licence
+					if (reponse.get(0).isString() != null)	{
-					//Ajout des informations licence
+						utilisateur.setLicence(reponse.get(0).isString().stringValue());
+					} else {
+						utilisateur.setLicence("");
+					}
 					if (reponse.get(0).isString() != null)	{
-						utilisateur.setLicence(reponse.get(0).isString().stringValue());
+					//Coel.LogVersFirebug("Utilisateur CoeL chargé !!");
-					} else {
-						utilisateur.setLicence("");
+					//Coel.LogVersFirebug("id: " + identifie + ", login: " + login + ", licence: " + utilisateur.getLicence());
-					}
+					//Coel.LogVersFirebug("Taille réponse:" + reponse.size());
-					if (reponse.size() > 0) {
-						// Identifiant de l'utilisateur ou identifiant de session si non identifié
+					// Utilisateur connecté (non anonyme)
-						utilisateur.setId(((JSONString) reponse.get(1)).stringValue());
+					if (reponse.size() > 3) {
+						//Coel.LogVersFirebug("Utilisateur identifié, on charge plus de trucs !");
+						// Identifiant de l'utilisateur ou identifiant de session si non identifié
+						String idUtilisateur = ((JSONString) reponse.get(1)).stringValue();
-						// Drapeau levé si l'utilisateur est déjà identifié
+						//Coel.LogVersFirebug("ID utilisateur: " + idUtilisateur);
-						utilisateur.setIdentification(((JSONBoolean) reponse.get(2)).booleanValue());
+						utilisateur.setId(idUtilisateur);
-						// Plus de deux valeurs, l'utilisateur est identifié nous récupérons des données supplémentaires
+						// Nom complet de l'utilisateur
+						if (reponse.get(3).isString() != null) {
+							String nomComplet = ((JSONString) reponse.get(3)).stringValue();
-						if (reponse.size() > 3) {
+							//Coel.LogVersFirebug("Nom complet: " + nomComplet);
-							// Nom complet de l'utilisateur
-							if (reponse.get(3).isString() != null) {
+							utilisateur.setNomComplet(nomComplet);
-								utilisateur.setNomComplet(((JSONString) reponse.get(3)).stringValue());
+						}
-							}
+						// Prénom de l'utilisateur
+						if (reponse.get(4).isString() != null) {
+							String prenom = ((JSONString) reponse.get(4)).stringValue();
-							// Prénom de l'utilisateur
+							utilisateur.setPrenom(prenom);
-							if (reponse.get(4).isString() != null) {
-								utilisateur.setPrenom(((JSONString) reponse.get(4)).stringValue());
+							//Coel.LogVersFirebug("Prénom: " + prenom);
-							}
+						}
+						// Nom de l'utilisateur
-							// Nom de l'utilisateur
+						if (reponse.get(5).isString() != null) {
-							if (reponse.get(5).isString() != null) {
+							String nom = ((JSONString) reponse.get(5)).stringValue();
-								utilisateur.setNom(((JSONString) reponse.get(5)).stringValue());
+							utilisateur.setNom(nom);
-							}
 							//Coel.LogVersFirebug("Nom: " + nom);
+						}
+						// Paramètre => was ist das ?
+						if (reponse.get(6).isString() != null) {
-							// Paramètres
+							String parametre = ((JSONString) reponse.get(6)).stringValue();
-							if (reponse.get(6).isString() != null) {
+							utilisateur.setParametre(parametre);
-								utilisateur.setParametre(((JSONString) reponse.get(6)).stringValue());
+							//Coel.LogVersFirebug("Paramètre: " + parametre);
+						}
+					}
-						}
+					//Coel.LogVersFirebug("Rafraîchissement vue");
-						vueARafraichir.rafraichir(utilisateur);
+					vueARafraichir.rafraichir(utilisateur);
+				}
+			}
 		});
 		});

Subversion Repositories eFlore/Applications.coel

(root)/trunk/src/org/tela_botanica/client/modeles/UtilisateurAsyncDao.java – Rev 1732 → 1906