红果免费短剧 v6.2.3.32版本的 MD5 值为：a6b05492607eab2c8a25f26d2f238ae0

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

package com.dragon.read.social.editor.jsb;

import android.content.Context;
import android.util.Log;
import com.bytedance.accountseal.a.l;
import com.bytedance.sdk.xbridge.annotations.XBridgeMethod;
import com.bytedance.sdk.xbridge.cn.protocol.StatefulMethod;
import com.bytedance.sdk.xbridge.cn.registry.core.IBDXBridgeContext;
import com.bytedance.sdk.xbridge.cn.registry.core.model.idl.CompletionBlock;
import com.bytedance.sdk.xbridge.cn.registry.core.model.idl.XBaseModel;
import com.bytedance.sdk.xbridge.cn.registry.core.model.idl.XBaseResultModel;
import com.dragon.read.app.App;
import com.dragon.read.base.ssconfig.template.hp;
import com.dragon.read.social.editor.UgcTopicPostEditorFragment;
import com.dragon.read.social.editor.booklist.UgcBookListEditorFragment;
import com.dragon.read.social.editor.jsb.a;
import io.reactivex.Single;
import io.reactivex.SingleEmitter;
import io.reactivex.SingleOnSubscribe;
import io.reactivex.disposables.Disposable;
import io.reactivex.functions.Consumer;
import java.util.ArrayList;
import java.util.List;
import kotlin.jvm.internal.Intrinsics;
import org.json.JSONObject;

@XBridgeMethod(name = "readingGetDraftList", owner = "pengdali.uaena@bytedance.com")
public final class e extends com.dragon.read.social.editor.jsb.a implements StatefulMethod {

    public Disposable f82975c;

    @Override
    public void release() {
        Disposable disposable = this.f82975c;
        if (disposable != null) {
            disposable.dispose();
        }
    }

    public static final class b<T> implements Consumer<List<? extends JSONObject>> {

        final CompletionBlock<a.c> f82978a;

        b(CompletionBlock<a.c> completionBlock) {
            this.f82978a = completionBlock;
        }

        @Override
        public final void accept(List<? extends JSONObject> list) {
            CompletionBlock<a.c> completionBlock = this.f82978a;
            XBaseModel a2 = com.bytedance.sdk.xbridge.cn.registry.core.utils.c.a((Class<XBaseModel>) a.c.class);
            ((a.c) a2).setDraftData(list);
            CompletionBlock.DefaultImpls.onSuccess$default(completionBlock, (XBaseResultModel) a2, null, 2, null);
        }
    }

    public static final class c<T> implements Consumer<Throwable> {

        final CompletionBlock<a.c> f82979a;

        c(CompletionBlock<a.c> completionBlock) {
            this.f82979a = completionBlock;
        }

        @Override
        public final void accept(Throwable th) {
            CompletionBlock.DefaultImpls.onFailure$default(this.f82979a, 0, "exception:" + Log.getStackTraceString(th), null, 4, null);
        }
    }

    public static final class a<T> implements SingleOnSubscribe<List<? extends JSONObject>> {

        final a.b f82976a;

        final Object f82977b;

        a(a.b bVar, Object obj) {
            this.f82976a = bVar;
            this.f82977b = obj;
        }

        @Override
        public final void subscribe(SingleEmitter<List<? extends JSONObject>> it2) {
            Intrinsics.checkNotNullParameter(it2, "it");
            String dataType = this.f82976a.getDataType();
            if (Intrinsics.areEqual(dataType, "topic_comment")) {
                it2.onSuccess(UgcTopicPostEditorFragment.B.a((Context) this.f82977b, this.f82976a.getCount().intValue()));
            } else if (Intrinsics.areEqual(dataType, "booklist")) {
                it2.onSuccess(UgcBookListEditorFragment.B.a());
            } else {
                it2.onSuccess(new ArrayList());
            }
        }
    }

    @Override
    public void handle(IBDXBridgeContext bridgeContext, a.b bVar, CompletionBlock<a.c> completionBlock) {
        Object ownerActivity;
        Intrinsics.checkNotNullParameter(bridgeContext, "bridgeContext");
        Intrinsics.checkNotNullParameter(bVar, l.i);
        Intrinsics.checkNotNullParameter(completionBlock, l.o);
        if (!hp.f45217a.b()) {
            CompletionBlock.DefaultImpls.onFailure$default(completionBlock, -3, "没有命中实验，不要调用！", null, 4, null);
            return;
        }
        if (bridgeContext.getOwnerActivity() == null) {
            ownerActivity = App.context();
        } else {
            ownerActivity = bridgeContext.getOwnerActivity();
        }
        if (ownerActivity == null) {
            CompletionBlock.DefaultImpls.onFailure$default(completionBlock, 0, "context is null!", null, 4, null);
        } else {
            this.f82975c = Single.create(new a(bVar, ownerActivity)).subscribe(new b(completionBlock), new c(completionBlock));
        }
    }
}