Tasker v6.6.3 - g0.java 源代码

package lg;

import android.net.Uri;
import com.joaomgcd.taskerm.util.b7;
import com.joaomgcd.taskerm.util.dd;
import com.joaomgcd.taskerm.util.h3;
import com.joaomgcd.taskerm.util.l7;
import com.joaomgcd.taskerm.util.pe;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.util.HashMap;
import java.util.Map;
import net.dinglisch.android.taskerm.pp;

public final class g0<TResult, TResultError extends h3> extends e0<l<TResult, TResultError>, TResult, TResultError> implements c0 {
    private final pe d;

    public g0(l<TResult, TResultError> lVar) {
        super(lVar);
        jk.p.i(lVar, "args");
        this.d = lVar.F().i();
    }

    private final long C(OutputStream outputStream, String str, String str2) {
        long M = n1.M(outputStream, "Content-Disposition: form-data; name=\"" + str + "\"");
        if (str2 != null) {
            M += n1.M(outputStream, "; filename=\"" + str2 + "\"");
        }
        return M + n1.Q(outputStream);
    }

    static long D(g0 g0Var, OutputStream outputStream, String str, String str2, int i, Object obj) {
        if ((i & 2) != 0) {
            str2 = null;
        }
        return g0Var.C(outputStream, str, str2);
    }

    private final long E(OutputStream outputStream, String str) {
        jk.i0 i0Var = new jk.i0();
        if (str != null) {
            return G(i0Var, outputStream, str);
        }
        if (!(((l) t()).F() instanceof c1)) {
            return i0Var.i;
        }
        String H0 = pp.H0(((c1) ((l) t()).F()).p());
        return (H0 == null || H0.length() == 0) ? i0Var.i : G(i0Var, outputStream, H0);
    }

    static long F(g0 g0Var, OutputStream outputStream, String str, int i, Object obj) {
        if ((i & 1) != 0) {
            str = null;
        }
        return g0Var.E(outputStream, str);
    }

    private static final long G(jk.i0 i0Var, OutputStream outputStream, String str) {
        long M = i0Var.i + n1.M(outputStream, "Content-Type: " + str);
        i0Var.i = M;
        long Q = M + n1.Q(outputStream);
        i0Var.i = Q;
        return Q;
    }

    private final long H(OutputStream outputStream, String str, long j, boolean z) {
        long O;
        long N;
        String str2;
        w0 F = ((l) t()).F();
        String e = F.e();
        if (e == null || e.length() == 0) {
            long P = j + n1.P(outputStream);
            HashMap<String, String> f = ((l) t()).f();
            O = P + n1.O(outputStream, str, f != null ? f.get(n1.A()) : null) + n1.P(outputStream) + M(outputStream, z);
            N = n1.N(outputStream);
        } else {
            long I = j + I(outputStream, str);
            if (F instanceof c1) {
                str2 = ((c1) F).p().getName();
                jk.p.h(str2, "getName(...)");
            } else {
                str2 = e;
            }
            O = I + L(outputStream, e, str2, z) + n1.N(outputStream);
            N = n1.Q(outputStream);
        }
        return O + N;
    }

    private final long I(OutputStream outputStream, final String str) {
        jk.i0 i0Var = new jk.i0();
        HashMap<String, String> v3 = b7.v3((Uri) b7.n6(null, new ik.a() {
            @Override
            public final Object e() {
                Uri J;
                J = g0.J(str);
                return J;
            }
        }, 1, null));
        if (v3.size() > 0) {
            for (Map.Entry<String, String> entry : v3.entrySet()) {
                K(i0Var, outputStream, this, entry.getKey(), entry.getValue());
            }
        } else {
            K(i0Var, outputStream, this, "body", str);
        }
        long Q = i0Var.i + n1.Q(outputStream);
        i0Var.i = Q;
        return Q;
    }

    public static final Uri J(String str) {
        return l7.D("http://test.com?" + str);
    }

    private static final <TResult, TResultError extends h3> void K(jk.i0 i0Var, OutputStream outputStream, g0<TResult, TResultError> g0Var, String str, String str2) {
        long j = i0Var.i;
        if (j > 0) {
            i0Var.i = j + n1.Q(outputStream);
        }
        long P = i0Var.i + n1.P(outputStream);
        i0Var.i = P;
        long D = P + D(g0Var, outputStream, str, null, 2, null);
        i0Var.i = D;
        long E = D + g0Var.E(outputStream, "text/plain");
        i0Var.i = E;
        long Q = E + n1.Q(outputStream);
        i0Var.i = Q;
        i0Var.i = Q + n1.M(outputStream, str2);
    }

    private final long L(OutputStream outputStream, String str, String str2, boolean z) throws IOException {
        return n1.P(outputStream) + C(outputStream, str, str2) + F(this, outputStream, null, 1, null) + n1.M(outputStream, "Content-Transfer-Encoding: binary") + n1.Q(outputStream) + n1.Q(outputStream) + a(outputStream, ((l) t()).F().g(), ((l) t()).F().h(), ((l) t()).i(), z);
    }

    private final long M(OutputStream outputStream, boolean z) throws IOException {
        return n1.M(outputStream, "Content-Type: application/octet-stream") + n1.Q(outputStream) + n1.Q(outputStream) + a(outputStream, ((l) t()).F().g(), ((l) t()).F().h(), ((l) t()).i(), z);
    }

    @Override
    public long a(OutputStream outputStream, InputStream inputStream, Long l, dd ddVar, boolean z) throws IOException {
        return super.a(outputStream, inputStream, l, ddVar, z);
    }

    @Override
    protected pe v() {
        return this.d;
    }

    @Override
    public Long w() {
        Long h = ((l) t()).F().h();
        if (h != null) {
            return Long.valueOf(h.longValue() + ((l) t()).C().length());
        }
        return null;
    }

    @Override
    protected long y(HttpURLConnection httpURLConnection, boolean z) throws IOException {
        jk.p.i(httpURLConnection, "<this>");
        OutputStream outputStream = null;
        try {
            String C = ((l) t()).C();
            n1.l(httpURLConnection, ((l) t()).F().e());
            outputStream = x(httpURLConnection, z);
            return H(outputStream, C, 0L, z);
        } finally {
            if (outputStream != null) {
                outputStream.close();
            }
            if (!z) {
                ((l) t()).F().g().close();
            }
        }
    }
}