Added getUnreadAmount function and changed ContactListCellFac' constr.
This commit is contained in:
parent
0e4fec100a
commit
11b3cebcb9
@ -111,6 +111,15 @@ public class Chat implements Serializable {
|
|||||||
messages.add(0, message);
|
messages.add(0, message);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public int getUnreadAmount() {
|
||||||
|
int unreadMessagesAmount = 0;
|
||||||
|
for (int i = messages.size() - 1; i >= 0; i--) {
|
||||||
|
if (messages.get(i).getStatus() == MessageStatus.RECEIVED) unreadMessagesAmount++;
|
||||||
|
else break;
|
||||||
|
}
|
||||||
|
return unreadMessagesAmount;
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @return all messages in the current chat
|
* @return all messages in the current chat
|
||||||
* @since Envoy Client v0.1-beta
|
* @since Envoy Client v0.1-beta
|
||||||
|
@ -52,7 +52,7 @@ public final class ChatScene implements Restorable {
|
|||||||
private ListView<Message> messageList;
|
private ListView<Message> messageList;
|
||||||
|
|
||||||
@FXML
|
@FXML
|
||||||
private ListView<Contact> userList;
|
private ListView<Chat> userList;
|
||||||
|
|
||||||
@FXML
|
@FXML
|
||||||
private Button postButton;
|
private Button postButton;
|
||||||
@ -121,7 +121,7 @@ public final class ChatScene implements Restorable {
|
|||||||
logger.log(Level.WARNING, "Could not read current chat: ", e1);
|
logger.log(Level.WARNING, "Could not read current chat: ", e1);
|
||||||
}
|
}
|
||||||
Platform.runLater(() -> { messageList.refresh(); scrollToMessageListEnd(); });
|
Platform.runLater(() -> { messageList.refresh(); scrollToMessageListEnd(); });
|
||||||
}
|
} // TODO set lable to getunreadmessages return value
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
@ -143,8 +143,9 @@ public final class ChatScene implements Restorable {
|
|||||||
eventBus.register(UserStatusChange.class,
|
eventBus.register(UserStatusChange.class,
|
||||||
e -> userList.getItems()
|
e -> userList.getItems()
|
||||||
.stream()
|
.stream()
|
||||||
.filter(c -> c.getID() == e.getID())
|
.filter(c -> c.getRecipient().getID() == e.getID())
|
||||||
.findAny()
|
.findAny()
|
||||||
|
.map(u -> u.getRecipient())
|
||||||
.ifPresent(u -> { ((User) u).setStatus(e.get()); Platform.runLater(userList::refresh); }));
|
.ifPresent(u -> { ((User) u).setStatus(e.get()); Platform.runLater(userList::refresh); }));
|
||||||
|
|
||||||
// Listen to contacts changes
|
// Listen to contacts changes
|
||||||
@ -153,13 +154,14 @@ public final class ChatScene implements Restorable {
|
|||||||
switch (e.getOperationType()) {
|
switch (e.getOperationType()) {
|
||||||
case ADD:
|
case ADD:
|
||||||
localDB.getUsers().put(contact.getName(), contact);
|
localDB.getUsers().put(contact.getName(), contact);
|
||||||
localDB.getChats().add(contact instanceof User ? new Chat(contact) : new GroupChat(client.getSender(), contact));
|
Chat chat = contact instanceof User ? new Chat(contact) : new GroupChat(client.getSender(), contact);
|
||||||
Platform.runLater(() -> userList.getItems().add(contact));
|
localDB.getChats().add(chat);
|
||||||
|
Platform.runLater(() -> userList.getItems().add(chat));
|
||||||
break;
|
break;
|
||||||
case REMOVE:
|
case REMOVE:
|
||||||
localDB.getUsers().remove(contact.getName());
|
localDB.getUsers().remove(contact.getName());
|
||||||
localDB.getChats().removeIf(c -> c.getRecipient().getID() == contact.getID());
|
localDB.getChats().removeIf(c -> c.getRecipient().getID() == contact.getID());
|
||||||
Platform.runLater(() -> userList.getItems().removeIf(c -> c.getID() == contact.getID()));
|
Platform.runLater(() -> userList.getItems().removeIf(c -> c.getRecipient().getID() == contact.getID()));
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
@ -181,7 +183,7 @@ public final class ChatScene implements Restorable {
|
|||||||
this.client = client;
|
this.client = client;
|
||||||
this.writeProxy = writeProxy;
|
this.writeProxy = writeProxy;
|
||||||
|
|
||||||
userList.setItems(FXCollections.observableList(localDB.getChats().stream().map(Chat::getRecipient).collect(Collectors.toList())));
|
userList.setItems(FXCollections.observableList(localDB.getChats().stream().collect(Collectors.toList())));
|
||||||
contactLabel.setText(localDB.getUser().getName());
|
contactLabel.setText(localDB.getUser().getName());
|
||||||
MessageControl.setUser(localDB.getUser());
|
MessageControl.setUser(localDB.getUser());
|
||||||
if (!client.isOnline()) updateInfoLabel("You are offline", "infoLabel-info");
|
if (!client.isOnline()) updateInfoLabel("You are offline", "infoLabel-info");
|
||||||
@ -199,7 +201,7 @@ public final class ChatScene implements Restorable {
|
|||||||
*/
|
*/
|
||||||
@FXML
|
@FXML
|
||||||
private void userListClicked() {
|
private void userListClicked() {
|
||||||
final Contact user = userList.getSelectionModel().getSelectedItem();
|
final Contact user = userList.getSelectionModel().getSelectedItem().getRecipient();
|
||||||
if (user != null && (currentChat == null || !user.equals(currentChat.getRecipient()))) {
|
if (user != null && (currentChat == null || !user.equals(currentChat.getRecipient()))) {
|
||||||
|
|
||||||
// LEON: JFC <===> JAVA FRIED CHICKEN <=/=> Java Foundation Classes
|
// LEON: JFC <===> JAVA FRIED CHICKEN <=/=> Java Foundation Classes
|
||||||
|
@ -1,5 +1,7 @@
|
|||||||
package envoy.client.ui.controller;
|
package envoy.client.ui.controller;
|
||||||
|
|
||||||
|
import java.util.ArrayList;
|
||||||
|
import java.util.List;
|
||||||
import java.util.logging.Level;
|
import java.util.logging.Level;
|
||||||
import java.util.logging.Logger;
|
import java.util.logging.Logger;
|
||||||
|
|
||||||
@ -10,12 +12,12 @@ import javafx.scene.control.Alert.AlertType;
|
|||||||
import javafx.scene.control.ButtonType;
|
import javafx.scene.control.ButtonType;
|
||||||
import javafx.scene.control.ListView;
|
import javafx.scene.control.ListView;
|
||||||
|
|
||||||
|
import envoy.client.data.Chat;
|
||||||
import envoy.client.data.LocalDB;
|
import envoy.client.data.LocalDB;
|
||||||
import envoy.client.event.SendEvent;
|
import envoy.client.event.SendEvent;
|
||||||
import envoy.client.ui.ClearableTextField;
|
import envoy.client.ui.ClearableTextField;
|
||||||
import envoy.client.ui.SceneContext;
|
import envoy.client.ui.SceneContext;
|
||||||
import envoy.client.ui.listcell.ContactListCellFactory;
|
import envoy.client.ui.listcell.ContactListCellFactory;
|
||||||
import envoy.data.Contact;
|
|
||||||
import envoy.event.ElementOperation;
|
import envoy.event.ElementOperation;
|
||||||
import envoy.event.EventBus;
|
import envoy.event.EventBus;
|
||||||
import envoy.event.contact.ContactOperation;
|
import envoy.event.contact.ContactOperation;
|
||||||
@ -37,7 +39,7 @@ public class ContactSearchScene {
|
|||||||
private ClearableTextField searchBar;
|
private ClearableTextField searchBar;
|
||||||
|
|
||||||
@FXML
|
@FXML
|
||||||
private ListView<Contact> contactList;
|
private ListView<Chat> contactList;
|
||||||
|
|
||||||
private SceneContext sceneContext;
|
private SceneContext sceneContext;
|
||||||
|
|
||||||
@ -61,7 +63,12 @@ public class ContactSearchScene {
|
|||||||
contactList.setCellFactory(ContactListCellFactory::new);
|
contactList.setCellFactory(ContactListCellFactory::new);
|
||||||
searchBar.setClearButtonListener(e -> { searchBar.getTextField().clear(); contactList.getItems().clear(); });
|
searchBar.setClearButtonListener(e -> { searchBar.getTextField().clear(); contactList.getItems().clear(); });
|
||||||
eventBus.register(ContactSearchResult.class,
|
eventBus.register(ContactSearchResult.class,
|
||||||
response -> Platform.runLater(() -> { contactList.getItems().clear(); contactList.getItems().addAll(response.get()); }));
|
response -> Platform.runLater(() -> {
|
||||||
|
List<Chat> chats = new ArrayList<Chat>();
|
||||||
|
response.get().stream().forEach(r -> chats.add(new Chat(r)));
|
||||||
|
contactList.getItems().clear();
|
||||||
|
contactList.getItems().addAll(chats);
|
||||||
|
}));
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -96,21 +103,21 @@ public class ContactSearchScene {
|
|||||||
*/
|
*/
|
||||||
@FXML
|
@FXML
|
||||||
private void contactListClicked() {
|
private void contactListClicked() {
|
||||||
final var contact = contactList.getSelectionModel().getSelectedItem();
|
final var chat = contactList.getSelectionModel().getSelectedItem();
|
||||||
if (contact != null) {
|
if (chat != null) {
|
||||||
final var alert = new Alert(AlertType.CONFIRMATION);
|
final var alert = new Alert(AlertType.CONFIRMATION);
|
||||||
alert.setTitle("Add Contact to Contact List");
|
alert.setTitle("Add Contact to Contact List");
|
||||||
alert.setHeaderText("Add the user " + contact.getName() + " to your contact list?");
|
alert.setHeaderText("Add the user " + chat.getRecipient().getName() + " to your contact list?");
|
||||||
// Normally, this would be total BS (we are already on the FX Thread), however
|
// Normally, this would be total BS (we are already on the FX Thread), however
|
||||||
// it could be proven that the creation of this dialog wrapped in
|
// it could be proven that the creation of this dialog wrapped in
|
||||||
// Platform.runLater is less error-prone than without it
|
// Platform.runLater is less error-prone than without it
|
||||||
Platform.runLater(() -> alert.showAndWait().filter(btn -> btn == ButtonType.OK).ifPresent(btn -> {
|
Platform.runLater(() -> alert.showAndWait().filter(btn -> btn == ButtonType.OK).ifPresent(btn -> {
|
||||||
final var event = new ContactOperation(contact, ElementOperation.ADD);
|
final var event = new ContactOperation(chat.getRecipient(), ElementOperation.ADD);
|
||||||
// Sends the event to the server
|
// Sends the event to the server
|
||||||
eventBus.dispatch(new SendEvent(event));
|
eventBus.dispatch(new SendEvent(event));
|
||||||
// Updates the UI
|
// Updates the UI
|
||||||
eventBus.dispatch(event);
|
eventBus.dispatch(event);
|
||||||
logger.log(Level.INFO, "Added contact " + contact);
|
logger.log(Level.INFO, "Added contact " + chat);
|
||||||
}));
|
}));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -7,12 +7,13 @@ import javafx.fxml.FXML;
|
|||||||
import javafx.scene.control.*;
|
import javafx.scene.control.*;
|
||||||
import javafx.scene.control.Alert.AlertType;
|
import javafx.scene.control.Alert.AlertType;
|
||||||
|
|
||||||
|
import envoy.client.data.Chat;
|
||||||
import envoy.client.data.LocalDB;
|
import envoy.client.data.LocalDB;
|
||||||
import envoy.client.event.SendEvent;
|
import envoy.client.event.SendEvent;
|
||||||
import envoy.client.ui.ClearableTextField;
|
import envoy.client.ui.ClearableTextField;
|
||||||
import envoy.client.ui.SceneContext;
|
import envoy.client.ui.SceneContext;
|
||||||
import envoy.client.ui.listcell.ContactListCellFactory;
|
import envoy.client.ui.listcell.ContactListCellFactory;
|
||||||
import envoy.data.Contact;
|
import envoy.data.Group;
|
||||||
import envoy.event.EventBus;
|
import envoy.event.EventBus;
|
||||||
import envoy.event.GroupCreation;
|
import envoy.event.GroupCreation;
|
||||||
import envoy.util.Bounds;
|
import envoy.util.Bounds;
|
||||||
@ -34,7 +35,7 @@ public class GroupCreationScene {
|
|||||||
private ClearableTextField groupNameField;
|
private ClearableTextField groupNameField;
|
||||||
|
|
||||||
@FXML
|
@FXML
|
||||||
private ListView<Contact> contactList;
|
private ListView<Chat> contactList;
|
||||||
|
|
||||||
private SceneContext sceneContext;
|
private SceneContext sceneContext;
|
||||||
|
|
||||||
@ -56,7 +57,11 @@ public class GroupCreationScene {
|
|||||||
public void initializeData(SceneContext sceneContext, LocalDB localDB) {
|
public void initializeData(SceneContext sceneContext, LocalDB localDB) {
|
||||||
this.sceneContext = sceneContext;
|
this.sceneContext = sceneContext;
|
||||||
Platform.runLater(() -> contactList.getItems()
|
Platform.runLater(() -> contactList.getItems()
|
||||||
.addAll(localDB.getUsers().values().stream().filter(c -> c.getID() != localDB.getUser().getID()).collect(Collectors.toList())));
|
.addAll(localDB.getChats()
|
||||||
|
.stream()
|
||||||
|
.filter(c -> !(c.getRecipient() instanceof Group))
|
||||||
|
.filter(c -> c.getRecipient().getID() != localDB.getUser().getID())
|
||||||
|
.collect(Collectors.toList())));
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -93,7 +98,7 @@ public class GroupCreationScene {
|
|||||||
groupNameField.getTextField().clear();
|
groupNameField.getTextField().clear();
|
||||||
} else {
|
} else {
|
||||||
eventBus.dispatch(new SendEvent(new GroupCreation(name,
|
eventBus.dispatch(new SendEvent(new GroupCreation(name,
|
||||||
contactList.getSelectionModel().getSelectedItems().stream().map(Contact::getID).collect(Collectors.toSet()))));
|
contactList.getSelectionModel().getSelectedItems().stream().map(c -> c.getRecipient().getID()).collect(Collectors.toSet()))));
|
||||||
new Alert(AlertType.INFORMATION, String.format("Group '%s' successfully created.", name)).showAndWait();
|
new Alert(AlertType.INFORMATION, String.format("Group '%s' successfully created.", name)).showAndWait();
|
||||||
sceneContext.pop();
|
sceneContext.pop();
|
||||||
}
|
}
|
||||||
|
@ -36,5 +36,8 @@ public class ContactControl extends VBox {
|
|||||||
getChildren().add(statusLabel);
|
getChildren().add(statusLabel);
|
||||||
} else // Member count
|
} else // Member count
|
||||||
getChildren().add(new Label(((Group) contact).getContacts().size() + " members"));
|
getChildren().add(new Label(((Group) contact).getContacts().size() + " members"));
|
||||||
|
|
||||||
|
final var unreadMessagesLabel = new Label("5");
|
||||||
|
getChildren().add(unreadMessagesLabel);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -3,7 +3,7 @@ package envoy.client.ui.listcell;
|
|||||||
import javafx.scene.control.ListCell;
|
import javafx.scene.control.ListCell;
|
||||||
import javafx.scene.control.ListView;
|
import javafx.scene.control.ListView;
|
||||||
|
|
||||||
import envoy.data.Contact;
|
import envoy.client.data.Chat;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Project: <strong>envoy-client</strong><br>
|
* Project: <strong>envoy-client</strong><br>
|
||||||
@ -13,15 +13,15 @@ import envoy.data.Contact;
|
|||||||
* @author Kai S. K. Engelbart
|
* @author Kai S. K. Engelbart
|
||||||
* @since Envoy Client v0.1-beta
|
* @since Envoy Client v0.1-beta
|
||||||
*/
|
*/
|
||||||
public class ContactListCellFactory extends ListCell<Contact> {
|
public class ContactListCellFactory extends ListCell<Chat> {
|
||||||
|
|
||||||
private final ListView<Contact> listView;
|
private final ListView<Chat> listView;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param listView the list view inside which this cell is contained
|
* @param listView the list view inside which this cell is contained
|
||||||
* @since Envoy Client v0.1-beta
|
* @since Envoy Client v0.1-beta
|
||||||
*/
|
*/
|
||||||
public ContactListCellFactory(ListView<Contact> listView) { this.listView = listView; }
|
public ContactListCellFactory(ListView<Chat> listView) { this.listView = listView; }
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Displays the name of a contact. If the contact is a user, their online status
|
* Displays the name of a contact. If the contact is a user, their online status
|
||||||
@ -30,13 +30,13 @@ public class ContactListCellFactory extends ListCell<Contact> {
|
|||||||
* @since Envoy Client v0.1-beta
|
* @since Envoy Client v0.1-beta
|
||||||
*/
|
*/
|
||||||
@Override
|
@Override
|
||||||
protected void updateItem(Contact contact, boolean empty) {
|
protected void updateItem(Chat chat, boolean empty) {
|
||||||
super.updateItem(contact, empty);
|
super.updateItem(chat, empty);
|
||||||
if (empty || contact == null) {
|
if (empty || chat.getRecipient() == null) {
|
||||||
setText(null);
|
setText(null);
|
||||||
setGraphic(null);
|
setGraphic(null);
|
||||||
} else {
|
} else {
|
||||||
final var control = new ContactControl(contact);
|
final var control = new ContactControl(chat.getRecipient());
|
||||||
prefWidthProperty().bind(listView.widthProperty().subtract(40));
|
prefWidthProperty().bind(listView.widthProperty().subtract(40));
|
||||||
setGraphic(control);
|
setGraphic(control);
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user