package o;

import com.scb.phone.data.entity.transfer.SingleDataEntity;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Iterator;
import java.util.List;
import java.util.Objects;

/* loaded from: classes3.dex */
public final class nsT implements InterfaceC2070aWe {
    private final gDK a;
    private final Hfm b;
    private final DDE c;
    private final tRa d;
    final UAu e;

    @InterfaceC13391fZD
    public nsT(DDE dde, UAu uAu, Hfm hfm, tRa tra, gDK gdk) {
        this.c = dde;
        this.e = uAu;
        this.b = hfm;
        this.d = tra;
        this.a = gdk;
    }

    @Override // o.InterfaceC2070aWe
    public final AbstractC13163fSk<HCR> a() {
        return this.c.d.getNotifications().map(new fSS(this) { // from class: o.auv
            private nsT d;

            @Override // o.fSS
            public final Object a(Object obj) {
                return this.d.e.c((C3606bBK) ((SingleDataEntity) obj).getData());
            }

            {
                this.d = this;
            }
        });
    }

    @Override // o.InterfaceC2070aWe
    public final AbstractC13163fSk<HCR> a(String str) {
        return this.c.d.getNotifications(str).map(new fSS(this) { // from class: o.qoU
            private nsT b;

            @Override // o.fSS
            public final Object a(Object obj) {
                return this.b.e.c((C3606bBK) ((SingleDataEntity) obj).getData());
            }

            {
                this.b = this;
            }
        });
    }

    @Override // o.InterfaceC2070aWe
    public final AbstractC13163fSk<AWC> e() {
        AbstractC13163fSk<SingleDataEntity<rLP>> notificationUnreadCount = this.c.d.getNotificationUnreadCount();
        final Hfm hfm = this.b;
        Objects.requireNonNull(hfm);
        return notificationUnreadCount.map(new fSS(hfm) { // from class: o.yOR
            private Hfm d;

            @Override // o.fSS
            public final Object a(Object obj) {
                return Hfm.d((SingleDataEntity<rLP>) obj);
            }

            {
                this.d = hfm;
            }
        });
    }

    @Override // o.InterfaceC2070aWe
    public final AbstractC13175fSw<List<XNX>> c() {
        fUY fuy = new fUY(new C13372fYk(this.c.d.getNotificationPreferences().firstOrError(), new fSS() { // from class: o.NVw
            @Override // o.fSS
            public final Object a(Object obj) {
                return ((ypB) ((SingleDataEntity) obj).getData()).e;
            }
        }), new fSS() { // from class: o.Hfb
            @Override // o.fSS
            public final Object a(Object obj) {
                return AbstractC13163fSk.fromIterable((List) obj);
            }
        });
        final tRa tra = this.d;
        Objects.requireNonNull(tra);
        return fuy.map(new fSS(tra) { // from class: o.JiA
            private tRa e;

            @Override // o.fSS
            public final Object a(Object obj) {
                return this.e.b((xMn) obj);
            }

            {
                this.e = tra;
            }
        }).toList();
    }

    @Override // o.InterfaceC2070aWe
    public final fRY b(List<XNX> list) {
        DDE dde = this.c;
        gDK gdk = this.a;
        C14957gcv.e(list, "");
        List<XNX> list2 = list;
        mFW mfw = gdk.a;
        C14957gcv.e(list2, "");
        ArrayList arrayList = new ArrayList(list2 instanceof Collection ? list2.size() : 10);
        Iterator<T> it = list2.iterator();
        while (it.hasNext()) {
            arrayList.add(mfw.a((XNX) it.next()));
        }
        return dde.d.updateNotificationPreferences(new ypB(arrayList)).flatMapCompletable(new fSS() { // from class: o.QKy
            @Override // o.fSS
            public final Object a(Object obj) {
                return new wSg();
            }
        });
    }
}