package xyz.stream.api.viewmodel;

import android.content.Context;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Random;
import tv.danmaku.ijk.media.player.IjkMediaPlayer;
import xyz.stream.api.database.entity.ServerEntity;
import xyz.stream.api.entity.BaseEntity;

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

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

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final /* synthetic */ androidx.lifecycle.w f35989b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final /* synthetic */ Context f35990c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final /* synthetic */ IptvViewModel f35991d;

    public /* synthetic */ n(IptvViewModel iptvViewModel, androidx.lifecycle.w wVar, Context context, int i10) {
        this.f35988a = i10;
        this.f35991d = iptvViewModel;
        this.f35989b = wVar;
        this.f35990c = context;
    }

    @Override // xyz.stream.api.e
    public final void a(String str) {
        int i10 = this.f35988a;
        androidx.lifecycle.w wVar = this.f35989b;
        switch (i10) {
            case 0:
                wVar.j(null);
                break;
            default:
                wVar.j(Boolean.FALSE);
                this.f35991d.handleError(this.f35990c, str);
                break;
        }
    }

    public final void b(BaseEntity baseEntity) {
        ServerEntity serverEntity;
        int i10 = this.f35988a;
        IptvViewModel iptvViewModel = this.f35991d;
        Context context = this.f35990c;
        androidx.lifecycle.w wVar = this.f35989b;
        switch (i10) {
            case 0:
                List listE = xyz.stream.api.database.f.d().e();
                if (listE == null) {
                    listE = new ArrayList();
                }
                List list = listE;
                ArrayList<ServerEntity> arrayList = new ArrayList(list);
                ServerEntity serverEntity2 = null;
                if (baseEntity == null) {
                    wVar.j(null);
                } else if (baseEntity.getCode() != 200) {
                    wVar.j(null);
                    iptvViewModel.handleError(context, baseEntity.getMsg());
                } else {
                    ArrayList arrayList2 = new ArrayList();
                    List<Map> list2 = (List) xyz.stream.utils.m.f36162a.fromJson(baseEntity.getData(), new IptvViewModel$1$1().getType());
                    if (list2 != null && !list2.isEmpty()) {
                        for (Map map : list2) {
                            String str = (String) map.get("name");
                            String strI = xyz.stream.api.database.f.i((String) map.get(IjkMediaPlayer.OnNativeInvokeListener.ARG_URL));
                            if (str != null && strI != null) {
                                Iterator it = list.iterator();
                                while (true) {
                                    if (!it.hasNext()) {
                                        xyz.stream.api.database.f fVarD = xyz.stream.api.database.f.d();
                                        fVarD.getClass();
                                        try {
                                            serverEntity = (ServerEntity) fVarD.f35809b.submit(new ya.d(fVarD, str, strI, 1)).get();
                                        } catch (Exception e10) {
                                            u.a.g(e10, new StringBuilder("getServerByNameAndUrl error: "));
                                            serverEntity = serverEntity2;
                                        }
                                        if (serverEntity == null) {
                                            ServerEntity serverEntity3 = new ServerEntity(new Random().nextInt(50000000), str, Integer.valueOf(((int) System.currentTimeMillis()) / 1000), Integer.valueOf((int) (System.currentTimeMillis() / 1000)), strI, "", "", "", 10, "", 1);
                                            xyz.stream.api.database.f.d().g(serverEntity3);
                                            arrayList2.add(serverEntity3);
                                        }
                                        break;
                                    } else {
                                        ServerEntity serverEntity4 = (ServerEntity) it.next();
                                        String strI2 = xyz.stream.api.database.f.i(serverEntity4.getRootPath());
                                        if (serverEntity4.getServerName().equals(str) && strI.equals(strI2)) {
                                            arrayList.remove(serverEntity4);
                                        }
                                    }
                                }
                                serverEntity2 = null;
                            }
                        }
                    }
                    for (ServerEntity serverEntity5 : arrayList) {
                        xyz.stream.utils.h.b("Deleted IPTV server: " + serverEntity5.getServerName() + ", success: " + xyz.stream.api.database.f.d().m(serverEntity5.getId()));
                    }
                    wVar.j(arrayList2);
                }
                break;
            default:
                if (baseEntity == null) {
                    wVar.j(Boolean.FALSE);
                } else if (baseEntity.getCode() != 200) {
                    wVar.j(Boolean.FALSE);
                    iptvViewModel.handleError(context, baseEntity.getMsg());
                } else {
                    wVar.j(Boolean.TRUE);
                }
                break;
        }
    }

    @Override // xyz.stream.api.e
    public final /* bridge */ /* synthetic */ void onSuccess(Object obj) {
        switch (this.f35988a) {
            case 0:
                b((BaseEntity) obj);
                break;
            default:
                b((BaseEntity) obj);
                break;
        }
    }
}