/*
 * Click nbfs://nbhost/SystemFileSystem/Templates/Licenses/license-default.txt to change this license
 * Click nbfs://nbhost/SystemFileSystem/Templates/Classes/Class.java to edit this template
 */
package com.megatim.fdxconsultation.model.message.systeme;

import com.megatim.fdxconsultation.model.administration.User;
import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import javax.websocket.EncodeException;
import javax.websocket.Session;

/**
 *
 * @author Lenovo P53
 */
public class UserSesionApplication {

    private static UserSesionApplication userSesion;
    private static HashMap<String, UserWebSocket> users;

    public static UserSesionApplication getInstance() {
        if (userSesion == null) {
            userSesion = new UserSesionApplication();
            users = new HashMap<String, UserWebSocket>();
        }
        return userSesion;
    }

    public synchronized static HashMap<String, UserWebSocket> getUsers() {
        return users;
    }

    public static void setUsers(HashMap<String, UserWebSocket> users) {
        UserSesionApplication.users = users;
    }

    public void addSession(User utilidateur, Session session, String type) {
        this.users.put(session.getId(), new UserWebSocket(session, utilidateur, type));
    }

    public void removeSession(Session session) {
        this.users.remove(session.getId());
    }

    public void send(Session session, ApplicationData message) throws IOException, EncodeException {
        session.getBasicRemote().sendObject(message);
    }
    
    public static boolean siUtilisateurConnecte(User user) {
        boolean etat = false;        
        UserWebSocket userSession = null;
        Iterator<String> iterator = UserSesionApplication.getInstance().getUsers().keySet().iterator();
        while(iterator.hasNext()){
            userSession = UserSesionApplication.getInstance().getUsers().get(iterator.next());
            if((userSession != null && userSession.getUtilisateur() != null)
                    && user != null
                    && userSession.getUtilisateur().getId() == user.getId()){
                etat = true;
                break;
            }
        }
        return etat;
    }
    
    public void removeAllSessionsForUser(User user) {
        
        //Variables
        List<String> sessionsId = new ArrayList();
        
        //On parcourt la liste des sessions
        UserSesionApplication.getInstance().getUsers().forEach((sessionId, userSession) -> {
            
            //Si l'utilisateur non null
            if((userSession != null && userSession.getUtilisateur() != null)
                    && user != null
                    && userSession.getUtilisateur().getId() == user.getId()){
                
                //On recuoère les sessions de l'utilisateur
                sessionsId.add(sessionId);
                
            }
        });
        
        //On retire les sessions de l'utilisateur
        for(String sessionId : sessionsId){
            
            //On retire la session
            this.users.remove(sessionId);
            
            System.out.println("=============================removeAllSessionsForUser=====================================>");
            
        }
        
    }

}