package xyz.netfly.player;

import android.app.Activity;
import androidx.emoji2.text.v;
import androidx.media3.common.C;
import java.lang.ref.WeakReference;
import java.util.Map;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import org.drive_hunter.R;
import xyz.stream.api.entity.BaseEntity;
import xyz.stream.api.entity.SubtitlePlayEntity;
import xyz.stream.view.UiUtils;

/* JADX INFO: loaded from: classes3.dex */
public final class h implements xyz.stream.api.e {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final /* synthetic */ SubtitlePlayEntity f35199a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final /* synthetic */ n f35200b;

    public h(n nVar, SubtitlePlayEntity subtitlePlayEntity) {
        this.f35200b = nVar;
        this.f35199a = subtitlePlayEntity;
    }

    public static void b(h hVar, BaseEntity baseEntity, SubtitlePlayEntity subtitlePlayEntity) {
        hVar.getClass();
        UiUtils.dismissProgressDialog();
        Map map = (Map) xyz.stream.utils.m.f36162a.fromJson(baseEntity.getData(), new SubtitleController$3$1().getType());
        String str = (String) map.get("task_id");
        n nVar = hVar.f35200b;
        if (str == null || str.isEmpty()) {
            Activity activity = nVar.f35233s;
            UiUtils.showTip(activity, activity.getString(R.string.translation_failed));
            WeakReference weakReference = nVar.f35223i;
            if (weakReference == null || weakReference.get() == null) {
                return;
            }
            ((wf.a) nVar.f35223i.get()).d();
            return;
        }
        String str2 = (String) map.get("turbo_url");
        if (str2 == null || str2.isEmpty()) {
            if (nVar.f35228n) {
                nVar.x();
            }
            ScheduledExecutorService scheduledExecutorServiceNewSingleThreadScheduledExecutor = Executors.newSingleThreadScheduledExecutor();
            nVar.f35226l = scheduledExecutorServiceNewSingleThreadScheduledExecutor;
            scheduledExecutorServiceNewSingleThreadScheduledExecutor.scheduleWithFixedDelay(new com.tekartik.sqflite.g(nVar, str, 16), 0L, C.DEFAULT_MAX_SEEK_TO_PREVIOUS_POSITION_MS, TimeUnit.MILLISECONDS);
            return;
        }
        n.a(nVar, str2, subtitlePlayEntity.getTitle());
        WeakReference weakReference2 = nVar.f35223i;
        if (weakReference2 == null || weakReference2.get() == null) {
            return;
        }
        ((wf.a) nVar.f35223i.get()).d();
    }

    @Override // xyz.stream.api.e
    public final void a(String str) {
        n nVar = this.f35200b;
        if (nVar.o()) {
            nVar.f35233s.runOnUiThread(new com.tekartik.sqflite.g(this, str, 19));
        }
    }

    @Override // xyz.stream.api.e
    public final void onSuccess(Object obj) {
        BaseEntity baseEntity = (BaseEntity) obj;
        n nVar = this.f35200b;
        if (nVar.o()) {
            int i10 = 18;
            if (baseEntity == null || baseEntity.getCode() != 200) {
                nVar.f35233s.runOnUiThread(new com.tekartik.sqflite.g(this, baseEntity, 18));
            } else {
                nVar.f35233s.runOnUiThread(new v(this, baseEntity, this.f35199a, i10));
            }
        }
    }
}