Zinder/Client.java at main · vava408/Zinder · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
import java.io.*;
import java.net.*;
import java.util.*;
import javax.swing.SwingUtilities;

public class Client {
	private Socket socket;
	private ObjectOutputStream out;
	private ObjectInputStream in;
	private Controleur controleur;
	private String idUtilisateurConnecte;

	private static final String SERVER_ADDRESS = "di-docker";
	private static final int SERVER_PORT = 9043;

	public Client()
	{
		connecterAuServeur();

		this.controleur = new Controleur(this);

		SwingUtilities.invokeLater(() -> {
			controleur.afficherConnexion();
		});
	}

	private void connecterAuServeur()
	{
		try
		{
			socket = new Socket(SERVER_ADDRESS, SERVER_PORT);
			out = new ObjectOutputStream(socket.getOutputStream());
			in = new ObjectInputStream(socket.getInputStream());

			new Thread(this::ecouterServeur).start();

			System.out.println("Connecté au serveur");
		}
		catch (IOException e)
		{
			System.err.println("Erreur de connexion au serveur: " + e.getMessage());
		}
	}

	private void ecouterServeur()
	{
		try
		{
			while (true)
			{
				Object messageRecu = in.readObject();
				traiterMessageServeur(messageRecu);
			}
		}
		catch (IOException | ClassNotFoundException e)
		{
			System.err.println("Erreur communication serveur: " + e.getMessage());
		}
	}

	private void traiterMessageServeur(Object message)
	{
		if (message instanceof List)
		{
			@SuppressWarnings("unchecked")
			List<Profil> profils = (List<Profil>) message;
			controleur.recevoirProfils(profils);
		}
		else if (message instanceof Message)
		{
			Message msgChat = (Message) message;
			controleur.recevoirMessage(msgChat);
		}
		else if (message instanceof Profil)
		{
			Profil profilMatch = (Profil) message;
			controleur.nouveauMatch(profilMatch);
		}
		else if (message instanceof Map)
		{
			@SuppressWarnings("unchecked")
			Map<String, Object> responseMap = (Map<String, Object>) message;
			String type = (String) responseMap.get("type");

			if (type.equals("PROFIL_CREE"))
			{
				Profil profilMisAJour = (Profil) responseMap.get("profil");
				idUtilisateurConnecte = profilMisAJour.getId();
				controleur.mettreAJourProfilUtilisateur(profilMisAJour);
			}
			else if (type.equals("CONNEXION_REUSSIE"))
			{
				Profil profilConnecte = (Profil) responseMap.get("profil");
				idUtilisateurConnecte = profilConnecte.getId();
				controleur.mettreAJourProfilUtilisateur(profilConnecte);

				@SuppressWarnings("unchecked")
				List<Message> historiqueMessages = (List<Message>) responseMap.get("historique_messages");
				if (historiqueMessages != null) {
					controleur.recevoirHistoriqueMessages(historiqueMessages);
				}
			}
			else if (type.equals("ERREUR_CONNEXION"))
			{
				String message_erreur = (String) responseMap.get("message");
				controleur.afficherErreurConnexion(message_erreur);
			}
		}
	}

	public void envoyerNouveauProfil(Profil profil)
	{
		envoyerAuServeur("NOUVEAU_PROFIL", profil);
	}

	public void envoyerDemandeConnexion(String identifiant, String motDePasse)
	{
		Map<String, String> infoConnexion = new HashMap<>();
		infoConnexion.put("identifiant", identifiant);
		infoConnexion.put("motDePasse", motDePasse);
		envoyerAuServeur("CONNEXION", infoConnexion);
	}

	public void envoyerLike(String idUtilisateur, String idProfilLike)
	{
		envoyerAuServeur("LIKE", new String[]{idUtilisateur, idProfilLike});
	}

	public void envoyerMessage(Message message)
	{
		envoyerAuServeur("MESSAGE", message);
	}

	private void envoyerAuServeur(String type, Object contenu)
	{
		try
		{
			Map<String, Object> messageMap = new HashMap<>();
			messageMap.put("type", type);
			messageMap.put("contenu", contenu);
			out.writeObject(messageMap);
			out.flush();
		}
		catch (IOException e)
		{
			System.err.println("Erreur envoi au serveur: " + e.getMessage());
		}
	}

	public static void main(String[] args)
	{
		new Client();
	}
}