package okhttp3.internal.sse;

import androidx.media3.container.NalUnitUtil;
import androidx.media3.exoplayer.rtsp.SessionDescription;
import androidx.media3.extractor.text.ttml.TtmlNode;
import defpackage.cr4;
import defpackage.kp6;
import defpackage.lg0;
import defpackage.ly6;
import defpackage.pq6;
import defpackage.sh0;
import defpackage.uz1;
import defpackage.vx8;
import defpackage.zo0;
import java.io.IOException;
import kotlin.Metadata;
import okhttp3.internal.Util;

/* JADX INFO: loaded from: classes3.dex */
@Metadata(d1 = {"\u00004\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\u000e\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u000b\n\u0002\b\t\u0018\u0000 \u00172\u00020\u0001:\u0002\u0018\u0017B\u0017\u0012\u0006\u0010\u0003\u001a\u00020\u0002\u0012\u0006\u0010\u0005\u001a\u00020\u0004¢\u0006\u0004\b\u0006\u0010\u0007J+\u0010\u000e\u001a\u00020\r2\b\u0010\t\u001a\u0004\u0018\u00010\b2\b\u0010\n\u001a\u0004\u0018\u00010\b2\u0006\u0010\f\u001a\u00020\u000bH\u0002¢\u0006\u0004\b\u000e\u0010\u000fJ\r\u0010\u0011\u001a\u00020\u0010¢\u0006\u0004\b\u0011\u0010\u0012R\u0014\u0010\u0003\u001a\u00020\u00028\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0003\u0010\u0013R\u0014\u0010\u0005\u001a\u00020\u00048\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0005\u0010\u0014R\u0018\u0010\u0015\u001a\u0004\u0018\u00010\b8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\u0015\u0010\u0016¨\u0006\u0019"}, d2 = {"Lokhttp3/internal/sse/ServerSentEventReader;", "", "Lsh0;", "source", "Lokhttp3/internal/sse/ServerSentEventReader$Callback;", "callback", "<init>", "(Lsh0;Lokhttp3/internal/sse/ServerSentEventReader$Callback;)V", "", TtmlNode.ATTR_ID, SessionDescription.ATTR_TYPE, "Llg0;", "data", "Le6a;", "completeEvent", "(Ljava/lang/String;Ljava/lang/String;Llg0;)V", "", "processNextEvent", "()Z", "Lsh0;", "Lokhttp3/internal/sse/ServerSentEventReader$Callback;", "lastId", "Ljava/lang/String;", "Companion", "Callback", "okhttp-sse"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
@vx8
public final class ServerSentEventReader {

    @kp6
    private static final zo0 CRLF;

    /* JADX INFO: renamed from: Companion, reason: from kotlin metadata */
    @kp6
    public static final Companion INSTANCE = new Companion(null);

    @kp6
    private static final ly6 options;

    @kp6
    private final Callback callback;

    @pq6
    private String lastId;

    @kp6
    private final sh0 source;

    @Metadata(d1 = {"\u0000 \n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0010\u000e\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\t\n\u0002\b\u0004\bf\u0018\u00002\u00020\u0001J+\u0010\u0007\u001a\u00020\u00062\b\u0010\u0003\u001a\u0004\u0018\u00010\u00022\b\u0010\u0004\u001a\u0004\u0018\u00010\u00022\u0006\u0010\u0005\u001a\u00020\u0002H&¢\u0006\u0004\b\u0007\u0010\bJ\u0017\u0010\u000b\u001a\u00020\u00062\u0006\u0010\n\u001a\u00020\tH&¢\u0006\u0004\b\u000b\u0010\f¨\u0006\r"}, d2 = {"Lokhttp3/internal/sse/ServerSentEventReader$Callback;", "", "", TtmlNode.ATTR_ID, SessionDescription.ATTR_TYPE, "data", "Le6a;", "onEvent", "(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V", "", "timeMs", "onRetryChange", "(J)V", "okhttp-sse"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    public interface Callback {
        void onEvent(@pq6 String id, @pq6 String type, @kp6 String data);

        void onRetryChange(long timeMs);
    }

    @Metadata(d1 = {"\u00006\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\t\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0003\b\u0086\u0003\u0018\u00002\u00020\u0001B\t\b\u0002¢\u0006\u0004\b\u0002\u0010\u0003J\u001b\u0010\b\u001a\u00020\u0007*\u00020\u00042\u0006\u0010\u0006\u001a\u00020\u0005H\u0002¢\u0006\u0004\b\b\u0010\tJ\u0013\u0010\u000b\u001a\u00020\n*\u00020\u0004H\u0002¢\u0006\u0004\b\u000b\u0010\fR\u0017\u0010\u000e\u001a\u00020\r8\u0006¢\u0006\f\n\u0004\b\u000e\u0010\u000f\u001a\u0004\b\u0010\u0010\u0011R\u0014\u0010\u0013\u001a\u00020\u00128\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0013\u0010\u0014¨\u0006\u0015"}, d2 = {"Lokhttp3/internal/sse/ServerSentEventReader$Companion;", "", "<init>", "()V", "Lsh0;", "Llg0;", "data", "Le6a;", "readData", "(Lsh0;Llg0;)V", "", "readRetryMs", "(Lsh0;)J", "Lly6;", "options", "Lly6;", "getOptions", "()Lly6;", "Lzo0;", "CRLF", "Lzo0;", "okhttp-sse"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    public static final class Companion {
        public /* synthetic */ Companion(uz1 uz1Var) {
            this();
        }

        /* JADX INFO: Access modifiers changed from: private */
        public final void readData(sh0 sh0Var, lg0 lg0Var) throws IOException {
            lg0Var.ak(10);
            sh0Var.ba(lg0Var, sh0Var.ae(ServerSentEventReader.CRLF));
            sh0Var.bi(getOptions());
        }

        /* JADX INFO: Access modifiers changed from: private */
        public final long readRetryMs(sh0 sh0Var) throws IOException {
            return Util.toLongOrDefault(sh0Var.aj(), -1L);
        }

        @kp6
        public final ly6 getOptions() {
            return ServerSentEventReader.options;
        }

        private Companion() {
        }
    }

    static {
        zo0 zo0Var = zo0.d;
        options = ly6.a.b(zo0.a.c("\r\n"), zo0.a.c("\r"), zo0.a.c("\n"), zo0.a.c("data: "), zo0.a.c("data:"), zo0.a.c("data\r\n"), zo0.a.c("data\r"), zo0.a.c("data\n"), zo0.a.c("id: "), zo0.a.c("id:"), zo0.a.c("id\r\n"), zo0.a.c("id\r"), zo0.a.c("id\n"), zo0.a.c("event: "), zo0.a.c("event:"), zo0.a.c("event\r\n"), zo0.a.c("event\r"), zo0.a.c("event\n"), zo0.a.c("retry: "), zo0.a.c("retry:"));
        CRLF = zo0.a.c("\r\n");
    }

    public ServerSentEventReader(@kp6 sh0 sh0Var, @kp6 Callback callback) {
        cr4.g(sh0Var, "source");
        cr4.g(callback, "callback");
        this.source = sh0Var;
        this.callback = callback;
    }

    private final void completeEvent(String id, String type, lg0 data) throws IOException {
        if (data.b != 0) {
            this.lastId = id;
            data.skip(1L);
            this.callback.onEvent(id, type, data.aa());
        }
    }

    public final boolean processNextEvent() throws IOException {
        String strAj = this.lastId;
        lg0 lg0Var = new lg0();
        while (true) {
            String strAj2 = null;
            while (true) {
                sh0 sh0Var = this.source;
                ly6 ly6Var = options;
                int iBi = sh0Var.bi(ly6Var);
                if (iBi >= 0 && iBi < 3) {
                    completeEvent(strAj, strAj2, lg0Var);
                    return true;
                }
                if (3 <= iBi && iBi < 5) {
                    INSTANCE.readData(this.source, lg0Var);
                } else if (5 <= iBi && iBi < 8) {
                    lg0Var.ak(10);
                } else if (8 <= iBi && iBi < 10) {
                    strAj = this.source.aj();
                    if (strAj.length() <= 0) {
                        strAj = null;
                    }
                } else if (10 <= iBi && iBi < 13) {
                    strAj = null;
                } else if (13 <= iBi && iBi < 15) {
                    strAj2 = this.source.aj();
                    if (strAj2.length() > 0) {
                    }
                } else if (15 > iBi || iBi >= 18) {
                    if (18 <= iBi && iBi < 20) {
                        long retryMs = INSTANCE.readRetryMs(this.source);
                        if (retryMs != -1) {
                            this.callback.onRetryChange(retryMs);
                        }
                    } else {
                        if (iBi != -1) {
                            throw new AssertionError();
                        }
                        long jAe = this.source.ae(CRLF);
                        if (jAe == -1) {
                            return false;
                        }
                        this.source.skip(jAe);
                        this.source.bi(ly6Var);
                    }
                }
            }
        }
    }
}