mirror of
https://github.com/fluencelabs/codec
synced 2025-07-06 09:51:36 +00:00
137
README.md
137
README.md
@ -1,3 +1,138 @@
|
|||||||
|
[](https://travis-ci.org/fluencelabs/codec)
|
||||||
|
|
||||||
# Codec
|
# Codec
|
||||||
|
|
||||||
Like bijections, but pure and suitable for `cats`.
|
`Codec` is an opinionated library for `cats`-friendly pure (reversible) conversions between types, with possible errors represented with `Either`.
|
||||||
|
|
||||||
|
It's cross-built for Scala and Scala.js, and can also be used for other free-of-effect conversions to reach functional composability.
|
||||||
|
|
||||||
|
## Motivation
|
||||||
|
|
||||||
|
### Use partial functions, track the errors
|
||||||
|
|
||||||
|
Often it's useful to do some validation alongside conversion, like in `String => Int`.
|
||||||
|
|
||||||
|
However, this function throws when malformed input is given. Hence `String => Either[Throwable, Int]`, being a total function, should fit better.
|
||||||
|
|
||||||
|
In this case, error is reflected in type system. It keeps things pure. We go further, forcing the error to be of type `CodecError`, so that later it's easy to track where it comes from, especially in asynchronous environment.
|
||||||
|
|
||||||
|
This uni-direction type is called `fluence.codec.PureCodec.Func` for a fixed `CodecError` error type. Any other error type could be used by extending `fluence.codec.MonadicalEitherArrow[Error]`.
|
||||||
|
|
||||||
|
Bidirection type `A <=> B` is composed from two `Func`s and is called `Bijection`.
|
||||||
|
|
||||||
|
### Lawful composition
|
||||||
|
|
||||||
|
A type `Func[A, B]`, being something like `A => Either[E, B]`, is not very composable on it's own, so we implemented `cats.arrow.ArrowChoice[Func]` for it. You may use `cats.syntax.compose._` or anything like that to receive `andThen` and other lawful functions.
|
||||||
|
|
||||||
|
`Bijection[A, B]` is more complex type, so it has only `Compose[Bijection]` typeclass. Finally you can do something like this:
|
||||||
|
|
||||||
|
```scala
|
||||||
|
import cats.syntax.compose._
|
||||||
|
import fluence.codec.PureCodec
|
||||||
|
|
||||||
|
val intToBytes: PureCodec[Int, Array[Byte]] = PureCodec[Int, String] andThen PureCodec[String, Array[Byte]]
|
||||||
|
```
|
||||||
|
|
||||||
|
Errors are handled in monad-like "fail-fast" fashion.
|
||||||
|
|
||||||
|
### Benefit from different Monads
|
||||||
|
|
||||||
|
In general, functional types conversion could be lazy or eager, be performed in current thread or another. This choice should not affect the logic of conversion, as it's pure.
|
||||||
|
|
||||||
|
`PureCodec` may use any monad to preform execution upon, retaining its nature. The most simple case is strict eager evaluation:
|
||||||
|
|
||||||
|
```scala
|
||||||
|
import cats.Id
|
||||||
|
|
||||||
|
val resEagerSync: Either[CodecError, Array[Byte]] = intToBytes.runF[Id](33)
|
||||||
|
|
||||||
|
```
|
||||||
|
|
||||||
|
You may use any monad, like `Task`, `Coeval`, `Eval`, `IO`...
|
||||||
|
|
||||||
|
### Minimal dependencies
|
||||||
|
|
||||||
|
`codec-core` depends only on `cats`. Each particular codec set is moved into separate module.
|
||||||
|
|
||||||
|
### Cross compile
|
||||||
|
|
||||||
|
In case of complex algorithms, it's worthy to share codebase between platforms. We cross-compile all the codecs possible both to Scala and Scala.js.
|
||||||
|
|
||||||
|
## Installation
|
||||||
|
|
||||||
|
```scala
|
||||||
|
// Bintray repo is used so far. Migration to Maven Central is planned
|
||||||
|
resolvers += Resolver.bintrayRepo("fluencelabs", "releases")
|
||||||
|
|
||||||
|
val codecV = "0.0.1"
|
||||||
|
|
||||||
|
libraryDependencies ++= Seq(
|
||||||
|
"one.fluence" %%% "codec-core" % codecV, // basic types
|
||||||
|
"one.fluence" %%% "codec-bits" % codecV, // scodec-bits conversions for ByteVector
|
||||||
|
"one.fluence" %%% "codec-circe" % codecV, // json handling with circe
|
||||||
|
"one.fluence" %%% "codec-protobuf" % codecV, // ByteString conversions for both scala and scala.js
|
||||||
|
"one.fluence" %% "codec-kryo" % codecV // typesafe kryo codecs, only for scala
|
||||||
|
)
|
||||||
|
```
|
||||||
|
|
||||||
|
## Example
|
||||||
|
|
||||||
|
```scala
|
||||||
|
import cats.syntax.compose._
|
||||||
|
import fluence.codec.PureCodec
|
||||||
|
import fluence.codec.circe.CirceCodecs._
|
||||||
|
import io.circe.{Decoder, Encoder, Json}
|
||||||
|
import scodec.bits.ByteVector
|
||||||
|
import fluence.codec.bits.BitsCodecs._
|
||||||
|
|
||||||
|
// Simple class
|
||||||
|
case class User(id: Int, name: String)
|
||||||
|
|
||||||
|
// Encode and decode with circe
|
||||||
|
implicit val encoder: Encoder[User] =
|
||||||
|
user ⇒ Json.obj("id" → Encoder.encodeInt(user.id), "name" → Encoder.encodeString(user.name))
|
||||||
|
|
||||||
|
implicit val decoder: Decoder[User] = cursor ⇒
|
||||||
|
for {
|
||||||
|
id ← cursor.downField("id").as[Int]
|
||||||
|
name ← cursor.downField("name").as[String]
|
||||||
|
} yield User(id, name)
|
||||||
|
|
||||||
|
// Get codec for encoder/decoder
|
||||||
|
implicit val userJson: PureCodec[User, Json] = circeJsonCodec(encoder, decoder)
|
||||||
|
|
||||||
|
// A trivial string to bytes codec; never use it in production!
|
||||||
|
implicit val stringCodec: PureCodec[String, Array[Byte]] =
|
||||||
|
PureCodec.liftB(_.getBytes, bs ⇒ new String(bs))
|
||||||
|
|
||||||
|
// Convert user to byte vector and vice versa
|
||||||
|
implicit val userJsonVec: PureCodec[User, ByteVector] =
|
||||||
|
PureCodec[User, Json] andThen
|
||||||
|
PureCodec[Json, String] andThen
|
||||||
|
PureCodec[String, Array[Byte]] andThen
|
||||||
|
PureCodec[Array[Byte], ByteVector]
|
||||||
|
|
||||||
|
// Try it with an instance
|
||||||
|
val user = User(234, "Hey Bob")
|
||||||
|
|
||||||
|
// unsafe() is to be used in tests only; it throws!
|
||||||
|
println(userJsonVec.direct.unsafe(user).toBase64)
|
||||||
|
|
||||||
|
// eyJpZCI6MjM0LCJuYW1lIjoiSGV5IEJvYiJ9
|
||||||
|
```
|
||||||
|
|
||||||
|
For more real-world examples, see [Fluence](https://github.com/fluencelabs/fluence).
|
||||||
|
|
||||||
|
## Roadmap
|
||||||
|
|
||||||
|
- `connect[A, B, C]` to compose several Funcs or Bijections
|
||||||
|
- `sbt-tut` for docs
|
||||||
|
- Implement more codecs
|
||||||
|
- Enhance `Func` api with shortcuts to `EitherT` methods
|
||||||
|
- Consider improving performance: `EitherT` [is not so fast](https://twitter.com/alexelcu/status/988031831357485056) (at least yet)
|
||||||
|
|
||||||
|
## License
|
||||||
|
|
||||||
|
Fluence is free software; you can redistribute it and/or modify it under the terms of the GNU Affero General Public License v3 (AGPLv3) as published by the Free Software Foundation.
|
||||||
|
|
||||||
|
Fluence includes some [external modules](https://github.com/fluencelabs/codec/blob/master/build.sbt) that carry their own licensing.
|
27
build.sbt
27
build.sbt
@ -22,10 +22,10 @@ val commons = Seq(
|
|||||||
organizationHomepage := Some(new URL("https://fluence.one")),
|
organizationHomepage := Some(new URL("https://fluence.one")),
|
||||||
startYear := Some(2017),
|
startYear := Some(2017),
|
||||||
licenses += ("AGPL-V3", new URL("http://www.gnu.org/licenses/agpl-3.0.en.html")),
|
licenses += ("AGPL-V3", new URL("http://www.gnu.org/licenses/agpl-3.0.en.html")),
|
||||||
headerLicense := Some(License.AGPLv3("2017", organizationName.value)),
|
headerLicense := Some(License.AGPLv3("2017", organizationName.value)),
|
||||||
bintrayOrganization := Some("fluencelabs"),
|
bintrayOrganization := Some("fluencelabs"),
|
||||||
publishMavenStyle := true,
|
publishMavenStyle := true,
|
||||||
bintrayRepository := "releases"
|
bintrayRepository := "releases"
|
||||||
)
|
)
|
||||||
|
|
||||||
commons
|
commons
|
||||||
@ -61,12 +61,12 @@ lazy val `codec-core` = crossProject(JVMPlatform, JSPlatform)
|
|||||||
commons,
|
commons,
|
||||||
kindProjector,
|
kindProjector,
|
||||||
libraryDependencies ++= Seq(
|
libraryDependencies ++= Seq(
|
||||||
"org.typelevel" %%% "cats-core" % Cats1V,
|
"org.typelevel" %%% "cats-core" % Cats1V,
|
||||||
"org.typelevel" %%% "cats-laws" % Cats1V % Test,
|
"org.typelevel" %%% "cats-laws" % Cats1V % Test,
|
||||||
"org.typelevel" %%% "cats-testkit" % Cats1V % Test,
|
"org.typelevel" %%% "cats-testkit" % Cats1V % Test,
|
||||||
"com.github.alexarchambault" %%% "scalacheck-shapeless_1.13" % "1.1.8" % Test,
|
"com.github.alexarchambault" %%% "scalacheck-shapeless_1.13" % "1.1.8" % Test,
|
||||||
"org.scalacheck" %%% "scalacheck" % ScalacheckV % Test,
|
"org.scalacheck" %%% "scalacheck" % ScalacheckV % Test,
|
||||||
"org.scalatest" %%% "scalatest" % ScalatestV % Test
|
"org.scalatest" %%% "scalatest" % ScalatestV % Test
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
.jsSettings(
|
.jsSettings(
|
||||||
@ -84,9 +84,9 @@ lazy val `codec-bits` = crossProject(JVMPlatform, JSPlatform)
|
|||||||
.settings(
|
.settings(
|
||||||
commons,
|
commons,
|
||||||
libraryDependencies ++= Seq(
|
libraryDependencies ++= Seq(
|
||||||
"org.scodec" %%% "scodec-bits" % ScodecBitsV,
|
"org.scodec" %%% "scodec-bits" % ScodecBitsV,
|
||||||
"org.scalacheck" %%% "scalacheck" % ScalacheckV % Test,
|
"org.scalacheck" %%% "scalacheck" % ScalacheckV % Test,
|
||||||
"org.scalatest" %%% "scalatest" % ScalatestV % Test
|
"org.scalatest" %%% "scalatest" % ScalatestV % Test
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
.jsSettings(
|
.jsSettings(
|
||||||
@ -125,8 +125,8 @@ lazy val `codec-kryo` = project
|
|||||||
commons,
|
commons,
|
||||||
libraryDependencies ++= Seq(
|
libraryDependencies ++= Seq(
|
||||||
chill,
|
chill,
|
||||||
"com.chuusai" %% "shapeless" % ShapelessV,
|
"com.chuusai" %% "shapeless" % ShapelessV,
|
||||||
"org.scalatest" %% "scalatest" % ScalatestV % Test
|
"org.scalatest" %% "scalatest" % ScalatestV % Test
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
.dependsOn(`codec-core-jvm`)
|
.dependsOn(`codec-core-jvm`)
|
||||||
@ -148,4 +148,3 @@ lazy val `codec-protobuf` = crossProject(JVMPlatform, JSPlatform)
|
|||||||
|
|
||||||
lazy val `codec-protobuf-jvm` = `codec-protobuf`.jvm
|
lazy val `codec-protobuf-jvm` = `codec-protobuf`.jvm
|
||||||
lazy val `codec-protobuf-js` = `codec-protobuf`.js
|
lazy val `codec-protobuf-js` = `codec-protobuf`.js
|
||||||
|
|
||||||
|
@ -22,7 +22,7 @@ import io.circe._
|
|||||||
|
|
||||||
object CirceCodecs {
|
object CirceCodecs {
|
||||||
|
|
||||||
implicit def circeJsonCodec[T](encoder: Encoder[T], decoder: Decoder[T]): PureCodec[T, Json] =
|
implicit def circeJsonCodec[T](implicit encoder: Encoder[T], decoder: Decoder[T]): PureCodec[T, Json] =
|
||||||
PureCodec.liftEitherB[T, Json](
|
PureCodec.liftEitherB[T, Json](
|
||||||
t ⇒ Right(encoder.apply(t)),
|
t ⇒ Right(encoder.apply(t)),
|
||||||
json ⇒ decoder.decodeJson(json).left.map(f ⇒ CodecError("Cannot decode json value", causedBy = Some(f)))
|
json ⇒ decoder.decodeJson(json).left.map(f ⇒ CodecError("Cannot decode json value", causedBy = Some(f)))
|
||||||
|
@ -1 +1 @@
|
|||||||
sbt.version = 1.1.2
|
sbt.version = 1.1.4
|
||||||
|
Reference in New Issue
Block a user