PipelineBaron

package com.plasmaconduit.framework

import com.plasmaconduit.conveyance.Box
import com.plasmaconduit.edge.http._
import com.plasmaconduit.framework._
import com.plasmaconduit.framework.mvc.Controller
import com.plasmaconduit.framework.mvc.middlewares.SessionMiddleware
import com.plasmaconduit.framework.routes.containers.{HttpGetMethodRoutes, HttpRoutes}
import com.plasmaconduit.framework.routes.destinations.HttpPathRoute
import com.plasmaconduit.framework.sessions.jwt.JWTSessionHandler

PipelineBaron

final case class SimpleController() extends Controller {

  def action(implicit request: HttpRequest) = {
    Ok("Simple string response.")
  }

}

PipelineBaron

final case class SimpleController() extends Controller {
 
  def action(implicit request: HttpRequest) = {
    Found("").withHeader(Location("/login"))
  }
 
}

PipelineBaron

final case class ExampleController() extends Controller {

  def middleware = Seq(LoggingMiddleware(), CacheMiddleware())
  
  def action(implicit request: HttpRequest) = Ok("Hello")
  
}

PipelineBaron

final case class IdentityMiddleware() extends Middleware {
  
  def intercept(next: Controller) = AdhocController { request =>
    next.action(request)
  }
  
}

PipelineBaron

final case class AuthenticatedOnlyMiddleware() extends Middleware {
  
  def intercept(next: Controller) = AdhocController { request =>
    request
      .session
      .get("user")
      .map(_ => next.action(request))
      .getOrElse(Found("").withHeader(Location("/login")))
  }
  

PipelineBaron

final case class SessionVisitsController() extends Controller {

  def action(implicit request: HttpRequest) = {
    val visits = request.session.get("visits").getOrElse("0").toLong
    Ok(s"This is so cool, you've viewed it $visits times!")
      .withSession(request.session.set("visits", (visits + 1).toString))
  }

}

PipelineBaron

val server = PlasmaConduit(
  port       = 3000,
  middleware = List(SessionMiddleware(JWTSessionHandler(JWTSha256, "topsykretz"))),
  defaultRoute = MissingController(),
  routes       = HttpRoutes(
    HttpGetMethodRoutes(
      HttpPathRoute("/", RootController()),
    )
  )
)

PipelineBaron

final case class JsonController() extends Controller {
 
  def action(implicit request: HttpRequest): Box[Throwable, HttpResponse] = {
    Ok(JsObject(
      "status"  -> "ok",
      "message" -> JsObject(
        "email" -> "users@gmail.com",
        "admin" -> false
      )
    ))

PipelineBaron

import com.plasmaconduit.json._

val result = JsonParser.parse("""{"key1": "value", "key2": true}""")