vergnet/clavardator
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

fix tcp message receiving

Browse source
This commit is contained in:
Arnaud Vergnet 2020-12-16 12:26:43 +01:00
parent 1d3e56e9b7
commit 362f5fa2f8
3 changed files with 8 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/main/java/fr/insa/clavardator/db/DatabaseController.java
View file

@ -33,7 +33,7 @@ public class DatabaseController {
* @param callback Function called when the request is done * @param callback Function called when the request is done
*/ */
public void addMessage(Message message, MessageCallback callback) { public void addMessage(Message message, MessageCallback callback) {
callback.onMessageSaved();
} }

5
src/main/java/fr/insa/clavardator/ui/chat/ChatController.java
View file

@ -7,6 +7,8 @@ import fr.insa.clavardator.ui.LoadingScreenController;
import fr.insa.clavardator.ui.NoSelectionModel; import fr.insa.clavardator.ui.NoSelectionModel;
import fr.insa.clavardator.users.PeerUser; import fr.insa.clavardator.users.PeerUser;
import fr.insa.clavardator.util.ErrorCallback; import fr.insa.clavardator.util.ErrorCallback;
import fr.insa.clavardator.util.Log;
import javafx.application.Platform;
import javafx.collections.FXCollections; import javafx.collections.FXCollections;
import javafx.fxml.FXML; import javafx.fxml.FXML;
import javafx.fxml.Initializable; import javafx.fxml.Initializable;
@ -64,8 +66,9 @@ public class ChatController implements Initializable {
} }
private void onMessageAdded(PeerUser user, Message message) { private void onMessageAdded(PeerUser user, Message message) {
Log.v(this.getClass().getSimpleName(), "Message added: " + message.getText());
messageList.getItems().add(message); messageList.getItems().add(message);
messageList.scrollTo(messageList.getItems().size() - 1); Platform.runLater(() -> messageList.scrollTo(messageList.getItems().size() - 1));
} }
private void setState(State state) { private void setState(State state) {

6
src/main/java/fr/insa/clavardator/users/PeerUser.java
View file

@ -118,11 +118,11 @@ public class PeerUser extends User implements Comparable<PeerUser> {
connection.receive( connection.receive(
msg -> { msg -> {
Log.v(this.getClass().getSimpleName(), "Received message from " + id); Log.v(this.getClass().getSimpleName(), "Received message from " + id);
if (msg.getClass().isInstance(UserInformation.class)) { if (msg instanceof UserInformation) {
assert ((UserInformation) msg).id == getId(); assert ((UserInformation) msg).id == getId();
Log.v(this.getClass().getSimpleName(), "Message username: " + ((UserInformation) msg).getUsername()); Log.v(this.getClass().getSimpleName(), "Message username: " + ((UserInformation) msg).getUsername());
setUsername(((UserInformation) msg).getUsername()); setUsername(((UserInformation) msg).getUsername());
} else if (msg.getClass().isInstance(Message.class)) { } else if (msg instanceof Message) {
assert ((Message) msg).getRecipient().id != id; assert ((Message) msg).getRecipient().id != id;
Log.v(this.getClass().getSimpleName(), "Message text: " + ((Message) msg).getText()); Log.v(this.getClass().getSimpleName(), "Message text: " + ((Message) msg).getText());
history.addMessage((Message) msg); history.addMessage((Message) msg);
@ -130,7 +130,7 @@ public class PeerUser extends User implements Comparable<PeerUser> {
}, },
e -> { e -> {
Log.e(this.getClass().getSimpleName(), "Error receiving message from " + id, e); Log.e(this.getClass().getSimpleName(), "Error receiving message from " + id, e);
if (e.getClass().isInstance(EOFException.class)) { if (e instanceof EOFException) {
disconnect(); disconnect();
} else { } else {
errorCallback.onError(e); errorCallback.onError(e);