AkkaGuiChatSourceCode/RemoteChatServiceActor.java at master · corradods/AkkaGuiChatSourceCode · 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
package remote;

import akka.actor.ActorRef;
import akka.actor.UntypedActor;
import akka.actor.ActorSystem;
import akka.actor.Props;
import com.typesafe.config.ConfigFactory;
import java.util.HashMap;

public class RemoteChatServiceActor extends UntypedActor {


  private GuiServer chat;
  private HashMap <ActorRef,String> users;
  private Messages messages;

  public RemoteChatServiceActor(GuiServer chat) {
    this.chat = chat;
    messages = new Messages();
    users = new HashMap<>();

    /*
    for(ActorRef ref : users.keySet())
        ref.tell(,getSelf());
    */
  }

  private void writeToLog(String logMessage) {
      this.chat.getLog().setText(this.chat.getLog().getText()+logMessage);
  }

  @Override
  public void onReceive(Object message) {

      switch(message.getClass().getSimpleName()) {

        case "LoginMessage":
                            handleLoginMessage(message);
                            break;

        case "LogoutMessage":
                            //handleLogoutMessage(message);
                             break;

        case "ChatMessage":
                            //handleChatMessage(message);
                            break;

        default:
                writeToLog("Messaggio non riconosciuto!...");
                break;

      }
  }

  private void handleLoginMessage(Object message) {
          if(users.containsValue(((Messages.LoginMessage)message).getNickname())) //nickname gia usato
              {
                writeToLog("SYSTEM: Nickname duplicato "+((Messages.LoginMessage)message).getNickname());
                getSender().tell(messages.new RejectLogin("Questo nickname è gia in uso \n"),getSelf());

                }
          else
            {
              writeToLog("Nickname accettato "+ ((Messages.LoginMessage)message).getNickname()+"\n");
              users.put(getSender(),((Messages.LoginMessage)message).getNickname());
              getSender().tell(messages.new AckLogin("users"),getSelf());
          }


  }

  public static void main(String[] args) {

    GuiServer frame = new GuiServer();
    frame.setVisible(true);
    frame.setLocationRelativeTo(null);
    frame.setTitle("Server - Akka Chat");

    final ActorSystem system = ActorSystem.create("ChatSystem", ConfigFactory.load(("chat")));

    final ActorRef remoteActor =system.actorOf(Props.create(RemoteChatServiceActor.class,frame), "remoteActor");

    frame.setActorReference(remoteActor);
    frame.printBootstrapMessage();
  }


}