How to access reactive Panache Entity Session Manager from a websocket endpoint?

[Feavy]

Hello everyone,

I am trying access a reactive Panache Entity Session Manager from a websocket but I cannot get it to work.

Here User is a basic PanacheEntity with a name attribute:

@Entity(name = "user")
public class User extends PanacheEntity {
    public String username;

    @ReactiveTransactional
    public static Uni<User> findByName(String username) {
        return find("username", username).firstResult();
    }
}

I tried two solutions:

1

@ServerEndpoint("/websocket/{name}")
@ApplicationScoped
class StartWebSocket {

    @OnOpen
    fun onOpen(session: Session, @PathParam("name") name: String) {
        User.findByName(name).subscribe().with{ println("Found: ${it?.username}")
   }
}

This one throws an exception:

could not execute query: java.util.concurrent.CompletionException: java.lang.IllegalStateException: Session/EntityManager is closed

I don't understand why the session is closed on this vert.x thread (vert.x-eventloop-thread-3,5,main)

2

The session is closed, so let's open one...

@ServerEndpoint("/websocket/{name}")
@ApplicationScoped
class StartWebSocket(
    val sessionFactory: SessionFactory
) {

    @OnOpen
    fun onOpen(session: Session, @PathParam("name") name: String) {
        sessionFactory.withSession { User.findByName(name) }.subscribe().with{ println("Found: ${it?.username}") }
   }
}

...but it doesn't work too.. Or to be more precise, it works 3 times and then it fails for timeout.

Does someone have an idea on how to make it work please?

Thanks!

[quarkus-bot[bot]]

/cc @FroMage, @loicmathieu

[Feavy]

Update:

I have no problem when using a raw query with Session object (even though I still need to open the session manually).

So the problem seems to be on Reactive Panache side, which doesn't work well with the session opened manually.

@ServerEndpoint("/websocket/{name}")
@ApplicationScoped
class StartWebSocket(
    val sessionFactory: SessionFactory
) {

    @OnOpen
    fun onOpen(session: Session, @PathParam("name") name: String) {
        sessionFactory.withSession { it.createQuery<User>("from User").singleResult }.subscribe().with { println("Found: ${it?.username}") }
   }
}