436 lines
15 KiB
Java
436 lines
15 KiB
Java
package o;
|
|
|
|
import com.google.firebase.crashlytics.internal.common.IdManager;
|
|
import com.scb.phone.data.entity.transfer.SingleDataEntity;
|
|
import java.util.ArrayList;
|
|
import java.util.List;
|
|
import java.util.Objects;
|
|
import o.PRA;
|
|
import org.threeten.bp.OffsetDateTime;
|
|
|
|
/* loaded from: classes3.dex */
|
|
public final class Ksd implements Oxn {
|
|
final gSD a;
|
|
final Ifc b;
|
|
final SCs c;
|
|
final DXU d;
|
|
final PRs e;
|
|
private final EBo f;
|
|
private final PJq g;
|
|
private final C0827Phe h;
|
|
private final PIZ i;
|
|
private final kCg j;
|
|
private final vgA l;
|
|
|
|
@InterfaceC13391fZD
|
|
public Ksd(EBo eBo, PJq pJq, PIZ piz, vgA vga, PRs pRs, gSD gsd, DXU dxu, kCg kcg, SCs sCs, Ifc ifc, C0827Phe c0827Phe) {
|
|
this.f = eBo;
|
|
this.e = pRs;
|
|
this.a = gsd;
|
|
this.d = dxu;
|
|
this.j = kcg;
|
|
this.c = sCs;
|
|
this.g = pJq;
|
|
this.i = piz;
|
|
this.l = vga;
|
|
this.b = ifc;
|
|
this.h = c0827Phe;
|
|
}
|
|
|
|
@Override // o.Oxn
|
|
public final AbstractC13163fSk<WZW> d(C10894eS c10894eS) {
|
|
return this.f.a.newOutgoingSummary(c10894eS).flatMap(new fSS(this) { // from class: o.KeA
|
|
private Ksd a;
|
|
|
|
@Override // o.fSS
|
|
public final Object a(Object obj) {
|
|
PRs pRs = this.a.e;
|
|
qlo qloVar = (qlo) ((SingleDataEntity) obj).getData();
|
|
WZW c = WZW.c();
|
|
Jyf jyf = pRs.b;
|
|
Iterable iterable = qloVar.c;
|
|
if (iterable == null) {
|
|
iterable = new ArrayList();
|
|
}
|
|
YKU yku = new YKU(iterable);
|
|
c.c = (List) new YKU(yku.a, new wxK(yku.b, new InterfaceC1244Ytw(jyf) { // from class: o.ADq
|
|
private Jyf a;
|
|
|
|
@Override // o.InterfaceC1244Ytw
|
|
public final Object d(Object obj2) {
|
|
sRx srx = (sRx) obj2;
|
|
LOB e = LOB.e();
|
|
e.s = srx.f9268o;
|
|
e.g = srx.j;
|
|
e.j = srx.i;
|
|
e.l = srx.g;
|
|
e.i = srx.d;
|
|
e.f = srx.h;
|
|
e.h = srx.f;
|
|
e.k = (OffsetDateTime) ZTC.e(new Object[]{srx.n, null}, 267499366, -267499366, (int) System.currentTimeMillis());
|
|
e.m = srx.k.e;
|
|
e.f8250o = srx.k.c;
|
|
e.c = Double.valueOf(srx.c).doubleValue();
|
|
e.d = srx.e;
|
|
e.b = (OffsetDateTime) ZTC.e(new Object[]{srx.b, null}, 267499366, -267499366, (int) System.currentTimeMillis());
|
|
e.a = srx.a;
|
|
e.n = srx.l;
|
|
return e;
|
|
}
|
|
|
|
{
|
|
this.a = jyf;
|
|
}
|
|
})).a(new PRA.Sts(new PRA.AnonymousClass4(), new PRA.AnonymousClass8()));
|
|
c.h = qloVar.a;
|
|
c.d = qloVar.d;
|
|
c.a = qloVar.e;
|
|
c.b = qloVar.b;
|
|
return AbstractC13163fSk.just(c);
|
|
}
|
|
|
|
{
|
|
this.a = this;
|
|
}
|
|
});
|
|
}
|
|
|
|
@Override // o.Oxn
|
|
public final AbstractC13163fSk<vdc> c(C10894eS c10894eS) {
|
|
return this.f.a.newIncomingSummary(c10894eS).flatMap(new fSS(this) { // from class: o.QsY
|
|
private Ksd c;
|
|
|
|
@Override // o.fSS
|
|
public final Object a(Object obj) {
|
|
gSD gsd = this.c.a;
|
|
wpd wpdVar = (wpd) ((SingleDataEntity) obj).getData();
|
|
vdc a = vdc.a();
|
|
a.i = wpdVar.d;
|
|
a.a = wpdVar.b;
|
|
a.b = wpdVar.c;
|
|
a.c = wpdVar.a;
|
|
final Juy juy = gsd.a;
|
|
Iterable iterable = wpdVar.e;
|
|
if (iterable == null) {
|
|
iterable = new ArrayList();
|
|
}
|
|
YKU yku = new YKU(iterable);
|
|
a.d = (List) new YKU(yku.a, new wxK(yku.b, new InterfaceC1244Ytw(juy) { // from class: o.tnC
|
|
private Juy a;
|
|
|
|
@Override // o.InterfaceC1244Ytw
|
|
public final Object d(Object obj2) {
|
|
ZPk zPk = (ZPk) obj2;
|
|
kVY e = kVY.e();
|
|
e.r = zPk.m;
|
|
e.j = zPk.i;
|
|
e.i = zPk.j;
|
|
e.m = zPk.f;
|
|
e.h = zPk.d;
|
|
e.f = zPk.g;
|
|
e.g = zPk.h;
|
|
e.n = (OffsetDateTime) ZTC.e(new Object[]{zPk.k, null}, 267499366, -267499366, (int) System.currentTimeMillis());
|
|
e.l = zPk.l.e;
|
|
e.k = zPk.l.c;
|
|
e.b = Double.valueOf(zPk.a).doubleValue();
|
|
e.d = zPk.e;
|
|
e.c = (OffsetDateTime) ZTC.e(new Object[]{zPk.b, null}, 267499366, -267499366, (int) System.currentTimeMillis());
|
|
e.a = zPk.c;
|
|
e.f9191o = zPk.f8481o;
|
|
return e;
|
|
}
|
|
|
|
{
|
|
this.a = juy;
|
|
}
|
|
})).a(new PRA.Sts(new PRA.AnonymousClass4(), new PRA.AnonymousClass8()));
|
|
return AbstractC13163fSk.just(a);
|
|
}
|
|
|
|
{
|
|
this.c = this;
|
|
}
|
|
});
|
|
}
|
|
|
|
@Override // o.Oxn
|
|
public final AbstractC13163fSk<Kaq> a(C10672eL c10672eL) {
|
|
AbstractC13163fSk<SingleDataEntity<C16393nuI>> confirmRequester = this.f.a.confirmRequester(c10672eL);
|
|
final C0827Phe c0827Phe = this.h;
|
|
Objects.requireNonNull(c0827Phe);
|
|
return confirmRequester.map(new fSS(c0827Phe) { // from class: o.kXJ
|
|
private C0827Phe d;
|
|
|
|
@Override // o.fSS
|
|
public final Object a(Object obj) {
|
|
return C0827Phe.e((SingleDataEntity<C16393nuI>) obj);
|
|
}
|
|
|
|
{
|
|
this.d = c0827Phe;
|
|
}
|
|
});
|
|
}
|
|
|
|
@Override // o.Oxn
|
|
public final AbstractC13163fSk<C15972jzc> b(C10635eK c10635eK) {
|
|
AbstractC13163fSk<SingleDataEntity<ePY>> doOnSubscribe = this.f.a.confirmPayer(c10635eK).doOnSubscribe(new fSQ() { // from class: o.nbX
|
|
@Override // o.fSQ
|
|
public final void c(Object obj) {
|
|
DiG.e("8101");
|
|
DiG.e("8102");
|
|
}
|
|
});
|
|
final kCg kcg = this.j;
|
|
Objects.requireNonNull(kcg);
|
|
return doOnSubscribe.map(new fSS(kcg) { // from class: o.VGl
|
|
private kCg a;
|
|
|
|
@Override // o.fSS
|
|
public final Object a(Object obj) {
|
|
C15972jzc fku;
|
|
SingleDataEntity singleDataEntity = (SingleDataEntity) obj;
|
|
ePY epy = (ePY) Objects.requireNonNull((ePY) singleDataEntity.getData());
|
|
String str = singleDataEntity.getStatus().e;
|
|
boolean equals = Objects.equals(str, "8101");
|
|
String str2 = IdManager.DEFAULT_VERSION_NAME;
|
|
if (!equals && !Objects.equals(str, "8102") && !Objects.equals(str, "8103")) {
|
|
fku = C15972jzc.b();
|
|
String str3 = epy.p;
|
|
if (str3 == null) {
|
|
str3 = "";
|
|
}
|
|
fku.y = str3;
|
|
String str4 = epy.t;
|
|
if (str4 == null) {
|
|
str4 = "";
|
|
}
|
|
fku.v = (OffsetDateTime) ZTC.e(new Object[]{str4, null}, 267499366, -267499366, (int) System.currentTimeMillis());
|
|
String str5 = epy.q;
|
|
if (str5 == null) {
|
|
str5 = "";
|
|
}
|
|
fku.p = str5;
|
|
String str6 = epy.s;
|
|
if (str6 == null) {
|
|
str6 = "";
|
|
}
|
|
fku.w = str6;
|
|
String str7 = epy.f8957o;
|
|
if (str7 == null) {
|
|
str7 = "";
|
|
}
|
|
fku.t = str7;
|
|
String str8 = epy.n;
|
|
if (str8 == null) {
|
|
str8 = "";
|
|
}
|
|
fku.r = str8;
|
|
String str9 = epy.r;
|
|
if (str9 == null) {
|
|
str9 = "";
|
|
}
|
|
fku.q = str9;
|
|
String str10 = epy.m;
|
|
if (str10 == null) {
|
|
str10 = "";
|
|
}
|
|
fku.s = str10;
|
|
String str11 = epy.b;
|
|
if (str11 == null) {
|
|
str11 = IdManager.DEFAULT_VERSION_NAME;
|
|
}
|
|
fku.i = Double.parseDouble(str11);
|
|
String str12 = epy.a;
|
|
if (str12 == null) {
|
|
str12 = "";
|
|
}
|
|
fku.h = str12;
|
|
String str13 = epy.f;
|
|
if (str13 == null) {
|
|
str13 = IdManager.DEFAULT_VERSION_NAME;
|
|
}
|
|
fku.k = Double.parseDouble(str13);
|
|
String str14 = epy.h;
|
|
if (str14 == null) {
|
|
str14 = "";
|
|
}
|
|
fku.f9188o = str14;
|
|
String str15 = epy.k;
|
|
fku.n = str15 != null ? str15 : "";
|
|
String str16 = epy.d;
|
|
if (str16 == null) {
|
|
str16 = IdManager.DEFAULT_VERSION_NAME;
|
|
}
|
|
fku.l = Double.parseDouble(str16);
|
|
String str17 = epy.j;
|
|
if (str17 != null) {
|
|
str2 = str17;
|
|
}
|
|
fku.m = str2;
|
|
} else {
|
|
String str18 = (String) Objects.requireNonNull(epy.c);
|
|
String str19 = (String) Objects.requireNonNull(epy.e);
|
|
String str20 = epy.b;
|
|
if (str20 != null) {
|
|
str2 = str20;
|
|
}
|
|
fku = new FKU(str18, str19, (String) Objects.requireNonNull(str2), (String) Objects.requireNonNull(epy.v), (String) Objects.requireNonNull(epy.g), (String) Objects.requireNonNull(epy.l), (String) Objects.requireNonNull(epy.i));
|
|
}
|
|
fku.a((iJI) ZTC.e(new Object[]{singleDataEntity}, 321450472, -321450471, (int) System.currentTimeMillis()));
|
|
return fku;
|
|
}
|
|
|
|
{
|
|
this.a = kcg;
|
|
}
|
|
}).doFinally(new Cbf());
|
|
}
|
|
|
|
@Override // o.Oxn
|
|
public final void b() {
|
|
this.g.d = null;
|
|
}
|
|
|
|
@Override // o.Oxn
|
|
public final void d() {
|
|
vgA vga = this.l;
|
|
vga.b = null;
|
|
vga.e = null;
|
|
}
|
|
|
|
@Override // o.Oxn
|
|
public final void c() {
|
|
PIZ piz = this.i;
|
|
piz.c = null;
|
|
piz.a = null;
|
|
}
|
|
|
|
@Override // o.Oxn
|
|
public final AbstractC13163fSk<C8987dbH> e() {
|
|
SingleDataEntity<C1656aKf> singleDataEntity = this.g.d;
|
|
if (singleDataEntity != null) {
|
|
return AbstractC13163fSk.just(SCs.e(singleDataEntity));
|
|
}
|
|
AbstractC13163fSk<SingleDataEntity<C1656aKf>> landing = this.f.a.getLanding();
|
|
final PJq pJq = this.g;
|
|
Objects.requireNonNull(pJq);
|
|
return landing.doOnNext(new fSQ(pJq) { // from class: o.GxP
|
|
private PJq d;
|
|
|
|
@Override // o.fSQ
|
|
public final void c(Object obj) {
|
|
this.d.d = (SingleDataEntity) obj;
|
|
}
|
|
|
|
{
|
|
this.d = pJq;
|
|
}
|
|
}).flatMap(new fSS(this) { // from class: o.jeh
|
|
private Ksd e;
|
|
|
|
@Override // o.fSS
|
|
public final Object a(Object obj) {
|
|
SCs sCs = this.e.c;
|
|
return AbstractC13163fSk.just(SCs.e((SingleDataEntity<C1656aKf>) obj));
|
|
}
|
|
|
|
{
|
|
this.e = this;
|
|
}
|
|
});
|
|
}
|
|
|
|
@Override // o.Oxn
|
|
public final C1006TnQ a() {
|
|
return Ifc.e(this.i.c);
|
|
}
|
|
|
|
@Override // o.Oxn
|
|
public final C10829eQ i() {
|
|
return this.i.a;
|
|
}
|
|
|
|
@Override // o.QpH
|
|
public final void f() {
|
|
this.g.d = null;
|
|
PIZ piz = this.i;
|
|
piz.c = null;
|
|
piz.a = null;
|
|
vgA vga = this.l;
|
|
vga.b = null;
|
|
vga.e = null;
|
|
}
|
|
|
|
@Override // o.Oxn
|
|
public final AbstractC13163fSk<osO> b(C10864eR c10864eR) {
|
|
SingleDataEntity<C17570xrA> singleDataEntity = this.l.b;
|
|
if (singleDataEntity != null) {
|
|
return AbstractC13163fSk.just(DXU.b(singleDataEntity));
|
|
}
|
|
AbstractC13163fSk<SingleDataEntity<C17570xrA>> reviewPayer = this.f.a.reviewPayer(c10864eR);
|
|
final vgA vga = this.l;
|
|
Objects.requireNonNull(vga);
|
|
return reviewPayer.doOnNext(new fSQ(vga) { // from class: o.Hps
|
|
private vgA d;
|
|
|
|
@Override // o.fSQ
|
|
public final void c(Object obj) {
|
|
this.d.b = (SingleDataEntity) obj;
|
|
}
|
|
|
|
{
|
|
this.d = vga;
|
|
}
|
|
}).flatMap(new fSS(this) { // from class: o.EAk
|
|
private Ksd c;
|
|
|
|
@Override // o.fSS
|
|
public final Object a(Object obj) {
|
|
DXU dxu = this.c.d;
|
|
return AbstractC13163fSk.just(DXU.b((SingleDataEntity<C17570xrA>) obj));
|
|
}
|
|
|
|
{
|
|
this.c = this;
|
|
}
|
|
});
|
|
}
|
|
|
|
@Override // o.Oxn
|
|
public final AbstractC13163fSk<C1006TnQ> a(C10829eQ c10829eQ) {
|
|
SingleDataEntity<kGX> singleDataEntity = this.i.c;
|
|
this.i.a = c10829eQ;
|
|
if (singleDataEntity != null) {
|
|
return AbstractC13163fSk.just(Ifc.e(singleDataEntity));
|
|
}
|
|
AbstractC13163fSk<SingleDataEntity<kGX>> reviewRequester = this.f.a.reviewRequester(c10829eQ);
|
|
final PIZ piz = this.i;
|
|
Objects.requireNonNull(piz);
|
|
return reviewRequester.doOnNext(new fSQ(piz) { // from class: o.EJA
|
|
private PIZ a;
|
|
|
|
@Override // o.fSQ
|
|
public final void c(Object obj) {
|
|
this.a.c = (SingleDataEntity) obj;
|
|
}
|
|
|
|
{
|
|
this.a = piz;
|
|
}
|
|
}).flatMap(new fSS(this) { // from class: o.oIY
|
|
private Ksd a;
|
|
|
|
@Override // o.fSS
|
|
public final Object a(Object obj) {
|
|
Ifc ifc = this.a.b;
|
|
return AbstractC13163fSk.just(Ifc.e((SingleDataEntity<kGX>) obj));
|
|
}
|
|
|
|
{
|
|
this.a = this;
|
|
}
|
|
});
|
|
}
|
|
}
|