fs2-http/Lobby

Luciano

@lJoublanc

In that case I suggest you look at the guide, linked from README.md. At the end there is examples of "how to talk to the external world"

Soren

@srnb_gitlab

I match those to some set of event handlers

Luciano

@lJoublanc

Ah ok... In that case, let me see ...

Soren

@srnb_gitlab

And the event handlers should be able to have an effect on what is sent through the WS

Luciano

@lJoublanc

Yeah, I think this is straightforward. Create a pipe like this:
in => in.evalMap( x => IO {mycallback(x) } )

You need to use evalMap rather than map to show there is a side-effect (your callback).

The input type in will be a stream from the websocket. The output type will be the return type of your callback.

Does that make sense?

You'll also need to implement codecs for Frame according to the readme. I.e. this translates between the binary representation sent to the server, and your scala objects. You can get help for that on the scodec channel; I can help out here too.

Soren

@srnb_gitlab

It's just Json in this case, I'll be using Circe to parse

Soren

@srnb_gitlab

So does that mean every event handler needs to be fed an IO with some sort of callback?

I don't understand how that helps event handlers to send things to the WS

Adam Chlupacek

@AdamChlupacek

@srnb_gitlab Sending to WS and processing messages from WS is usually done via queues. That way you can direct the data where ever you want.

Soren

@srnb_gitlab

Apparently the websocket docs are way out of date; Stream#mergeDrainL no longer exists meaning I can't follow what those docs do

Luciano

@lJoublanc

I think this can be replaced with concurrently without probs.

(you may have to swap the arguments possibly).

Soren

@srnb_gitlab

Well, I'm not getting errors

case class EventSocket[F[_]](myShard: Int, maxShards: Int, queue: Queue[F, Event])(implicit concurrent: Concurrent[F]) {

  def wsPipe(matcher: EventMatcher, handler: PartialFunction[Event, Option[Event]]): Pipe[F, Frame[String], Frame[String]] = { inbound =>
    val output = queue.dequeue.map(e => Frame.Text(e.asJson.noSpaces))
    output.concurrently(inbound.flatMap { in =>
      val json: Json = parse(in.a).right.toOption.get
      val matched: Stream[F, Option[Event]] = matcher[F](json)
      val handeled: Stream[F, Option[Event]] = matched.map(_.flatMap(handler))
      val queued: Stream[F, Unit] = handeled.flatMap(_.fold[Stream[F, Unit]](Stream.empty)(e => Stream.eval(queue.enqueue1(e))))
      queued
    })
  }

}

Am I doing this correctly?

Luciano

@lJoublanc

Just check the concurrently signature in the scaladoc; make sure it matches mergeDrainL i.e. the Nothing has to be on the correct side.

Soren

@srnb_gitlab

Any ADT to represent Websocket URIs?

Huh, URI can do wss but WebSocketRequest can't do URI

Soren

@srnb_gitlab

I just made my own match case for now

Media Type must be text, but is DefaultMediaType(application,json,true,true,WrappedArray(json))

How do I fix this? I'm using circe, should I just do bodyAs[Json] instead?

Soren

@srnb_gitlab

java.lang.Throwable: Failed to decode value: cannot acquire 16526844176 bits from a vector that contains 728 bits, content: ByteVector(95 bytes, 0x7b2274223a6e756c6c2c2273223a6e756c6c2c226f70223a31302c2264223a7b226865617274626561745f696e74657276616c223a34313235302c225f7472616365223a5b22676174657761792d7072642d6d61696e2d6b673677225d7d7d)

Why does fs2-http want 2GB

Soren

@srnb_gitlab

The first issue is an issue with normal requests, and the second is an issue with websockets, by the way

Soren

@srnb_gitlab

Should I make an issue on GitHub or is there something I need to fix on my end?

Pavel Chlupacek

@pchlupacek

@srnb_gitlab please feel free open issue. Even when this will be on your end, it us easier for us to respond, hence we will see you source code. I likely say that it is the case, hence both ws and http are used in production.

Soren

@srnb_gitlab

@pchlupacek #32 #33 #34

Pavel Chlupacek

@pchlupacek

@srnb_gitlab thanks, will reply you back. On the documentation/sample could do you have some free time to perhaps suggest P/R to fix that?

Soren

@srnb_gitlab

Yep, I can do that

#35

Soren

@srnb_gitlab

I need a plain text value option for the Authorization header

Adam Chlupacek

@AdamChlupacek

Hello @srnb_gitlab what do you mean plain text value? is the BasicHttpCredentials not enough?

Soren

@srnb_gitlab

@AdamChlupacek I didn't see a BasicHttpCredentials. I just recently had to move from DigestHttpCredentials to OAuthToken due to some sort of java error (But the only reason I can use OAuth token is because the token has a space in it)

Adam Chlupacek

@AdamChlupacek

@srnb_gitlab yeah no problem

Soren

@srnb_gitlab

How do I tell a websocket to close with some sort of code?

I need to exit the application at some point.

Pavel Chlupacek

@pchlupacek

easiest way is to terminate stream that is piped to websocket. That will in turn close websocket

Soren

@srnb_gitlab

Is there a way to close with a code though? Not just terminate the connection?

Adam Chlupacek

@AdamChlupacek

@srnb_gitlab Currently there is no way to do that, it should not be hard to extend the frames so that once of the frames in the websocket pipe will be close, and afterwards everything will clean up.

Soren

@srnb_gitlab

@AdamChlupacek BasicHttpCredentials is not enough

I need straight up plaintext

Adam Chlupacek

@AdamChlupacek

@srnb_gitlab could you please provide how the header should look like? I am not entirely sure what you mean by plain text

Soren

@srnb_gitlab

s"Authorization: ${mpPlaintextCredentials.text}" @AdamChlupacek

case class PlaintextCredentials(text: String)

Adam Chlupacek

@AdamChlupacek

@srnb_gitlab such format is sadly not RFC compliant according to https://tools.ietf.org/html/rfc7235#section-4.2, however you coud use our HttpCredentials.DigestHttpCredentials header in form of DigestHttpCredentials(mpPlaintextCredentials.text, Map.empty) this should be encoded into the form you require.

Soren

@srnb_gitlab

@AdamChlupacek Ah, but that gives an error that it's not an instance of OAuthCredentials

Adam Chlupacek

@AdamChlupacek

OAuthCredentials? That does not seem to be a concept in fs2-http? is that response that you get from the server where you are trying to connect?

@srnb_gitlab actually, what version of protocols are you using currently?

Soren

@srnb_gitlab

@AdamChlupacek What do you mean?

https://gitlab.com/dscala/discocat/blob/master/src/main/scala/org/discordscala/discocat/util/RequestUtil.scala#L14 OAuthToken, my bad

Where communities thrive

People

Repo info

Activity