refactor server room operations

ChatApp/src/ChatApp.java

@@ -1,23 +1,21 @@
 import java.net.InetSocketAddress;
-import java.util.Scanner;
 
-import client.Client;
+import client.ClientConsole;
 import server.Server;
 
 public class ChatApp {
     public static void main(String[] args) throws Exception {
         Server server = new Server(6665);
-        Client client = new Client(new InetSocketAddress("localhost", 6665));
+        ClientConsole client = new ClientConsole(new InetSocketAddress("localhost", 6665));
 
-        client.SendCreateRoom("101");
+        client.getClientInterface().SendCreateRoom("101");
 
-        Scanner scanner = new Scanner(System.in);
-        while (true) {
-            String message = scanner.nextLine();
-            System.out.print("\033[1A");
-            System.out.print("\r\033[2K");
-            System.out.flush();
-            client.visitMessage(message);
-        }
+        client.joinThread();
+
+        System.out.println("Stopping server ...");
+
+        server.close();
+
+        System.out.println("Done !");
     }
 }

ChatApp/src/client/Client.java

@@ -1,118 +1,55 @@
 package client;
 
-import java.io.IOException;
 import java.net.DatagramSocket;
 import java.net.InetSocketAddress;
 import java.net.SocketException;
-import java.util.Objects;
-import java.util.Scanner;
 
-import network.protocol.packets.*;
+import network.protocol.packets.CreateRoomPacket;
+import network.protocol.packets.DisconnectPacket;
+import network.protocol.packets.JoinRoomPacket;
+import network.protocol.packets.LeaveRoomPacket;
+import network.protocol.packets.LoginPacket;
+import network.protocol.packets.RequestRoomListPacket;
+import network.protocol.packets.SendChatMessagePacket;
 
 public class Client {
 
 	private final ClientConnexion connexion;
+	private final ClientListener callback;
 
-	public static void main(String[] args) {
-		String host = "localhost";
-		int port = 6665;
-		try {
-			Client client = new Client(new InetSocketAddress(host, port));
-			Scanner scanner = new Scanner(System.in);
-			while(true) {
-				String message = scanner.nextLine();
-				client.visitMessage(message);
-			}
-		} catch (SocketException e) {
-			e.printStackTrace();
-		}
-	}
-
-	public Client(InetSocketAddress serverAddress) throws SocketException {
-		this.connexion = new ClientConnexion(new DatagramSocket(), serverAddress);
-		Scanner scanner = new Scanner(System.in);
-		System.out.println("Enter your pseudo:");
-		String pseudo = scanner.nextLine();
+	public Client(InetSocketAddress serverAddress, ClientListener callback, String pseudo) throws SocketException {
+		this.connexion = new ClientConnexion(new DatagramSocket(), serverAddress, callback);
+		this.callback = callback;
 		login(pseudo);
 	}
 
-	public void visitMessage(String message){
-		try {
-			if(message.startsWith("/")){
-				if(message.startsWith("/createRoom")) {
-					String roomName = message.substring(12).trim();
-					SendCreateRoom(roomName);
-				} else if(message.startsWith("/listRooms")) {
-					RequestRoomList();
-				} else if(message.startsWith("/joinRoom")) {
-					String roomName = message.substring(10).trim();
-					SendJoinRoom(roomName);
-				} else if(message.startsWith("/leaveRoom")) {
-					SendLeaveRoom();
-				} else if(message.startsWith("/help")) {
-					System.out.println("Available commands:");
-					System.out.println("\t/createRoom <roomName>");
-					System.out.println("\t/listRooms");
-					System.out.println("\t/joinRoom <roomName>");
-					System.out.println("\t/leaveRoom");
-					System.out.println("\t/help");
-				}
-				else {
-					System.out.println("Unknown command");
-				}
-			} else {
-				SendChatMessage(message);
-			}
-		} catch (Exception e) {
-			e.printStackTrace();
-		}
+	public void close() {
+		this.connexion.sendPacket(new DisconnectPacket("Leaving"));
+		this.connexion.close();
+		this.callback.handleDisconnect();
 	}
 
 	private void login(String pseudo) {
-		try {
-			this.connexion.sendPacket(new LoginPacket(pseudo));
-		} catch (IOException e) {
-			e.printStackTrace();
-		}
+		this.connexion.sendPacket(new LoginPacket(pseudo));
 	}
 
 	public void SendChatMessage(String message) {
-		try {
-			this.connexion.sendPacket(new SendChatMessagePacket(message));
-		} catch (IOException e) {
-			e.printStackTrace();
-		}
+		this.connexion.sendPacket(new SendChatMessagePacket(message));
 	}
 
 	public void SendCreateRoom(String roomName) {
-		try {
-			this.connexion.sendPacket(new CreateRoomPacket(roomName));
-		} catch (Exception e) {
-			e.printStackTrace();
-		}
+		this.connexion.sendPacket(new CreateRoomPacket(roomName));
 	}
 
 	public void SendJoinRoom(String roomName) {
-		try {
-			this.connexion.sendPacket(new JoinRoomPacket(roomName));
-		} catch (Exception e) {
-			e.printStackTrace();
-		}
+		this.connexion.sendPacket(new JoinRoomPacket(roomName));
 	}
 
 	public void SendLeaveRoom() {
-		try {
-			this.connexion.sendPacket(new LeaveRoomPacket());
-		} catch (Exception e) {
-			e.printStackTrace();
-		}
+		this.connexion.sendPacket(new LeaveRoomPacket());
 	}
 
 	public void RequestRoomList() {
-		try {
-			this.connexion.sendPacket(new RequestRoomListPacket());
-		} catch (Exception e) {
-			e.printStackTrace();
-		}
+		this.connexion.sendPacket(new RequestRoomListPacket());
 	}
 }

ChatApp/src/client/ClientConnexion.java

@@ -7,11 +7,11 @@ import java.net.InetSocketAddress;
 import network.PacketHandler;
 import network.SocketReader;
 import network.SocketWriter;
-import network.protocol.ANSIColor;
 import network.protocol.Packet;
 import network.protocol.PacketVisitor;
 import network.protocol.packets.ChatMessagePacket;
 import network.protocol.packets.CreateRoomPacket;
+import network.protocol.packets.DisconnectPacket;
 import network.protocol.packets.JoinRoomPacket;
 import network.protocol.packets.LeaveRoomPacket;
 import network.protocol.packets.LoginPacket;
@@ -25,19 +25,27 @@ public class ClientConnexion implements PacketVisitor, PacketHandler{
 	private final InetSocketAddress serverAddress;
 	private final SocketWriter writer;
 	private final SocketReader reader;
+	private final ClientListener callback;
 
-	public ClientConnexion(DatagramSocket socket, InetSocketAddress serverAddress) {
+	public ClientConnexion(DatagramSocket socket, InetSocketAddress serverAddress, ClientListener callback) {
 		this.serverAddress = serverAddress;
 		this.writer = new SocketWriter(socket);
 		this.reader = new SocketReader(socket, this);
+		this.callback = callback;
 	}
 
 	public void close() {
 		this.reader.stop();
 	}
 
-	public void sendPacket(Packet packet) throws IOException {
-		this.writer.sendPacket(packet, serverAddress);
+	public void sendPacket(Packet packet) {
+		try {
+			this.writer.sendPacket(packet, serverAddress);
+		} catch (IOException e) {
+			this.close();
+			this.callback.handleDisconnect();
+			e.printStackTrace();
+		}
 	}
 
 	@Override
@@ -48,16 +56,23 @@ public class ClientConnexion implements PacketVisitor, PacketHandler{
 
 	@Override
 	public void visitPacket(ChatMessagePacket packet) {
-		StringBuilder sb = new StringBuilder();
-		String time = packet.getTime().toString();
-		sb.append("&y[");
-		sb.append(time, 11, 19); // We only take the HH:MM:SS part
-		sb.append("]&n");
-		sb.append(" ");
-		sb.append(packet.getChatter());
-		sb.append(" : ");
-		sb.append(packet.getContent()).append("&n"); // make the color back to normal at the end of every message
-		System.out.println(ANSIColor.formatString(sb.toString()));
+		this.callback.handleChatMessage(packet.getTime(), packet.getChatter(), packet.getContent());
+	}
+
+	@Override
+	public void visitPacket(RoomListPacket packet) {
+		this.callback.handleRoomList(packet.getRoomNames());
+	}
+
+	@Override
+	public void visitPacket(ServerResponsePacket packet) {
+		this.callback.handleServerResponse(packet.getResponse());
+	}
+
+	@Override
+	public void visitPacket(DisconnectPacket packet) {
+		this.close();
+		this.callback.handleDisconnect();
 	}
 
 	@Override
@@ -85,25 +100,9 @@ public class ClientConnexion implements PacketVisitor, PacketHandler{
 		throw new UnsupportedOperationException("Unimplemented method 'visitPacket'");
 	}
 
-	@Override
-	public void visitPacket(RoomListPacket packet) {
-		System.out.println("Rooms :");
-		for (String room : packet.getRoomNames()) {
-			System.out.println("\t" + room);
-		}
-	}
-
 	@Override
 	public void visitPacket(SendChatMessagePacket packet) {
 		throw new UnsupportedOperationException("Unimplemented method 'visitPacket'");
 	}
 	
-	@Override
-	public void visitPacket(ServerResponsePacket packet) {
-		if(packet.getResponse() == ServerResponsePacket.Response.MessageSent || packet.getResponse() == ServerResponsePacket.Response.MessageNotSent) {
-			return;
-		}
-		System.out.println(packet.getResponse());
-	}
-
 }

ChatApp/src/client/ClientConsole.java

@@ -0,0 +1,128 @@
+package client;
+
+import java.net.InetSocketAddress;
+import java.net.SocketException;
+import java.time.Instant;
+import java.util.List;
+import java.util.Scanner;
+
+import network.protocol.ANSIColor;
+import network.protocol.packets.ServerResponsePacket;
+import network.protocol.packets.ServerResponsePacket.Response;
+
+public class ClientConsole implements ClientListener {
+
+	private Client client;
+	private final Thread inputThread;
+	private final Scanner scanner;
+
+	public static void main(String[] args) {
+		new ClientConsole(new InetSocketAddress("localhost", 6665));
+	}
+
+	public ClientConsole(InetSocketAddress address) {
+		this.inputThread = new Thread(this::inputLoop);
+		this.scanner = new Scanner(System.in);
+		String pseudo = inputPseudo();
+		try {
+			this.client = new Client(address, this, pseudo);
+			this.inputThread.start();
+		} catch (SocketException e) {
+			e.printStackTrace();
+		}
+	}
+
+	private String inputPseudo() {
+		System.out.println("Enter your pseudo:");
+		String pseudo = this.scanner.nextLine();
+		return pseudo;
+	}
+
+	public Client getClientInterface() {
+		return this.client;
+	}
+
+	private void inputLoop() {
+		while (!Thread.interrupted()) {
+			String message = scanner.nextLine();
+			visitMessage(message);
+		}
+		this.scanner.close();
+	}
+
+	public void joinThread() throws InterruptedException {
+		this.inputThread.join();
+	}
+
+	private void visitMessage(String message) {
+		try {
+			if (message.startsWith("/")) {
+				if (message.startsWith("/createRoom")) {
+					String roomName = message.substring(12).trim();
+					this.client.SendCreateRoom(roomName);
+				} else if (message.startsWith("/listRooms")) {
+					this.client.RequestRoomList();
+				} else if (message.startsWith("/joinRoom")) {
+					String roomName = message.substring(10).trim();
+					this.client.SendJoinRoom(roomName);
+				} else if (message.startsWith("/leaveRoom")) {
+					this.client.SendLeaveRoom();
+				} else if (message.startsWith("/bye")) {
+					this.client.close();
+				} else if (message.startsWith("/help")) {
+					System.out.println("Available commands:");
+					System.out.println("\t/bye");
+					System.out.println("\t/createRoom <roomName>");
+					System.out.println("\t/listRooms");
+					System.out.println("\t/joinRoom <roomName>");
+					System.out.println("\t/leaveRoom");
+					System.out.println("\t/help");
+				} else {
+					System.out.println("Unknown command");
+				}
+			} else {
+				this.client.SendChatMessage(message);
+			}
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+	}
+
+	@Override
+	public void handleDisconnect() {
+		System.out.println("Disconnected !");
+		this.inputThread.interrupt();
+	}
+
+	@Override
+	public void handleChatMessage(Instant time, String chatter, String content) {
+		StringBuilder sb = new StringBuilder();
+		String strTime = time.toString();
+		sb.append("&y[");
+		sb.append(strTime, 11, 19); // We only take the HH:MM:SS part
+		sb.append("]&n");
+		sb.append(" ");
+		sb.append(chatter);
+		sb.append(" : ");
+		sb.append(content).append("&n"); // make the color back to normal at the end of every message
+		System.out.println(ANSIColor.formatString(sb.toString()));
+	}
+
+	@Override
+	public void handleRoomList(List<String> roomNames) {
+		System.out.println("Rooms :");
+		for (String room : roomNames) {
+			System.out.println("\t" + room);
+		}
+	}
+
+	@Override
+	public void handleServerResponse(Response response) {
+		if (response == ServerResponsePacket.Response.MessageSent
+				|| response == ServerResponsePacket.Response.MessageNotSent) {
+			return;
+		}
+		System.out.println(response);
+	}
+
+}

ChatApp/src/client/ClientListener.java

@@ -0,0 +1,15 @@
+package client;
+
+import java.time.Instant;
+import java.util.List;
+
+import network.protocol.packets.ServerResponsePacket;
+
+public interface ClientListener {
+
+	void handleDisconnect();
+	void handleChatMessage(Instant time, String chatter, String content);
+	void handleRoomList(List<String> roomNames);
+	void handleServerResponse(ServerResponsePacket.Response response);
+	
+}

ChatApp/src/network/SocketReader.java

@@ -24,6 +24,7 @@ public class SocketReader {
 
 	public void stop() {
 		this.readThread.interrupt();
+		socket.close();
 	}
 
 	private void readLoop() {

ChatApp/src/network/protocol/PacketVisitor.java

@@ -2,6 +2,7 @@ package network.protocol;
 
 import network.protocol.packets.ChatMessagePacket;
 import network.protocol.packets.CreateRoomPacket;
+import network.protocol.packets.DisconnectPacket;
 import network.protocol.packets.JoinRoomPacket;
 import network.protocol.packets.LeaveRoomPacket;
 import network.protocol.packets.LoginPacket;
@@ -18,6 +19,7 @@ public interface PacketVisitor {
 	
 	void visitPacket(ChatMessagePacket packet);
 	void visitPacket(CreateRoomPacket packet);
+	void visitPacket(DisconnectPacket packet);
 	void visitPacket(JoinRoomPacket packet);
 	void visitPacket(LeaveRoomPacket packet);
 	void visitPacket(LoginPacket packet);

ChatApp/src/network/protocol/packets/DisconnectPacket.java

@@ -0,0 +1,23 @@
+package network.protocol.packets;
+
+import network.protocol.Packet;
+import network.protocol.PacketVisitor;
+
+public class DisconnectPacket extends Packet {
+
+	private final String reason;
+
+	public DisconnectPacket(String reason) {
+		this.reason = reason;
+	}
+
+	public String getReason() {
+		return reason;
+	}
+
+	@Override
+	public void accept(PacketVisitor packetVisitor) {
+		packetVisitor.visitPacket(this);
+	}
+
+}

ChatApp/src/network/protocol/packets/RoomListPacket.java

@@ -1,19 +1,19 @@
 package network.protocol.packets;
 
-import java.util.ArrayList;
+import java.util.List;
 
 import network.protocol.Packet;
 import network.protocol.PacketVisitor;
 
 public class RoomListPacket extends Packet {
 
-	private final ArrayList<String> roomNames;
+	private final List<String> roomNames;
 
-	public RoomListPacket(ArrayList<String> roomNames) {
+	public RoomListPacket(List<String> roomNames) {
 		this.roomNames = roomNames;
 	}
 
-	public ArrayList<String> getRoomNames() {
+	public List<String> getRoomNames() {
 		return roomNames;
 	}
 

ChatApp/src/server/Server.java

@@ -19,65 +19,67 @@ public class Server implements PacketHandler {
 	private final DatagramSocket serverSocket;
 	private final Map<InetSocketAddress, ServerConnexion> connexions;
 	private final SocketReader reader;
-	private final Map<String, ArrayList<ServerConnexion>> roomNames;
+	private final Map<String, ArrayList<ServerConnexion>> rooms;
 
 	public Server(int port) throws SocketException {
 		this.serverSocket = new DatagramSocket(port);
 		this.connexions = new HashMap<>();
 		this.reader = new SocketReader(serverSocket, this);
-		this.roomNames = new HashMap<>();
+		this.rooms = new HashMap<>();
 	}
 
 	public ArrayList<String> getRoomNames() {
-		return roomNames.keySet().stream().collect(ArrayList::new, ArrayList::add, ArrayList::addAll);
+		return rooms.keySet().stream().collect(ArrayList::new, ArrayList::add, ArrayList::addAll);
 	}
 
 	public String getRoomName(ServerConnexion connexion) {
-		for (Map.Entry<String, ArrayList<ServerConnexion>> entry : roomNames.entrySet()) {
-			if(entry.getValue().contains(connexion)) {
+		for (Map.Entry<String, ArrayList<ServerConnexion>> entry : rooms.entrySet()) {
+			if (entry.getValue().contains(connexion)) {
 				return entry.getKey();
 			}
 		}
 		return null;
 	}
 
-	public void createRoom(String roomName, ServerConnexion connexion) throws SocketException {
-		if(roomNames.containsKey(roomName)) {
-			throw new SocketException("Room already exists");
+	public boolean createRoom(String roomName, ServerConnexion connexion) {
+		if (rooms.containsKey(roomName)) {
+			return false;
 		}
-		roomNames.put(roomName, new ArrayList<>());
-		roomNames.get(roomName).add(connexion);
+		rooms.put(roomName, new ArrayList<>());
+		rooms.get(roomName).add(connexion);
+		return true;
 	}
 
-	public void leaveRoom(ServerConnexion connexion) throws SocketException {
+	public boolean leaveRoom(ServerConnexion connexion) {
 		String roomName = getRoomName(connexion);
-		if(roomName != null) {
-			roomNames.get(roomName).remove(connexion);
+		if (roomName != null) {
+			rooms.get(roomName).remove(connexion);
 			// Remove the room if it is empty
-			if(roomNames.get(roomName).isEmpty()) {
-				roomNames.remove(roomName);
+			if (rooms.get(roomName).isEmpty()) {
+				rooms.remove(roomName);
 			}
-			return;
+			return true;
 		}
-		throw new SocketException("Room does not exist");
+		return false;
 	}
 
-	public void joinRoom(String roomName, ServerConnexion connexion) throws SocketException {
-		if(roomNames.containsKey(roomName) && !roomNames.get(roomName).contains(connexion)) {
-			roomNames.get(roomName).add(connexion);
-			return;
+	public boolean joinRoom(String roomName, ServerConnexion connexion) {
+		if (rooms.containsKey(roomName) && !rooms.get(roomName).contains(connexion)) {
+			rooms.get(roomName).add(connexion);
+			return true;
 		}
-		throw new SocketException("Room does not exist");
+		return false;
 	}
 
-	public void sendToRoom(ServerConnexion connexion, SendChatMessagePacket packet) throws SocketException {
+	public boolean sendToRoom(ServerConnexion connexion, SendChatMessagePacket packet) {
 		String roomName = getRoomName(connexion);
-		ChatMessagePacket chatPacket = new ChatMessagePacket(Instant.now(), connexion.getChatterName(), packet.getContent());
-		if(roomName != null && roomNames.containsKey(roomName)) {
-			roomNames.get(roomName).forEach(con -> con.sendPacket(chatPacket));
-			return;
+		ChatMessagePacket chatPacket = new ChatMessagePacket(Instant.now(), connexion.getChatterName(),
+				packet.getContent());
+		if (roomName != null && rooms.containsKey(roomName)) {
+			rooms.get(roomName).forEach(con -> con.sendPacket(chatPacket));
+			return true;
 		}
-		throw new SocketException("You are not in a room or the room does not exist");
+		return false;
 	}
 
 	public void close() {
@@ -89,6 +91,20 @@ public class Server implements PacketHandler {
 				.anyMatch(connexion -> pseudo.equals(connexion.getChatterName()));
 	}
 
+	void removeConnexion(ServerConnexion connexion) {
+		for (var it = this.connexions.entrySet().iterator(); it.hasNext();) {
+			var entry = it.next();
+			if (entry.getValue() == connexion) {
+				it.remove();
+				break;
+			}
+		}
+		for (var entry : this.rooms.entrySet()) {
+			if (entry.getValue().remove(connexion))
+				return;
+		}
+	}
+
 	@Override
 	public void handlePacket(Packet packet, InetSocketAddress address) {
 		if (!connexions.containsKey(address)) {

ChatApp/src/server/ServerConnexion.java

@@ -3,13 +3,13 @@ package server;
 import java.io.IOException;
 import java.net.DatagramSocket;
 import java.net.InetSocketAddress;
-import java.net.SocketException;
 
 import network.SocketWriter;
 import network.protocol.Packet;
 import network.protocol.PacketVisitor;
 import network.protocol.packets.ChatMessagePacket;
 import network.protocol.packets.CreateRoomPacket;
+import network.protocol.packets.DisconnectPacket;
 import network.protocol.packets.JoinRoomPacket;
 import network.protocol.packets.LeaveRoomPacket;
 import network.protocol.packets.LoginPacket;
@@ -41,43 +41,26 @@ public class ServerConnexion implements PacketVisitor {
 			this.writer.sendPacket(packet, clientAddress);
 		} catch (IOException e) {
 			e.printStackTrace();
+			this.server.removeConnexion(this);
 		}
 	}
 
-	@Override
-	public void visitPacket(ChatMessagePacket packet) {
-		// I'm never supposed to receive this from the client
-		throw new UnsupportedOperationException("Unimplemented method 'visitPacket'");
-	}
-
 	@Override
 	public void visitPacket(CreateRoomPacket packet) {
-		try {
-			server.createRoom(packet.getRoomName(), this);
-			sendPacket(new ServerResponsePacket(Response.RoomCreated));
-		} catch (SocketException e) {
-			sendPacket(new ServerResponsePacket(Response.RoomNotCreated));
-		}
+		boolean created = server.createRoom(packet.getRoomName(), this);
+		sendPacket(new ServerResponsePacket(created ? Response.RoomCreated : Response.RoomNotCreated));
 	}
 
 	@Override
 	public void visitPacket(JoinRoomPacket packet) {
-		try {
-			server.joinRoom(packet.getRoomName(), this);
-			sendPacket(new ServerResponsePacket(Response.RoomJoined));
-		} catch (SocketException e) {
-			sendPacket(new ServerResponsePacket(Response.RoomNotJoined));
-		}
+		boolean joined = server.joinRoom(packet.getRoomName(), this);
+		sendPacket(new ServerResponsePacket(joined ? Response.RoomJoined : Response.RoomNotJoined));
 	}
 
 	@Override
 	public void visitPacket(LeaveRoomPacket packet) {
-		try {
-			server.leaveRoom(this);
-			sendPacket(new ServerResponsePacket(Response.RoomLeft));
-		} catch (SocketException e) {
-			sendPacket(new ServerResponsePacket(Response.RoomNotLeft));
-		}
+		boolean left = server.leaveRoom(this);
+		sendPacket(new ServerResponsePacket(left ? Response.RoomLeft : Response.RoomNotLeft));
 	}
 
 	@Override
@@ -97,6 +80,22 @@ public class ServerConnexion implements PacketVisitor {
 		sendPacket(new RoomListPacket(server.getRoomNames()));
 	}
 
+	@Override
+	public void visitPacket(SendChatMessagePacket packet) {
+		boolean messageSent = server.sendToRoom(this, packet);
+		sendPacket(new ServerResponsePacket(messageSent ? Response.MessageSent : Response.MessageNotSent));
+	}
+
+	@Override
+	public void visitPacket(DisconnectPacket packet) {
+		this.onDisconnect();
+	}
+
+	private void onDisconnect() {
+		this.server.removeConnexion(this);
+		System.out.println("[Server] Chatter " + chatterName + " disconnected !");
+	}
+
 	@Override
 	public void visitPacket(RoomListPacket packet) {
 		// I'm never supposed to receive this from the client
@@ -104,12 +103,9 @@ public class ServerConnexion implements PacketVisitor {
 	}
 
 	@Override
-	public void visitPacket(SendChatMessagePacket packet) {
-		try {
-			server.sendToRoom(this, packet);
-		} catch (SocketException e) {
-			sendPacket(new ServerResponsePacket(Response.MessageNotSent));
-		}
+	public void visitPacket(ChatMessagePacket packet) {
+		// I'm never supposed to receive this from the client
+		throw new UnsupportedOperationException("Unimplemented method 'visitPacket'");
 	}
 
 	@Override