Hi @mafcocinco. I’d be happy to help, but I need a few more details. A minimal, but full, example would help. For starters, are you passing the handler fn directly into start-server as is? Because Aleph handlers only accept a single request parameter, but your handler takes two.

Cool. I’ll get you a full example.

This could probably be slightly simpler but hopefully gives the general idea of what I’m trying to accomplish

@mafcocinco And is the commented code what you’re running to test it, when you get the error? (For future reference, you probably want to put all that in a (comment ....) block for ease of REPLing)

yes, it is. And thanks, I will use comment going forward.

@mafcocinco Hey, can you run your minimal example and verify that it shows the error you expect? There’s several things going wrong that aren’t what you initially described 🙂 1. ring.util.http-response isn’t a ring namespace. 2. I’m getting `SEVERE: cannot coerce clojure.lang.PersistentArrayMap into binary representation java.lang.IllegalArgumentException: Don’t know how to convert class clojure.lang.PersistentArrayMap into class java.nio.ByteBuffer` when I try to put into the core.async channel, which is a totally different error 1. Why did you add core.async? Manifold’s s/put, which you described using earlier, is correct. You can use it to write directly to the stream in state*

Let me revise.

ring.util.http-response is part of a metosin library. That should be easy to remove

Cool. Can you also remove the worker thread relaying from core.async to the websocket stream? I think we need to simplify this a bit

Also, have you run the websocket examples in https://aleph.io/aleph/literate.html#aleph.examples.websocket ? Did they work ok?

yes, the examples worked for me.

the s/put! returns true but the s/take! from conn returns nil

OK, let me take another look. Which version of aleph are you on, btw?

^^^ @mafcocinco Which Aleph version (and other dep versions) are you using?

aleph 0.4.6, reitit vesion 0.4.2

sorry for the delay, out on holiday break

Thanks @mafcocinco I’ll take a look later

I understand conceptually what you are saying but not sure how to implement it. Would that basically mean not calling (ring/ring-handler default) for any websocket routes? E.g. passing the result of (ring/router) directly to (http/start-server …)?

@mafcocinco I think so. And you may or may not be able to use ring/router either, if it tries to transform data. You want something that directly routes data to the handler, with no attempt to interpret the data as HTTP at all, invoke middlewares, etc. After the initial handshake, WebSockets ditches HTTP and is much lower-level, more like TCP sockets. Ring and HTTP don’t apply. Maybe try reitit’s default, non-ring router.

I’ll give that a try. Thank you for your help!