361 lines
17 KiB
Java
361 lines
17 KiB
Java
package com.discord.stores;
|
|
|
|
import android.content.Context;
|
|
import c.d.b.a.a;
|
|
import com.discord.api.guildrolesubscription.GuildRoleSubscriptionGroupListing;
|
|
import com.discord.api.guildrolesubscription.GuildRoleSubscriptionTierListing;
|
|
import com.discord.api.premium.PriceTierType;
|
|
import com.discord.utilities.rest.RestAPI;
|
|
import com.discord.utilities.rx.ObservableExtensionsKt;
|
|
import d0.t.h0;
|
|
import d0.t.n;
|
|
import d0.z.d.m;
|
|
import java.util.ArrayList;
|
|
import java.util.HashMap;
|
|
import java.util.LinkedHashMap;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
import kotlin.jvm.functions.Function0;
|
|
import kotlin.jvm.functions.Function1;
|
|
import kotlin.jvm.internal.DefaultConstructorMarker;
|
|
/* compiled from: StoreGuildRoleSubscriptions.kt */
|
|
public final class StoreGuildRoleSubscriptions extends StoreV2 {
|
|
private final Dispatcher dispatcher;
|
|
private final Map<Long, GuildRoleSubscriptionGroupState> guildRoleSubscriptionGroups;
|
|
private Map<Long, ? extends GuildRoleSubscriptionGroupState> guildRoleSubscriptionGroupsSnapshot;
|
|
private final Map<Long, Map<Long, GuildRoleSubscriptionTierListing>> guildRoleSubscriptionTiers;
|
|
private Map<Long, ? extends Map<Long, GuildRoleSubscriptionTierListing>> guildRoleSubscriptionTiersSnapshot;
|
|
private PriceTierState priceTierState;
|
|
private PriceTierState priceTierStateSnapshot;
|
|
private final RestAPI restAPI;
|
|
|
|
/* compiled from: StoreGuildRoleSubscriptions.kt */
|
|
public static abstract class GuildRoleSubscriptionGroupState {
|
|
|
|
/* compiled from: StoreGuildRoleSubscriptions.kt */
|
|
public static final class Failed extends GuildRoleSubscriptionGroupState {
|
|
private final String errorMessage;
|
|
|
|
public Failed() {
|
|
this(null, 1, null);
|
|
}
|
|
|
|
public Failed(String str) {
|
|
super(null);
|
|
this.errorMessage = str;
|
|
}
|
|
|
|
/* JADX INFO: this call moved to the top of the method (can break code semantics) */
|
|
public /* synthetic */ Failed(String str, int i, DefaultConstructorMarker defaultConstructorMarker) {
|
|
this((i & 1) != 0 ? null : str);
|
|
}
|
|
|
|
public final String getErrorMessage() {
|
|
return this.errorMessage;
|
|
}
|
|
}
|
|
|
|
/* compiled from: StoreGuildRoleSubscriptions.kt */
|
|
public static final class Loaded extends GuildRoleSubscriptionGroupState {
|
|
private final GuildRoleSubscriptionGroupListing guildRoleSubscriptionGroupListing;
|
|
|
|
public Loaded(GuildRoleSubscriptionGroupListing guildRoleSubscriptionGroupListing) {
|
|
super(null);
|
|
this.guildRoleSubscriptionGroupListing = guildRoleSubscriptionGroupListing;
|
|
}
|
|
|
|
public static /* synthetic */ Loaded copy$default(Loaded loaded, GuildRoleSubscriptionGroupListing guildRoleSubscriptionGroupListing, int i, Object obj) {
|
|
if ((i & 1) != 0) {
|
|
guildRoleSubscriptionGroupListing = loaded.guildRoleSubscriptionGroupListing;
|
|
}
|
|
return loaded.copy(guildRoleSubscriptionGroupListing);
|
|
}
|
|
|
|
public final GuildRoleSubscriptionGroupListing component1() {
|
|
return this.guildRoleSubscriptionGroupListing;
|
|
}
|
|
|
|
public final Loaded copy(GuildRoleSubscriptionGroupListing guildRoleSubscriptionGroupListing) {
|
|
return new Loaded(guildRoleSubscriptionGroupListing);
|
|
}
|
|
|
|
public boolean equals(Object obj) {
|
|
if (this != obj) {
|
|
return (obj instanceof Loaded) && m.areEqual(this.guildRoleSubscriptionGroupListing, ((Loaded) obj).guildRoleSubscriptionGroupListing);
|
|
}
|
|
return true;
|
|
}
|
|
|
|
public final GuildRoleSubscriptionGroupListing getGuildRoleSubscriptionGroupListing() {
|
|
return this.guildRoleSubscriptionGroupListing;
|
|
}
|
|
|
|
public int hashCode() {
|
|
GuildRoleSubscriptionGroupListing guildRoleSubscriptionGroupListing = this.guildRoleSubscriptionGroupListing;
|
|
if (guildRoleSubscriptionGroupListing != null) {
|
|
return guildRoleSubscriptionGroupListing.hashCode();
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
public String toString() {
|
|
StringBuilder P = a.P("Loaded(guildRoleSubscriptionGroupListing=");
|
|
P.append(this.guildRoleSubscriptionGroupListing);
|
|
P.append(")");
|
|
return P.toString();
|
|
}
|
|
}
|
|
|
|
/* compiled from: StoreGuildRoleSubscriptions.kt */
|
|
public static final class Loading extends GuildRoleSubscriptionGroupState {
|
|
public static final Loading INSTANCE = new Loading();
|
|
|
|
private Loading() {
|
|
super(null);
|
|
}
|
|
}
|
|
|
|
private GuildRoleSubscriptionGroupState() {
|
|
}
|
|
|
|
public /* synthetic */ GuildRoleSubscriptionGroupState(DefaultConstructorMarker defaultConstructorMarker) {
|
|
this();
|
|
}
|
|
}
|
|
|
|
/* compiled from: StoreGuildRoleSubscriptions.kt */
|
|
public static abstract class PriceTierState {
|
|
|
|
/* compiled from: StoreGuildRoleSubscriptions.kt */
|
|
public static final class Failed extends PriceTierState {
|
|
private final String errorMessage;
|
|
|
|
public Failed() {
|
|
this(null, 1, null);
|
|
}
|
|
|
|
public Failed(String str) {
|
|
super(null);
|
|
this.errorMessage = str;
|
|
}
|
|
|
|
/* JADX INFO: this call moved to the top of the method (can break code semantics) */
|
|
public /* synthetic */ Failed(String str, int i, DefaultConstructorMarker defaultConstructorMarker) {
|
|
this((i & 1) != 0 ? null : str);
|
|
}
|
|
|
|
public final String getErrorMessage() {
|
|
return this.errorMessage;
|
|
}
|
|
}
|
|
|
|
/* compiled from: StoreGuildRoleSubscriptions.kt */
|
|
public static final class Loaded extends PriceTierState {
|
|
private final List<Integer> priceTiers;
|
|
|
|
/* JADX INFO: super call moved to the top of the method (can break code semantics) */
|
|
public Loaded(List<Integer> list) {
|
|
super(null);
|
|
m.checkNotNullParameter(list, "priceTiers");
|
|
this.priceTiers = list;
|
|
}
|
|
|
|
/* JADX DEBUG: Multi-variable search result rejected for r0v0, resolved type: com.discord.stores.StoreGuildRoleSubscriptions$PriceTierState$Loaded */
|
|
/* JADX WARN: Multi-variable type inference failed */
|
|
public static /* synthetic */ Loaded copy$default(Loaded loaded, List list, int i, Object obj) {
|
|
if ((i & 1) != 0) {
|
|
list = loaded.priceTiers;
|
|
}
|
|
return loaded.copy(list);
|
|
}
|
|
|
|
public final List<Integer> component1() {
|
|
return this.priceTiers;
|
|
}
|
|
|
|
public final Loaded copy(List<Integer> list) {
|
|
m.checkNotNullParameter(list, "priceTiers");
|
|
return new Loaded(list);
|
|
}
|
|
|
|
public boolean equals(Object obj) {
|
|
if (this != obj) {
|
|
return (obj instanceof Loaded) && m.areEqual(this.priceTiers, ((Loaded) obj).priceTiers);
|
|
}
|
|
return true;
|
|
}
|
|
|
|
public final List<Integer> getPriceTiers() {
|
|
return this.priceTiers;
|
|
}
|
|
|
|
public int hashCode() {
|
|
List<Integer> list = this.priceTiers;
|
|
if (list != null) {
|
|
return list.hashCode();
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
public String toString() {
|
|
return a.J(a.P("Loaded(priceTiers="), this.priceTiers, ")");
|
|
}
|
|
}
|
|
|
|
/* compiled from: StoreGuildRoleSubscriptions.kt */
|
|
public static final class Loading extends PriceTierState {
|
|
public static final Loading INSTANCE = new Loading();
|
|
|
|
private Loading() {
|
|
super(null);
|
|
}
|
|
}
|
|
|
|
/* compiled from: StoreGuildRoleSubscriptions.kt */
|
|
public static final class Uninitialized extends PriceTierState {
|
|
public static final Uninitialized INSTANCE = new Uninitialized();
|
|
|
|
private Uninitialized() {
|
|
super(null);
|
|
}
|
|
}
|
|
|
|
private PriceTierState() {
|
|
}
|
|
|
|
public /* synthetic */ PriceTierState(DefaultConstructorMarker defaultConstructorMarker) {
|
|
this();
|
|
}
|
|
}
|
|
|
|
public StoreGuildRoleSubscriptions(Dispatcher dispatcher, RestAPI restAPI) {
|
|
m.checkNotNullParameter(dispatcher, "dispatcher");
|
|
m.checkNotNullParameter(restAPI, "restAPI");
|
|
this.dispatcher = dispatcher;
|
|
this.restAPI = restAPI;
|
|
PriceTierState.Uninitialized uninitialized = PriceTierState.Uninitialized.INSTANCE;
|
|
this.priceTierState = uninitialized;
|
|
this.priceTierStateSnapshot = uninitialized;
|
|
this.guildRoleSubscriptionGroups = new LinkedHashMap();
|
|
this.guildRoleSubscriptionGroupsSnapshot = h0.emptyMap();
|
|
this.guildRoleSubscriptionTiers = new LinkedHashMap();
|
|
this.guildRoleSubscriptionTiersSnapshot = h0.emptyMap();
|
|
}
|
|
|
|
/* JADX INFO: this call moved to the top of the method (can break code semantics) */
|
|
public /* synthetic */ StoreGuildRoleSubscriptions(Dispatcher dispatcher, RestAPI restAPI, int i, DefaultConstructorMarker defaultConstructorMarker) {
|
|
this(dispatcher, (i & 2) != 0 ? RestAPI.Companion.getApi() : restAPI);
|
|
}
|
|
|
|
public static final /* synthetic */ Dispatcher access$getDispatcher$p(StoreGuildRoleSubscriptions storeGuildRoleSubscriptions) {
|
|
return storeGuildRoleSubscriptions.dispatcher;
|
|
}
|
|
|
|
public static final /* synthetic */ Map access$getGuildRoleSubscriptionGroups$p(StoreGuildRoleSubscriptions storeGuildRoleSubscriptions) {
|
|
return storeGuildRoleSubscriptions.guildRoleSubscriptionGroups;
|
|
}
|
|
|
|
public static final /* synthetic */ Map access$getGuildRoleSubscriptionTiers$p(StoreGuildRoleSubscriptions storeGuildRoleSubscriptions) {
|
|
return storeGuildRoleSubscriptions.guildRoleSubscriptionTiers;
|
|
}
|
|
|
|
public static final /* synthetic */ PriceTierState access$getPriceTierState$p(StoreGuildRoleSubscriptions storeGuildRoleSubscriptions) {
|
|
return storeGuildRoleSubscriptions.priceTierState;
|
|
}
|
|
|
|
public static final /* synthetic */ void access$handleGuildRoleSubscriptionGroupFetch(StoreGuildRoleSubscriptions storeGuildRoleSubscriptions, long j, GuildRoleSubscriptionGroupListing guildRoleSubscriptionGroupListing) {
|
|
storeGuildRoleSubscriptions.handleGuildRoleSubscriptionGroupFetch(j, guildRoleSubscriptionGroupListing);
|
|
}
|
|
|
|
public static final /* synthetic */ void access$setPriceTierState$p(StoreGuildRoleSubscriptions storeGuildRoleSubscriptions, PriceTierState priceTierState) {
|
|
storeGuildRoleSubscriptions.priceTierState = priceTierState;
|
|
}
|
|
|
|
private final void handleGuildRoleSubscriptionGroupFetch(long j, GuildRoleSubscriptionGroupListing guildRoleSubscriptionGroupListing) {
|
|
this.dispatcher.schedule(new StoreGuildRoleSubscriptions$handleGuildRoleSubscriptionGroupFetch$1(this, guildRoleSubscriptionGroupListing, j));
|
|
}
|
|
|
|
public final void fetchGuildRoleSubscriptionGroup(long j, long j2) {
|
|
if (!(((GuildRoleSubscriptionGroupState) this.guildRoleSubscriptionGroupsSnapshot.get(Long.valueOf(j))) instanceof GuildRoleSubscriptionGroupState.Loading)) {
|
|
this.dispatcher.schedule(new StoreGuildRoleSubscriptions$fetchGuildRoleSubscriptionGroup$1(this, j));
|
|
ObservableExtensionsKt.appSubscribe$default(ObservableExtensionsKt.restSubscribeOn$default(this.restAPI.getGuildRoleSubscriptionGroupListing(j, j2), false, 1, null), StoreGuildRoleSubscriptions.class, (Context) null, (Function1) null, new StoreGuildRoleSubscriptions$fetchGuildRoleSubscriptionGroup$3(this, j), (Function0) null, (Function0) null, new StoreGuildRoleSubscriptions$fetchGuildRoleSubscriptionGroup$2(this, j), 54, (Object) null);
|
|
}
|
|
}
|
|
|
|
public final void fetchGuildRoleSubscriptionGroupsForGuild(long j) {
|
|
if (!(((GuildRoleSubscriptionGroupState) this.guildRoleSubscriptionGroupsSnapshot.get(Long.valueOf(j))) instanceof GuildRoleSubscriptionGroupState.Loading)) {
|
|
this.dispatcher.schedule(new StoreGuildRoleSubscriptions$fetchGuildRoleSubscriptionGroupsForGuild$1(this, j));
|
|
ObservableExtensionsKt.appSubscribe$default(ObservableExtensionsKt.restSubscribeOn$default(this.restAPI.getGuildRoleSubscriptionGroupListings(j), false, 1, null), StoreGuildRoleSubscriptions.class, (Context) null, (Function1) null, new StoreGuildRoleSubscriptions$fetchGuildRoleSubscriptionGroupsForGuild$3(this, j), (Function0) null, (Function0) null, new StoreGuildRoleSubscriptions$fetchGuildRoleSubscriptionGroupsForGuild$2(this, j), 54, (Object) null);
|
|
}
|
|
}
|
|
|
|
public final void fetchPriceTiersIfNonExisting() {
|
|
PriceTierState priceTierState = this.priceTierState;
|
|
if (!(priceTierState instanceof PriceTierState.Loading) && !(priceTierState instanceof PriceTierState.Loaded)) {
|
|
this.dispatcher.schedule(new StoreGuildRoleSubscriptions$fetchPriceTiersIfNonExisting$1(this));
|
|
ObservableExtensionsKt.appSubscribe$default(ObservableExtensionsKt.restSubscribeOn$default(this.restAPI.getPriceTiers(PriceTierType.GUILD_ROLE_SUBSCRIPTIONS.getApiValue()), false, 1, null), StoreGuildRoleSubscriptions.class, (Context) null, (Function1) null, new StoreGuildRoleSubscriptions$fetchPriceTiersIfNonExisting$3(this), (Function0) null, (Function0) null, new StoreGuildRoleSubscriptions$fetchPriceTiersIfNonExisting$2(this), 54, (Object) null);
|
|
}
|
|
}
|
|
|
|
public final GuildRoleSubscriptionGroupState getGuildRoleSubscriptionState(long j) {
|
|
ArrayList arrayList;
|
|
List<Long> f;
|
|
GuildRoleSubscriptionGroupState guildRoleSubscriptionGroupState = (GuildRoleSubscriptionGroupState) this.guildRoleSubscriptionGroupsSnapshot.get(Long.valueOf(j));
|
|
GuildRoleSubscriptionGroupListing guildRoleSubscriptionGroupListing = null;
|
|
if (guildRoleSubscriptionGroupState == null) {
|
|
return null;
|
|
}
|
|
if (!(guildRoleSubscriptionGroupState instanceof GuildRoleSubscriptionGroupState.Loaded)) {
|
|
return guildRoleSubscriptionGroupState;
|
|
}
|
|
GuildRoleSubscriptionGroupListing guildRoleSubscriptionGroupListing2 = ((GuildRoleSubscriptionGroupState.Loaded) guildRoleSubscriptionGroupState).getGuildRoleSubscriptionGroupListing();
|
|
if (guildRoleSubscriptionGroupListing2 == null || (f = guildRoleSubscriptionGroupListing2.f()) == null) {
|
|
arrayList = n.emptyList();
|
|
} else {
|
|
ArrayList arrayList2 = new ArrayList();
|
|
for (Number number : f) {
|
|
long longValue = number.longValue();
|
|
Map map = (Map) this.guildRoleSubscriptionTiersSnapshot.get(Long.valueOf(j));
|
|
GuildRoleSubscriptionTierListing guildRoleSubscriptionTierListing = map != null ? (GuildRoleSubscriptionTierListing) map.get(Long.valueOf(longValue)) : null;
|
|
if (guildRoleSubscriptionTierListing != null) {
|
|
arrayList2.add(guildRoleSubscriptionTierListing);
|
|
}
|
|
}
|
|
arrayList = arrayList2;
|
|
}
|
|
if (guildRoleSubscriptionGroupListing2 != null) {
|
|
guildRoleSubscriptionGroupListing = GuildRoleSubscriptionGroupListing.a(guildRoleSubscriptionGroupListing2, 0, 0, 0, 0, null, null, arrayList, 63);
|
|
}
|
|
return new GuildRoleSubscriptionGroupState.Loaded(guildRoleSubscriptionGroupListing);
|
|
}
|
|
|
|
public final PriceTierState getPriceTiersState() {
|
|
return this.priceTierStateSnapshot;
|
|
}
|
|
|
|
public final void handleGuildRoleSubscriptionGroupUpdate(long j, GuildRoleSubscriptionGroupListing guildRoleSubscriptionGroupListing) {
|
|
m.checkNotNullParameter(guildRoleSubscriptionGroupListing, "guildRoleSubscriptionGroupListing");
|
|
this.dispatcher.schedule(new StoreGuildRoleSubscriptions$handleGuildRoleSubscriptionGroupUpdate$1(this, j, guildRoleSubscriptionGroupListing));
|
|
}
|
|
|
|
public final void handleGuildRoleSubscriptionTierListingCreate(long j, long j2, GuildRoleSubscriptionTierListing guildRoleSubscriptionTierListing) {
|
|
m.checkNotNullParameter(guildRoleSubscriptionTierListing, "guildRoleSubscriptionTierListing");
|
|
handleGuildRoleSubscriptionTierListingUpdate(j, guildRoleSubscriptionTierListing);
|
|
fetchGuildRoleSubscriptionGroup(j, j2);
|
|
}
|
|
|
|
public final void handleGuildRoleSubscriptionTierListingUpdate(long j, GuildRoleSubscriptionTierListing guildRoleSubscriptionTierListing) {
|
|
m.checkNotNullParameter(guildRoleSubscriptionTierListing, "guildRoleSubscriptionTierListing");
|
|
this.dispatcher.schedule(new StoreGuildRoleSubscriptions$handleGuildRoleSubscriptionTierListingUpdate$1(this, j, guildRoleSubscriptionTierListing));
|
|
}
|
|
|
|
@Override // com.discord.stores.StoreV2
|
|
@StoreThread
|
|
public void snapshotData() {
|
|
super.snapshotData();
|
|
this.priceTierStateSnapshot = this.priceTierState;
|
|
this.guildRoleSubscriptionGroupsSnapshot = new HashMap(this.guildRoleSubscriptionGroups);
|
|
this.guildRoleSubscriptionTiersSnapshot = new HashMap(this.guildRoleSubscriptionTiers);
|
|
}
|
|
}
|