fluencelabs/codec
1
0
Fork 0
mirror of https://github.com/fluencelabs/codec synced 2025-04-25 06:42:14 +00:00
Code Issues Projects Releases Wiki Activity

Node composition (#14)

Browse Source 
* NodeComposer and docker build

* ByteVector and grpc tests&codecs

* remove debugging output

* license headers

* changed NodeComposerSpec ports
This commit is contained in:
Dmitry Kurinskiy 2018-01-25 16:27:31 +03:00 committed by GitHub
parent 6775c43d90
commit fe1972a775
1 changed files with 24 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
core/src/main/scala/fluence/codec/Codec.scala
View File

@ -18,8 +18,9 @@
package fluence.codec
import cats.data.Kleisli
import cats.{ Applicative, FlatMap, Traverse }
import cats.{ Applicative, ApplicativeError, FlatMap, Traverse }
import cats.syntax.applicative._
import scodec.bits.ByteVector
import scala.language.{ higherKinds, implicitConversions }
@ -39,6 +40,11 @@ final case class Codec[F[_], A, B](encode: A ⇒ F[B], decode: B ⇒ F[A]) {
def andThen[C](other: Codec[F, B, C])(implicit F: FlatMap[F]): Codec[F, A, C] =
Codec((self.direct andThen other.direct).run, (other.inverse andThen self.inverse).run)
def compose[C](other: Codec[F, C, A])(implicit F: FlatMap[F]): Codec[F, C, B] =
Codec((other.direct andThen self.direct).run, (self.inverse andThen other.inverse).run)
def swap: Codec[F, B, A] = Codec(decode, encode)
}
object Codec {
@ -54,6 +60,23 @@ object Codec {
implicit def toInverse[F[_], A, B](implicit cod: Codec[F, A, B]): Kleisli[F, B, A] =
cod.inverse
implicit def swap[F[_], A, B](implicit cod: Codec[F, A, B]): Codec[F, B, A] =
Codec[F, B, A](cod.decode, cod.encode)
implicit def byteVectorArray[F[_] : Applicative]: Codec[F, Array[Byte], ByteVector] =
pure(ByteVector.apply, _.toArray)
// TODO: descriptive error
implicit def byteVectorB64[F[_]](implicit F: ApplicativeError[F, Throwable]): Codec[F, String, ByteVector] =
Codec(
str ⇒
ByteVector.fromBase64(str).fold[F[ByteVector]](
F.raiseError(new IllegalArgumentException(s"Given string is not valid b64: $str"))
)(_.pure[F]),
_.toBase64.pure[F]
)
def codec[F[_], O, B](implicit codec: Codec[F, O, B]): Codec[F, O, B] = codec
/**