akka HTTP Phoenix

A simple implementation of (most of) the Phoenix Channels protocol with akka HTTP for WebSocket communication and circe for JSON

Installation

akka HTTP Phoenix is available for Scala 2.11 and 2.12

libraryDependencies += "io.taig" %% "akka-http-phoenix" % "1.0.0"

Usage

import akka.actor.ActorSystem
import akka.http.scaladsl.model.ws.WebSocketRequest
import akka.stream.ActorMaterializer
import io.circe.syntax._
import io.taig.akka.http.phoenix._

import scala.concurrent._
import scala.concurrent.duration._
import scala.language.postfixOps

implicit val system = ActorSystem()
implicit val materializer = ActorMaterializer()

val request = WebSocketRequest( "ws://localhost:4000/socket/websocket" )
val topic = Topic( "echo", "foobar" )

import system.dispatcher

val future = for {
    // Open socket connection to the Phoenix server
    phoenix ← Phoenix( request )
    // Join a channel
    Right( channel ) ← phoenix.join( topic )
    // Send a message and wait for response
    Result.Success( response ) ← channel.send( Event( "echo" ), "foobar".asJson )
    // Shutdown socket connection from the client side
    _ = phoenix.close()
} yield response

scala> try {
     |     Await.result( future, 5 seconds )
     | } finally {
     |     Await.result( system.terminate(), 5 seconds )
     | }
res5: io.taig.akka.http.phoenix.message.Response =
Response(Topic(echo:foobar),Event(phx_reply),Some(Payload(Status(ok),{
  "payload" : "foobar"
})),Ref(1))

Test-Suite & Documentation

Code executed by the unit tests or documentation generation via tut requires the phoenix_echo app to be running in the background. Use the provided Dockerfile to create an image with pre-installed requirements.