2018-10-20 14:42:03 +00:00
|
|
|
package eu.faircode.email;
|
|
|
|
|
2018-10-29 08:09:56 +00:00
|
|
|
/*
|
|
|
|
This file is part of FairEmail.
|
|
|
|
|
|
|
|
FairEmail is free software: you can redistribute it and/or modify
|
|
|
|
it under the terms of the GNU General Public License as published by
|
|
|
|
the Free Software Foundation, either version 3 of the License, or
|
|
|
|
(at your option) any later version.
|
|
|
|
|
2018-10-29 10:46:49 +00:00
|
|
|
FairEmail is distributed in the hope that it will be useful,
|
2018-10-29 08:09:56 +00:00
|
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
|
|
GNU General Public License for more details.
|
|
|
|
|
|
|
|
You should have received a copy of the GNU General Public License
|
2018-10-29 10:46:49 +00:00
|
|
|
along with FairEmail. If not, see <http://www.gnu.org/licenses/>.
|
2018-10-29 08:09:56 +00:00
|
|
|
|
2018-12-31 08:04:33 +00:00
|
|
|
Copyright 2018-2019 by Marcel Bokhorst (M66B)
|
2018-10-29 08:09:56 +00:00
|
|
|
*/
|
|
|
|
|
2019-01-12 10:45:57 +00:00
|
|
|
import java.util.HashMap;
|
|
|
|
import java.util.Map;
|
|
|
|
|
|
|
|
import androidx.lifecycle.Lifecycle;
|
|
|
|
import androidx.lifecycle.LifecycleObserver;
|
|
|
|
import androidx.lifecycle.LifecycleOwner;
|
|
|
|
import androidx.lifecycle.LiveData;
|
|
|
|
import androidx.lifecycle.Observer;
|
|
|
|
import androidx.lifecycle.OnLifecycleEvent;
|
2018-10-20 14:42:03 +00:00
|
|
|
import androidx.lifecycle.ViewModel;
|
|
|
|
import androidx.paging.PagedList;
|
|
|
|
|
|
|
|
public class ViewModelMessages extends ViewModel {
|
2019-01-12 10:45:57 +00:00
|
|
|
private Map<Boolean, LiveData<PagedList<TupleMessageEx>>> messages = new HashMap<>();
|
|
|
|
|
2019-01-14 07:21:48 +00:00
|
|
|
void setMessages(AdapterMessage.ViewType viewType, LifecycleOwner owner, final LiveData<PagedList<TupleMessageEx>> messages) {
|
|
|
|
final boolean thread = (viewType == AdapterMessage.ViewType.THREAD);
|
2019-01-12 10:45:57 +00:00
|
|
|
this.messages.put(thread, messages);
|
2019-01-14 07:21:48 +00:00
|
|
|
|
2019-01-31 08:57:28 +00:00
|
|
|
if (thread)
|
|
|
|
owner.getLifecycle().addObserver(new LifecycleObserver() {
|
|
|
|
@OnLifecycleEvent(Lifecycle.Event.ON_DESTROY)
|
|
|
|
public void onDestroyed() {
|
|
|
|
Log.i("Removed model thread");
|
|
|
|
ViewModelMessages.this.messages.remove(thread);
|
|
|
|
}
|
|
|
|
});
|
|
|
|
else {
|
|
|
|
// Keep list up-to-date for previous/next navigation
|
|
|
|
messages.observeForever(new Observer<PagedList<TupleMessageEx>>() {
|
|
|
|
@Override
|
|
|
|
public void onChanged(PagedList<TupleMessageEx> messages) {
|
|
|
|
}
|
|
|
|
});
|
|
|
|
}
|
2019-01-12 10:45:57 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
void observe(AdapterMessage.ViewType viewType, LifecycleOwner owner, Observer<PagedList<TupleMessageEx>> observer) {
|
2019-01-20 15:22:21 +00:00
|
|
|
if (owner.getLifecycle().getCurrentState().isAtLeast(Lifecycle.State.INITIALIZED)) {
|
2019-01-12 10:45:57 +00:00
|
|
|
final boolean thread = (viewType == AdapterMessage.ViewType.THREAD);
|
|
|
|
messages.get(thread).observe(owner, observer);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
void removeObservers(AdapterMessage.ViewType viewType, LifecycleOwner owner) {
|
2019-01-20 15:22:21 +00:00
|
|
|
if (owner.getLifecycle().getCurrentState().isAtLeast(Lifecycle.State.INITIALIZED)) {
|
2019-01-12 10:45:57 +00:00
|
|
|
boolean thread = (viewType == AdapterMessage.ViewType.THREAD);
|
|
|
|
LiveData<PagedList<TupleMessageEx>> list = messages.get(thread);
|
|
|
|
if (list != null)
|
|
|
|
list.removeObservers(owner);
|
|
|
|
}
|
|
|
|
}
|
2018-10-20 14:42:03 +00:00
|
|
|
|
2018-10-21 14:07:45 +00:00
|
|
|
@Override
|
|
|
|
protected void onCleared() {
|
2019-01-12 10:45:57 +00:00
|
|
|
messages.clear();
|
2018-10-21 14:07:45 +00:00
|
|
|
}
|
|
|
|
|
2019-01-30 19:05:01 +00:00
|
|
|
void observePrevNext(LifecycleOwner owner, final long id, final IPrevNext intf) {
|
2019-01-12 10:45:57 +00:00
|
|
|
LiveData<PagedList<TupleMessageEx>> list = messages.get(false);
|
2019-01-30 12:51:50 +00:00
|
|
|
if (list == null) {
|
|
|
|
Log.w("Observe previous/next without list");
|
2019-01-26 14:32:52 +00:00
|
|
|
return;
|
2019-01-30 12:51:50 +00:00
|
|
|
}
|
2019-01-26 11:56:23 +00:00
|
|
|
|
2019-01-30 19:05:01 +00:00
|
|
|
Log.i("Observe previous/next id=" + id);
|
2019-01-26 14:32:52 +00:00
|
|
|
list.observe(owner, new Observer<PagedList<TupleMessageEx>>() {
|
|
|
|
@Override
|
2019-01-30 12:51:50 +00:00
|
|
|
public void onChanged(PagedList<TupleMessageEx> messages) {
|
2019-01-30 19:05:01 +00:00
|
|
|
Log.i("Observe previous/next id=" + id + " messages=" + messages.size());
|
2019-01-30 12:51:50 +00:00
|
|
|
|
|
|
|
for (int pos = 0; pos < messages.size(); pos++) {
|
|
|
|
TupleMessageEx item = messages.get(pos);
|
2019-01-30 19:05:01 +00:00
|
|
|
if (item != null && id == item.id) {
|
2019-01-30 12:51:50 +00:00
|
|
|
boolean load = false;
|
|
|
|
|
2019-01-26 14:32:52 +00:00
|
|
|
if (pos - 1 >= 0) {
|
2019-01-30 12:51:50 +00:00
|
|
|
TupleMessageEx next = messages.get(pos - 1);
|
2019-01-26 14:32:52 +00:00
|
|
|
if (next == null)
|
|
|
|
load = true;
|
2019-02-02 12:58:28 +00:00
|
|
|
intf.onNext(true, next == null ? null : next.id);
|
2019-01-26 14:32:52 +00:00
|
|
|
} else
|
2019-02-02 12:58:28 +00:00
|
|
|
intf.onNext(false, null);
|
2019-01-26 14:32:52 +00:00
|
|
|
|
2019-01-30 12:51:50 +00:00
|
|
|
if (pos + 1 < messages.size()) {
|
|
|
|
TupleMessageEx prev = messages.get(pos + 1);
|
2019-01-26 14:32:52 +00:00
|
|
|
if (prev == null)
|
|
|
|
load = true;
|
2019-02-02 12:58:28 +00:00
|
|
|
intf.onPrevious(true, prev == null ? null : prev.id);
|
2019-01-26 14:32:52 +00:00
|
|
|
} else
|
2019-02-02 12:58:28 +00:00
|
|
|
intf.onPrevious(false, null);
|
|
|
|
|
|
|
|
intf.onFound(pos, messages.size());
|
2019-01-26 14:32:52 +00:00
|
|
|
|
|
|
|
if (load)
|
2019-01-30 12:51:50 +00:00
|
|
|
messages.loadAround(pos);
|
2019-01-26 14:32:52 +00:00
|
|
|
|
2019-01-30 12:51:50 +00:00
|
|
|
return;
|
2019-01-26 14:32:52 +00:00
|
|
|
}
|
|
|
|
}
|
2019-01-30 12:51:50 +00:00
|
|
|
|
2019-01-30 19:05:01 +00:00
|
|
|
Log.w("Observe previous/next gone id=" + id);
|
2019-01-26 14:32:52 +00:00
|
|
|
}
|
|
|
|
});
|
2018-10-20 19:04:05 +00:00
|
|
|
}
|
|
|
|
|
2019-01-26 14:32:52 +00:00
|
|
|
interface IPrevNext {
|
2019-01-29 10:08:22 +00:00
|
|
|
void onPrevious(boolean exists, Long id);
|
2019-01-26 14:32:52 +00:00
|
|
|
|
2019-01-29 10:08:22 +00:00
|
|
|
void onNext(boolean exists, Long id);
|
2019-02-02 12:58:28 +00:00
|
|
|
|
|
|
|
void onFound(int position, int size);
|
2018-10-20 14:42:03 +00:00
|
|
|
}
|
|
|
|
}
|