package org.jboss.resteasy.test.asynch.resource;

import java.io.IOException;

import jakarta.servlet.ReadListener;
import jakarta.servlet.ServletInputStream;
import jakarta.servlet.http.HttpServletRequest;
import jakarta.ws.rs.GET;
import jakarta.ws.rs.POST;
import jakarta.ws.rs.Path;
import jakarta.ws.rs.container.AsyncResponse;
import jakarta.ws.rs.container.Suspended;
import jakarta.ws.rs.core.Context;

@Path("")
public class AsyncUnhandledExceptionResource {

    @Context
    private HttpServletRequest request;

    @POST
    @Path("listener")
    public void a(@Suspended final AsyncResponse async) throws IOException {
        final ServletInputStream inputStream = request.getInputStream();

        inputStream.setReadListener(new ReadListener() {
            @Override
            public void onDataAvailable() throws IOException {
                throw new java.lang.IllegalStateException("a exception");
            }

            @Override
            public void onAllDataRead() throws IOException {
            }

            @Override
            public void onError(Throwable t) {
                async.resume(t);
            }
        });
    }

    @GET
    @Path("thread")
    public void b(@Suspended final AsyncResponse response) {
        new Thread() {
            public void run() {
                try {
                    Thread.sleep(1000);
                    response.resume(new IllegalStateException("b exception"));
                } catch (Exception e) {
                    throw new RuntimeException(e);
                }
            }
        }.start();
    }
}
