huntc

### Keybase proof

I hereby claim:

  * I am huntc on github.
  * I am huntc (https://keybase.io/huntc) on keybase.
  * I have a public key ASAK5MC9gaWxTBKWnZcUlTofK-51TIDi2R-UDtMGGUh_7Ao

To claim this, I am signing this object:

huntc

package com.lightbend.conductr.eslite

import javax.inject.Named

import akka.NotUsed
import akka.actor.ActorRef
import akka.pattern.ask
import com.fasterxml.jackson.databind.node.ObjectNode
import com.google.inject.Inject
import com.lightbend.conductr.eslite.dto._

huntc

val (recycleQueue, recycleSource) =
  Source
    .queue[SoilStateReading](100, OverflowStrategy.dropTail)
    .prefixAndTail(0)
    .map(_._2)
    .toMat(Sink.head)(Keep.both)
    .run()
StreamConverters.fromInputStream(() => this.getClass.getClassLoader.getResourceAsStream("sensors.log"))
  .via(SoilStateReading.csvParser)
  .merge(Source.fromFutureSource(recycleSource))

huntc

import akka.NotUsed
import akka.stream.scaladsl.Flow

case object NotZero

// Emits either an Int when zero, or a domain object indicating
// that the Int is non zero. Use this approach instead of relying
// on exceptions. Exceptions are for exceptional conditions,
// largely unanticipated, and they will terminate a stream.
val flow: Flow[Int, Either[NotZero.type, Int], NotUsed] = 

huntc

      private val tracerConfig = new Configuration(
        config.getString("lora-server.jaeger.service-name"),
        if (config.getBoolean("lora-server.jaeger.constant-sampling"))
          new SamplerConfiguration("const", 1)
        else new SamplerConfiguration(),
        new ReporterConfiguration(
          true, // logSpans
          config.getString("lora-server.jaeger.agent-host"),
          config.getInt("lora-server.jaeger.agent-port"),
          config.getDuration("lora-server.jaeger.flush-interval").toMillis.toInt,

huntc

  sealed abstract class Event(val id: Int)

  final case class CountersUpdated(override val id: Int,
                                   counter: Option[Int])
      extends Event(id)

  final case class DeviceIdUpdated(override val id: Int, deviceId: Int) extends Event(id)

huntc

import scala.util.Try

type PreRelease = Either[String, Int]

object SemVer {
  val pattern = """^(\d+)\.(\d+)\.(\d+)(-(([1-9a-zA-Z][0-9a-zA-Z-]*)(\.([1-9a-zA-Z][0-9a-zA-Z-]*))))?$""".r
  
  def apply(s: String): SemVer =
    s match {
      case pattern(major, minor, patch, _, _, preRelease1, _, preRelease2) =>

huntc

/*
 * Copyright 2018 Titan Class Pty Ltd
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software

huntc

use std::env;
use std::fs::File;
use std::io::{BufRead, BufReader};
use std::os::raw::c_double;

use chrono::{Duration, NaiveDateTime};

struct State {
    x0: Option<(NaiveDateTime, c_double)>,
    x1: Option<(NaiveDateTime, c_double)>,

huntc

val storageLoader = storage
  .load(LatestDashboardsEvents.Codec(
          principal.getSecret(DashboardsEvents.EventsKey)),
        latestDashboardsEventsId)
  .map { maybeSnapshot =>
    maybeSnapshot.getOrElse(LatestDashboardsEvents(List.empty, None))
  }

def tailFromOffset(
    offset: Option[Long],