Juby210
/
discord-jadx
1
0
Fork 1
Code Issues Pull Requests Projects Releases Activity

89.11 - Stable (89011)

This commit is contained in:
Juby210 2021-09-01 23:26:33 +02:00
parent 6060696778
commit f576fb7f4f
2403 changed files with 34046 additions and 33085 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app/build.gradle
View File

@ -10,8 +10,8 @@ android {
applicationId 'com.discord'
minSdkVersion 21
targetSdkVersion 29
versionCode 88014
versionName "88.14 - Stable"
versionCode 89011
versionName "89.11 - Stable"
testInstrumentationRunner "androidx.test.runner.AndroidJUnitRunner"
}

2
app/src/main/AndroidManifest.xml
View File

@ -1,5 +1,5 @@
<?xml version="1.0" encoding="utf-8"?>
<manifest xmlns:android="http://schemas.android.com/apk/res/android" android:versionCode="88014" android:versionName="88.14 - Stable" android:installLocation="auto" android:compileSdkVersion="30" android:compileSdkVersionCodename="11" package="com.discord" platformBuildVersionCode="30" platformBuildVersionName="11">
<manifest xmlns:android="http://schemas.android.com/apk/res/android" android:versionCode="89011" android:versionName="89.11 - Stable" android:installLocation="auto" android:compileSdkVersion="30" android:compileSdkVersionCodename="11" package="com.discord" platformBuildVersionCode="30" platformBuildVersionName="11">
<uses-sdk android:minSdkVersion="21" android:targetSdkVersion="29"/>
<uses-feature android:name="android.hardware.camera" android:required="false"/>
<uses-feature android:name="android.hardware.camera.autofocus" android:required="false"/>

3
app/src/main/java/androidx/constraintlayout/solver/SolverVariable.java
View File

@ -1,7 +1,6 @@
package androidx.constraintlayout.solver;
import androidx.exifinterface.media.ExifInterface;
import c.a.q.m0.c.e;
import c.d.b.a.a;
import java.util.Arrays;
import java.util.HashSet;
@ -143,7 +142,7 @@ public class SolverVariable {
L4.append(i3);
return L4.toString();
} else if (ordinal == 3) {
StringBuilder L5 = a.L(e.a);
StringBuilder L5 = a.L("e");
int i4 = uniqueErrorId + 1;
uniqueErrorId = i4;
L5.append(i4);

3
app/src/main/java/androidx/lifecycle/LifecycleCoroutineScopeImpl.java
View File

@ -1,6 +1,5 @@
package androidx.lifecycle;
import androidx.core.app.NotificationCompat;
import androidx.lifecycle.Lifecycle;
import c.q.a.k.a;
import d0.z.d.m;
@ -36,7 +35,7 @@ public final class LifecycleCoroutineScopeImpl extends LifecycleCoroutineScope i
@Override // androidx.lifecycle.LifecycleEventObserver
public void onStateChanged(LifecycleOwner lifecycleOwner, Lifecycle.Event event) {
m.checkNotNullParameter(lifecycleOwner, "source");
m.checkNotNullParameter(event, NotificationCompat.CATEGORY_EVENT);
m.checkNotNullParameter(event, "event");
if (getLifecycle$lifecycle_runtime_ktx_release().getCurrentState().compareTo(Lifecycle.State.DESTROYED) <= 0) {
getLifecycle$lifecycle_runtime_ktx_release().removeObserver(this);
a.j(getCoroutineContext(), null, 1, null);

3
app/src/main/java/androidx/lifecycle/WithLifecycleStateKt$suspendWithStateAtLeastUnchecked$$inlined$suspendCancellableCoroutine$lambda$1.java
View File

@ -1,6 +1,5 @@
package androidx.lifecycle;
import androidx.core.app.NotificationCompat;
import androidx.lifecycle.Lifecycle;
import d0.k;
import d0.l;
@ -30,7 +29,7 @@ public final class WithLifecycleStateKt$suspendWithStateAtLeastUnchecked$$inline
public void onStateChanged(LifecycleOwner lifecycleOwner, Lifecycle.Event event) {
Object obj;
m.checkNotNullParameter(lifecycleOwner, "source");
m.checkNotNullParameter(event, NotificationCompat.CATEGORY_EVENT);
m.checkNotNullParameter(event, "event");
if (event == Lifecycle.Event.upTo(this.$state$inlined)) {
this.$this_suspendWithStateAtLeastUnchecked$inlined.removeObserver(this);
CancellableContinuation cancellableContinuation = this.$co;

4
app/src/main/java/c/a/a/b/f.java
View File

@ -265,7 +265,7 @@ public final class f extends AppViewModel<d> {
StoreChannels channels = companion.getChannels();
Observable<User> observeUser = users.observeUser(j);
Observable<Integer> observe = userRelationships.observe(j);
Observable r = channels.observeChannel(j2).Y(new d(guilds, j)).r();
Observable r = channels.observeChannel(j2).X(new d(guilds, j)).r();
m.checkNotNullExpressionValue(r, "storeChannels\n … .distinctUntilChanged()");
observable2 = Observable.i(observeUser, observe, r, e.a).r();
m.checkNotNullExpressionValue(observable2, "Observable.combineLatest… .distinctUntilChanged()");
@ -276,7 +276,7 @@ public final class f extends AppViewModel<d> {
m.checkNotNullParameter(observable2, "storeObservable");
this.k = j;
this.l = api;
this.j = PublishSubject.k0();
this.j = PublishSubject.j0();
ObservableExtensionsKt.appSubscribe$default(ObservableExtensionsKt.ui$default(ObservableExtensionsKt.computationLatest(observable2), this, null, 2, null), f.class, (Context) null, (Function1) null, (Function1) null, (Function0) null, (Function0) null, new b(this), 62, (Object) null);
}

6
app/src/main/java/c/a/a/f/a/a.java
View File

@ -215,9 +215,9 @@ public final class a extends AppDialog {
public static final void g(a aVar) {
Objects.requireNonNull(aVar);
Observable<Long> d02 = Observable.d0(300, TimeUnit.MILLISECONDS);
m.checkNotNullExpressionValue(d02, "Observable\n .time…S, TimeUnit.MILLISECONDS)");
ObservableExtensionsKt.appSubscribe$default(ObservableExtensionsKt.ui$default(d02, aVar, null, 2, null), a.class, (Context) null, (Function1) null, (Function1) null, (Function0) null, (Function0) null, new b(aVar), 62, (Object) null);
Observable<Long> c02 = Observable.c0(300, TimeUnit.MILLISECONDS);
m.checkNotNullExpressionValue(c02, "Observable\n .time…S, TimeUnit.MILLISECONDS)");
ObservableExtensionsKt.appSubscribe$default(ObservableExtensionsKt.ui$default(c02, aVar, null, 2, null), a.class, (Context) null, (Function1) null, (Function1) null, (Function0) null, (Function0) null, new b(aVar), 62, (Object) null);
}
public static final d h(a aVar) {

3
app/src/main/java/c/a/a/s.java
View File

@ -4,7 +4,6 @@ import android.content.Context;
import android.view.View;
import android.widget.LinearLayout;
import android.widget.TextView;
import androidx.core.app.NotificationCompat;
import androidx.fragment.app.Fragment;
import androidx.fragment.app.FragmentViewModelLazyKt;
import c.a.a.w;
@ -122,7 +121,7 @@ public final class s extends AppDialog {
@Override // kotlin.jvm.functions.Function1
public Unit invoke(w.b bVar) {
w.b bVar2 = bVar;
m.checkNotNullParameter(bVar2, NotificationCompat.CATEGORY_EVENT);
m.checkNotNullParameter(bVar2, "event");
s sVar = this.this$0;
KProperty[] kPropertyArr = s.i;
Objects.requireNonNull(sVar);

2
app/src/main/java/c/a/a/w.java
View File

@ -149,6 +149,6 @@ public final class w extends AppViewModel<d> {
m.checkNotNullParameter(observable2, "storeObservable");
this.k = api;
ObservableExtensionsKt.appSubscribe$default(ObservableExtensionsKt.ui$default(ObservableExtensionsKt.computationLatest(observable2), this, null, 2, null), w.class, (Context) null, (Function1) null, (Function1) null, (Function0) null, (Function0) null, new u(this), 62, (Object) null);
this.j = PublishSubject.k0();
this.j = PublishSubject.j0();
}
}

2
app/src/main/java/c/a/d/a0.java
View File

@ -16,6 +16,6 @@ public final class a0<T, R> implements Observable.c<T, R> {
@Override // j0.k.b
public Object call(Object obj) {
return ((Observable) obj).Y(new z(this));
return ((Observable) obj).X(new z(this));
}
}

2
app/src/main/java/c/a/d/e.java
View File

@ -22,7 +22,7 @@ public final class e extends o implements Function1<Exception, Unit> {
@Override // kotlin.jvm.functions.Function1
public Unit invoke(Exception exc) {
Exception exc2 = exc;
m.checkNotNullParameter(exc2, c.a.q.m0.c.e.a);
m.checkNotNullParameter(exc2, "e");
AppFragment appFragment = this.this$0.this$0;
m.j(appFragment, b.k(appFragment, R.string.unable_to_open_media_chooser, new Object[]{exc2.getMessage()}, null, 4), 0, 4);
return Unit.a;

2
app/src/main/java/c/a/d/l.java
View File

@ -8,7 +8,7 @@ import rx.subjects.BehaviorSubject;
/* compiled from: AppState.kt */
public final class l {
public static final ArrayList<Object> a = new ArrayList<>(4);
public static final BehaviorSubject<Integer> b = BehaviorSubject.l0(0);
public static final BehaviorSubject<Integer> b = BehaviorSubject.k0(0);
/* renamed from: c reason: collision with root package name */
public static final l f45c = new l();

4
app/src/main/java/c/a/d/o.java
View File

@ -58,7 +58,7 @@ public final class o {
@Override // j0.k.b
public Object call(Object obj) {
return ((Observable) obj).Y(new s(this)).r();
return ((Observable) obj).X(new s(this)).r();
}
}
@ -78,7 +78,7 @@ public final class o {
@Override // j0.k.b
public Object call(Object obj) {
return ((Observable) obj).Y(new t(this));
return ((Observable) obj).X(new t(this));
}
}

2
app/src/main/java/c/a/d/s.java
View File

@ -15,6 +15,6 @@ public final class s<T, R> implements b<Map<K, ? extends V>, Observable<? extend
@Override // j0.k.b
public Object call(Object obj) {
Map map = (Map) obj;
return Observable.A(this.i.i).x(new p(map)).g0(q.i, new r(this, map));
return Observable.A(this.i.i).x(new p(map)).f0(q.i, new r(this, map));
}
}

2
app/src/main/java/c/a/e/b.java
View File

@ -42,7 +42,7 @@ public final class b implements Application.ActivityLifecycleCallbacks {
if (function1 != null) {
function1 = new c(function1);
}
d.f52c = q.W(cVar, (Action1) function1);
d.f52c = q.V(cVar, (Action1) function1);
}
@Override // android.app.Application.ActivityLifecycleCallbacks

6
app/src/main/java/c/a/e/d.java
View File

@ -15,9 +15,9 @@ public final class d {
public static final d d = new d();
static {
BehaviorSubject l0 = BehaviorSubject.l0(true);
m.checkNotNullExpressionValue(l0, "BehaviorSubject.create(isBackgrounded)");
b = l0;
BehaviorSubject k0 = BehaviorSubject.k0(true);
m.checkNotNullExpressionValue(k0, "BehaviorSubject.create(isBackgrounded)");
b = k0;
}
public final Observable<Boolean> a() {

2
app/src/main/java/c/a/k/b.java
View File

@ -219,7 +219,7 @@ public final class b {
m.checkNotNullParameter(objArr, "formatArgs");
m.checkNotNullParameter(renderContext, "renderContext");
Map<String, String> map = renderContext.a;
List<? extends Object> list = renderContext.f2060c;
List<? extends Object> list = renderContext.f2064c;
boolean z2 = true;
if (!map.isEmpty()) {
charSequence = a.replace(charSequence, new f(map));

2
app/src/main/java/c/a/k/f/c.java
View File

@ -38,7 +38,7 @@ public final class c extends Node.a<RenderContext> {
spannableStringBuilder.setSpan(obj2, length, spannableStringBuilder.length(), 33);
}
}
Hook.a aVar2 = hook != null ? hook.f2059c : null;
Hook.a aVar2 = hook != null ? hook.f2063c : null;
if (aVar2 != null) {
aVar = aVar2;
} else if (URLUtil.isValidUrl(this.a)) {

3
app/src/main/java/c/a/n/a.java
View File

@ -6,7 +6,6 @@ import android.graphics.Point;
import android.util.Log;
import android.view.MotionEvent;
import android.view.View;
import androidx.core.app.NotificationCompat;
import com.discord.overlay.OverlayManager;
import com.discord.overlay.R;
import com.discord.overlay.views.OverlayBubbleWrap;
@ -25,7 +24,7 @@ public final class a implements View.OnTouchListener {
@Override // android.view.View.OnTouchListener
public final boolean onTouch(View view, MotionEvent motionEvent) {
boolean z2;
m.checkNotNullExpressionValue(motionEvent, NotificationCompat.CATEGORY_EVENT);
m.checkNotNullExpressionValue(motionEvent, "event");
int action = motionEvent.getAction();
if (action == 1 || action == 2) {
c.a.n.h.a aVar = this.i.m;

2
app/src/main/java/c/a/p/e.java
View File

@ -31,7 +31,7 @@ public final class e<T> implements Action1<k.c> {
if (subscription != null) {
subscription.unsubscribe();
}
appMediaPlayer.b = Observable.E(500, 500, TimeUnit.MILLISECONDS, appMediaPlayer.i).K().I(a.a()).W(new g(appMediaPlayer), new h(appMediaPlayer));
appMediaPlayer.b = Observable.E(500, 500, TimeUnit.MILLISECONDS, appMediaPlayer.i).K().I(a.a()).V(new g(appMediaPlayer), new h(appMediaPlayer));
} else if (i == 4) {
PublishSubject<AppMediaPlayer.Event> publishSubject3 = this.i.a;
publishSubject3.j.onNext(AppMediaPlayer.Event.e.a);

6
app/src/main/java/c/a/p/k.java
View File

@ -12,9 +12,9 @@ import java.util.List;
import rx.subjects.PublishSubject;
/* compiled from: RxPlayerEventListener.kt */
public final class k implements g1.a {
public final PublishSubject<c> i = PublishSubject.k0();
public final PublishSubject<a> j = PublishSubject.k0();
public final PublishSubject<b> k = PublishSubject.k0();
public final PublishSubject<c> i = PublishSubject.j0();
public final PublishSubject<a> j = PublishSubject.j0();
public final PublishSubject<b> k = PublishSubject.j0();
/* compiled from: RxPlayerEventListener.kt */
public static final class a {

6
app/src/main/java/c/a/q/a0.java
View File

@ -24,10 +24,10 @@ public final /* synthetic */ class a0 extends k implements Function1<Pair<? exte
Pair<? extends Map<String, ? extends EncodeQuality>, ? extends RtcConnection.State> pair2 = pair;
m.checkNotNullParameter(pair2, "p1");
RtcConnection rtcConnection = (RtcConnection) this.receiver;
if (rtcConnection.Z) {
if (rtcConnection.f2127a0) {
Map map = (Map) pair2.component1();
if (m.areEqual((RtcConnection.State) pair2.component2(), RtcConnection.State.f.a)) {
rtcConnection.T.i(rtcConnection.k, "local MediaSinkWants: " + map, null);
rtcConnection.U.i(rtcConnection.k, "local MediaSinkWants: " + map, null);
a aVar = rtcConnection.v;
if (aVar == null) {
RtcConnection.o(rtcConnection, "onLocalMediaSinkWants() socket was null.", null, null, 6);
@ -39,7 +39,7 @@ public final /* synthetic */ class a0 extends k implements Function1<Pair<? exte
m.checkNotNullParameter(linkedHashMap, "wants");
aVar.b();
if (aVar.q >= 5) {
aVar.p(15, linkedHashMap);
aVar.o(15, linkedHashMap);
}
}
}

30
app/src/main/java/c/a/q/b0.java
View File

@ -43,23 +43,23 @@ public final class b0 implements MediaEngineConnection.d {
rtcConnection.q = transportInfo;
MediaEngineConnection mediaEngineConnection2 = rtcConnection.w;
if (mediaEngineConnection2 != null) {
d dVar = new d(1000, rtcConnection.T, mediaEngineConnection2, new VoiceQuality(), rtcConnection.A, new KrispOveruseDetector(mediaEngineConnection2), 0, 64);
d dVar = new d(1000, rtcConnection.U, mediaEngineConnection2, new VoiceQuality(), rtcConnection.A, new KrispOveruseDetector(mediaEngineConnection2), 0, 64);
dVar.a.clear();
Subscription subscription = dVar.b;
if (subscription != null && !subscription.isUnsubscribed()) {
dVar.a();
}
dVar.b = Observable.D(0, dVar.f225c, TimeUnit.MILLISECONDS).W(new b(dVar), new c(dVar));
dVar.b = Observable.D(0, dVar.f225c, TimeUnit.MILLISECONDS).V(new b(dVar), new c(dVar));
rtcConnection.n = dVar;
rtcConnection.o = false;
}
if (transportInfo.f2141c.ordinal() != 0) {
if (transportInfo.f2146c.ordinal() != 0) {
StringBuilder L = c.d.b.a.a.L("Unsupported protocol: ");
L.append(transportInfo.f2141c);
L.append(transportInfo.f2146c);
L.append('.');
RtcConnection.j(rtcConnection, true, L.toString(), null, false, 12);
} else {
rtcConnection.T.recordBreadcrumb("Sending UDP info to RTC server.", rtcConnection.k);
rtcConnection.U.recordBreadcrumb("Sending UDP info to RTC server.", rtcConnection.k);
c.a.q.n0.a aVar = rtcConnection.v;
if (aVar == null) {
RtcConnection.o(rtcConnection, "onEngineConnectionConnected() socket was null.", null, null, 6);
@ -77,7 +77,7 @@ public final class b0 implements MediaEngineConnection.d {
for (a aVar2 : list) {
arrayList.add(new Payloads.Protocol.CodecInfo(aVar2.a, aVar2.b, aVar2.f215c, aVar2.d, aVar2.e));
}
aVar.p(1, new Payloads.Protocol("udp", protocolInfo, arrayList));
aVar.o(1, new Payloads.Protocol("udp", protocolInfo, arrayList));
}
for (RtcConnection.c cVar : rtcConnection.m) {
cVar.onMediaEngineConnectionConnected(rtcConnection);
@ -109,8 +109,8 @@ public final class b0 implements MediaEngineConnection.d {
rtcConnection.q();
}
if (rtcConnection.r.a == RtcConnection.State.f.a) {
rtcConnection.C = Long.valueOf(rtcConnection.U.currentTimeMillis());
rtcConnection.H = true;
rtcConnection.C = Long.valueOf(rtcConnection.V.currentTimeMillis());
rtcConnection.I = true;
Map<String, Object> mutableMapOf = h0.mutableMapOf(d0.o.to("connect_count", Integer.valueOf(rtcConnection.D)));
Long l = rtcConnection.B;
Long l2 = rtcConnection.C;
@ -120,7 +120,7 @@ public final class b0 implements MediaEngineConnection.d {
}
rtcConnection.b(mutableMapOf);
rtcConnection.p(RtcConnection.AnalyticsEvent.VOICE_CONNECTION_SUCCESS, mutableMapOf);
MediaSinkWantsManager mediaSinkWantsManager = rtcConnection.F;
MediaSinkWantsManager mediaSinkWantsManager = rtcConnection.G;
if (mediaSinkWantsManager != null) {
mediaSinkWantsManager.b(new i(mediaSinkWantsManager, rtcConnection.w));
}
@ -171,9 +171,9 @@ public final class b0 implements MediaEngineConnection.d {
public void onSpeaking(long j, int i, boolean z2) {
c.a.q.n0.a aVar;
RtcConnection rtcConnection = this.a;
if (j == rtcConnection.R && (aVar = rtcConnection.v) != null) {
if (j == rtcConnection.S && (aVar = rtcConnection.v) != null) {
aVar.b();
aVar.p(5, new Payloads.Speaking(i, Integer.valueOf(z2 ? 1 : 0), 0, null, 8, null));
aVar.o(5, new Payloads.Speaking(i, Integer.valueOf(z2 ? 1 : 0), 0, null, 8, null));
}
for (RtcConnection.c cVar : rtcConnection.m) {
cVar.onSpeaking(j, z2);
@ -185,12 +185,12 @@ public final class b0 implements MediaEngineConnection.d {
m.checkNotNullParameter(streamParametersArr, "streams");
RtcConnection rtcConnection = this.a;
List<StreamParameters> asList = j.asList(streamParametersArr);
if (j == rtcConnection.R) {
if (j == rtcConnection.S) {
c.a.q.n0.a aVar = rtcConnection.v;
if (aVar == null) {
RtcConnection.o(rtcConnection, "sendVideo() socket was null.", null, null, 6);
} else {
rtcConnection.J = (long) i2;
rtcConnection.K = (long) i2;
if (i2 != 0) {
rtcConnection.o = true;
}
@ -211,9 +211,9 @@ public final class b0 implements MediaEngineConnection.d {
}
m.checkNotNullParameter(arrayList, "streams");
aVar.b();
aVar.p(12, new Payloads.Video(i, i2, i3, null, arrayList));
aVar.o(12, new Payloads.Video(i, i2, i3, null, arrayList));
}
MediaSinkWantsManager mediaSinkWantsManager = rtcConnection.F;
MediaSinkWantsManager mediaSinkWantsManager = rtcConnection.G;
if (mediaSinkWantsManager != null) {
mediaSinkWantsManager.b(new k(mediaSinkWantsManager, i2 != 0));
}

66
app/src/main/java/c/a/q/h0.java
View File

@ -58,9 +58,15 @@ public final class h0 implements a.d {
}
MediaEngineConnection mediaEngineConnection2 = rtcConnection.w;
if (mediaEngineConnection2 != null) {
mediaEngineConnection2.o(rtcConnection.L);
mediaEngineConnection2.o(rtcConnection.M);
}
Long l = rtcConnection.F;
long currentTimeMillis = l != null ? rtcConnection.V.currentTimeMillis() - l.longValue() : 0;
boolean z3 = true;
boolean z4 = currentTimeMillis > 30000;
if ((num != null && num.intValue() == 1000) || z4) {
z3 = false;
}
boolean z3 = num == null || num.intValue() != 1000;
if (!(rtcConnection.r.a instanceof RtcConnection.State.d)) {
rtcConnection.n(z3, str);
d dVar = rtcConnection.n;
@ -70,16 +76,16 @@ public final class h0 implements a.d {
rtcConnection.n = null;
rtcConnection.o = false;
}
rtcConnection.f2128z = 0;
rtcConnection.f2133z = 0;
rtcConnection.C = null;
MediaSinkWantsManager mediaSinkWantsManager = rtcConnection.F;
MediaSinkWantsManager mediaSinkWantsManager = rtcConnection.G;
if (mediaSinkWantsManager != null) {
mediaSinkWantsManager.b(new g(mediaSinkWantsManager));
}
rtcConnection.u(new RtcConnection.State.d(z3));
if (z3) {
long fail = rtcConnection.p.fail(new d0(rtcConnection));
Logger.w$default(rtcConnection.T, rtcConnection.k, "Disconnect was not clean! Reason: " + str + ", code: " + num + ". Reconnecting in " + (fail / ((long) 1000)) + " seconds.", null, 4, null);
Logger.w$default(rtcConnection.U, rtcConnection.k, "Disconnect was not clean! Reason: " + str + ", code: " + num + ". Reconnecting in " + (fail / ((long) 1000)) + " seconds.", null, 4, null);
}
}
@ -97,7 +103,7 @@ public final class h0 implements a.d {
public void d(String str) {
m.checkNotNullParameter(str, "mediaSessionId");
RtcConnection rtcConnection = this.a;
rtcConnection.I = str;
rtcConnection.J = str;
for (RtcConnection.c cVar : rtcConnection.m) {
cVar.onMediaSessionIdReceived();
rtcConnection.p(RtcConnection.AnalyticsEvent.MEDIA_SESSION_JOINED, new LinkedHashMap());
@ -124,9 +130,9 @@ public final class h0 implements a.d {
Logger.i$default(eVar.q, "VideoQuality: handleVideoStreamUpdate(userId: " + j + ", videoSsrc: " + j2 + ')', null, 2, null);
}
}
if (j != rtcConnection.R) {
if (j != rtcConnection.S) {
boolean z3 = false;
if (rtcConnection.F != null) {
if (rtcConnection.G != null) {
if (list != null) {
r3 = new ArrayList(o.collectionSizeOrDefault(list, 10));
for (Payloads.Stream stream : list) {
@ -145,8 +151,8 @@ public final class h0 implements a.d {
}
list2 = d0.t.m.listOf(new Payloads.Stream(MediaStreamTrack.VIDEO_TRACK_KIND, "100", null, 100, valueOf, valueOf2, null, Boolean.valueOf(z3), null));
}
rtcConnection.F.c(j, Long.valueOf((long) i));
MediaSinkWantsManager mediaSinkWantsManager = rtcConnection.F;
rtcConnection.G.c(j, Long.valueOf((long) i));
MediaSinkWantsManager mediaSinkWantsManager = rtcConnection.G;
Objects.requireNonNull(mediaSinkWantsManager);
m.checkNotNullParameter(list2, "ssrcs");
mediaSinkWantsManager.b(new l(mediaSinkWantsManager, list2, j));
@ -192,8 +198,8 @@ public final class h0 implements a.d {
Integer num;
m.checkNotNullParameter(map, "wants");
RtcConnection rtcConnection = this.a;
if (rtcConnection.F != null) {
long j = rtcConnection.J;
if (rtcConnection.G != null) {
long j = rtcConnection.K;
int intValue = (j == 0 || (num = map.get(String.valueOf(j))) == null) ? 0 : num.intValue();
Integer num2 = map.get("any");
int intValue2 = num2 != null ? num2.intValue() : 0;
@ -201,12 +207,12 @@ public final class h0 implements a.d {
intValue = intValue2 > 0 ? intValue2 : 100;
}
e.c cVar = null;
rtcConnection.T.i(rtcConnection.k, "remote MediaSinkWants: " + map + ", decided on encode quality " + intValue, null);
rtcConnection.U.i(rtcConnection.k, "remote MediaSinkWants: " + map + ", decided on encode quality " + intValue, null);
EncodeQuality[] values = EncodeQuality.values();
for (int i = 10; i >= 0; i--) {
EncodeQuality encodeQuality = values[i];
if (encodeQuality.getValue() <= intValue) {
e eVar = rtcConnection.F.j;
e eVar = rtcConnection.G.j;
j0 j0Var = eVar.e;
m.checkNotNullParameter(encodeQuality, "wantValue");
List<e.c> list = eVar.d;
@ -255,7 +261,7 @@ public final class h0 implements a.d {
r.removeFirst(rtcConnection.u);
}
if (j > ((long) 500)) {
rtcConnection.f2128z++;
rtcConnection.f2133z++;
}
double d = (double) j;
Objects.requireNonNull(RtcConnection.Quality.Companion);
@ -273,17 +279,17 @@ public final class h0 implements a.d {
public void i() {
RtcConnection rtcConnection = this.a;
rtcConnection.p.cancel();
rtcConnection.T.recordBreadcrumb("Connected to RTC server.", rtcConnection.k);
rtcConnection.U.recordBreadcrumb("Connected to RTC server.", rtcConnection.k);
a aVar = rtcConnection.v;
if (aVar == null) {
RtcConnection.o(rtcConnection, "onSocketConnect() socket was null.", null, null, 6);
return;
}
List listOf = d0.t.m.listOf(new Payloads.Stream(MediaStreamTrack.VIDEO_TRACK_KIND, "100", null, 100, null, null, null, null, null));
String str = rtcConnection.Q;
long j = rtcConnection.R;
String str2 = rtcConnection.O;
boolean z2 = rtcConnection.P;
String str = rtcConnection.R;
long j = rtcConnection.S;
String str2 = rtcConnection.P;
boolean z2 = rtcConnection.Q;
m.checkNotNullParameter(str, "serverId");
m.checkNotNullParameter(str2, "sessionId");
m.checkNotNullParameter(listOf, "streams");
@ -291,7 +297,7 @@ public final class h0 implements a.d {
aVar.f221s = str;
aVar.t = str2;
aVar.A = a.c.IDENTIFYING;
aVar.p(0, new Payloads.Identify(str, j, str2, aVar.D, z2, listOf));
aVar.o(0, new Payloads.Identify(str, j, str2, aVar.D, z2, listOf));
rtcConnection.u(RtcConnection.State.a.a);
}
@ -299,14 +305,14 @@ public final class h0 implements a.d {
public void j(long j) {
Map<String, Object> b;
RtcConnection rtcConnection = this.a;
if ((rtcConnection.V instanceof RtcConnection.d.a) && (b = rtcConnection.A.b(String.valueOf(j))) != null) {
if ((rtcConnection.W instanceof RtcConnection.d.a) && (b = rtcConnection.A.b(String.valueOf(j))) != null) {
rtcConnection.l(j, b);
}
MediaSinkWantsManager mediaSinkWantsManager = rtcConnection.F;
MediaSinkWantsManager mediaSinkWantsManager = rtcConnection.G;
if (mediaSinkWantsManager != null) {
mediaSinkWantsManager.c(j, null);
}
MediaSinkWantsManager mediaSinkWantsManager2 = rtcConnection.F;
MediaSinkWantsManager mediaSinkWantsManager2 = rtcConnection.G;
if (mediaSinkWantsManager2 != null) {
List emptyList = n.emptyList();
m.checkNotNullParameter(emptyList, "ssrcs");
@ -349,10 +355,10 @@ public final class h0 implements a.d {
if (isEmpty) {
arrayList2 = d0.t.m.listOf(new StreamParameters(MediaType.Video, "100", i2 + 1, i2 + 2, false, 0, 100, 0));
}
MediaEngine mediaEngine = rtcConnection.S;
long j = rtcConnection.R;
MediaEngine mediaEngine = rtcConnection.T;
long j = rtcConnection.S;
MediaEngine.a aVar = new MediaEngine.a(i2, str, i, arrayList2);
RtcConnection.d dVar = rtcConnection.V;
RtcConnection.d dVar = rtcConnection.W;
if (m.areEqual(dVar, RtcConnection.d.a.a)) {
type = MediaEngineConnection.Type.DEFAULT;
} else if (dVar instanceof RtcConnection.d.b) {
@ -365,7 +371,7 @@ public final class h0 implements a.d {
RtcConnection.o(rtcConnection, "onSocketHello(): connect() return null.", null, null, 6);
return;
}
g.l(rtcConnection.L);
g.l(rtcConnection.M);
rtcConnection.w = g;
}
@ -384,12 +390,12 @@ public final class h0 implements a.d {
@Override // c.a.q.n0.a.d
public void onSpeaking(long j, int i, boolean z2) {
RtcConnection rtcConnection = this.a;
if (j != rtcConnection.R) {
if (j != rtcConnection.S) {
MediaEngineConnection mediaEngineConnection = rtcConnection.w;
if (mediaEngineConnection != null) {
mediaEngineConnection.s(j, i, null, rtcConnection.g(j), rtcConnection.h(j));
}
MediaSinkWantsManager mediaSinkWantsManager = rtcConnection.F;
MediaSinkWantsManager mediaSinkWantsManager = rtcConnection.G;
if (mediaSinkWantsManager != null) {
mediaSinkWantsManager.c(j, Long.valueOf((long) i));
}

2
app/src/main/java/c/a/q/j.java
View File

@ -34,7 +34,7 @@ public final class j extends o implements Function0<Unit> {
Long l2 = this.$userId;
if (l2 == null) {
this.this$0.e = null;
} else if (this.this$0.f2121c.contains(l2)) {
} else if (this.this$0.f2125c.contains(l2)) {
MediaSinkWantsManager mediaSinkWantsManager2 = this.this$0;
Long l3 = this.$userId;
mediaSinkWantsManager2.e = l3;

2
app/src/main/java/c/a/q/k0/f.java
View File

@ -20,7 +20,7 @@ public final class f extends ContentObserver {
DiscordAudioManager discordAudioManager = this.a;
int streamVolume = discordAudioManager.e.getStreamVolume(3);
discordAudioManager.w = streamVolume;
SerializedSubject<Integer, Integer> serializedSubject = discordAudioManager.f2134y;
SerializedSubject<Integer, Integer> serializedSubject = discordAudioManager.f2139y;
serializedSubject.j.onNext(Integer.valueOf(streamVolume));
}
}

4
app/src/main/java/c/a/q/l.java
View File

@ -96,10 +96,10 @@ public final class l extends o implements Function0<Unit> {
}
if (arrayList2.isEmpty()) {
this.this$0.b.remove(Long.valueOf(this.$userId));
this.this$0.f2121c.remove(Long.valueOf(this.$userId));
this.this$0.f2125c.remove(Long.valueOf(this.$userId));
} else {
this.this$0.b.put(Long.valueOf(this.$userId), arrayList2);
this.this$0.f2121c.add(Long.valueOf(this.$userId));
this.this$0.f2125c.add(Long.valueOf(this.$userId));
}
this.this$0.d(arrayList2.isEmpty() ? n.emptyList() : d0.t.m.listOf(String.valueOf(this.$userId)));
return Unit.a;

6
app/src/main/java/c/a/q/m0/b.java
View File

@ -170,7 +170,7 @@ public final class b extends ScreenCapturerAndroid {
if (subscription != null) {
subscription.unsubscribe();
}
Observable<Long> d02 = Observable.d0(((long) this.p) / 1000000, TimeUnit.MILLISECONDS);
Observable<Long> c02 = Observable.c0(((long) this.p) / 1000000, TimeUnit.MILLISECONDS);
SurfaceTextureHelper surfaceTextureHelper = this.l;
if (surfaceTextureHelper == null) {
m.throwUninitializedPropertyAccessException("surfaceTextureHelper");
@ -180,7 +180,7 @@ public final class b extends ScreenCapturerAndroid {
Looper looper = handler.getLooper();
AtomicReference<j0.j.b.a> atomicReference = j0.j.b.a.a;
Objects.requireNonNull(looper, "looper == null");
this.v = d02.X(new j0.j.b.b(looper)).W(new c(this), d.i);
this.v = c02.W(new j0.j.b.b(looper)).V(new c(this), d.i);
}
}
@ -216,7 +216,7 @@ public final class b extends ScreenCapturerAndroid {
if (thumbnailEmitter != null) {
synchronized (thumbnailEmitter) {
thumbnailEmitter.d.release();
thumbnailEmitter.f2144c.release();
thumbnailEmitter.f2149c.release();
JniCommon.nativeFreeByteBuffer(thumbnailEmitter.b);
thumbnailEmitter.a = RecyclerView.FOREVER_NS;
}

2
app/src/main/java/c/a/q/m0/c/b.java
View File

@ -37,7 +37,7 @@ public final class b implements Connection.OnVideoCallback {
int i = this.$ssrc;
String str = this.$streamIdentifier;
StreamParameters[] streamParametersArr = this.$streams;
eVar.f.put(Long.valueOf(j), Long.valueOf((long) i));
eVar.e.put(Long.valueOf(j), Long.valueOf((long) i));
eVar.y(new h(eVar, j, str, i, streamParametersArr));
return Unit.a;
}

2
app/src/main/java/c/a/q/m0/c/c.java
View File

@ -29,7 +29,7 @@ public final class c implements Connection.UserSpeakingStatusChangedCallback {
e eVar = this.this$0.a;
long j = this.$userId;
boolean z2 = this.$isUserSpeakingNow;
Integer num = eVar.e.get(Long.valueOf(j));
Integer num = eVar.d.get(Long.valueOf(j));
eVar.y(new g(j, num != null ? num.intValue() : 0, z2));
return Unit.a;
}

27
app/src/main/java/c/a/q/m0/c/d.java
View File

@ -34,28 +34,25 @@ public final class d implements Discord.ConnectToServerCallback {
e eVar = this.this$0.a;
Discord.ConnectionInfo connectionInfo = this.$connectionInfo;
String str = this.$errorMessage;
Logger logger = eVar.m;
String str2 = e.a;
m.checkNotNullExpressionValue(str2, "TAG");
Logger.i$default(logger, str2, "handleConnection(). errorMessage: " + str, null, 4, null);
Logger.i$default(eVar.l, "MediaEngineConnectionLegacy", c.d.b.a.a.s("handleConnection(). errorMessage: ", str), null, 4, null);
if (connectionInfo != null) {
if (str == null || str.length() == 0) {
String str3 = connectionInfo.localAddress;
m.checkNotNullExpressionValue(str3, "connectionInfo.localAddress");
String str2 = connectionInfo.localAddress;
m.checkNotNullExpressionValue(str2, "connectionInfo.localAddress");
int i = connectionInfo.localPort;
String str4 = connectionInfo.protocol;
m.checkNotNullExpressionValue(str4, "connectionInfo.protocol");
Objects.requireNonNull(str4, "null cannot be cast to non-null type java.lang.String");
String upperCase = str4.toUpperCase();
String str3 = connectionInfo.protocol;
m.checkNotNullExpressionValue(str3, "connectionInfo.protocol");
Objects.requireNonNull(str3, "null cannot be cast to non-null type java.lang.String");
String upperCase = str3.toUpperCase();
m.checkNotNullExpressionValue(upperCase, "(this as java.lang.String).toUpperCase()");
MediaEngineConnection.TransportInfo transportInfo = new MediaEngineConnection.TransportInfo(str3, i, MediaEngineConnection.TransportInfo.Protocol.valueOf(upperCase));
MediaEngineConnection.TransportInfo transportInfo = new MediaEngineConnection.TransportInfo(str2, i, MediaEngineConnection.TransportInfo.Protocol.valueOf(upperCase));
MediaEngineConnection.ConnectionState connectionState = MediaEngineConnection.ConnectionState.CONNECTED;
eVar.f218c = connectionState;
eVar.b = connectionState;
eVar.y(new a(eVar, connectionState));
c.a.q.m0.a aVar = new c.a.q.m0.a("opus", 1, MediaStreamTrack.AUDIO_TRACK_KIND, 120, null);
eVar.j.clear();
eVar.j.add(aVar);
eVar.j.addAll(eVar.p);
eVar.i.clear();
eVar.i.add(aVar);
eVar.i.addAll(eVar.o);
eVar.y(new l(0, eVar, transportInfo));
return Unit.a;
}

142
app/src/main/java/c/a/q/m0/c/e.java
View File

@ -32,26 +32,25 @@ import kotlin.jvm.functions.Function0;
import kotlin.jvm.functions.Function1;
/* compiled from: MediaEngineConnectionLegacy.kt */
public final class e implements MediaEngineConnection {
public static final String a = "e";
public final CopyOnWriteArrayList<MediaEngineConnection.d> b;
public final CopyOnWriteArrayList<MediaEngineConnection.d> a;
public MediaEngineConnection.ConnectionState b;
/* renamed from: c reason: collision with root package name */
public MediaEngineConnection.ConnectionState f218c;
public boolean d;
public final Map<Long, Integer> e;
public final Map<Long, Long> f = new LinkedHashMap();
public boolean f218c;
public final Map<Long, Integer> d;
public final Map<Long, Long> e = new LinkedHashMap();
public final Set<Long> f = new LinkedHashSet();
public final Set<Long> g = new LinkedHashSet();
public final Set<Long> h = new LinkedHashSet();
public final Set<Long> i = new LinkedHashSet();
public final List<c.a.q.m0.a> j = new ArrayList();
public final Connection k;
public final c.a.q.c l;
public final Logger m;
public final t n;
public final Discord o;
public final List<c.a.q.m0.a> p;
public final MediaEngineConnection.Type q;
public final long r;
public final List<c.a.q.m0.a> i = new ArrayList();
public final Connection j;
public final c.a.q.c k;
public final Logger l;
public final t m;
public final Discord n;
public final List<c.a.q.m0.a> o;
public final MediaEngineConnection.Type p;
public final long q;
/* compiled from: MediaEngineConnectionLegacy.kt */
public static final class a extends d0.z.d.o implements Function1<Connection, Unit> {
@ -82,9 +81,7 @@ public final class e implements MediaEngineConnection {
long j = this.$userId;
int i = this.$audioSsrc;
int i2 = (int) this.$resolvedVideoSsrc;
e eVar = this.this$0;
String str = e.a;
Objects.requireNonNull(eVar);
Objects.requireNonNull(this.this$0);
connection2.connectUser(j, i, i2, i2 > 0 ? i2 + 1 : 0, this.$isMuted, this.$volume);
return Unit.a;
}
@ -291,7 +288,7 @@ public final class e implements MediaEngineConnection {
Connection connection2 = connection;
d0.z.d.m.checkNotNullParameter(connection2, "$receiver");
connection2.setVADLeadingFramesToBuffer(this.$inputModeOptions.b);
connection2.setVADTrailingFramesToSend(this.$inputModeOptions.f2143c);
connection2.setVADTrailingFramesToSend(this.$inputModeOptions.f2148c);
connection2.setVADTriggerThreshold((float) this.$inputModeOptions.a);
connection2.setVADAutoThreshold(this.$inputModeOptions.d ? 3 : -1);
connection2.setVADUseKrisp(this.$inputModeOptions.e);
@ -434,7 +431,7 @@ public final class e implements MediaEngineConnection {
Connection connection2 = connection;
d0.z.d.m.checkNotNullParameter(connection2, "$receiver");
MediaEngineConnection.b bVar = this.$quality;
connection2.setEncodingQuality(bVar.a, bVar.b, bVar.f2142c, bVar.d, this.$framerate);
connection2.setEncodingQuality(bVar.a, bVar.b, bVar.f2147c, bVar.d, this.$framerate);
return Unit.a;
}
}
@ -559,69 +556,66 @@ public final class e implements MediaEngineConnection {
d0.z.d.m.checkNotNullParameter(type, "type");
d0.z.d.m.checkNotNullParameter(aVar, "connectionOptions");
d0.z.d.m.checkNotNullParameter(list2, "listeners");
this.l = cVar;
this.m = logger;
this.n = tVar;
this.o = discord;
this.p = list;
this.q = type;
this.r = j2;
this.k = cVar;
this.l = logger;
this.m = tVar;
this.n = discord;
this.o = list;
this.p = type;
this.q = j2;
MediaEngineConnection.ConnectionState connectionState = MediaEngineConnection.ConnectionState.CONNECTING;
this.f218c = connectionState;
this.e = h0.mutableMapOf(d0.o.to(Long.valueOf(j2), Integer.valueOf(aVar.a)));
this.b = connectionState;
this.d = h0.mutableMapOf(d0.o.to(Long.valueOf(j2), Integer.valueOf(aVar.a)));
int i2 = aVar.a;
String str = aVar.b;
int i3 = aVar.f2140c;
int i3 = aVar.f2145c;
Object[] array = aVar.d.toArray(new StreamParameters[0]);
Objects.requireNonNull(array, "null cannot be cast to non-null type kotlin.Array<T>");
Connection connectToServer = discord.connectToServer(i2, j2, str, i3, (StreamParameters[]) array, new d(this));
d0.z.d.m.checkNotNullExpressionValue(connectToServer, "voiceEngineLegacy.connec…fo, errorMessage) }\n }");
connectToServer.setOnVideoCallback(new b(this));
connectToServer.setUserSpeakingStatusChangedCallback(new c(this));
this.k = connectToServer;
this.b = new CopyOnWriteArrayList<>(list2);
this.f218c = connectionState;
this.j = connectToServer;
this.a = new CopyOnWriteArrayList<>(list2);
this.b = connectionState;
y(new a(this, connectionState));
}
public static final void x(e eVar, Function0 function0) {
c.a.q.c cVar = eVar.l;
c.a.q.c cVar = eVar.k;
cVar.k.execute(new i(function0));
}
@Override // com.discord.rtcconnection.mediaengine.MediaEngineConnection
public synchronized void a(Intent intent, ThumbnailEmitter thumbnailEmitter) {
d0.z.d.m.checkNotNullParameter(intent, "permission");
z(new t(new c.a.q.m0.b(intent, new u(), this.m, thumbnailEmitter)));
z(new t(new c.a.q.m0.b(intent, new u(), this.l, thumbnailEmitter)));
}
@Override // com.discord.rtcconnection.mediaengine.MediaEngineConnection
public boolean b() {
return this.n.a;
return this.m.a;
}
@Override // com.discord.rtcconnection.mediaengine.MediaEngineConnection
public void c(boolean z2) {
this.d = z2;
this.f218c = z2;
z(new r(z2));
}
@Override // com.discord.rtcconnection.mediaengine.MediaEngineConnection
public void d(long j2, boolean z2) {
if (z2) {
this.i.add(Long.valueOf(j2));
this.h.add(Long.valueOf(j2));
} else {
this.i.remove(Long.valueOf(j2));
this.h.remove(Long.valueOf(j2));
}
y(new m(j2, z2));
}
@Override // com.discord.rtcconnection.mediaengine.MediaEngineConnection
public void destroy() {
Logger logger = this.m;
String str = a;
d0.z.d.m.checkNotNullExpressionValue(str, "TAG");
Logger.i$default(logger, str, "destroy(). Disconnecting from server", null, 4, null);
Logger.i$default(this.l, "MediaEngineConnectionLegacy", "destroy(). Disconnecting from server", null, 4, null);
z(b.i);
y(new c(this));
}
@ -639,12 +633,12 @@ public final class e implements MediaEngineConnection {
@Override // com.discord.rtcconnection.mediaengine.MediaEngineConnection
public boolean g(long j2) {
return this.h.contains(Long.valueOf(j2));
return this.g.contains(Long.valueOf(j2));
}
@Override // com.discord.rtcconnection.mediaengine.MediaEngineConnection
public MediaEngineConnection.Type getType() {
return this.q;
return this.p;
}
@Override // com.discord.rtcconnection.mediaengine.MediaEngineConnection
@ -666,7 +660,7 @@ public final class e implements MediaEngineConnection {
public void k(MediaEngineConnection.InputMode inputMode, MediaEngineConnection.c cVar) {
d0.z.d.m.checkNotNullParameter(inputMode, "inputMode");
d0.z.d.m.checkNotNullParameter(cVar, "inputModeOptions");
t tVar = this.n;
t tVar = this.m;
if (inputMode == MediaEngineConnection.InputMode.VOICE_ACTIVITY) {
boolean z2 = cVar.d;
}
@ -677,14 +671,14 @@ public final class e implements MediaEngineConnection {
@Override // com.discord.rtcconnection.mediaengine.MediaEngineConnection
public void l(MediaEngineConnection.d dVar) {
d0.z.d.m.checkNotNullParameter(dVar, "listener");
this.b.add(dVar);
dVar.onConnectionStateChange(this, this.f218c);
this.a.add(dVar);
dVar.onConnectionStateChange(this, this.b);
}
@Override // com.discord.rtcconnection.mediaengine.MediaEngineConnection
public void m(MediaEngineConnection.b bVar) {
d0.z.d.m.checkNotNullParameter(bVar, "quality");
z(new p(bVar, this.d ? bVar.e : bVar.f));
z(new p(bVar, this.f218c ? bVar.e : bVar.f));
}
@Override // com.discord.rtcconnection.mediaengine.MediaEngineConnection
@ -696,12 +690,12 @@ public final class e implements MediaEngineConnection {
@Override // com.discord.rtcconnection.mediaengine.MediaEngineConnection
public void o(MediaEngineConnection.d dVar) {
d0.z.d.m.checkNotNullParameter(dVar, "listener");
this.b.remove(dVar);
this.a.remove(dVar);
}
@Override // com.discord.rtcconnection.mediaengine.MediaEngineConnection
public boolean p(long j2) {
return this.i.contains(Long.valueOf(j2));
return this.h.contains(Long.valueOf(j2));
}
@Override // com.discord.rtcconnection.mediaengine.MediaEngineConnection
@ -715,7 +709,7 @@ public final class e implements MediaEngineConnection {
Object obj2;
d0.z.d.m.checkNotNullParameter(str, "audioCodec");
d0.z.d.m.checkNotNullParameter(str2, "videoCodec");
Iterator<T> it = this.j.iterator();
Iterator<T> it = this.i.iterator();
while (true) {
obj = null;
if (!it.hasNext()) {
@ -728,7 +722,7 @@ public final class e implements MediaEngineConnection {
}
}
c.a.q.m0.a aVar = (c.a.q.m0.a) obj2;
Iterator<T> it2 = this.j.iterator();
Iterator<T> it2 = this.i.iterator();
while (true) {
if (!it2.hasNext()) {
break;
@ -765,35 +759,30 @@ public final class e implements MediaEngineConnection {
@Override // com.discord.rtcconnection.mediaengine.MediaEngineConnection
public void s(long j2, int i2, Integer num, boolean z2, float f2) {
if (i2 == 0) {
Logger logger = this.m;
String str = a;
d0.z.d.m.checkNotNullExpressionValue(str, "TAG");
Logger.w$default(logger, str, "Attempting to create user " + j2 + " with 0 audio SSRC", null, 4, null);
Logger.w$default(this.l, "MediaEngineConnectionLegacy", c.d.b.a.a.p("Attempting to create user ", j2, " with 0 audio SSRC"), null, 4, null);
return;
}
Long valueOf = num != null ? Long.valueOf((long) num.intValue()) : this.f.get(Long.valueOf(j2));
Long valueOf = num != null ? Long.valueOf((long) num.intValue()) : this.e.get(Long.valueOf(j2));
long longValue = valueOf != null ? valueOf.longValue() : 0;
Integer num2 = this.e.get(Long.valueOf(j2));
Integer num2 = this.d.get(Long.valueOf(j2));
boolean z3 = false;
boolean z4 = num2 == null || num2.intValue() != i2;
Long l2 = this.f.get(Long.valueOf(j2));
Long l2 = this.e.get(Long.valueOf(j2));
if (l2 == null || l2.longValue() != longValue) {
z3 = true;
}
if (z4 || z3) {
Logger logger2 = this.m;
String str2 = a;
d0.z.d.m.checkNotNullExpressionValue(str2, "TAG");
Logger.i$default(logger2, str2, "creating user: " + j2 + " with audio SSRC: " + i2 + " and video SSRC: " + num, null, 4, null);
Logger logger = this.l;
Logger.i$default(logger, "MediaEngineConnectionLegacy", "creating user: " + j2 + " with audio SSRC: " + i2 + " and video SSRC: " + num, null, 4, null);
z(new a(this, j2, i2, longValue, z2, f2));
}
if (z2) {
this.g.add(Long.valueOf(j2));
this.f.add(Long.valueOf(j2));
} else {
this.g.remove(Long.valueOf(j2));
this.f.remove(Long.valueOf(j2));
}
this.e.put(Long.valueOf(j2), Integer.valueOf(i2));
this.f.put(Long.valueOf(j2), Long.valueOf(longValue));
this.d.put(Long.valueOf(j2), Integer.valueOf(i2));
this.e.put(Long.valueOf(j2), Long.valueOf(longValue));
}
@Override // com.discord.rtcconnection.mediaengine.MediaEngineConnection
@ -805,7 +794,7 @@ public final class e implements MediaEngineConnection {
@Override // com.discord.rtcconnection.mediaengine.MediaEngineConnection
public boolean u(long j2) {
return this.g.contains(Long.valueOf(j2));
return this.f.contains(Long.valueOf(j2));
}
@Override // com.discord.rtcconnection.mediaengine.MediaEngineConnection
@ -817,28 +806,25 @@ public final class e implements MediaEngineConnection {
public void w(long j2, boolean z2) {
z(new k(j2, z2));
if (z2) {
this.g.add(Long.valueOf(j2));
this.f.add(Long.valueOf(j2));
} else {
this.g.remove(Long.valueOf(j2));
this.f.remove(Long.valueOf(j2));
}
y(new l(j2, z2));
}
public final void y(Function1<? super MediaEngineConnection.d, Unit> function1) {
for (MediaEngineConnection.d dVar : this.b) {
for (MediaEngineConnection.d dVar : this.a) {
try {
d0.z.d.m.checkNotNullExpressionValue(dVar, "it");
function1.invoke(dVar);
} catch (Exception e) {
Logger logger = this.m;
String str = a;
d0.z.d.m.checkNotNullExpressionValue(str, "TAG");
Logger.e$default(logger, str, "Error in listener", e, null, 8, null);
Logger.e$default(this.l, "MediaEngineConnectionLegacy", "Error in listener", e, null, 8, null);
}
}
}
public final synchronized void z(Function1<? super Connection, Unit> function1) {
function1.invoke(this.k);
function1.invoke(this.j);
}
}

5
app/src/main/java/c/a/q/m0/c/f.java
View File

@ -21,9 +21,6 @@ public final class f implements Connection.GetStatsCallback {
@Override // co.discord.media_engine.Connection.GetStatsCallback
public void onStatsError(Throwable th) {
Logger logger = this.a.this$0.m;
String str = e.a;
m.checkNotNullExpressionValue(str, "TAG");
Logger.e$default(logger, str, "error collecting stats", th, null, 8, null);
Logger.e$default(this.a.this$0.l, "MediaEngineConnectionLegacy", "error collecting stats", th, null, 8, null);
}
}

2
app/src/main/java/c/a/q/m0/c/h.java
View File

@ -35,7 +35,7 @@ public final class h extends o implements Function1<MediaEngineConnection.d, Uni
long j = this.$userId;
String str = this.$streamId;
Integer intOrNull = str != null ? s.toIntOrNull(str) : null;
Integer num = this.this$0.e.get(Long.valueOf(this.$userId));
Integer num = this.this$0.d.get(Long.valueOf(this.$userId));
int intValue = num != null ? num.intValue() : 0;
int i = this.$videoSsrc;
Objects.requireNonNull(this.this$0);

2
app/src/main/java/c/a/q/m0/c/k.java
View File

@ -366,7 +366,7 @@ public final class k implements MediaEngine {
discord2.setEchoCancellation(z2);
}
k kVar3 = this.this$0;
boolean z4 = voiceConfig.f2139c;
boolean z4 = voiceConfig.f2144c;
Discord discord3 = kVar3.f;
if (discord3 != null) {
discord3.setNoiseSuppression(z4);

181
app/src/main/java/c/a/q/n0/a.java
View File

@ -5,7 +5,6 @@ import android.os.Looper;
import android.os.Process;
import androidx.annotation.AnyThread;
import androidx.core.app.NotificationCompat;
import androidx.core.view.PointerIconCompat;
import com.airbnb.lottie.parser.AnimatableValueParser;
import com.discord.models.domain.ModelAuditLogEntry;
import com.discord.rtcconnection.socket.io.Opcodes;
@ -31,7 +30,6 @@ import java.util.Timer;
import java.util.TimerTask;
import java.util.concurrent.CopyOnWriteArraySet;
import java.util.concurrent.TimeUnit;
import javax.net.ssl.SSLException;
import javax.net.ssl.SSLSocketFactory;
import kotlin.Unit;
import kotlin.jvm.functions.Function0;
@ -197,7 +195,7 @@ public final class a extends WebSocketListener implements DebugPrintable {
@Override // java.util.TimerTask, java.lang.Runnable
public void run() {
this.i.o(new C0041a(this));
this.i.n(new C0041a(this));
}
}
@ -247,20 +245,10 @@ public final class a extends WebSocketListener implements DebugPrintable {
/* renamed from: invoke */
public Unit mo1invoke() {
if (!(!m.areEqual(this.$webSocket, this.this$0.r))) {
if (this.$t instanceof SSLException) {
a.d(this.this$0, null, 1);
a aVar = this.this$0;
aVar.b();
for (d dVar : aVar.p) {
m.checkNotNullExpressionValue(dVar, "it");
dVar.b(false, Integer.valueOf((int) PointerIconCompat.TYPE_CONTEXT_MENU), null);
}
} else {
a aVar2 = this.this$0;
StringBuilder L = c.d.b.a.a.L("An error with the websocket occurred: ");
L.append(this.$t.getMessage());
a.a(aVar2, true, null, L.toString());
}
a aVar = this.this$0;
StringBuilder L = c.d.b.a.a.L("An error with the websocket occurred: ");
L.append(this.$t.getMessage());
a.a(aVar, true, null, L.toString());
}
return Unit.a;
}
@ -296,7 +284,7 @@ public final class a extends WebSocketListener implements DebugPrintable {
long currentTimeMillis = aVar.H.currentTimeMillis();
Long l = aVar.f224z;
long longValue = currentTimeMillis - (l != null ? l.longValue() : 0);
aVar.k("[READY] took " + longValue + " ms");
aVar.j("[READY] took " + longValue + " ms");
aVar.b();
for (d dVar : aVar.p) {
m.checkNotNullExpressionValue(dVar, "it");
@ -305,7 +293,7 @@ public final class a extends WebSocketListener implements DebugPrintable {
break;
case 3:
a aVar2 = this.this$0;
aVar2.p(3, String.valueOf(aVar2.H.currentTimeMillis()));
aVar2.o(3, String.valueOf(aVar2.H.currentTimeMillis()));
break;
case 4:
a aVar3 = this.this$0;
@ -348,7 +336,7 @@ public final class a extends WebSocketListener implements DebugPrintable {
long longValue2 = ((Number) c5).longValue();
long currentTimeMillis2 = aVar5.H.currentTimeMillis();
long j = currentTimeMillis2 - longValue2;
aVar5.j("got heartbeat ack after " + j + " ms");
aVar5.i("got heartbeat ack after " + j + " ms");
aVar5.f222x = Long.valueOf(currentTimeMillis2);
aVar5.v = true;
aVar5.b();
@ -364,7 +352,7 @@ public final class a extends WebSocketListener implements DebugPrintable {
a aVar6 = this.this$0;
StringBuilder L = c.d.b.a.a.L("unknown opcode: ");
L.append(this.$message.getOpcode());
aVar6.k(L.toString());
aVar6.j(L.toString());
break;
case 8:
a aVar7 = this.this$0;
@ -375,12 +363,12 @@ public final class a extends WebSocketListener implements DebugPrintable {
if (timerTask != null) {
timerTask.cancel();
}
aVar7.k("[HELLO] raw: " + hello);
aVar7.j("[HELLO] raw: " + hello);
aVar7.u = Long.valueOf(hello.getHeartbeatIntervalMs());
aVar7.q = hello.getServerVersion();
aVar7.w.cancel();
aVar7.v = true;
aVar7.m();
aVar7.l();
break;
case 9:
this.this$0.o.succeed();
@ -484,16 +472,16 @@ public final class a extends WebSocketListener implements DebugPrintable {
L.append(aVar.B);
L.append(" -- isHeartbeatRecentEnough: ");
L.append(z2);
aVar.h(false, 4801, L.toString());
aVar.g(false, 4801, L.toString());
} else {
aVar.k("[RESUME] resuming session. serverId=" + str2 + " sessionId=" + str);
aVar.j("[RESUME] resuming session. serverId=" + str2 + " sessionId=" + str);
aVar.b();
for (d dVar2 : aVar.p) {
m.checkNotNullExpressionValue(dVar2, "it");
dVar2.h();
}
aVar.A = c.RESUMING;
aVar.p(7, new Payloads.Resume(str3, str, str2));
aVar.o(7, new Payloads.Resume(str3, str, str2));
}
}
a aVar2 = this.this$0;
@ -504,7 +492,7 @@ public final class a extends WebSocketListener implements DebugPrintable {
a aVar3 = this.this$0;
StringBuilder L2 = c.d.b.a.a.L("[CONNECTED] to ");
L2.append(this.this$0.C);
aVar3.k(L2.toString());
aVar3.j(L2.toString());
a aVar4 = this.this$0;
aVar4.b();
for (d dVar3 : aVar4.p) {
@ -565,22 +553,17 @@ public final class a extends WebSocketListener implements DebugPrintable {
public static final void a(a aVar, boolean z2, Integer num, String str) {
aVar.A = c.DISCONNECTED;
if ((num != null && num.intValue() == 4004) || ((num != null && num.intValue() == 4015) || ((num != null && num.intValue() == 4011) || (num != null && num.intValue() == 4006)))) {
aVar.h(true, num, str);
aVar.g(true, num, str);
} else if (aVar.o.hasReachedFailureThreshold()) {
aVar.l("[WS CLOSED] Backoff exceeded. Resetting.");
aVar.h(z2, num, str);
aVar.k("[WS CLOSED] Backoff exceeded. Resetting.");
aVar.g(z2, num, str);
} else {
aVar.c(null);
String H = c.d.b.a.a.H(new Object[]{Double.valueOf(((double) aVar.o.fail(new c(aVar, z2, num, str))) / 1000.0d)}, 1, "%.2f", "java.lang.String.format(this, *args)");
aVar.l("`[WS CLOSED] (" + z2 + ", " + num + ", " + str + ") retrying in " + H + " seconds.");
aVar.k("`[WS CLOSED] (" + z2 + ", " + num + ", " + str + ") retrying in " + H + " seconds.");
}
}
public static /* synthetic */ void d(a aVar, Function1 function1, int i2) {
int i3 = i2 & 1;
aVar.c(null);
}
public final void b() {
c.a.q.c cVar = this.G;
Objects.requireNonNull(cVar);
@ -607,21 +590,9 @@ public final class a extends WebSocketListener implements DebugPrintable {
this.r = null;
}
@Override // com.discord.utilities.debug.DebugPrintable
public void debugPrint(DebugPrintBuilder debugPrintBuilder) {
m.checkNotNullParameter(debugPrintBuilder, "dp");
debugPrintBuilder.appendKeyValue("serverId", this.f221s);
debugPrintBuilder.appendKeyValue("sessionId", this.t);
debugPrintBuilder.appendKeyValue("heartbeatInterval", this.u);
debugPrintBuilder.appendKeyValue("lastHeartbeatAckTime", this.f222x);
debugPrintBuilder.appendKeyValue("connectionStartTime", this.f224z);
debugPrintBuilder.appendKeyValue("connectionState", this.A);
debugPrintBuilder.appendKeyValue("resumable", Boolean.valueOf(this.B));
}
public final void e() {
public final void d() {
b();
k("[CLOSE]");
j("[CLOSE]");
c(e.i);
this.f221s = null;
this.t = null;
@ -634,14 +605,26 @@ public final class a extends WebSocketListener implements DebugPrintable {
}
}
public final boolean f() {
@Override // com.discord.utilities.debug.DebugPrintable
public void debugPrint(DebugPrintBuilder debugPrintBuilder) {
m.checkNotNullParameter(debugPrintBuilder, "dp");
debugPrintBuilder.appendKeyValue("serverId", this.f221s);
debugPrintBuilder.appendKeyValue("sessionId", this.t);
debugPrintBuilder.appendKeyValue("heartbeatInterval", this.u);
debugPrintBuilder.appendKeyValue("lastHeartbeatAckTime", this.f222x);
debugPrintBuilder.appendKeyValue("connectionStartTime", this.f224z);
debugPrintBuilder.appendKeyValue("connectionState", this.A);
debugPrintBuilder.appendKeyValue("resumable", Boolean.valueOf(this.B));
}
public final boolean e() {
b();
if (this.A != c.DISCONNECTED) {
l("Cannot start a new connection, connection state is not disconnected");
k("Cannot start a new connection, connection state is not disconnected");
return false;
}
this.A = c.CONNECTING;
g();
f();
b();
for (d dVar : this.p) {
m.checkNotNullExpressionValue(dVar, "it");
@ -650,10 +633,10 @@ public final class a extends WebSocketListener implements DebugPrintable {
return true;
}
public final void g() {
public final void f() {
StringBuilder L = c.d.b.a.a.L("[CONNECT] ");
L.append(this.C);
k(L.toString());
j(L.toString());
if (this.r != null) {
this.F.e(this.l, "Connect called with already existing websocket", null, null);
c(f.i);
@ -671,19 +654,19 @@ public final class a extends WebSocketListener implements DebugPrintable {
aVar.a(1, TimeUnit.MINUTES);
SSLSocketFactory sSLSocketFactory = this.E;
if (sSLSocketFactory != null) {
h.a aVar2 = f0.e0.k.h.f2792c;
h.a aVar2 = f0.e0.k.h.f2797c;
aVar.b(sSLSocketFactory, f0.e0.k.h.a.n());
}
String D = c.d.b.a.a.D(new StringBuilder(), this.C, "?v=5");
k("attempting WSS connection with " + D);
j("attempting WSS connection with " + D);
x xVar = new x(aVar);
Request.a aVar3 = new Request.a();
aVar3.f(D);
this.r = xVar.g(aVar3.a(), this);
}
public final void h(boolean z2, Integer num, String str) {
l("[DISCONNECT] (" + z2 + ", " + num + ", " + str + ')');
public final void g(boolean z2, Integer num, String str) {
k("[DISCONNECT] (" + z2 + ", " + num + ", " + str + ')');
c(null);
this.f221s = null;
this.t = null;
@ -696,40 +679,40 @@ public final class a extends WebSocketListener implements DebugPrintable {
}
}
public final void i(long j2, String str, boolean z2) {
public final void h(long j2, String str, boolean z2) {
m.checkNotNullParameter(str, ModelAuditLogEntry.CHANGE_KEY_REASON);
b();
if (this.r != null) {
k("Performing an immediate heartbeat on existing socket: " + str);
j("Performing an immediate heartbeat on existing socket: " + str);
this.w.cancel();
b bVar = new b(this);
this.w = bVar;
this.n.schedule(bVar, j2);
} else if (!z2) {
k("Immediate heartbeat requested, but is disconnected and a reset was not requested: " + str);
j("Immediate heartbeat requested, but is disconnected and a reset was not requested: " + str);
} else if (this.o.isPending() && this.r == null) {
k("Connection backoff reset Immediate heartbeat when socket was disconnected.");
j("Connection backoff reset Immediate heartbeat when socket was disconnected.");
this.o.succeed();
n(false, 4802, "Reset backoff.");
m(false, 4802, "Reset backoff.");
}
}
public final void j(String str) {
public final void i(String str) {
Logger.d$default(this.F, this.l, str, null, 4, null);
}
public final void k(String str) {
public final void j(String str) {
Logger.i$default(this.F, this.l, str, null, 4, null);
}
public final void l(String str) {
public final void k(String str) {
Logger.w$default(this.F, this.l, str, null, 4, null);
}
public final void m() {
public final void l() {
if (this.v) {
this.v = false;
p(3, String.valueOf(this.H.currentTimeMillis()));
o(3, String.valueOf(this.H.currentTimeMillis()));
Long l2 = this.u;
if (l2 != null) {
b bVar = new b(this);
@ -737,25 +720,25 @@ public final class a extends WebSocketListener implements DebugPrintable {
this.n.schedule(bVar, l2.longValue());
return;
}
l("onHeartbeatInterval called when heartbeatInterval was null");
k("onHeartbeatInterval called when heartbeatInterval was null");
return;
}
c(d.i);
String H = c.d.b.a.a.H(new Object[]{Double.valueOf(((double) this.o.fail(new e(this))) / 1000.0d)}, 1, "%.2f", "java.lang.String.format(this, *args)");
l("[ACK TIMEOUT] reconnecting in " + H + " seconds.");
k("[ACK TIMEOUT] reconnecting in " + H + " seconds.");
}
public final void n(boolean z2, Integer num, String str) {
k("[RECONNECT] wasFatal=" + z2 + " code=" + num + " reason=" + str);
public final void m(boolean z2, Integer num, String str) {
j("[RECONNECT] wasFatal=" + z2 + " code=" + num + " reason=" + str);
c(l.i);
this.A = c.RECONNECTING;
g();
f();
}
/* JADX WARN: Multi-variable type inference failed */
/* JADX WARNING: Unknown variable types count: 1 */
@AnyThread
public final void o(Function0<Unit> function0) {
public final void n(Function0<Unit> function0) {
c.a.q.c cVar = this.G;
if (function0 != null) {
function0 = new f(function0);
@ -763,12 +746,30 @@ public final class a extends WebSocketListener implements DebugPrintable {
cVar.k.execute((Runnable) function0);
}
public final void o(int i2, Object obj) {
WebSocket webSocket = this.r;
if (webSocket == null) {
StringBuilder L = c.d.b.a.a.L("opcode() websocket null. opcode: ");
L.append(Opcodes.INSTANCE.getNameOf(i2));
this.F.e(this.l, L.toString(), null, null);
return;
}
try {
String m = this.m.m(new Payloads.Outgoing(i2, obj));
i("sending (" + Opcodes.INSTANCE.getNameOf(i2) + "): " + m);
m.checkNotNullExpressionValue(m, "json");
webSocket.a(m);
} catch (Exception unused) {
k("exception sending opcode: " + i2 + " and payload: " + obj);
}
}
@Override // okhttp3.WebSocketListener
public void onClosed(WebSocket webSocket, int i2, String str) {
m.checkNotNullParameter(webSocket, "webSocket");
m.checkNotNullParameter(str, ModelAuditLogEntry.CHANGE_KEY_REASON);
super.onClosed(webSocket, i2, str);
o(new h(this, webSocket, i2, str));
n(new h(this, webSocket, i2, str));
}
@Override // okhttp3.WebSocketListener
@ -783,21 +784,21 @@ public final class a extends WebSocketListener implements DebugPrintable {
m.checkNotNullParameter(webSocket, "webSocket");
m.checkNotNullParameter(th, "t");
super.onFailure(webSocket, th, response);
o(new i(this, webSocket, th));
n(new i(this, webSocket, th));
}
@Override // okhttp3.WebSocketListener
public void onMessage(WebSocket webSocket, String str) {
m.checkNotNullParameter(webSocket, "webSocket");
m.checkNotNullParameter(str, NotificationCompat.MessagingStyle.Message.KEY_TEXT);
Payloads.Incoming incoming = (Payloads.Incoming) c.i.a.f.e.o.c.q0(Payloads.Incoming.class).cast(this.m.g(str, Payloads.Incoming.class));
Payloads.Incoming incoming = (Payloads.Incoming) c.i.a.f.e.o.c.r0(Payloads.Incoming.class).cast(this.m.g(str, Payloads.Incoming.class));
super.onMessage(webSocket, str);
StringBuilder L = c.d.b.a.a.L("received (");
L.append(Opcodes.INSTANCE.getNameOf(incoming.getOpcode()));
L.append("): ");
L.append(incoming);
j(L.toString());
o(new j(this, webSocket, incoming));
i(L.toString());
n(new j(this, webSocket, incoming));
}
@Override // okhttp3.WebSocketListener
@ -805,24 +806,6 @@ public final class a extends WebSocketListener implements DebugPrintable {
m.checkNotNullParameter(webSocket, "webSocket");
m.checkNotNullParameter(response, "response");
super.onOpen(webSocket, response);
o(new k(this, webSocket));
}
public final void p(int i2, Object obj) {
WebSocket webSocket = this.r;
if (webSocket == null) {
StringBuilder L = c.d.b.a.a.L("opcode() websocket null. opcode: ");
L.append(Opcodes.INSTANCE.getNameOf(i2));
this.F.e(this.l, L.toString(), null, null);
return;
}
try {
String m = this.m.m(new Payloads.Outgoing(i2, obj));
j("sending (" + Opcodes.INSTANCE.getNameOf(i2) + "): " + m);
m.checkNotNullExpressionValue(m, "json");
webSocket.a(m);
} catch (Exception unused) {
l("exception sending opcode: " + i2 + " and payload: " + obj);
}
n(new k(this, webSocket));
}
}

4
app/src/main/java/c/a/q/n0/b.java
View File

@ -24,7 +24,7 @@ public final class b extends TimerTask {
public Unit mo1invoke() {
a aVar = this.this$0.i;
int i = a.i;
aVar.m();
aVar.l();
return Unit.a;
}
}
@ -35,6 +35,6 @@ public final class b extends TimerTask {
@Override // java.util.TimerTask, java.lang.Runnable
public void run() {
this.i.o(new a(this));
this.i.n(new a(this));
}
}

2
app/src/main/java/c/a/q/n0/c.java
View File

@ -28,7 +28,7 @@ public final class c extends o implements Function0<Unit> {
Integer num = this.$code;
String str = this.$reason;
int i = a.i;
aVar.n(z2, num, str);
aVar.m(z2, num, str);
return Unit.a;
}
}

2
app/src/main/java/c/a/q/n0/e.java
View File

@ -19,7 +19,7 @@ public final class e extends o implements Function0<Unit> {
public Unit mo1invoke() {
a aVar = this.this$0;
int i = a.i;
aVar.n(true, 4800, "Heartbeat timeout.");
aVar.m(true, 4800, "Heartbeat timeout.");
return Unit.a;
}
}

4
app/src/main/java/c/a/q/o.java
View File

@ -29,9 +29,9 @@ public final class o extends d0.z.d.o implements Function0<Unit> {
if (aVar == null) {
RtcConnection.o(rtcConnection, "handleConnectivityChange() socket was null.", null, null, 6);
} else if (booleanValue) {
aVar.i(5000, "network detected online", true);
aVar.h(5000, "network detected online", true);
} else {
aVar.i(15000, "network detected offline", false);
aVar.h(15000, "network detected offline", false);
}
return Unit.a;
}

6
app/src/main/java/c/a/q/o0/a.java
View File

@ -122,13 +122,13 @@ public final /* synthetic */ class a extends k implements Function1<Stats, Unit>
if (booleanValue) {
krispOveruseDetector.d.f(KrispOveruseDetector.Status.CPU_OVERUSE);
} else if (longValue == 0) {
int i = krispOveruseDetector.f2120c + 1;
krispOveruseDetector.f2120c = i;
int i = krispOveruseDetector.f2124c + 1;
krispOveruseDetector.f2124c = i;
if (i > 2) {
krispOveruseDetector.d.f(KrispOveruseDetector.Status.FAILED);
}
} else {
krispOveruseDetector.f2120c = 0;
krispOveruseDetector.f2124c = 0;
}
}
krispOveruseDetector.b = stats2.getOutboundRtpAudio();

7
app/src/main/java/c/a/q/p.java
View File

@ -1,6 +1,7 @@
package c.a.q;
import com.discord.rtcconnection.RtcConnection;
import d0.z.d.m;
import rx.functions.Action1;
/* compiled from: RtcConnection.kt */
public final class p<T> implements Action1<Boolean> {
@ -13,6 +14,10 @@ public final class p<T> implements Action1<Boolean> {
/* JADX DEBUG: Method arguments types fixed to match base method, original types: [java.lang.Object] */
@Override // rx.functions.Action1
public void call(Boolean bool) {
this.i.s(new o(this, bool));
Boolean bool2 = bool;
this.i.s(new o(this, bool2));
RtcConnection rtcConnection = this.i;
m.checkNotNullExpressionValue(bool2, "isConnected");
rtcConnection.F = bool2.booleanValue() ? null : Long.valueOf(this.i.V.currentTimeMillis());
}
}

2
app/src/main/java/c/a/q/r.java
View File

@ -13,6 +13,6 @@ public final class r extends RtcConnection.b {
@Override // com.discord.rtcconnection.RtcConnection.b, com.discord.rtcconnection.RtcConnection.c
public void onStateChange(RtcConnection.StateChange stateChange) {
m.checkNotNullParameter(stateChange, "stateChange");
this.i.f2125s.onNext(stateChange);
this.i.f2130s.onNext(stateChange);
}
}

16
app/src/main/java/c/a/q/s.java
View File

@ -34,7 +34,7 @@ public final class s extends o implements Function0<Unit> {
if (str == null || str.length() == 0) {
a aVar = rtcConnection.v;
if (aVar != null) {
aVar.e();
aVar.d();
}
rtcConnection.u(RtcConnection.State.b.a);
} else {
@ -43,7 +43,7 @@ public final class s extends o implements Function0<Unit> {
String replace$default2 = t.replace$default(t, ":80", ":443", false, 4, (Object) null);
a aVar2 = rtcConnection.v;
if (aVar2 != null) {
aVar2.e();
aVar2.d();
}
if (rtcConnection.t) {
RtcConnection.j(rtcConnection, false, "Connect called on destroyed instance.", null, false, 4);
@ -53,16 +53,16 @@ public final class s extends o implements Function0<Unit> {
rtcConnection.r("connecting via endpoint: " + replace$default + " token: " + str2);
try {
URI uri = new URI(t);
rtcConnection.f2126x = uri.getHost();
rtcConnection.f2127y = Integer.valueOf(uri.getPort());
rtcConnection.f2131x = uri.getHost();
rtcConnection.f2132y = Integer.valueOf(uri.getPort());
} catch (Exception e) {
rtcConnection.T.e(rtcConnection.k, "Failed to parse RTC endpoint", e, g0.mapOf(d0.o.to("endpoint", replace$default)));
rtcConnection.U.e(rtcConnection.k, "Failed to parse RTC endpoint", e, g0.mapOf(d0.o.to("endpoint", replace$default)));
}
a aVar3 = new a(replace$default2, str2, sSLSocketFactory, rtcConnection.T, rtcConnection.S.c(), rtcConnection.U, rtcConnection.k);
h0 h0Var = rtcConnection.K;
a aVar3 = new a(replace$default2, str2, sSLSocketFactory, rtcConnection.U, rtcConnection.T.c(), rtcConnection.V, rtcConnection.k);
h0 h0Var = rtcConnection.L;
m.checkNotNullParameter(h0Var, "listener");
aVar3.p.add(h0Var);
aVar3.f();
aVar3.e();
rtcConnection.v = aVar3;
}
}

4
app/src/main/java/c/a/q/w.java
View File

@ -27,10 +27,10 @@ public final class w extends o implements Function0<Unit> {
/* renamed from: invoke */
public Unit mo1invoke() {
RtcConnection rtcConnection = this.this$0;
rtcConnection.B = Long.valueOf(rtcConnection.U.currentTimeMillis());
rtcConnection.B = Long.valueOf(rtcConnection.V.currentTimeMillis());
RtcConnection rtcConnection2 = this.this$0;
rtcConnection2.D++;
rtcConnection2.E = rtcConnection2.S.a().c0(2, TimeUnit.SECONDS).W(new t(this), new v(this));
rtcConnection2.E = rtcConnection2.T.a().b0(2, TimeUnit.SECONDS).V(new t(this), new v(this));
return Unit.a;
}
}

2
app/src/main/java/c/a/r/b.java
View File

@ -77,7 +77,7 @@ public final class b extends k implements Function2<CoroutineScope, Continuation
}
String joinToString$default = u.joinToString$default(arrayList, "&", null, null, 0, null, null, 62, null);
RequestBody.Companion companion = RequestBody.Companion;
MediaType.a aVar = MediaType.f2909c;
MediaType.a aVar = MediaType.f2914c;
RequestBody a = companion.a(joinToString$default, MediaType.a.a(ShareTarget.ENCODING_TYPE_URL_ENCODED));
Request.a aVar2 = new Request.a();
m.checkParameterIsNotNull(a, "body");

3
app/src/main/java/c/a/y/d.java
View File

@ -2,7 +2,6 @@ package c.a.y;
import android.view.KeyEvent;
import android.view.View;
import androidx.core.app.NotificationCompat;
import com.discord.views.CodeVerificationView;
import d0.g0.y;
import d0.z.d.m;
@ -17,7 +16,7 @@ public final class d implements View.OnKeyListener {
@Override // android.view.View.OnKeyListener
public final boolean onKey(View view, int i, KeyEvent keyEvent) {
m.checkNotNullExpressionValue(keyEvent, NotificationCompat.CATEGORY_EVENT);
m.checkNotNullExpressionValue(keyEvent, "event");
if (keyEvent.getAction() == 0) {
CodeVerificationView codeVerificationView = this.i;
CodeVerificationView.a aVar = CodeVerificationView.i;

2
app/src/main/java/c/a/y/j0/e.java
View File

@ -4,7 +4,7 @@ import org.webrtc.RendererCommon;
import rx.subjects.BehaviorSubject;
/* compiled from: RxRendererEvents.kt */
public final class e implements RendererCommon.RendererEvents {
public final BehaviorSubject<a> i = BehaviorSubject.k0();
public final BehaviorSubject<a> i = BehaviorSubject.j0();
/* compiled from: RxRendererEvents.kt */
public static final class a {

6
app/src/main/java/c/a/y/l.java
View File

@ -71,9 +71,9 @@ public abstract class l extends OverlayDialog implements AppComponent {
public l(Context context) {
super(context);
m.checkNotNullParameter(context, "context");
PublishSubject k0 = PublishSubject.k0();
m.checkNotNullExpressionValue(k0, "PublishSubject.create()");
this.w = k0;
PublishSubject j02 = PublishSubject.j0();
m.checkNotNullExpressionValue(j02, "PublishSubject.create()");
this.w = j02;
setOnClickListener(new k(this));
}

7
app/src/main/java/c/a/y/l0/c/a.java
View File

@ -41,14 +41,11 @@ public final class a extends MGRecyclerViewHolder<c, d> {
m.checkNotNullParameter(dVar2, "data");
super.onConfigure(i, dVar2);
d.a aVar = (d.a) dVar2;
long j = aVar.k;
String str = aVar.l;
String str2 = aVar.m;
SimpleDraweeView simpleDraweeView = this.a.b;
m.checkNotNullExpressionValue(simpleDraweeView, "binding.discoveryStageCardSpeakerAvatar");
SimpleDraweeViewExtensionsKt.setUserIcon$default(simpleDraweeView, Long.valueOf(j), str, null, false, R.dimen.avatar_size_medium, 12, null);
SimpleDraweeViewExtensionsKt.setAvatar$default(simpleDraweeView, aVar.k, false, R.dimen.avatar_size_medium, aVar.l, 2, null);
TextView textView = this.a.f64c;
m.checkNotNullExpressionValue(textView, "binding.discoveryStageCardSpeakerName");
textView.setText(str2);
textView.setText(aVar.m);
}
}

48
app/src/main/java/c/a/y/l0/c/d.java
View File

@ -1,5 +1,7 @@
package c.a.y.l0.c;
import com.discord.models.member.GuildMember;
import com.discord.models.user.User;
import com.discord.utilities.mg_recycler.MGRecyclerDataPayload;
import d0.z.d.m;
import kotlin.jvm.internal.DefaultConstructorMarker;
@ -10,20 +12,21 @@ public abstract class d implements MGRecyclerDataPayload {
/* compiled from: SpeakersItem.kt */
public static final class a extends d {
public final long k;
public final String l;
public final User k;
public final GuildMember l;
public final String m;
public final String n;
/* JADX INFO: super call moved to the top of the method (can break code semantics) */
public a(long j, String str, String str2, String str3) {
super(String.valueOf(j), 0, null);
m.checkNotNullParameter(str2, "displayName");
m.checkNotNullParameter(str3, "positionKey");
this.k = j;
this.l = str;
this.m = str2;
this.n = str3;
public a(User user, GuildMember guildMember, String str, String str2) {
super(String.valueOf(user.getId()), 0, null);
m.checkNotNullParameter(user, "user");
m.checkNotNullParameter(str, "displayName");
m.checkNotNullParameter(str2, "positionKey");
this.k = user;
this.l = guildMember;
this.m = str;
this.n = str2;
}
public boolean equals(Object obj) {
@ -34,27 +37,28 @@ public abstract class d implements MGRecyclerDataPayload {
return false;
}
a aVar = (a) obj;
return this.k == aVar.k && m.areEqual(this.l, aVar.l) && m.areEqual(this.m, aVar.m) && m.areEqual(this.n, aVar.n);
return m.areEqual(this.k, aVar.k) && m.areEqual(this.l, aVar.l) && m.areEqual(this.m, aVar.m) && m.areEqual(this.n, aVar.n);
}
public int hashCode() {
int a = a0.a.a.b.a(this.k) * 31;
String str = this.l;
User user = this.k;
int i = 0;
int hashCode = (a + (str != null ? str.hashCode() : 0)) * 31;
String str2 = this.m;
int hashCode2 = (hashCode + (str2 != null ? str2.hashCode() : 0)) * 31;
String str3 = this.n;
if (str3 != null) {
i = str3.hashCode();
int hashCode = (user != null ? user.hashCode() : 0) * 31;
GuildMember guildMember = this.l;
int hashCode2 = (hashCode + (guildMember != null ? guildMember.hashCode() : 0)) * 31;
String str = this.m;
int hashCode3 = (hashCode2 + (str != null ? str.hashCode() : 0)) * 31;
String str2 = this.n;
if (str2 != null) {
i = str2.hashCode();
}
return hashCode2 + i;
return hashCode3 + i;
}
public String toString() {
StringBuilder L = c.d.b.a.a.L("IndividualSpeakerItem(userId=");
StringBuilder L = c.d.b.a.a.L("IndividualSpeakerItem(user=");
L.append(this.k);
L.append(", userAvatar=");
L.append(", guildMember=");
L.append(this.l);
L.append(", displayName=");
L.append(this.m);

2
app/src/main/java/c/a/y/n0/a.java
View File

@ -21,6 +21,6 @@ public final class a implements View.OnClickListener {
if (!(googlePlayInAppSku == null || (function1 = giftSelectView.j) == null)) {
function1.invoke(googlePlayInAppSku);
}
giftSelectView.i.f1773c.setOnClickListener(null);
giftSelectView.i.f1775c.setOnClickListener(null);
}
}

12
app/src/main/java/c/a/y/w.java
View File

@ -90,9 +90,9 @@ public final class w extends OverlayBubbleWrap implements AppComponent {
s0 s0Var = new s0(simpleDraweeView, simpleDraweeView);
m.checkNotNullExpressionValue(s0Var, "OverlayVoiceBubbleBindin…rom(context), this, true)");
this.f245x = s0Var;
PublishSubject k0 = PublishSubject.k0();
m.checkNotNullExpressionValue(k0, "PublishSubject.create()");
this.f246y = k0;
PublishSubject j02 = PublishSubject.j0();
m.checkNotNullExpressionValue(j02, "PublishSubject.create()");
this.f246y = j02;
}
@Override // com.discord.overlay.views.OverlayBubbleWrap
@ -130,9 +130,9 @@ public final class w extends OverlayBubbleWrap implements AppComponent {
@Override // android.view.View, android.view.ViewGroup
public void onAttachedToWindow() {
super.onAttachedToWindow();
Observable<R> Y = StoreStream.Companion.getVoiceChannelSelected().observeSelectedVoiceChannelId().Y(a.i);
m.checkNotNullExpressionValue(Y, "StoreStream\n .get…d()\n }\n }");
ObservableExtensionsKt.appSubscribe$default(ObservableExtensionsKt.ui$default(ObservableExtensionsKt.computationLatest(Y), this, null, 2, null), w.class, getContext(), (Function1) null, (Function1) null, (Function0) null, (Function0) null, new b(this), 60, (Object) null);
Observable<R> X = StoreStream.Companion.getVoiceChannelSelected().observeSelectedVoiceChannelId().X(a.i);
m.checkNotNullExpressionValue(X, "StoreStream\n .get…d()\n }\n }");
ObservableExtensionsKt.appSubscribe$default(ObservableExtensionsKt.ui$default(ObservableExtensionsKt.computationLatest(X), this, null, 2, null), w.class, getContext(), (Function1) null, (Function1) null, (Function0) null, (Function0) null, new b(this), 60, (Object) null);
}
@Override // com.discord.overlay.views.OverlayBubbleWrap, android.view.View

2
app/src/main/java/c/a/y/z.java
View File

@ -33,7 +33,7 @@ import rx.Observable;
import rx.subjects.BehaviorSubject;
/* compiled from: OverlayVoiceSelectorBubbleDialog.kt */
public final class z extends l implements AppComponent {
public final BehaviorSubject<String> A = BehaviorSubject.l0("");
public final BehaviorSubject<String> A = BehaviorSubject.k0("");
public String B;
/* renamed from: y reason: collision with root package name */

34
app/src/main/java/c/a/z/a/a/d.java
View File

@ -1,36 +1,22 @@
package c.a.z.a.a;
import com.discord.api.channel.Channel;
import com.discord.stores.StoreStream;
import com.discord.utilities.rx.ObservableExtensionsKt;
import d0.z.d.m;
import c.d.b.a.a;
import com.discord.models.member.GuildMember;
import com.discord.models.user.User;
import com.discord.widgets.channels.SimpleMembersAdapter;
import j0.k.b;
import j0.l.e.j;
import java.util.concurrent.TimeUnit;
import rx.Observable;
import java.util.Map;
/* compiled from: lambda */
public final /* synthetic */ class d implements b {
public final /* synthetic */ long i;
public final /* synthetic */ long j;
public final /* synthetic */ Observable k;
public final /* synthetic */ Map i;
public /* synthetic */ d(long j, long j2, Observable observable) {
this.i = j;
this.j = j2;
this.k = observable;
public /* synthetic */ d(Map map) {
this.i = map;
}
@Override // j0.k.b
public final Object call(Object obj) {
long j = this.i;
long j2 = this.j;
Observable observable = this.k;
Channel channel = (Channel) obj;
if (channel == null) {
return new j(null);
}
Observable h = Observable.h(StoreStream.getUsers().observeMe(), StoreStream.getGuilds().observeGuild(j), StoreStream.getPermissions().observePermissionsForChannel(j2), observable.o(300, TimeUnit.MILLISECONDS).Y(new g(j, channel)).r(), new h(channel));
m.checkNotNullExpressionValue(h, "observable");
return ObservableExtensionsKt.computationBuffered(h).r();
User user = (User) obj;
return new SimpleMembersAdapter.MemberItem(user, (GuildMember) a.c(user, this.i));
}
}

43
app/src/main/java/c/a/z/a/a/e.java
View File

@ -1,23 +1,36 @@
package c.a.z.a.a;
import c.d.b.a.a;
import com.discord.models.member.GuildMember;
import com.discord.models.user.User;
import java.util.Map;
import rx.functions.Func2;
import com.discord.api.channel.Channel;
import com.discord.stores.StoreStream;
import com.discord.utilities.rx.ObservableExtensionsKt;
import d0.z.d.m;
import j0.k.b;
import j0.l.e.j;
import java.util.concurrent.TimeUnit;
import rx.Observable;
/* compiled from: lambda */
public final /* synthetic */ class e implements Func2 {
public final /* synthetic */ Map i;
public final /* synthetic */ class e implements b {
public final /* synthetic */ long i;
public final /* synthetic */ long j;
public final /* synthetic */ Observable k;
public /* synthetic */ e(Map map) {
this.i = map;
public /* synthetic */ e(long j, long j2, Observable observable) {
this.i = j;
this.j = j2;
this.k = observable;
}
@Override // rx.functions.Func2
public final Object call(Object obj, Object obj2) {
Map map = this.i;
User user = (User) obj;
User user2 = (User) obj2;
return Integer.valueOf(GuildMember.compareUserNames(user, user2, (GuildMember) a.c(user, map), (GuildMember) a.c(user2, map)));
@Override // j0.k.b
public final Object call(Object obj) {
long j = this.i;
long j2 = this.j;
Observable observable = this.k;
Channel channel = (Channel) obj;
if (channel == null) {
return new j(null);
}
Observable h = Observable.h(StoreStream.getUsers().observeMe(), StoreStream.getGuilds().observeGuild(j), StoreStream.getPermissions().observePermissionsForChannel(j2), observable.o(300, TimeUnit.MILLISECONDS).X(new g(j, channel)).r(), new j(channel));
m.checkNotNullExpressionValue(h, "observable");
return ObservableExtensionsKt.computationBuffered(h).r();
}
}

27
app/src/main/java/c/a/z/a/a/f.java
View File

@ -1,22 +1,23 @@
package c.a.z.a.a;
import com.discord.stores.StoreStream;
import j0.k.b;
import java.util.List;
import c.d.b.a.a;
import com.discord.models.member.GuildMember;
import com.discord.models.user.User;
import java.util.Map;
import rx.functions.Func2;
/* compiled from: lambda */
public final /* synthetic */ class f implements b {
public final /* synthetic */ List i;
public final /* synthetic */ String j;
public final /* synthetic */ class f implements Func2 {
public final /* synthetic */ Map i;
public /* synthetic */ f(List list, String str) {
this.i = list;
this.j = str;
public /* synthetic */ f(Map map) {
this.i = map;
}
@Override // j0.k.b
public final Object call(Object obj) {
Map map = (Map) obj;
return StoreStream.getUsers().observeUsers(map.keySet()).Y(new k(this.i, map, this.j));
@Override // rx.functions.Func2
public final Object call(Object obj, Object obj2) {
Map map = this.i;
User user = (User) obj;
User user2 = (User) obj2;
return Integer.valueOf(GuildMember.compareUserNames(user, user2, (GuildMember) a.c(user, map), (GuildMember) a.c(user2, map)));
}
}

35
app/src/main/java/c/a/z/a/a/h.java
View File

@ -1,21 +1,32 @@
package c.a.z.a.a;
import com.discord.api.channel.Channel;
import com.discord.models.guild.Guild;
import com.discord.models.user.MeUser;
import com.discord.widgets.channels.permissions.WidgetChannelSettingsPermissionsAddMember;
import j0.k.b;
import j0.l.a.n;
import j0.l.a.o2;
import j0.l.a.r;
import j0.l.e.j;
import j0.l.e.l;
import java.util.List;
import rx.functions.Func4;
import java.util.Map;
import rx.Observable;
/* compiled from: lambda */
public final /* synthetic */ class h implements Func4 {
public final /* synthetic */ Channel a;
public final /* synthetic */ class h implements b {
public final /* synthetic */ List i;
public final /* synthetic */ Map j;
public final /* synthetic */ String k;
public /* synthetic */ h(Channel channel) {
this.a = channel;
public /* synthetic */ h(List list, Map map, String str) {
this.i = list;
this.j = map;
this.k = str;
}
@Override // rx.functions.Func4
public final Object call(Object obj, Object obj2, Object obj3, Object obj4) {
return WidgetChannelSettingsPermissionsAddMember.Model.lambda$null$1(this.a, (MeUser) obj, (Guild) obj2, (Long) obj3, (List) obj4);
@Override // j0.k.b
public final Object call(Object obj) {
List list = this.i;
Map map = this.j;
Observable g02 = Observable.g0(new r(Observable.A(((Map) obj).values()).x(new l(list)).x(new m(map)).x(new k(this.k)).i, new o2(new f(map), 10)));
l lVar = l.INSTANCE;
return (g02 instanceof j ? Observable.g0(new n.b(((j) g02).k, lVar)) : Observable.g0(new n(g02, lVar, j0.l.e.h.i))).F(new d(map)).e0();
}
}

16
app/src/main/java/c/a/z/a/a/i.java
View File

@ -1,18 +1,22 @@
package c.a.z.a.a;
import com.discord.models.user.User;
import com.discord.stores.StoreStream;
import j0.k.b;
import java.util.Locale;
import java.util.List;
import java.util.Map;
/* compiled from: lambda */
public final /* synthetic */ class i implements b {
public final /* synthetic */ String i;
public final /* synthetic */ List i;
public final /* synthetic */ String j;
public /* synthetic */ i(String str) {
this.i = str;
public /* synthetic */ i(List list, String str) {
this.i = list;
this.j = str;
}
@Override // j0.k.b
public final Object call(Object obj) {
return Boolean.valueOf(((User) obj).getUsername().toLowerCase(Locale.ROOT).contains(this.i));
Map map = (Map) obj;
return StoreStream.getUsers().observeUsers(map.keySet()).X(new h(this.i, map, this.j));
}
}

32
app/src/main/java/c/a/z/a/a/j.java
View File

@ -1,29 +1,21 @@
package c.a.z.a.a;
import com.discord.api.permission.PermissionOverwrite;
import com.discord.models.user.User;
import j0.k.b;
import com.discord.api.channel.Channel;
import com.discord.models.guild.Guild;
import com.discord.models.user.MeUser;
import com.discord.widgets.channels.permissions.WidgetChannelSettingsPermissionsAddMember;
import java.util.List;
import rx.functions.Func4;
/* compiled from: lambda */
public final /* synthetic */ class j implements b {
public final /* synthetic */ List i;
public final /* synthetic */ class j implements Func4 {
public final /* synthetic */ Channel a;
public /* synthetic */ j(List list) {
this.i = list;
public /* synthetic */ j(Channel channel) {
this.a = channel;
}
@Override // j0.k.b
public final Object call(Object obj) {
List list = this.i;
User user = (User) obj;
if (list == null) {
return Boolean.TRUE;
}
for (int i = 0; i < list.size(); i++) {
if (((PermissionOverwrite) list.get(i)).e() == user.getId()) {
return Boolean.FALSE;
}
}
return Boolean.TRUE;
@Override // rx.functions.Func4
public final Object call(Object obj, Object obj2, Object obj3, Object obj4) {
return WidgetChannelSettingsPermissionsAddMember.Model.lambda$null$1(this.a, (MeUser) obj, (Guild) obj2, (Long) obj3, (List) obj4);
}
}

19
app/src/main/java/c/a/z/a/a/k.java
View File

@ -1,25 +1,18 @@
package c.a.z.a.a;
import com.discord.models.user.User;
import j0.k.b;
import java.util.List;
import java.util.Map;
import rx.Observable;
import java.util.Locale;
/* compiled from: lambda */
public final /* synthetic */ class k implements b {
public final /* synthetic */ List i;
public final /* synthetic */ Map j;
public final /* synthetic */ String k;
public final /* synthetic */ String i;
public /* synthetic */ k(List list, Map map, String str) {
this.i = list;
this.j = map;
this.k = str;
public /* synthetic */ k(String str) {
this.i = str;
}
@Override // j0.k.b
public final Object call(Object obj) {
List list = this.i;
Map map = this.j;
return Observable.A(((Map) obj).values()).x(new j(list)).x(new l(map)).x(new i(this.k)).T(new e(map)).F(v.i).f0();
return Boolean.valueOf(((User) obj).getUsername().toLowerCase(Locale.ROOT).contains(this.i));
}
}

22
app/src/main/java/c/a/z/a/a/l.java
View File

@ -1,19 +1,29 @@
package c.a.z.a.a;
import c.d.b.a.a;
import com.discord.api.permission.PermissionOverwrite;
import com.discord.models.user.User;
import j0.k.b;
import java.util.Map;
import java.util.List;
/* compiled from: lambda */
public final /* synthetic */ class l implements b {
public final /* synthetic */ Map i;
public final /* synthetic */ List i;
public /* synthetic */ l(Map map) {
this.i = map;
public /* synthetic */ l(List list) {
this.i = list;
}
@Override // j0.k.b
public final Object call(Object obj) {
return Boolean.valueOf(a.c((User) obj, this.i) != null);
List list = this.i;
User user = (User) obj;
if (list == null) {
return Boolean.TRUE;
}
for (int i = 0; i < list.size(); i++) {
if (((PermissionOverwrite) list.get(i)).e() == user.getId()) {
return Boolean.FALSE;
}
}
return Boolean.TRUE;
}
}

22
app/src/main/java/c/a/z/a/a/m.java
View File

@ -1,19 +1,19 @@
package c.a.z.a.a;
import android.text.Editable;
import com.discord.widgets.channels.permissions.WidgetChannelSettingsPermissionsAddMember;
import kotlin.jvm.functions.Function1;
import c.d.b.a.a;
import com.discord.models.user.User;
import j0.k.b;
import java.util.Map;
/* compiled from: lambda */
public final /* synthetic */ class m implements Function1 {
public final /* synthetic */ WidgetChannelSettingsPermissionsAddMember i;
public final /* synthetic */ class m implements b {
public final /* synthetic */ Map i;
public /* synthetic */ m(WidgetChannelSettingsPermissionsAddMember widgetChannelSettingsPermissionsAddMember) {
this.i = widgetChannelSettingsPermissionsAddMember;
public /* synthetic */ m(Map map) {
this.i = map;
}
@Override // kotlin.jvm.functions.Function1
public final Object invoke(Object obj) {
this.i.h((Editable) obj);
return null;
@Override // j0.k.b
public final Object call(Object obj) {
return Boolean.valueOf(a.c((User) obj, this.i) != null);
}
}

20
app/src/main/java/c/a/z/a/a/n.java
View File

@ -1,15 +1,19 @@
package c.a.z.a.a;
import android.text.TextUtils;
import android.text.Editable;
import com.discord.widgets.channels.permissions.WidgetChannelSettingsPermissionsAddMember;
import j0.k.b;
import kotlin.jvm.functions.Function1;
/* compiled from: lambda */
public final /* synthetic */ class n implements b {
public static final /* synthetic */ n i = new n();
public final /* synthetic */ class n implements Function1 {
public final /* synthetic */ WidgetChannelSettingsPermissionsAddMember i;
@Override // j0.k.b
public final Object call(Object obj) {
int i2 = WidgetChannelSettingsPermissionsAddMember.i;
return Boolean.valueOf(!TextUtils.isEmpty((String) obj));
public /* synthetic */ n(WidgetChannelSettingsPermissionsAddMember widgetChannelSettingsPermissionsAddMember) {
this.i = widgetChannelSettingsPermissionsAddMember;
}
@Override // kotlin.jvm.functions.Function1
public final Object invoke(Object obj) {
this.i.h((Editable) obj);
return null;
}
}

20
app/src/main/java/c/a/z/a/a/o.java
View File

@ -1,17 +1,15 @@
package c.a.z.a.a;
import com.discord.widgets.channels.permissions.WidgetChannelSettingsPermissionsAddRole;
import rx.functions.Action1;
import android.text.TextUtils;
import com.discord.widgets.channels.permissions.WidgetChannelSettingsPermissionsAddMember;
import j0.k.b;
/* compiled from: lambda */
public final /* synthetic */ class o implements Action1 {
public final /* synthetic */ WidgetChannelSettingsPermissionsAddRole i;
public final /* synthetic */ class o implements b {
public static final /* synthetic */ o i = new o();
public /* synthetic */ o(WidgetChannelSettingsPermissionsAddRole widgetChannelSettingsPermissionsAddRole) {
this.i = widgetChannelSettingsPermissionsAddRole;
}
@Override // rx.functions.Action1
public final void call(Object obj) {
WidgetChannelSettingsPermissionsAddRole.g(this.i, (WidgetChannelSettingsPermissionsAddRole.Model) obj);
@Override // j0.k.b
public final Object call(Object obj) {
int i2 = WidgetChannelSettingsPermissionsAddMember.i;
return Boolean.valueOf(!TextUtils.isEmpty((String) obj));
}
}

22
app/src/main/java/c/a/z/a/a/p.java
View File

@ -1,21 +1,17 @@
package c.a.z.a.a;
import com.discord.api.channel.Channel;
import com.discord.stores.StoreStream;
import j0.k.b;
import j0.l.e.j;
import rx.Observable;
import com.discord.widgets.channels.permissions.WidgetChannelSettingsPermissionsAddRole;
import rx.functions.Action1;
/* compiled from: lambda */
public final /* synthetic */ class p implements b {
public final /* synthetic */ long i;
public final /* synthetic */ class p implements Action1 {
public final /* synthetic */ WidgetChannelSettingsPermissionsAddRole i;
public /* synthetic */ p(long j) {
this.i = j;
public /* synthetic */ p(WidgetChannelSettingsPermissionsAddRole widgetChannelSettingsPermissionsAddRole) {
this.i = widgetChannelSettingsPermissionsAddRole;
}
@Override // j0.k.b
public final Object call(Object obj) {
Channel channel = (Channel) obj;
return channel == null ? new j(null) : Observable.h(StoreStream.getGuilds().observeGuild(channel.f()), StoreStream.getUsers().observeMe(), StoreStream.getPermissions().observePermissionsForChannel(this.i), StoreStream.getGuilds().observeSortedRoles(channel.f()).Y(new r(channel)), new q(channel));
@Override // rx.functions.Action1
public final void call(Object obj) {
WidgetChannelSettingsPermissionsAddRole.g(this.i, (WidgetChannelSettingsPermissionsAddRole.Model) obj);
}
}

24
app/src/main/java/c/a/z/a/a/q.java
View File

@ -1,21 +1,21 @@
package c.a.z.a.a;
import com.discord.api.channel.Channel;
import com.discord.models.guild.Guild;
import com.discord.models.user.MeUser;
import com.discord.widgets.channels.permissions.WidgetChannelSettingsPermissionsAddRole;
import java.util.List;
import rx.functions.Func4;
import com.discord.stores.StoreStream;
import j0.k.b;
import j0.l.e.j;
import rx.Observable;
/* compiled from: lambda */
public final /* synthetic */ class q implements Func4 {
public final /* synthetic */ Channel a;
public final /* synthetic */ class q implements b {
public final /* synthetic */ long i;
public /* synthetic */ q(Channel channel) {
this.a = channel;
public /* synthetic */ q(long j) {
this.i = j;
}
@Override // rx.functions.Func4
public final Object call(Object obj, Object obj2, Object obj3, Object obj4) {
return WidgetChannelSettingsPermissionsAddRole.Model.lambda$null$2(this.a, (Guild) obj, (MeUser) obj2, (Long) obj3, (List) obj4);
@Override // j0.k.b
public final Object call(Object obj) {
Channel channel = (Channel) obj;
return channel == null ? new j(null) : Observable.h(StoreStream.getGuilds().observeGuild(channel.f()), StoreStream.getUsers().observeMe(), StoreStream.getPermissions().observePermissionsForChannel(this.i), StoreStream.getGuilds().observeSortedRoles(channel.f()).X(new s(channel)), new r(channel));
}
}

19
app/src/main/java/c/a/z/a/a/r.java
View File

@ -1,20 +1,21 @@
package c.a.z.a.a;
import com.discord.api.channel.Channel;
import j0.k.b;
import j0.l.a.q;
import com.discord.models.guild.Guild;
import com.discord.models.user.MeUser;
import com.discord.widgets.channels.permissions.WidgetChannelSettingsPermissionsAddRole;
import java.util.List;
import rx.Observable;
import rx.functions.Func4;
/* compiled from: lambda */
public final /* synthetic */ class r implements b {
public final /* synthetic */ Channel i;
public final /* synthetic */ class r implements Func4 {
public final /* synthetic */ Channel a;
public /* synthetic */ r(Channel channel) {
this.i = channel;
this.a = channel;
}
@Override // j0.k.b
public final Object call(Object obj) {
return Observable.h0(new q((List) obj)).x(new s(this.i)).F(u.i).f0();
@Override // rx.functions.Func4
public final Object call(Object obj, Object obj2, Object obj3, Object obj4) {
return WidgetChannelSettingsPermissionsAddRole.Model.lambda$null$2(this.a, (Guild) obj, (MeUser) obj2, (Long) obj3, (List) obj4);
}
}

16
app/src/main/java/c/a/z/a/a/s.java
View File

@ -1,8 +1,10 @@
package c.a.z.a.a;
import com.discord.api.channel.Channel;
import com.discord.api.role.GuildRole;
import j0.k.b;
import j0.l.a.q;
import java.util.List;
import rx.Observable;
/* compiled from: lambda */
public final /* synthetic */ class s implements b {
public final /* synthetic */ Channel i;
@ -13,16 +15,6 @@ public final /* synthetic */ class s implements b {
@Override // j0.k.b
public final Object call(Object obj) {
Channel channel = this.i;
GuildRole guildRole = (GuildRole) obj;
if (channel.s() == null) {
return Boolean.TRUE;
}
for (int i = 0; i < channel.s().size(); i++) {
if (channel.s().get(i).e() == guildRole.getId()) {
return Boolean.FALSE;
}
}
return Boolean.TRUE;
return Observable.g0(new q((List) obj)).x(new t(this.i)).F(v.i).e0();
}
}

35
app/src/main/java/c/a/z/a/a/t.java
View File

@ -1,25 +1,28 @@
package c.a.z.a.a;
import com.discord.api.channel.Channel;
import com.discord.api.role.GuildRole;
import com.discord.widgets.channels.permissions.WidgetChannelSettingsEditPermissions;
import com.discord.widgets.channels.permissions.WidgetChannelSettingsPermissionsAddRole;
import kotlin.Unit;
import kotlin.jvm.functions.Function1;
import j0.k.b;
/* compiled from: lambda */
public final /* synthetic */ class t implements Function1 {
public final /* synthetic */ WidgetChannelSettingsPermissionsAddRole i;
public final /* synthetic */ WidgetChannelSettingsPermissionsAddRole.Model j;
public final /* synthetic */ class t implements b {
public final /* synthetic */ Channel i;
public /* synthetic */ t(WidgetChannelSettingsPermissionsAddRole widgetChannelSettingsPermissionsAddRole, WidgetChannelSettingsPermissionsAddRole.Model model) {
this.i = widgetChannelSettingsPermissionsAddRole;
this.j = model;
public /* synthetic */ t(Channel channel) {
this.i = channel;
}
@Override // kotlin.jvm.functions.Function1
public final Object invoke(Object obj) {
WidgetChannelSettingsPermissionsAddRole widgetChannelSettingsPermissionsAddRole = this.i;
WidgetChannelSettingsPermissionsAddRole.Model model = this.j;
WidgetChannelSettingsEditPermissions.createForRole(widgetChannelSettingsPermissionsAddRole.getContext(), WidgetChannelSettingsPermissionsAddRole.Model.access$200(model).f(), WidgetChannelSettingsPermissionsAddRole.Model.access$200(model).h(), ((GuildRole) obj).getId());
return Unit.a;
@Override // j0.k.b
public final Object call(Object obj) {
Channel channel = this.i;
GuildRole guildRole = (GuildRole) obj;
if (channel.s() == null) {
return Boolean.TRUE;
}
for (int i = 0; i < channel.s().size(); i++) {
if (channel.s().get(i).e() == guildRole.getId()) {
return Boolean.FALSE;
}
}
return Boolean.TRUE;
}
}

25
app/src/main/java/c/a/z/a/a/u.java
View File

@ -1,14 +1,25 @@
package c.a.z.a.a;
import com.discord.api.role.GuildRole;
import com.discord.widgets.channels.SimpleRolesAdapter;
import j0.k.b;
import com.discord.widgets.channels.permissions.WidgetChannelSettingsEditPermissions;
import com.discord.widgets.channels.permissions.WidgetChannelSettingsPermissionsAddRole;
import kotlin.Unit;
import kotlin.jvm.functions.Function1;
/* compiled from: lambda */
public final /* synthetic */ class u implements b {
public static final /* synthetic */ u i = new u();
public final /* synthetic */ class u implements Function1 {
public final /* synthetic */ WidgetChannelSettingsPermissionsAddRole i;
public final /* synthetic */ WidgetChannelSettingsPermissionsAddRole.Model j;
@Override // j0.k.b
public final Object call(Object obj) {
return new SimpleRolesAdapter.RoleItem((GuildRole) obj);
public /* synthetic */ u(WidgetChannelSettingsPermissionsAddRole widgetChannelSettingsPermissionsAddRole, WidgetChannelSettingsPermissionsAddRole.Model model) {
this.i = widgetChannelSettingsPermissionsAddRole;
this.j = model;
}
@Override // kotlin.jvm.functions.Function1
public final Object invoke(Object obj) {
WidgetChannelSettingsPermissionsAddRole widgetChannelSettingsPermissionsAddRole = this.i;
WidgetChannelSettingsPermissionsAddRole.Model model = this.j;
WidgetChannelSettingsEditPermissions.createForRole(widgetChannelSettingsPermissionsAddRole.getContext(), WidgetChannelSettingsPermissionsAddRole.Model.access$200(model).f(), WidgetChannelSettingsPermissionsAddRole.Model.access$200(model).h(), ((GuildRole) obj).getId());
return Unit.a;
}
}

6
app/src/main/java/c/a/z/a/a/v.java
View File

@ -1,7 +1,7 @@
package c.a.z.a.a;
import com.discord.models.user.User;
import com.discord.widgets.channels.SimpleMembersAdapter;
import com.discord.api.role.GuildRole;
import com.discord.widgets.channels.SimpleRolesAdapter;
import j0.k.b;
/* compiled from: lambda */
public final /* synthetic */ class v implements b {
@ -9,6 +9,6 @@ public final /* synthetic */ class v implements b {
@Override // j0.k.b
public final Object call(Object obj) {
return new SimpleMembersAdapter.MemberItem((User) obj);
return new SimpleRolesAdapter.RoleItem((GuildRole) obj);
}
}

3
app/src/main/java/c/b/a/a/g.java
View File

@ -1,6 +1,7 @@
package c.b.a.a;
import android.content.DialogInterface;
import c.i.a.f.e.o.c;
import com.lytefast.flexinput.fragment.FlexInputFragment;
import com.lytefast.flexinput.viewmodel.FlexInputViewModel;
/* compiled from: FlexInputFragment.kt */
@ -15,7 +16,7 @@ public final class g implements DialogInterface.OnDismissListener {
public final void onDismiss(DialogInterface dialogInterface) {
FlexInputViewModel flexInputViewModel;
if (this.i.isAdded() && !this.i.isHidden() && (flexInputViewModel = this.i.r) != null) {
flexInputViewModel.onContentDialogDismissed();
c.c0(flexInputViewModel, false, 1, null);
}
}
}

3
app/src/main/java/c/b/a/a/h.java
View File

@ -1,6 +1,7 @@
package c.b.a.a;
import android.view.View;
import c.i.a.f.e.o.c;
import com.lytefast.flexinput.fragment.FlexInputFragment;
import com.lytefast.flexinput.viewmodel.FlexInputViewModel;
import d0.z.d.m;
@ -24,7 +25,7 @@ public final class h extends o implements Function1<View, Unit> {
m.checkNotNullParameter(view, "it");
FlexInputViewModel flexInputViewModel = this.this$0.r;
if (flexInputViewModel != null) {
flexInputViewModel.onContentDialogDismissed();
c.c0(flexInputViewModel, false, 1, null);
}
return Unit.a;
}

2
app/src/main/java/c/b/a/a/l.java
View File

@ -58,6 +58,6 @@ public final class l extends o implements Function0<Unit> {
@Override // kotlin.jvm.functions.Function0
/* renamed from: invoke */
public final void mo1invoke() {
this.this$0.u = Observable.d0(300, TimeUnit.MILLISECONDS).I(j0.j.b.a.a()).V(new a(this));
this.this$0.u = Observable.c0(300, TimeUnit.MILLISECONDS).I(j0.j.b.a.a()).U(new a(this));
}
}

3
app/src/main/java/c/c/a/a0/f0.java
View File

@ -1,8 +1,7 @@
package c.c.a.a0;
import c.a.q.m0.c.e;
import c.c.a.a0.h0.c;
/* compiled from: ShapeTrimPathParser */
public class f0 {
public static c.a a = c.a.a("s", e.a, "o", "nm", "m", "hd");
public static c.a a = c.a.a("s", "e", "o", "nm", "m", "hd");
}

3
app/src/main/java/c/c/a/a0/l.java
View File

@ -1,9 +1,8 @@
package c.c.a.a0;
import c.a.q.m0.c.e;
import c.c.a.a0.h0.c;
/* compiled from: GradientFillParser */
public class l {
public static final c.a a = c.a.a("nm", "g", "o", "t", "s", e.a, "r", "hd");
public static final c.a a = c.a.a("nm", "g", "o", "t", "s", "e", "r", "hd");
public static final c.a b = c.a.a("p", "k");
}

3
app/src/main/java/c/c/a/a0/m.java
View File

@ -1,10 +1,9 @@
package c.c.a.a0;
import c.a.q.m0.c.e;
import c.c.a.a0.h0.c;
/* compiled from: GradientStrokeParser */
public class m {
public static c.a a = c.a.a("nm", "g", "o", "t", "s", e.a, "w", "lc", "lj", "ml", "hd", "d");
public static c.a a = c.a.a("nm", "g", "o", "t", "s", "e", "w", "lc", "lj", "ml", "hd", "d");
public static final c.a b = c.a.a("p", "k");
/* renamed from: c reason: collision with root package name */

3
app/src/main/java/c/c/a/a0/p.java
View File

@ -6,7 +6,6 @@ import android.view.animation.Interpolator;
import android.view.animation.LinearInterpolator;
import androidx.collection.SparseArrayCompat;
import androidx.core.view.animation.PathInterpolatorCompat;
import c.a.q.m0.c.e;
import c.c.a.a0.h0.c;
import c.c.a.b0.f;
import c.c.a.b0.g;
@ -20,7 +19,7 @@ public class p {
public static SparseArrayCompat<WeakReference<Interpolator>> b;
/* renamed from: c reason: collision with root package name */
public static c.a f259c = c.a.a("t", "s", e.a, "o", "i", "h", "to", "ti");
public static c.a f259c = c.a.a("t", "s", "e", "o", "i", "h", "to", "ti");
public static <T> a<T> a(c cVar, d dVar, float f, g0<T> g0Var, boolean z2) throws IOException {
T t;

4
app/src/main/java/c/e/b/c.java
View File

@ -77,8 +77,8 @@ public abstract class c {
q(fVar, replace2, arrayList, w.i);
n(fVar, replace2, arrayList, w.g);
q(fVar, replace2, arrayList, w.g);
n(fVar, replace2, arrayList, w.f2859c);
q(fVar, replace2, arrayList, w.f2859c);
n(fVar, replace2, arrayList, w.f2864c);
q(fVar, replace2, arrayList, w.f2864c);
o(fVar, replace2, arrayList);
cls2 = b.a(s2, fVar.b());
}

6
app/src/main/java/c/f/g/a/a/c.java
View File

@ -311,13 +311,13 @@ public class c extends AbstractDraweeController<CloseableReference<c.f.j.j.c>, I
ImageRequest imageRequest = this.I;
ImageRequest imageRequest2 = this.K;
ImageRequest[] imageRequestArr = this.J;
if (imageRequest == null || (uri = imageRequest.f2228c) == null) {
if (imageRequest == null || (uri = imageRequest.f2233c) == null) {
if (!(imageRequestArr == null || imageRequestArr.length <= 0 || imageRequestArr[0] == null)) {
ImageRequest imageRequest3 = imageRequestArr[0];
uri = imageRequest3 != null ? imageRequest3.f2228c : null;
uri = imageRequest3 != null ? imageRequest3.f2233c : null;
}
if (imageRequest2 != null) {
return imageRequest2.f2228c;
return imageRequest2.f2233c;
}
return null;
}

2
app/src/main/java/c/f/g/a/a/d.java
View File

@ -85,7 +85,7 @@ public class d extends AbstractDraweeControllerBuilder<d, ImageRequest, Closeabl
c.f.j.r.b.b();
try {
DraweeController draweeController = this.n;
String valueOf = String.valueOf(AbstractDraweeControllerBuilder.f2215c.getAndIncrement());
String valueOf = String.valueOf(AbstractDraweeControllerBuilder.f2220c.getAndIncrement());
if (draweeController instanceof c) {
cVar = (c) draweeController;
} else {

2
app/src/main/java/c/f/g/f/b.java
View File

@ -30,7 +30,7 @@ public class b extends g implements f0 {
if (!draweeHolder.a) {
a.m(c.class, "%x: Draw requested for a non-attached controller %x. %s", Integer.valueOf(System.identityHashCode(draweeHolder)), Integer.valueOf(System.identityHashCode(draweeHolder.e)), draweeHolder.toString());
draweeHolder.b = true;
draweeHolder.f2219c = true;
draweeHolder.f2224c = true;
draweeHolder.b();
}
}

2
app/src/main/java/c/f/j/c/f.java
View File

@ -156,7 +156,7 @@ public class f {
Objects.requireNonNull((z) this.g);
Executor executor = z.g.a;
if (eVar instanceof Boolean) {
return ((Boolean) eVar).booleanValue() ? z.g.f2940c : z.g.d;
return ((Boolean) eVar).booleanValue() ? z.g.f2945c : z.g.d;
}
z.g<e> gVar = new z.g<>();
if (gVar.h(eVar)) {

6
app/src/main/java/c/f/j/c/n.java
View File

@ -9,11 +9,11 @@ public class n implements i {
public static n a;
public CacheKey a(ImageRequest imageRequest, Object obj) {
return new b(imageRequest.f2228c.toString(), imageRequest.i, imageRequest.j, imageRequest.h, null, null, obj);
return new b(imageRequest.f2233c.toString(), imageRequest.i, imageRequest.j, imageRequest.h, null, null, obj);
}
public CacheKey b(ImageRequest imageRequest, Object obj) {
return new f(imageRequest.f2228c.toString());
return new f(imageRequest.f2233c.toString());
}
public CacheKey c(ImageRequest imageRequest, Object obj) {
@ -28,6 +28,6 @@ public class n implements i {
cacheKey = null;
str = null;
}
return new b(imageRequest.f2228c.toString(), imageRequest.i, imageRequest.j, imageRequest.h, cacheKey, str, obj);
return new b(imageRequest.f2233c.toString(), imageRequest.i, imageRequest.j, imageRequest.h, cacheKey, str, obj);
}
}

2
app/src/main/java/c/f/j/c/v.java
View File

@ -262,7 +262,7 @@ public class v<K, V> implements m<K, V>, w<K, V> {
MemoryCacheParams memoryCacheParams = this.f;
int min = Math.min(memoryCacheParams.d, memoryCacheParams.b - e());
MemoryCacheParams memoryCacheParams2 = this.f;
p = p(min, Math.min(memoryCacheParams2.f2221c, memoryCacheParams2.a - f()));
p = p(min, Math.min(memoryCacheParams2.f2226c, memoryCacheParams2.a - f()));
h(p);
}
i(p);

2
app/src/main/java/c/f/j/e/c.java
View File

@ -17,7 +17,7 @@ public class c implements f {
public h a(DiskCacheConfig diskCacheConfig) {
Objects.requireNonNull(this.a);
e eVar = new e(diskCacheConfig.a, diskCacheConfig.f2209c, diskCacheConfig.b, diskCacheConfig.h);
e eVar = new e(diskCacheConfig.a, diskCacheConfig.f2214c, diskCacheConfig.b, diskCacheConfig.h);
ExecutorService newSingleThreadExecutor = Executors.newSingleThreadExecutor();
return new d(eVar, diskCacheConfig.g, new d.c(diskCacheConfig.f, diskCacheConfig.e, diskCacheConfig.d), diskCacheConfig.i, diskCacheConfig.h, diskCacheConfig.j, newSingleThreadExecutor, false);
}

2
app/src/main/java/c/f/j/e/h.java
View File

@ -85,7 +85,7 @@ public class h {
ImageRequest.c f = ImageRequest.c.f(imageRequest.m, cVar);
String valueOf = String.valueOf(this.i.getAndIncrement());
if (!imageRequest.f) {
if (c.f.d.l.b.e(imageRequest.f2228c)) {
if (c.f.d.l.b.e(imageRequest.f2233c)) {
z2 = false;
c1 c1Var = new c1(imageRequest, valueOf, str, b0Var, obj, f, false, z2, imageRequest.l, this.l);
c.f.j.r.b.b();

4
app/src/main/java/c/f/j/e/p.java
View File

@ -153,7 +153,7 @@ public class p {
try {
b.b();
Objects.requireNonNull(imageRequest);
Uri uri = imageRequest.f2228c;
Uri uri = imageRequest.f2233c;
AnimatableValueParser.y(uri, "Uri is null.");
int i = imageRequest.d;
if (i != 0) {
@ -247,7 +247,7 @@ public class p {
}
}
}
if (this.m && imageRequest.f2229s > 0) {
if (this.m && imageRequest.f2234s > 0) {
synchronized (this) {
oVar = new o(r0Var, this.b.j.g());
}

2
app/src/main/java/c/f/j/p/a1.java
View File

@ -19,7 +19,7 @@ public class a1 extends g0 {
@Override // c.f.j.p.g0
public e d(ImageRequest imageRequest) throws IOException {
return c(this.f470c.openInputStream(imageRequest.f2228c), -1);
return c(this.f470c.openInputStream(imageRequest.f2233c), -1);
}
@Override // c.f.j.p.g0

2
app/src/main/java/c/f/j/p/d.java
View File

@ -45,7 +45,7 @@ public class d implements w0 {
HashMap hashMap = new HashMap();
this.h = hashMap;
hashMap.put(ModelAuditLogEntry.CHANGE_KEY_ID, str);
hashMap.put("uri_source", imageRequest == null ? "null-request" : imageRequest.f2228c);
hashMap.put("uri_source", imageRequest == null ? "null-request" : imageRequest.f2233c);
this.d = str2;
this.e = y0Var;
this.f = obj;

4
app/src/main/java/c/f/j/p/d0.java
View File

@ -25,10 +25,10 @@ public class d0 extends g0 {
@Override // c.f.j.p.g0
public e d(ImageRequest imageRequest) throws IOException {
int i;
InputStream open = this.f476c.open(imageRequest.f2228c.getPath().substring(1), 2);
InputStream open = this.f476c.open(imageRequest.f2233c.getPath().substring(1), 2);
AssetFileDescriptor assetFileDescriptor = null;
try {
assetFileDescriptor = this.f476c.openFd(imageRequest.f2228c.getPath().substring(1));
assetFileDescriptor = this.f476c.openFd(imageRequest.f2233c.getPath().substring(1));
i = (int) assetFileDescriptor.getLength();
} catch (IOException unused) {
i = -1;

2
app/src/main/java/c/f/j/p/e0.java
View File

@ -28,7 +28,7 @@ public class e0 extends g0 {
@Override // c.f.j.p.g0
public e d(ImageRequest imageRequest) throws IOException {
InputStream inputStream;
Uri uri = imageRequest.f2228c;
Uri uri = imageRequest.f2233c;
Uri uri2 = b.a;
boolean z2 = false;
if (uri.getPath() != null && b.c(uri) && "com.android.contacts".equals(uri.getAuthority()) && !uri.getPath().startsWith(b.a.getPath())) {

2
app/src/main/java/c/f/j/p/f0.java
View File

@ -42,7 +42,7 @@ public class f0 extends g0 implements j1<e> {
c.f.j.d.e eVar;
Cursor query;
e f2;
Uri uri = imageRequest.f2228c;
Uri uri = imageRequest.f2233c;
if (!b.b(uri) || (eVar = imageRequest.i) == null || (query = this.g.query(uri, f478c, null, null, null)) == null) {
return null;
}

4
app/src/main/java/c/f/j/p/i0.java
View File

@ -25,10 +25,10 @@ public class i0 extends g0 {
@Override // c.f.j.p.g0
public e d(ImageRequest imageRequest) throws IOException {
int i;
InputStream openRawResource = this.f485c.openRawResource(Integer.parseInt(imageRequest.f2228c.getPath().substring(1)));
InputStream openRawResource = this.f485c.openRawResource(Integer.parseInt(imageRequest.f2233c.getPath().substring(1)));
AssetFileDescriptor assetFileDescriptor = null;
try {
assetFileDescriptor = this.f485c.openRawResourceFd(Integer.parseInt(imageRequest.f2228c.getPath().substring(1)));
assetFileDescriptor = this.f485c.openRawResourceFd(Integer.parseInt(imageRequest.f2233c.getPath().substring(1)));
i = (int) assetFileDescriptor.getLength();
} catch (Resources.NotFoundException unused) {
i = -1;

4
app/src/main/java/c/f/j/p/j0.java
View File

@ -83,7 +83,7 @@ public class j0 implements v0<CloseableReference<c>> {
bitmap = ThumbnailUtils.createVideoThumbnail(str, i);
} else {
try {
ParcelFileDescriptor openFileDescriptor = j0.this.b.openFileDescriptor(this.p.f2228c, "r");
ParcelFileDescriptor openFileDescriptor = j0.this.b.openFileDescriptor(this.p.f2233c, "r");
MediaMetadataRetriever mediaMetadataRetriever = new MediaMetadataRetriever();
mediaMetadataRetriever.setDataSource(openFileDescriptor.getFileDescriptor());
bitmap = mediaMetadataRetriever.getFrameAtTime(-1);
@ -141,7 +141,7 @@ public class j0 implements v0<CloseableReference<c>> {
String str;
Uri uri;
Objects.requireNonNull(j0Var);
Uri uri2 = imageRequest.f2228c;
Uri uri2 = imageRequest.f2233c;
if (c.f.d.l.b.d(uri2)) {
return imageRequest.a().getPath();
}

2
app/src/main/java/c/f/j/p/m.java
View File

@ -18,7 +18,7 @@ public class m extends g0 {
@Override // c.f.j.p.g0
public e d(ImageRequest imageRequest) throws IOException {
boolean z2;
String uri = imageRequest.f2228c.toString();
String uri = imageRequest.f2233c.toString();
AnimatableValueParser.j(Boolean.valueOf(uri.substring(0, 5).equals("data:")));
int indexOf = uri.indexOf(44);
String substring = uri.substring(indexOf + 1, uri.length());

6
app/src/main/java/c/f/j/p/n.java
View File

@ -142,7 +142,7 @@ public class n implements v0<CloseableReference<c.f.j.j.c>> {
w0Var.d("image_format", eVar.k.b);
if (n.this.f || !b.m(i2, 16)) {
ImageRequest e2 = this.a.e();
if (n.this.g || !c.f.d.l.b.e(e2.f2228c)) {
if (n.this.g || !c.f.d.l.b.e(e2.f2233c)) {
eVar.p = AnimatableValueParser.c0(e2.j, e2.i, eVar, this.b);
}
}
@ -180,7 +180,7 @@ public class n implements v0<CloseableReference<c.f.j.j.c>> {
synchronized (c0Var) {
j = c0Var.j - c0Var.i;
}
String valueOf2 = String.valueOf(cVar2.f494c.e().f2228c);
String valueOf2 = String.valueOf(cVar2.f494c.e().f2233c);
int f = (z3 || m) ? eVar.f() : cVar2.o(eVar);
i p = (z3 || m) ? h.a : cVar2.p();
cVar2.d.e(cVar2.f494c, "DecodeProducer");
@ -440,7 +440,7 @@ public class n implements v0<CloseableReference<c.f.j.j.c>> {
public void b(l<CloseableReference<c.f.j.j.c>> lVar, w0 w0Var) {
try {
c.f.j.r.b.b();
this.e.b(!c.f.d.l.b.e(w0Var.e().f2228c) ? new a(this, lVar, w0Var, this.h, this.i) : new b(this, lVar, w0Var, new d(this.a), this.d, this.h, this.i), w0Var);
this.e.b(!c.f.d.l.b.e(w0Var.e().f2233c) ? new a(this, lVar, w0Var, this.h, this.i) : new b(this, lVar, w0Var, new d(this.a), this.d, this.h, this.i), w0Var);
c.f.j.r.b.b();
} catch (Throwable th) {
c.f.j.r.b.b();

2
app/src/main/java/c/f/j/p/o.java
View File

@ -36,7 +36,7 @@ public class o implements v0<CloseableReference<c>> {
ImageRequest e = w0Var.e();
ScheduledExecutorService scheduledExecutorService = this.b;
if (scheduledExecutorService != null) {
scheduledExecutorService.schedule(new a(lVar, w0Var), (long) e.f2229s, TimeUnit.MILLISECONDS);
scheduledExecutorService.schedule(new a(lVar, w0Var), (long) e.f2234s, TimeUnit.MILLISECONDS);
} else {
this.a.b(lVar, w0Var);
}

6
app/src/main/java/c/f/j/p/o0.java
View File

@ -64,7 +64,7 @@ public class o0 implements c<e, Void> {
this.f496c.b(eVar2, 9);
} else {
this.f496c.b(eVar2, 8);
ImageRequestBuilder b = ImageRequestBuilder.b(e.f2228c);
ImageRequestBuilder b = ImageRequestBuilder.b(e.f2233c);
b.e = e.h;
b.o = e.k;
b.f = e.b;
@ -73,11 +73,11 @@ public class o0 implements c<e, Void> {
b.j = e.q;
b.g = e.f;
b.i = e.l;
b.f2230c = e.i;
b.f2235c = e.i;
b.n = e.r;
b.d = e.j;
b.m = e.p;
b.p = e.f2229s;
b.p = e.f2234s;
int i = f2 - 1;
if (i >= 0) {
z3 = true;

Some files were not shown because too many files have changed in this diff Show More