Scala

Вече познаваме Scala доста добре

Моделиране на домейни

Избор на IO ефект
(асинхронност и конурентност)

• Cats Effect IO
• ZIO
• Monix Task
• Future

Структуриране на кода

Зависимости

Чистите функции често рефирират към други конкретни функции.

def countHttpResourceWords(url: String): IO[Long] =
  HttpUtils.get(url).map(_.body).map(countWords)

Зависимости

Във ФП това може да постигнем като функцията се подава като параметър:

def countHttpResourceWords(retrieveUrl: String => HttpResponse)(url: String): IO[Long] =
  retrieveUrl(url).map(_.body).map(countWords)

val asyncHttpCountHttpResourceWords = countHttpResourceWords(AsyncHttpClient.get) _

Dependency injection

Dependency injection чрез ООП модулност

trait HttpClient:
  def get(url: String): IO[HttpResponse]
  def post(url: String)(entity: Entity): IO[HttpResponse]

class ResourceProcessor(httpClient: HttpClient):
  def countHttpResourceWords(url: String): IO[Long] =
    httpClient.get(url).map(_.body).map(countWords)

val httpClient = new AsyncHttpClient
val resourceProcessor = new ResourceProcessor(httpClient)

resourceProcessor.countHttpResourceWords("http://example.org")

Защо dependency injection?

• Less coupling
  • не сме зависими от конкретна имплементация
  • винаги можем да я сменим с друга
  • зависими сме единствено от конкретен интерфейс
• позволява тестване
• зависимостите на всеки компонент стават по-явни

Кой навързва зависимостите?

Compile-time dependency injection – демо

Thin cake pattern

Още информация

DI in Scala guide

Безопасно боравене с Resource-и

Ефектни модули. Dependency Injection чрез Resource

Как да определим кои да са модулите

Уеб магазин

Домейни:

• Управление на потребителите (регистрация, информация за потребителите, аутентикация)
• Инвентар (продукти, наличност и т.н.)
• Магазин и поръчки

Разделение по слоеве?

Глобални ресурси?

Ефектни модули. Dependency Injection чрез Resource

Връзка със SQL база от данни

• Doobie
• Skunk
• Quill
• Slick
• Сравнение

Doobie

Doobie – Демо

Doobie – сериализация/десериализация към/от заявка

Anatomy of a Doobie query

JSON библиотеки

• circe - базира се на cats
• play-json - първоначално част от Play Framework, извадена в последствие. Използва jackson.
• json4s - “This project aims to provide a single AST to be used by other scala json libraries”

Circe

A JSON library for Scala powered by Cats

JSON types

Circe workflow

Encoding
Data Model -> Encoder -> Json -> String

Decoding
String -> Parser -> Json -> HCursor -> Decoder -> Data Model

Encoders

trait Encoder[A]:
  def apply(a: A): Json

Encoder examples

json/examples/IdCard

Decoding

String -> Parser -> Json -> HCursor -> Decoder -> Data Model

trait Parser:
  def parse(input: String): Either[ParsingFailure, Json]
  def decode[A: Decoder](input: String): Either[Error, A]


trait Decoder[A]:
  def apply(c: HCursor): Decoder.Result[A]

Добавяне на circe към проект

val circeVersion = "0.14.1"

libraryDependencies ++= Seq(
  "io.circe" %% "circe-core",
  "io.circe" %% "circe-generic",
  "io.circe" %% "circe-parser"
).map(_ % circeVersion)

• circe-core - core data type and type classes
• circe-generic - uses Shapeless to auto-generate Decoder/Encoder for case classes.
• circe-parser - Parser type class for decoding JSON

HTTP библиотеки

• http4s - based on cats-effect and fs2 (streaming). Provides an API that can work over various HTTP implementations
• akka-http - full server- and client-side HTTP stack on top of akka-actor and akka-stream
• Play Framework - build on Akka
• Scalatra - influenced on Ruby’s Sinatra. “microframework”

Помощни:

• tapir – описване на endpoint-и като данни. Endpoint-ите могат да бъдат интерпретирани към различни сървър и клиентски имплементации
• sttp – API за клиентски HTTP. Може да се свърже с различни имплементации на HTTP клиент

http4s

Http applications are just a Kleisli function from a streaming request to a polymorphic effect of a streaming response. So what’s the problem?

Започваме просто

case class Request(
    method: Method,
    uri: Uri,
    body: EntityBody,
    headers: Headers,
    ...
)

case class Response(
    status: Status,
    body: EntityBody,
    headers: Headers,
    ...
)

OptionT

OptionT[F[_], A] is a light wrapper on an F[Option[A]]

import cats.data.OptionT

type Http[F[_]] = Request => F[Response]
type HttpApp = Http[IO]

type OptionTIO[A] = OptionT[IO, A]
type HttpRoutes = Http[OptionTIO] 

Какво имаме накрая

type Http[F[_]] = Request => F[Response]

type HttpApp = Http[IO]

type HttpRoutes = Http[OptionT[IO, _]]
object HttpRoutes:
  def of(pf: PartialFunction[Request, IO[Response]]): HttpRoutes =
    req => OptionT(pf.lift(req).sequence)

Всъщност е малко по-различно

Kleisli

type Http[F[_]] = Kleisli[F, Request, Response]

type HttpApp[F[_]] = Http[F]

type HttpRoutes[F[_]] = Http[OptionT[F, _]]
object HttpRoutes:
  def of[F[_]: Defer: Applicative](pf: PartialFunction[Request[F], F[Response[F]]]): HttpRoutes[F] =
    Kleisli(req => OptionT(Defer[F].defer(pf.lift(req).sequence)))

Examples

middlewares

• документация
• Authentication
• Cross Origin Resource Sharing (CORS)
• Response Compression (GZip)
• Metrics
• X-Request-ID header

http client

• Освен сървърна част, http4s има и HTTP клиент
• пример от документацията

Tapir – Демо

Потоци

• Fs2
• Akka Streams
• Monix
• Play Iteratees

Fs2 – Демо

Въпроси :)?