Merge pull request #1 from wdias/develop

Added Visualization Support

build.sbt

@@ -1,24 +1,49 @@
 organization := "org.wdias"
 name := "wdias"
 version := "0.1"
-scalaVersion := "2.12.3"
+scalaVersion := "2.12.4"
+
+// Enable the Lightbend Telemetry (Cinnamon) sbt plugin
+lazy val app = project in file(".") enablePlugins (Cinnamon)
+// Add the Cinnamon Agent for run and test
+cinnamon in run := true
+cinnamon in test := true
+// Set the Cinnamon Agent log level
+cinnamonLogLevel := "INFO"
 
 scalacOptions := Seq("-unchecked", "-deprecation", "-encoding", "utf8")
 
-lazy val akkaVersion = "2.5.3"
-lazy val akkaHttpVersion   = "10.0.9"
-lazy val scalaTestVersion  = "3.0.1"
+lazy val akkaVersion = "2.5.7"
+lazy val akkaHttpVersion = "10.0.10"
+lazy val scalaTestVersion = "3.0.4"
 lazy val influxDBClientVersion = "0.5.2"
+lazy val logBackVersion = "1.2.3"
+lazy val slickVersion = "3.2.1"
+lazy val mysqlConnectorVersion = "5.1.36"
+lazy val netcdfVersion = "4.6.11"
 
 libraryDependencies ++= Seq(
-  "com.typesafe.akka" %% "akka-actor" % akkaVersion,
-  "com.typesafe.akka" %% "akka-stream" % akkaVersion,
-  "com.typesafe.akka" %% "akka-testkit" % akkaVersion,
-  "com.typesafe.akka" %% "akka-http" % akkaHttpVersion,
-  "com.typesafe.akka" %% "akka-http-spray-json" % akkaHttpVersion,
-  "com.paulgoldbaum" %% "scala-influxdb-client" % influxDBClientVersion,
-  "com.typesafe.akka" %% "akka-http-testkit" % akkaHttpVersion,
-  "org.scalatest"     %% "scalatest" % scalaTestVersion % "test"
+    "com.typesafe.akka" %% "akka-actor" % akkaVersion,
+    "com.typesafe.akka" %% "akka-stream" % akkaVersion,
+    "com.typesafe.akka" %% "akka-testkit" % akkaVersion,
+    "com.typesafe.akka" %% "akka-http" % akkaHttpVersion,
+    "com.typesafe.akka" %% "akka-http-spray-json" % akkaHttpVersion,
+    "com.paulgoldbaum" %% "scala-influxdb-client" % influxDBClientVersion,
+    "com.typesafe.akka" %% "akka-http-testkit" % akkaHttpVersion,
+    "org.scalatest" %% "scalatest" % scalaTestVersion % "test",
+    "com.typesafe.akka" %% "akka-slf4j" % akkaVersion,
+    "ch.qos.logback" % "logback-classic" % logBackVersion,
+    "com.typesafe.slick" %% "slick" % slickVersion,
+    "com.typesafe.slick" %% "slick-hikaricp" % slickVersion,
+    "mysql" % "mysql-connector-java" % mysqlConnectorVersion,
+    "edu.ucar" % "netcdfAll" % netcdfVersion,
+    "de.aktey.akka.visualmailbox" %% "collector" % "1.1.0",
+    // Use Coda Hale Metrics and Akka instrumentation
+    Cinnamon.library.cinnamonCHMetrics,
+    Cinnamon.library.cinnamonAkka,
+    Cinnamon.library.cinnamonCHMetricsElasticsearchReporter
 )
 
+resolvers += "Unidata Releases" at "https://artifacts.unidata.ucar.edu/repository/unidata-releases"
+
 licenses := Seq(("CC0", url("http://creativecommons.org/publicdomain/zero/1.0")))

project/lightbend.sbt

@@ -0,0 +1,4 @@
+credentials += Credentials(Path.userHome / ".lightbend" / "commercial.credentials")
+resolvers += "com-mvn" at "https://repo.lightbend.com/commercial-releases/"
+resolvers += Resolver.url("com-ivy",
+  url("https://repo.lightbend.com/commercial-releases/"))(Resolver.ivyStylePatterns)

project/plugins.sbt

@@ -6,3 +6,9 @@ addSbtPlugin("com.eed3si9n" % "sbt-assembly" % "0.14.5")
 
 addSbtPlugin("com.typesafe.sbt" % "sbt-native-packager" % "1.2.0")
 
+addSbtPlugin("com.lightbend.cinnamon" % "sbt-cinnamon" % "2.7.2")
+
+credentials += Credentials(Path.userHome / ".lightbend" / "commercial.credentials")
+
+resolvers += Resolver.url("lightbend-commercial",
+  url("https://repo.lightbend.com/commercial-releases"))(Resolver.ivyStylePatterns)

src/data/RF/Glencourse-2017-09-01.csv

@@ -1,3 +1,4 @@
+Time,Rainfall
 2017-09-01 00:00:00,0.000000
 2017-09-01 01:00:00,0.000000
 2017-09-01 02:00:00,0.000000

src/data/RF/Hanwella-2017-09-01.csv

@@ -1,3 +1,4 @@
+Time,Rainfall
 2017-09-01 00:00:00,0.000000
 2017-09-01 01:00:00,0.000000
 2017-09-01 02:00:00,0.000000

src/data/RF/MetaData.json

@@ -0,0 +1,15 @@
+{
+  "type": "Observed",
+  "station": {
+    "name": "Hanwella",
+    "latitude": 6.909722222,
+    "longitude": 80.08166667
+  },
+  "source": "HEC-HMS",
+  "unit": {
+    "unit": "m3/s",
+    "type": "Instantaneous"
+  },
+  "variable": "Precipitation",
+  "tags": ["Test1"]
+}

src/main/resources/application.conf

@@ -1,16 +1,105 @@
 akka {
-  loglevel = INFO
+  loggers = ["akka.event.slf4j.Slf4jLogger"]
+  loglevel = "INFO"
+  logging-filter = "akka.event.slf4j.Slf4jLoggingFilter"
 }
 
 http {
   interface = "0.0.0.0"
-  port = 8000
-  port1 = 9000
+  port-input = 8000
+  port-api = 9000
 }
 
 services {
   ip-api {
     host = "ip-api.com"
     port = 80
   }
-}
+}
+
+db-mysql {
+  dataSourceClass = "slick.jdbc.DriverDataSource"
+  properties = {
+    driver = "com.mysql.jdbc.Driver"
+    url = "jdbc:mysql://localhost:3306/wdias"
+    user = "wdias"
+    password = "wdias@123"
+  }
+}
+
+//akka.actor.default-mailbox.mailbox-type = "de.aktey.akka.visualmailbox.VisualMailboxType"
+
+//cinnamon {
+//  akka.actors {
+//    "/user/*" {
+//      report-by = class
+//      experimental.connections = true
+//    }
+//  }
+//
+//  akka.dimensions += address
+//
+//  chmetrics {
+//    reporters += "elasticsearch-reporter"
+//    reporters += "slf4j-reporter"
+//    elasticsearch-reporter {
+//      hosts = ["http://0.0.0.0:9200"]
+//      basic-auth {
+//        username = "elastic"
+//        password = "changeme"
+//      }
+//    }
+//  }
+//}
+
+cinnamon.application = "wdias"
+
+cinnamon.akka {
+  actors {
+    "/user/*" {
+      report-by = class
+      experimental.connections = true
+    }
+  }
+  dimensions += address
+}
+cinnamon.chmetrics {
+  reporters += "console-reporter"
+  reporters += "elasticsearch-reporter"
+  elasticsearch-reporter {
+    basic-auth {
+      username = "elastic"
+      password = "changeme"
+    }
+  }
+}
+
+//db-mysql {
+//  profile = "slick.jdbc.MySQLProfile$"
+//  db {
+//    dataSourceClass = "slick.jdbc.DriverDataSource"
+//    properties = {
+//      driver = "com.mysql.jdbc.Driver"
+//      url = "jdbc:mysql://localhost:3306/"
+//      databaseName = "wdias"
+//      user = "wdias"
+//      password = "wdias@123"
+//    }
+//  }
+//}
+
+//wdias-task-dispatcher {
+//  type = "Dispatcher"
+//  executor = "thread-pool-executor"
+//
+//  thread-pool-executor {
+//    fixed-pool-size = off
+//    core-pool-size-min = 8
+//    core-pool-size-factor = 3.0
+//    core-pool-size-max = 64
+//    max-pool-size-min = 8
+//    max-pool-size-factor = 3.0
+//    max-pool-size-max = 64
+//    task-queue-size = -1
+//  }
+//}

src/main/resources/logback.xml

@@ -0,0 +1,26 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<configuration>
+
+    <appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
+        <target>System.out</target>
+        <encoder>
+            <pattern>%X{akkaTimestamp} %-5level[%thread] %logger{0} - %msg%n</pattern>
+        </encoder>
+    </appender>
+
+    <appender name="FILE" class="ch.qos.logback.core.FileAppender">
+        <file>log/akka.log</file>
+        <append>false</append>
+        <encoder>
+            <pattern>%date{yyyy-MM-dd} %X{akkaTimestamp} %-5level[%thread] %logger{1} - %msg%n</pattern>
+        </encoder>
+    </appender>
+
+    <logger name="akka" level="INFO" />
+
+    <root level="INFO">
+        <appender-ref ref="CONSOLE"/>
+        <appender-ref ref="FILE"/>
+    </root>
+
+</configuration>