Mercury-IM/app/src/main/java/org/mercury_im/messenger/ui/chat/ChatViewModel.java

82 lines
2.8 KiB
Java
Raw Normal View History

2019-05-13 03:19:17 +02:00
package org.mercury_im.messenger.ui.chat;
2019-04-22 04:54:02 +02:00
2019-08-29 00:22:26 +02:00
import androidx.lifecycle.LiveData;
import androidx.lifecycle.MutableLiveData;
2019-05-18 10:06:16 +02:00
import androidx.lifecycle.ViewModel;
2019-04-22 04:54:02 +02:00
2019-05-04 00:27:02 +02:00
import org.jxmpp.jid.EntityBareJid;
2019-08-29 00:22:26 +02:00
import org.mercury_im.messenger.MercuryImApplication;
import org.mercury_im.messenger.persistence.model.ContactModel;
import org.mercury_im.messenger.persistence.model.MessageModel;
import org.mercury_im.messenger.persistence.repository.MessageRepository;
import org.mercury_im.messenger.persistence.repository.RosterRepository;
import java.util.List;
import javax.inject.Inject;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.CompositeDisposable;
import io.reactivex.functions.Consumer;
import io.reactivex.schedulers.Schedulers;
2019-05-04 00:27:02 +02:00
2019-04-22 04:54:02 +02:00
public class ChatViewModel extends ViewModel {
2019-05-04 00:27:02 +02:00
2019-08-29 00:22:26 +02:00
private final CompositeDisposable disposable = new CompositeDisposable();
@Inject
MessageRepository messageRepository;
@Inject
RosterRepository rosterRepository;
private MutableLiveData<ContactModel> contact = new MutableLiveData<>();
private MutableLiveData<List<MessageModel>> messages = new MutableLiveData<>();
private MutableLiveData<String> contactDisplayName = new MutableLiveData<>();
public ChatViewModel() {
super();
MercuryImApplication.getApplication().getAppComponent().inject(this);
}
public void init(long accountId, EntityBareJid jid) {
disposable.add(rosterRepository.getContact(accountId, jid)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe((Consumer<ContactModel>)
contactModel -> {
ChatViewModel.this.contact.setValue(contactModel);
String name = contactModel.getRosterName();
if (name == null) {
name = jid.getLocalpart().asUnescapedString();
}
contactDisplayName.setValue(name);
}));
disposable.add(messageRepository.getAllMessagesOfChat(accountId, jid)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe((Consumer<List<MessageModel>>)
messages -> ChatViewModel.this.messages.setValue(messages)));
}
@Override
protected void onCleared() {
super.onCleared();
disposable.clear();
}
2019-06-06 23:32:41 +02:00
2019-08-29 00:22:26 +02:00
public LiveData<List<MessageModel>> getMessages() {
return messages;
}
2019-05-04 00:27:02 +02:00
2019-08-29 00:22:26 +02:00
public LiveData<ContactModel> getContact() {
return contact;
2019-05-04 00:27:02 +02:00
}
2019-08-29 00:22:26 +02:00
public LiveData<String> getContactDisplayName() {
return contactDisplayName;
}
2019-04-22 04:54:02 +02:00
}