275 lines
12 KiB
Java
275 lines
12 KiB
Java
package com.discord.stores;
|
|
|
|
import android.content.Context;
|
|
import b.d.b.a.a;
|
|
import com.discord.api.guild.Guild;
|
|
import com.discord.models.domain.ModelInvite;
|
|
import com.discord.stores.updates.ObservationDeck;
|
|
import com.discord.stores.updates.ObservationDeckProvider;
|
|
import com.discord.utilities.error.Error;
|
|
import com.discord.utilities.rest.RestAPI;
|
|
import com.discord.utilities.rx.ObservableExtensionsKt;
|
|
import d0.t.h0;
|
|
import d0.z.d.m;
|
|
import j0.l.e.k;
|
|
import java.util.HashMap;
|
|
import java.util.LinkedHashMap;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
import kotlin.Unit;
|
|
import kotlin.jvm.functions.Function0;
|
|
import kotlin.jvm.functions.Function1;
|
|
import kotlin.jvm.internal.DefaultConstructorMarker;
|
|
import rx.Observable;
|
|
/* compiled from: StoreInstantInvites.kt */
|
|
public final class StoreInstantInvites extends StoreV2 {
|
|
private final Dispatcher dispatcher;
|
|
private final Map<Long, Map<String, ModelInvite>> invites;
|
|
private Map<Long, ? extends Map<String, ? extends ModelInvite>> invitesSnapshot;
|
|
private final Map<String, InviteState> knownInvites;
|
|
private Map<String, ? extends InviteState> knownInvitesSnapshot;
|
|
private final ObservationDeck observationDeck;
|
|
private final RestAPI restAPI;
|
|
|
|
/* compiled from: StoreInstantInvites.kt */
|
|
public static abstract class InviteState {
|
|
|
|
/* compiled from: StoreInstantInvites.kt */
|
|
public static final class Invalid extends InviteState {
|
|
public static final Invalid INSTANCE = new Invalid();
|
|
|
|
private Invalid() {
|
|
super(null);
|
|
}
|
|
}
|
|
|
|
/* compiled from: StoreInstantInvites.kt */
|
|
public static final class LoadFailed extends InviteState {
|
|
public static final LoadFailed INSTANCE = new LoadFailed();
|
|
|
|
private LoadFailed() {
|
|
super(null);
|
|
}
|
|
}
|
|
|
|
/* compiled from: StoreInstantInvites.kt */
|
|
public static final class Loading extends InviteState {
|
|
public static final Loading INSTANCE = new Loading();
|
|
|
|
private Loading() {
|
|
super(null);
|
|
}
|
|
}
|
|
|
|
/* compiled from: StoreInstantInvites.kt */
|
|
public static final class Resolved extends InviteState {
|
|
private final ModelInvite invite;
|
|
|
|
/* JADX INFO: super call moved to the top of the method (can break code semantics) */
|
|
public Resolved(ModelInvite modelInvite) {
|
|
super(null);
|
|
m.checkNotNullParameter(modelInvite, "invite");
|
|
this.invite = modelInvite;
|
|
}
|
|
|
|
public static /* synthetic */ Resolved copy$default(Resolved resolved, ModelInvite modelInvite, int i, Object obj) {
|
|
if ((i & 1) != 0) {
|
|
modelInvite = resolved.invite;
|
|
}
|
|
return resolved.copy(modelInvite);
|
|
}
|
|
|
|
public final ModelInvite component1() {
|
|
return this.invite;
|
|
}
|
|
|
|
public final Resolved copy(ModelInvite modelInvite) {
|
|
m.checkNotNullParameter(modelInvite, "invite");
|
|
return new Resolved(modelInvite);
|
|
}
|
|
|
|
public boolean equals(Object obj) {
|
|
if (this != obj) {
|
|
return (obj instanceof Resolved) && m.areEqual(this.invite, ((Resolved) obj).invite);
|
|
}
|
|
return true;
|
|
}
|
|
|
|
public final ModelInvite getInvite() {
|
|
return this.invite;
|
|
}
|
|
|
|
public int hashCode() {
|
|
ModelInvite modelInvite = this.invite;
|
|
if (modelInvite != null) {
|
|
return modelInvite.hashCode();
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
public String toString() {
|
|
StringBuilder R = a.R("Resolved(invite=");
|
|
R.append(this.invite);
|
|
R.append(")");
|
|
return R.toString();
|
|
}
|
|
}
|
|
|
|
private InviteState() {
|
|
}
|
|
|
|
public /* synthetic */ InviteState(DefaultConstructorMarker defaultConstructorMarker) {
|
|
this();
|
|
}
|
|
}
|
|
|
|
public final /* synthetic */ class WhenMappings {
|
|
public static final /* synthetic */ int[] $EnumSwitchMapping$0;
|
|
|
|
static {
|
|
Error.Type.values();
|
|
int[] iArr = new int[17];
|
|
$EnumSwitchMapping$0 = iArr;
|
|
iArr[Error.Type.DISCORD_REQUEST_ERROR.ordinal()] = 1;
|
|
iArr[Error.Type.NETWORK.ordinal()] = 2;
|
|
}
|
|
}
|
|
|
|
public StoreInstantInvites(Dispatcher dispatcher, ObservationDeck observationDeck, RestAPI restAPI) {
|
|
m.checkNotNullParameter(dispatcher, "dispatcher");
|
|
m.checkNotNullParameter(observationDeck, "observationDeck");
|
|
m.checkNotNullParameter(restAPI, "restAPI");
|
|
this.dispatcher = dispatcher;
|
|
this.observationDeck = observationDeck;
|
|
this.restAPI = restAPI;
|
|
this.invites = new LinkedHashMap();
|
|
this.invitesSnapshot = h0.emptyMap();
|
|
this.knownInvites = new LinkedHashMap();
|
|
this.knownInvitesSnapshot = h0.emptyMap();
|
|
}
|
|
|
|
/* JADX INFO: this call moved to the top of the method (can break code semantics) */
|
|
public /* synthetic */ StoreInstantInvites(Dispatcher dispatcher, ObservationDeck observationDeck, RestAPI restAPI, int i, DefaultConstructorMarker defaultConstructorMarker) {
|
|
this(dispatcher, (i & 2) != 0 ? ObservationDeckProvider.get() : observationDeck, (i & 4) != 0 ? RestAPI.Companion.getApi() : restAPI);
|
|
}
|
|
|
|
public static final /* synthetic */ Dispatcher access$getDispatcher$p(StoreInstantInvites storeInstantInvites) {
|
|
return storeInstantInvites.dispatcher;
|
|
}
|
|
|
|
public static final /* synthetic */ Map access$getInvites$p(StoreInstantInvites storeInstantInvites) {
|
|
return storeInstantInvites.invites;
|
|
}
|
|
|
|
public static final /* synthetic */ Map access$getKnownInvites(StoreInstantInvites storeInstantInvites) {
|
|
return storeInstantInvites.getKnownInvites();
|
|
}
|
|
|
|
public static final /* synthetic */ Map access$getKnownInvites$p(StoreInstantInvites storeInstantInvites) {
|
|
return storeInstantInvites.knownInvites;
|
|
}
|
|
|
|
public static final /* synthetic */ RestAPI access$getRestAPI$p(StoreInstantInvites storeInstantInvites) {
|
|
return storeInstantInvites.restAPI;
|
|
}
|
|
|
|
public static final /* synthetic */ void access$onLoadedInvites(StoreInstantInvites storeInstantInvites, List list) {
|
|
storeInstantInvites.onLoadedInvites(list);
|
|
}
|
|
|
|
public static final /* synthetic */ void access$setChatInvites(StoreInstantInvites storeInstantInvites, String str, InviteState inviteState) {
|
|
storeInstantInvites.setChatInvites(str, inviteState);
|
|
}
|
|
|
|
public static /* synthetic */ void fetchInviteIfNotLoaded$default(StoreInstantInvites storeInstantInvites, String str, Long l, String str2, Boolean bool, Function0 function0, int i, Object obj) {
|
|
storeInstantInvites.fetchInviteIfNotLoaded(str, (i & 2) != 0 ? null : l, (i & 4) != 0 ? null : str2, (i & 8) != 0 ? null : bool, (i & 16) != 0 ? null : function0);
|
|
}
|
|
|
|
/* JADX DEBUG: Type inference failed for r0v0. Raw type applied. Possible types: java.util.Map<java.lang.Long, ? extends java.util.Map<java.lang.String, ? extends com.discord.models.domain.ModelInvite>>, java.util.Map<java.lang.Long, java.util.Map<java.lang.String, com.discord.models.domain.ModelInvite>> */
|
|
private final Map<Long, Map<String, ModelInvite>> getInvites() {
|
|
return this.invitesSnapshot;
|
|
}
|
|
|
|
/* JADX DEBUG: Type inference failed for r0v0. Raw type applied. Possible types: java.util.Map<java.lang.String, ? extends com.discord.stores.StoreInstantInvites$InviteState>, java.util.Map<java.lang.String, com.discord.stores.StoreInstantInvites$InviteState> */
|
|
private final Map<String, InviteState> getKnownInvites() {
|
|
return this.knownInvitesSnapshot;
|
|
}
|
|
|
|
@StoreThread
|
|
private final void onLoadedInvites(List<? extends ModelInvite> list) {
|
|
this.invites.clear();
|
|
for (ModelInvite modelInvite : list) {
|
|
Guild guild = modelInvite.guild;
|
|
Long valueOf = guild != null ? Long.valueOf(guild.r()) : null;
|
|
if (valueOf != null) {
|
|
Map<String, ModelInvite> map = this.invites.get(valueOf);
|
|
if (map == null) {
|
|
map = new LinkedHashMap<>();
|
|
}
|
|
String str = modelInvite.code;
|
|
m.checkNotNullExpressionValue(str, "invite.code");
|
|
map.put(str, modelInvite);
|
|
this.invites.put(valueOf, map);
|
|
}
|
|
}
|
|
markChanged();
|
|
}
|
|
|
|
@StoreThread
|
|
private final void setChatInvites(String str, InviteState inviteState) {
|
|
this.knownInvites.put(str, inviteState);
|
|
markChanged();
|
|
}
|
|
|
|
public final void clearInvites(long j) {
|
|
this.dispatcher.schedule(new StoreInstantInvites$clearInvites$1(this, j));
|
|
}
|
|
|
|
public final void fetchGuildInvites(long j) {
|
|
ObservableExtensionsKt.appSubscribe$default(ObservableExtensionsKt.restSubscribeOn$default(this.restAPI.getGuildInvites(j), false, 1, null), StoreInstantInvites.class, (Context) null, (Function1) null, (Function1) null, (Function0) null, (Function0) null, new StoreInstantInvites$fetchGuildInvites$1(this), 62, (Object) null);
|
|
}
|
|
|
|
public final void fetchInviteIfNotLoaded(String str, Long l, String str2, Boolean bool, Function0<Unit> function0) {
|
|
m.checkNotNullParameter(str, "inviteCode");
|
|
this.dispatcher.schedule(new StoreInstantInvites$fetchInviteIfNotLoaded$1(this, ModelInvite.getInviteStoreKey(str, l), str, l, bool, str2, function0));
|
|
}
|
|
|
|
public final Map<String, ModelInvite> getInvites(long j) {
|
|
Map<String, ModelInvite> map = getInvites().get(Long.valueOf(j));
|
|
return map != null ? map : h0.emptyMap();
|
|
}
|
|
|
|
public final Observable<InviteState> observeInvite(String str) {
|
|
if (str == null) {
|
|
k kVar = new k(InviteState.LoadFailed.INSTANCE);
|
|
m.checkNotNullExpressionValue(kVar, "Observable.just(InviteState.LoadFailed)");
|
|
return kVar;
|
|
}
|
|
Observable<InviteState> q = ObservationDeck.connectRx$default(this.observationDeck, new ObservationDeck.UpdateSource[]{this}, false, null, null, new StoreInstantInvites$observeInvite$1(this), 14, null).F(new StoreInstantInvites$observeInvite$2(str)).q();
|
|
m.checkNotNullExpressionValue(q, "observationDeck.connectR… .distinctUntilChanged()");
|
|
return q;
|
|
}
|
|
|
|
public final Observable<Map<String, InviteState>> observeKnownInvites() {
|
|
Observable<Map<String, InviteState>> q = ObservationDeck.connectRx$default(this.observationDeck, new ObservationDeck.UpdateSource[]{this}, false, null, null, new StoreInstantInvites$observeKnownInvites$1(this), 14, null).q();
|
|
m.checkNotNullExpressionValue(q, "observationDeck.connectR… }.distinctUntilChanged()");
|
|
return q;
|
|
}
|
|
|
|
public final void onInviteRemoved(ModelInvite modelInvite) {
|
|
m.checkNotNullParameter(modelInvite, "invite");
|
|
this.dispatcher.schedule(new StoreInstantInvites$onInviteRemoved$1(this, modelInvite));
|
|
}
|
|
|
|
@Override // com.discord.stores.StoreV2
|
|
public void snapshotData() {
|
|
super.snapshotData();
|
|
LinkedHashMap linkedHashMap = new LinkedHashMap();
|
|
for (Map.Entry<Long, Map<String, ModelInvite>> entry : this.invites.entrySet()) {
|
|
linkedHashMap.put(Long.valueOf(entry.getKey().longValue()), new HashMap(entry.getValue()));
|
|
}
|
|
this.invitesSnapshot = linkedHashMap;
|
|
this.knownInvitesSnapshot = new HashMap(this.knownInvites);
|
|
}
|
|
}
|