Skip to content

Instantly share code, notes, and snippets.

View errores.scala
[info] Resolved dependencies
[warn]
[warn] Note: Unresolved dependencies path:
[error] sbt.librarymanagement.ResolveException: Error downloading com.github.cornerman.colibri:colibri-monix_sjs1_2.13:9add104
[error] Not found
[error] Not found
[error] not found: /home/elyphas/.ivy2/localcom.github.cornerman.colibri/colibri-monix_sjs1_2.13/9add104/ivys/ivy.xml
[error] not found: https://repo1.maven.org/maven2/com/github/cornerman/colibri/colibri-monix_sjs1_2.13/9add104/colibri-monix_sjs1_2.13-9add104.pom
[error] not found: https://jitpack.io/com/github/cornerman/colibri/colibri-monix_sjs1_2.13/9add104/colibri-monix_sjs1_2.13-9add104.pom
[error] Error downloading com.github.cornerman.colibri:colibri_sjs1_2.13:0b2299d
View migration.scala
case class BatchAndExpiration(batch: String, expiration: Long)
case class ItemInputScarango (
entidad: String,
batchAndExpiration: Option[BatchAndExpiration],
_id: Id[ItemInputScarango] = ItemInputScarango.id()
) extends Document[ItemInputScarango]
object ItemInputScarango extends DocumentModel[ItemInputScarango] {
override implicit val rw: ReaderWriter[ItemInputScarango] = ccRW
View repository.scala
class ComparativeRepository {
val hdlProcessingSideEffects = Handler.create[String]("").unsafeRunSync()
def processingSideEffects = hdlProcessingSideEffects.map {
case "" => None
case msg => Some(div( clear.both, cls:="processingSideEffects", msg))
}
val storeComparative = new StoreComparative()
View map over observable.scala
val eventDocument = PublishSubject[(Inputs, EventsDoobieWillDo)]()
//Old, New
val onEventDocument: Observable[Either[String, (Inputs, Inputs, EventsDoobieResult)]] =
eventDocument.dump("onEventDocument:").mapEval { case (oldItem, event) =>
Task.suspend {
Task.fromFuture {
val payload = Pickle.intoBytes[(Inputs, EventsDoobieWillDo)]((oldItem, event))
View queryArango.scala
val qryOutputs = aqlu"""
FOR item IN tblrecipe_details
LET item_por_pieza = (
FOR i IN tbl_claves_por_pieza FILTER i.cve_articulo == item.key_item RETURN i
)
FOR itemPre IN ( LENGTH(item_por_pieza) > 0 ? item_por_pieza: [ { /* no match exists*/ } ] )
LET recipesFechas = (
View arango.scala
class ConnectionScarango {
implicit val ec: scala.concurrent.ExecutionContext = scala.concurrent.ExecutionContext.global
Profig.initConfiguration().map { in => println(in) }
lazy val db = new ArangoDB(credentials = Some(Credentials("root", "jctaurys")))
lazy val dbExample = db.api.db("example")
//lazy val collection = dbExample.collection("proveedores")
View arangodb.scala
/* ArangoDB
db.tblrecipe.document("2021-88888")
{
"_key" : "2021-88888",
"_id" : "tblrecipe/2021-88888",
"_rev" : "_cRMJ_Yi---",
"fiscal_period" : 2021,
"folio" : "88888",
"date" : 1620049658325,
"id_area" : "3",
View scarango.scala
[error] (run-main-2) java.lang.RuntimeException: Failed to decode from {
[error]
[error] }
[error] java.lang.RuntimeException: Failed to decode from {
[error]
[error] }
[error] at com.outr.arango.ArangoDB$.config(ArangoDB.scala:100)
[error] at com.outr.arango.ArangoDB$.$lessinit$greater$default$1(ArangoDB.scala:17)
[error] at example.Hello$.delayedEndpoint$example$Hello$1(Hello.scala:15)
[error] at example.Hello$delayedInit$body.apply(Hello.scala:11)
View scarango
[error] (run-main-2) java.lang.RuntimeException: Failed to decode from {
[error]
[error] }
[error] java.lang.RuntimeException: Failed to decode from {
[error]
[error] }
[error] at com.outr.arango.ArangoDB$.config(ArangoDB.scala:100)
[error] at com.outr.arango.ArangoDB$.$lessinit$greater$default$1(ArangoDB.scala:17)
[error] at example.Hello$.delayedEndpoint$example$Hello$1(Hello.scala:15)
[error] at example.Hello$delayedInit$body.apply(Hello.scala:11)
View typeclass.scala
def unWrapJson(json: JsonValue) =
json match {
case JsonString(value) => value
case JsonDouble(value) => value.toString
}
sealed trait JsonValue
case class JsonString(value: String) extends JsonValue
case class JsonDouble(value: Double) extends JsonValue