elyphas

[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

elyphas

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

elyphas

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()

elyphas

  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))

elyphas

    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 = (

elyphas

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")

elyphas

/* 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", 

elyphas

[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)

elyphas

[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)

elyphas

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