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

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


package com.ss.videoarch.strategy.utils.smartStrategy;

import android.content.Context;
import android.os.Handler;
import android.os.Looper;
import android.text.TextUtils;
import android.util.Log;
import com.bytedance.pitaya.api.IPitayaCore;
import com.bytedance.pitaya.api.PTYDIDCallback;
import com.bytedance.pitaya.api.PTYMessageHandler;
import com.bytedance.pitaya.api.PTYNormalCallback;
import com.bytedance.pitaya.api.PTYPackageCallback;
import com.bytedance.pitaya.api.PTYSettingsCallback;
import com.bytedance.pitaya.api.PTYSetupCallback;
import com.bytedance.pitaya.api.PTYTaskResultCallback;
import com.bytedance.pitaya.api.PTYUIDCallback;
import com.bytedance.pitaya.api.PitayaCoreFactory;
import com.bytedance.pitaya.api.bean.PTYError;
import com.bytedance.pitaya.api.bean.PTYRequestConfig;
import com.bytedance.pitaya.api.bean.PTYSetupInfo;
import com.bytedance.pitaya.api.bean.PTYTaskConfig;
import com.bytedance.pitaya.api.bean.PTYTaskData;
import com.bytedance.pitaya.api.feature.store.PTYFeatureProducer;
import com.bytedance.pitaya.api.feature.store.PTYFeatureStoreInstance;
import com.bytedance.pitaya.api.mutilinstance.HostSetupListener;
import com.bytedance.pitaya.api.mutilinstance.HostSetupWatcher;
import com.ss.videoarch.strategy.dataCenter.config.a;
import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;

public class PitayaWrapper {
    private static volatile PitayaWrapper g;
    public StreamStrategyFeatureProducer f;

    public Handler f108640a = new Handler(Looper.getMainLooper());
    private final String h = "PitayaWrapper";
    private String i = "330361";
    private JSONObject j = null;

    public String f108641b = "";

    public String f108642c = "";
    private String k = "";
    public long d = 180000;
    public int e = -1;
    private PitayaBridge l = new PitayaBridge();

    public boolean a(String str, JSONObject jSONObject, PTYTaskResultCallback pTYTaskResultCallback) {
        if (b()) {
            PitayaCoreFactory.getCore(this.i).runTask(str, new PTYTaskData(jSONObject), new PTYTaskConfig(true, null, (float) a.a().p.e.mRunPtyPackageWaitTime), pTYTaskResultCallback);
            return true;
        }
        Log.e("PitayaWrapper", "pty not initialized");
        return false;
    }

    public static class StreamStrategyFeatureProducer extends PTYFeatureProducer {
        private final String FEATURE_GROUP_NAME = "live_stream_strategy_feature_group";

        @Override
        public String getGroupName() {
            return "live_stream_strategy_feature_group";
        }

        @Override
        public float getNumericFeature(String str, JSONObject jSONObject) {
            return 0.0f;
        }

        @Override
        public JSONArray getSeqFeature(String str, JSONObject jSONObject) {
            return null;
        }

        @Override
        public String getStringFeature(String str, JSONObject jSONObject) {
            return null;
        }

        StreamStrategyFeatureProducer() {
        }

        @Override
        public JSONObject getDictFeature(String str, JSONObject jSONObject) {
            return com.ss.videoarch.strategy.dataCenter.featureCenter.a.a().a(jSONObject, "2", "");
        }
    }

    public void c() {
        PitayaCoreFactory.getCore(this.i).requestUpdateAll();
    }

    public static PitayaWrapper a() {
        if (g == null) {
            synchronized (PitayaWrapper.class) {
                if (g == null) {
                    g = new PitayaWrapper();
                }
            }
        }
        return g;
    }

    public void d() {
        this.f = new StreamStrategyFeatureProducer();
        PTYFeatureStoreInstance.INSTANCE.getFeatureStore().registerFeatureProducer(this.f, new PTYNormalCallback() {
            @Override
            public void onResult(boolean z, PTYError pTYError) {
                if (z) {
                    Log.d("PitayaWrapper", "register feature producer success");
                    return;
                }
                Log.d("PitayaWrapper", "register feature producer fail, error:" + pTYError);
            }
        });
    }

    public boolean b() {
        return PitayaCoreFactory.getCore(this.i).isReady();
    }

    public void a(String str) {
        PitayaCoreFactory.getCore(this.i).removeMessageHandler(str);
    }

    public void a(Context context) {
        IPitayaCore core = PitayaCoreFactory.getCore(this.i);
        String str = this.i;
        com.ss.videoarch.strategy.b.a.a.a();
        core.setup(context, new PTYSetupInfo(str, "1.4.121.5", this.k, new PTYDIDCallback() {
            @Override
            public String getDid() {
                return PitayaWrapper.this.f108641b;
            }
        }, new PTYUIDCallback() {
            @Override
            public String getUid() {
                return PitayaWrapper.this.f108642c;
            }
        }, null, new PTYSettingsCallback() {
            @Override
            public JSONObject getSettings(String str2) {
                String str3 = a.a().p.e.mPitayaABSettingsParams;
                Log.d("PitayaWrapper", "pitayaABSettingsParams:" + str3);
                if (!TextUtils.isEmpty(str3)) {
                    try {
                        return new JSONObject().put("content", new JSONObject(str3));
                    } catch (JSONException e) {
                        e.printStackTrace();
                    }
                }
                return null;
            }
        }, 2, true, null, 2, null, false, false, null), new PTYSetupCallback() {
            @Override
            public void onResult(boolean z, PTYError pTYError) {
                Log.e("PitayaWrapper", "pty init result:" + z + ",error:" + pTYError);
                if (PitayaWrapper.this.f108640a != null && z) {
                    PitayaWrapper.this.f108640a.removeMessages(1028);
                    PitayaWrapper.this.f108640a.sendEmptyMessage(1028);
                }
            }
        });
    }

    public void b(String str, PTYPackageCallback pTYPackageCallback) {
        PitayaCoreFactory.getCore(this.i).queryPackage(str, pTYPackageCallback);
    }

    public void b(String str, PTYTaskResultCallback pTYTaskResultCallback) {
        PitayaCoreFactory.getCore(this.i).removeApplogRunEventCallback(str);
    }

    public void a(String str, PTYMessageHandler pTYMessageHandler) {
        PitayaCoreFactory.getCore(this.i).registerMessageHandler(str, pTYMessageHandler);
    }

    public void a(String str, PTYPackageCallback pTYPackageCallback) {
        PitayaCoreFactory.getCore(this.i).downloadPackage(str, pTYPackageCallback);
    }

    public void a(String str, PTYTaskResultCallback pTYTaskResultCallback) {
        PitayaCoreFactory.getCore(this.i).registerApplogRunEventCallback(str, pTYTaskResultCallback);
    }

    public void a(final Context context, JSONObject jSONObject, String str) {
        Handler handler;
        this.j = jSONObject;
        this.i = str;
        if (jSONObject != null) {
            if (jSONObject.has("device_id")) {
                this.f108641b = this.j.optString("device_id");
            }
            if (this.j.has("user_id")) {
                this.f108642c = this.j.optString("user_id");
            }
            if (this.j.has("channel")) {
                this.k = this.j.optString("channel");
            }
        }
        if (HostSetupWatcher.INSTANCE.isHostSetup()) {
            a(context);
            return;
        }
        HostSetupWatcher.INSTANCE.registerHostSetupListener(new HostSetupListener() {
            @Override
            public void onHostSetup(boolean z) {
                if (PitayaWrapper.this.e == 1 && PitayaWrapper.this.f108640a != null) {
                    PitayaWrapper.this.f108640a.removeMessages(1026);
                }
                if (z) {
                    PitayaWrapper.this.a(context);
                }
            }
        });
        if (this.e == 1 && (handler = this.f108640a) != null) {
            handler.sendEmptyMessageDelayed(1026, this.d);
        }
    }

    public void a(String str, PTYRequestConfig pTYRequestConfig, PTYPackageCallback pTYPackageCallback) {
        PitayaCoreFactory.getCore(this.i).requestUpdate(str, pTYRequestConfig, pTYPackageCallback);
    }
}