50 lines
1.4 KiB
Java
50 lines
1.4 KiB
Java
package org.mercury_im.messenger.data.repository;
|
|
|
|
import org.mercury_im.messenger.util.Optional;
|
|
import org.mercury_im.messenger.entity.Account;
|
|
import org.mercury_im.messenger.entity.contact.Peer;
|
|
|
|
import java.util.List;
|
|
|
|
import io.reactivex.Completable;
|
|
import io.reactivex.Maybe;
|
|
import io.reactivex.Observable;
|
|
import io.reactivex.Single;
|
|
|
|
public interface PeerRepository {
|
|
|
|
Single<Peer> insertPeer(Peer Peer);
|
|
|
|
default Observable<Optional<Peer>> observePeer(Peer peer) {
|
|
return observePeer(peer.getId());
|
|
}
|
|
|
|
Observable<Optional<Peer>> observePeer(long PeerId);
|
|
|
|
Maybe<Peer> getPeer(long PeerId);
|
|
|
|
default Observable<Optional<Peer>> observePeerByAddress(Account account, String address) {
|
|
return observePeerByAddress(account.getId(), address);
|
|
}
|
|
|
|
Observable<Optional<Peer>> observePeerByAddress(long accountId, String address);
|
|
|
|
default Maybe<Peer> getPeerByAddress(Account account, String address) {
|
|
return getPeerByAddress(account.getId(), address);
|
|
}
|
|
|
|
Maybe<Peer> getPeerByAddress(long accountId, String address);
|
|
|
|
Single<Peer> getOrCreatePeer(Account account, String address);
|
|
|
|
Single<Peer> getOrCreatePeer(long accountId, String address);
|
|
|
|
Observable<List<Peer>> observeAllPeers();
|
|
|
|
Single<Peer> updatePeer(Peer Peer);
|
|
|
|
Single<Peer> upsertPeer(Peer Peer);
|
|
|
|
Completable deletePeer(Peer Peer);
|
|
}
|