Picsart v24.6版本的 MD5 值为：21a61631d94e54da68d2ad9268b8b9d9

以下内容为反编译后的 u0.java 源代码，内容仅作参考

package bo.app;

import android.content.Context;
import android.content.SharedPreferences;
import bo.app.i2;
import com.braze.coroutine.BrazeCoroutineScope;
import com.braze.support.BrazeLogger;
import com.braze.support.StringUtils;
import java.util.concurrent.TimeUnit;
import kotlin.Unit;
import kotlin.coroutines.intrinsics.CoroutineSingletons;
import kotlin.coroutines.jvm.internal.SuspendLambda;
import kotlin.jvm.functions.Function0;
import kotlin.jvm.functions.Function1;
import kotlin.jvm.internal.DefaultConstructorMarker;
import kotlin.jvm.internal.FunctionReferenceImpl;
import kotlin.jvm.internal.Intrinsics;
import kotlin.jvm.internal.Lambda;
public final class u0 {
    public static final f f = new f(null);
    private static final long g = TimeUnit.SECONDS.toMillis(5);
    private final r5 a;
    private final k2 b;
    private final SharedPreferences c;
    private final w0 d;
    private myobfuscated.pn2.f1 e;

    public static final class a extends Lambda implements Function0 {
        public static final a b = new a();

        public a() {
            super(0);
        }

        @Override
        public final String invoke() {
            return "Cancelling ending of DUST subscription on delay and resuming stream";
        }
    }

    public static final class b extends Lambda implements Function0 {
        public static final b b = new b();

        public b() {
            super(0);
        }

        @Override
        public final String invoke() {
            return "Ending DUST subscription on delay";
        }
    }

    public static final class c extends SuspendLambda implements Function1 {
        int b;

        public static final class a extends Lambda implements Function0 {
            public static final a b = new a();

            public a() {
                super(0);
            }

            @Override
            public final String invoke() {
                return "Ending subscription on a delay";
            }
        }

        public c(myobfuscated.mk2.c cVar) {
            super(1, cVar);
            u0.this = r1;
        }

        @Override
        public final Object invoke(myobfuscated.mk2.c cVar) {
            return ((c) create(cVar)).invokeSuspend(Unit.a);
        }

        @Override
        public final myobfuscated.mk2.c create(myobfuscated.mk2.c cVar) {
            return new c(cVar);
        }

        @Override
        public final Object invokeSuspend(Object obj) {
            CoroutineSingletons coroutineSingletons = CoroutineSingletons.COROUTINE_SUSPENDED;
            if (this.b == 0) {
                myobfuscated.ik2.i.b(obj);
                BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, u0.this, (BrazeLogger.Priority) null, (Throwable) null, a.b, 3, (Object) null);
                u0.this.a();
                return Unit.a;
            }
            throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
        }
    }

    public static final class d extends Lambda implements Function0 {
        final u3 b;

        public d(u3 u3Var) {
            super(0);
            this.b = u3Var;
        }

        @Override
        public final String invoke() {
            return "Got network change event: " + this.b;
        }
    }

    public static final class e extends Lambda implements Function0 {
        public static final e b = new e();

        public e() {
            super(0);
        }

        @Override
        public final String invoke() {
            return "Received MITE value. Starting/resuming a new subscription";
        }
    }

    public static final class f {
        private f() {
        }

        public f(DefaultConstructorMarker defaultConstructorMarker) {
            this();
        }
    }

    public class g {
        public static final int[] a;

        static {
            int[] iArr = new int[i2.b.values().length];
            try {
                iArr[i2.b.CONTENT_CARD_REFRESH.ordinal()] = 1;
            } catch (NoSuchFieldError unused) {
            }
            a = iArr;
        }
    }

    public static final class h extends Lambda implements Function0 {
        public static final h b = new h();

        public h() {
            super(0);
        }

        @Override
        public final String invoke() {
            return "Ending DUST subscription";
        }
    }

    public static final class i extends Lambda implements Function0 {
        final i2 b;

        public i(i2 i2Var) {
            super(0);
            this.b = i2Var;
        }

        @Override
        public final String invoke() {
            return "Ingesting DUST message\n" + this.b;
        }
    }

    public static final class j extends Lambda implements Function0 {
        final i2.b b;

        public j(i2.b bVar) {
            super(0);
            this.b = bVar;
        }

        @Override
        public final String invoke() {
            return "Lacked logic to ingest message! Type: " + this.b;
        }
    }

    public static final class k extends Lambda implements Function0 {
        final String b;

        public k(String str) {
            super(0);
            this.b = str;
        }

        @Override
        public final String invoke() {
            return "setting mite value to " + this.b;
        }
    }

    public static final class l extends Lambda implements Function0 {
        final String b;
        final u0 c;

        public l(String str, u0 u0Var) {
            super(0);
            this.b = str;
            this.c = u0Var;
        }

        @Override
        public final String invoke() {
            return "Cannot start a dust subscription with mite " + this.b + " and enabled " + this.c.c().C();
        }
    }

    public static final class m extends Lambda implements Function0 {
        final boolean b;
        final String c;
        final String d;

        public m(boolean z, String str, String str2) {
            super(0);
            this.b = z;
            this.c = str;
            this.d = str2;
        }

        @Override
        public final String invoke() {
            return "Starting (resume = " + this.b + ") DUST subscription for mite: " + this.c + " to url: " + this.d;
        }
    }

    public class n extends FunctionReferenceImpl implements Function1 {
        public n(Object obj) {
            super(1, obj, u0.class, "ingestDustMessages", "ingestDustMessages(Lcom/braze/models/dust/IDustMessage;)V", 0);
        }

        public final void a(i2 p0) {
            Intrinsics.checkNotNullParameter(p0, "p0");
            ((u0) this.receiver).a(p0);
        }

        @Override
        public Object invoke(Object obj) {
            a((i2) obj);
            return Unit.a;
        }
    }

    public u0(r5 serverConfigStorageProvider, k2 internalPublisher, Context context, String str, String str2) {
        Intrinsics.checkNotNullParameter(serverConfigStorageProvider, "serverConfigStorageProvider");
        Intrinsics.checkNotNullParameter(internalPublisher, "internalPublisher");
        Intrinsics.checkNotNullParameter(context, "context");
        this.a = serverConfigStorageProvider;
        this.b = internalPublisher;
        SharedPreferences sharedPreferences = context.getSharedPreferences("com.braze.managers.dust.metadata" + StringUtils.getCacheFileSuffix(context, str, str2), 0);
        Intrinsics.checkNotNullExpressionValue(sharedPreferences, "context.getSharedPrefere…xt.MODE_PRIVATE\n        )");
        this.c = sharedPreferences;
        this.d = new w0();
        internalPublisher.c(x5.class, new myobfuscated.f6.c(this, 2));
        internalPublisher.c(z5.class, new myobfuscated.f6.d(this, 2));
        internalPublisher.c(u3.class, new myobfuscated.f6.q(this, 1));
        internalPublisher.c(v0.class, new myobfuscated.f6.r(this, 1));
    }

    public final void a(i2 i2Var) {
        BrazeLogger brazeLogger = BrazeLogger.INSTANCE;
        BrazeLogger.brazelog$default(brazeLogger, this, (BrazeLogger.Priority) null, (Throwable) null, new i(i2Var), 3, (Object) null);
        i2.b a2 = i2Var.a();
        if (g.a[a2.ordinal()] == 1) {
            this.b.a(new u(), u.class);
        } else {
            BrazeLogger.brazelog$default(brazeLogger, this, BrazeLogger.Priority.W, (Throwable) null, new j(a2), 2, (Object) null);
        }
    }

    public static final void a(u0 this$0, u3 it) {
        Intrinsics.checkNotNullParameter(this$0, "this$0");
        Intrinsics.checkNotNullParameter(it, "it");
        BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, this$0, (BrazeLogger.Priority) null, (Throwable) null, new d(it), 3, (Object) null);
        t3 a2 = it.a();
        t3 t3Var = t3.NONE;
        if (a2 == t3Var) {
            this$0.a();
        } else if (it.b() == t3Var) {
            this$0.a(true);
        }
    }

    public static final void a(u0 this$0, v0 it) {
        Intrinsics.checkNotNullParameter(this$0, "this$0");
        Intrinsics.checkNotNullParameter(it, "it");
        BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, this$0, (BrazeLogger.Priority) null, (Throwable) null, e.b, 3, (Object) null);
        String b2 = this$0.b();
        this$0.a(it.a());
        this$0.a(Intrinsics.c(b2, it.a()));
    }

    public static final void a(u0 this$0, x5 it) {
        Intrinsics.checkNotNullParameter(this$0, "this$0");
        Intrinsics.checkNotNullParameter(it, "it");
        BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, this$0, (BrazeLogger.Priority) null, (Throwable) null, a.b, 3, (Object) null);
        myobfuscated.pn2.f1 f1Var = this$0.e;
        if (f1Var != null) {
            f1Var.c(null);
        }
        this$0.a(true);
    }

    public static final void a(u0 this$0, z5 it) {
        Intrinsics.checkNotNullParameter(this$0, "this$0");
        Intrinsics.checkNotNullParameter(it, "it");
        BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, this$0, (BrazeLogger.Priority) null, (Throwable) null, b.b, 3, (Object) null);
        this$0.e = BrazeCoroutineScope.launchDelayed$default(BrazeCoroutineScope.INSTANCE, Long.valueOf(g), null, new c(null), 2, null);
    }

    private final void a(String str) {
        BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, this, (BrazeLogger.Priority) null, (Throwable) null, new k(str), 3, (Object) null);
        this.c.edit().putString("mite", str).apply();
    }

    private final void a(boolean z) {
        String b2 = b();
        if (b2 == null || !this.a.C()) {
            BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, this, (BrazeLogger.Priority) null, (Throwable) null, new l(b2, this), 3, (Object) null);
            return;
        }
        String concat = "https://dust.k8s.test-001.d-usw-2.braze.com/sse?mite=".concat(b2);
        BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, this, (BrazeLogger.Priority) null, (Throwable) null, new m(z, b2, concat), 3, (Object) null);
        this.d.a(concat, new n(this), z);
    }

    private final String b() {
        return this.c.getString("mite", null);
    }

    public final void a() {
        BrazeLogger.brazelog$default(BrazeLogger.INSTANCE, this, (BrazeLogger.Priority) null, (Throwable) null, h.b, 3, (Object) null);
        this.d.b();
    }

    public final r5 c() {
        return this.a;
    }
}