Skip to content

Commit

Permalink
[ALL][ISSUE-61]: fixing issue, refactoring (#62)
Browse files Browse the repository at this point in the history
  • Loading branch information
fsanaulla authored Jun 11, 2018
1 parent 1457731 commit b9bf2e8
Show file tree
Hide file tree
Showing 15 changed files with 28 additions and 28 deletions.
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
package com.github.fsanaulla.chronicler.akka.utils

import akka.http.scaladsl.model.Uri
import com.github.fsanaulla.chronicler.macros.Macros
import com.github.fsanaulla.chronicler.macros.annotations.{field, tag}
import com.github.fsanaulla.core.model._
import com.github.fsanaulla.macros.Macros
import com.github.fsanaulla.macros.annotations.{field, tag}

/**
* Created by fayaz on 11.07.17.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2,9 +2,9 @@ package com.github.fsanaulla.chronicler.async.utils

import java.net.URLEncoder

import com.github.fsanaulla.chronicler.macros.Macros
import com.github.fsanaulla.chronicler.macros.annotations.{field, tag}
import com.github.fsanaulla.core.model._
import com.github.fsanaulla.macros.Macros
import com.github.fsanaulla.macros.annotations.{field, tag}

/**
* Created by fayaz on 11.07.17.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,7 @@ final case class Point(
sb.append(measurement).append(",")
sb.append(tags.map(tag => tag.key + "=" + tag.value).mkString(","))
sb.append(" ")
sb.append(fields.map(_.toString).mkString(" "))
sb.append(fields.map(_.toString).mkString(","))

if (time != -1L) {
sb.append(" ").append(time)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,6 @@ class PointSpec extends FlatSpec with Matchers {
.addField("weight", 75.6)
.addTimestamp(ts)

p.serialize shouldEqual "test,city=London name=\"Jivi\" age=22i adult=true weight=75.6" + s" $ts"
p.serialize shouldEqual "test,city=London name=\"Jivi\",age=22i,adult=true,weight=75.6" + s" $ts"
}
}
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package com.github.fsanaulla.macros
package com.github.fsanaulla.chronicler.macros

import com.github.fsanaulla.core.model.{InfluxFormatter, InfluxReader, InfluxWriter}

Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
package com.github.fsanaulla.macros
package com.github.fsanaulla.chronicler.macros

import com.github.fsanaulla.macros.annotations.{field, tag, timestamp}
import com.github.fsanaulla.chronicler.macros.annotations.{field, tag, timestamp}

import scala.language.experimental.macros
import scala.reflect.macros.blackbox
Expand Down Expand Up @@ -205,7 +205,7 @@ private[macros] class MacrosImpl(val c: blackbox.Context) {
case (k, v: String) => k + "=" + "\"" + v + "\""
case (k, v: Int) => k + "=" + v + "i"
case (k, v) => k + "=" + v
} mkString(" ")
} mkString(",")

val nonOptTagsMap: Map[String, String] = Map(..$nonOptTags)
val nonOptTags: String = nonOptTagsMap map {
Expand All @@ -228,7 +228,7 @@ private[macros] class MacrosImpl(val c: blackbox.Context) {
case (k, v: String) => k + "=" + "\"" + v + "\""
case (k, v: Int) => k + "=" + v + "i"
case (k, v) => k + "=" + v
} mkString(" ")
} mkString(",")

val nonOptTagsMap: Map[String, String] = Map(..$nonOptTags)
val nonOptTags: String = nonOptTagsMap map {
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package com.github.fsanaulla.macros.annotations
package com.github.fsanaulla.chronicler.macros.annotations

/***
* Marker for declaring field value for influx point.
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package com.github.fsanaulla.macros.annotations
package com.github.fsanaulla.chronicler.macros.annotations

/***
* Marker for declaring influx point tag's. Can be only String.
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package com.github.fsanaulla.macros.annotations
package com.github.fsanaulla.chronicler.macros.annotations

/** Mark field that will be used as timestamp in InfluxDB.
* It can be optional, in this case will be used default
Expand Down
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package com.github.fsanaulla.macros
package com.github.fsanaulla.chronicler.macros

import com.github.fsanaulla.chronicler.macros.annotations.{field, tag, timestamp}
import com.github.fsanaulla.chronicler.testing.FlatSpecWithMatchers
import com.github.fsanaulla.core.model.InfluxFormatter
import com.github.fsanaulla.macros.annotations.{field, tag, timestamp}
import jawn.ast.{JArray, JNull, JNum, JString}

class MacroFormatterSpec extends FlatSpecWithMatchers {
Expand Down
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package com.github.fsanaulla.macros
package com.github.fsanaulla.chronicler.macros

import com.github.fsanaulla.chronicler.macros.annotations.{field, tag, timestamp}
import com.github.fsanaulla.chronicler.testing.FlatSpecWithMatchers
import com.github.fsanaulla.core.model.InfluxReader
import com.github.fsanaulla.macros.annotations.{field, tag, timestamp}
import jawn.ast._

class MacroReaderSpec extends FlatSpecWithMatchers {
Expand Down
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package com.github.fsanaulla.macros
package com.github.fsanaulla.chronicler.macros

import com.github.fsanaulla.chronicler.macros.annotations.{field, tag, timestamp}
import com.github.fsanaulla.chronicler.testing.FlatSpecWithMatchers
import com.github.fsanaulla.core.model.InfluxWriter
import com.github.fsanaulla.macros.annotations.{field, tag, timestamp}

class MacroWriterSpec extends FlatSpecWithMatchers {

Expand All @@ -21,14 +21,14 @@ class MacroWriterSpec extends FlatSpecWithMatchers {
val wr1: InfluxWriter[Test1] = Macros.writer[Test1]

"Macros.writer" should "write with None" in {
wr.write(Test("nm", None, "Berkly", 65)) shouldEqual "name=nm school=\"Berkly\" age=65i"
wr.write(Test("nm", None, "Berkly", 65)) shouldEqual "name=nm school=\"Berkly\",age=65i"
}

it should "write with Some" in {
wr.write(Test("nm", Some("sn"), "Berkly", 65)) shouldEqual "name=nm,surname=sn school=\"Berkly\" age=65i"
wr.write(Test("nm", Some("sn"), "Berkly", 65)) shouldEqual "name=nm,surname=sn school=\"Berkly\",age=65i"
}

it should "write with timestamp" in {
wr1.write(Test1("nm", Some("sn"), 65, "Berkly", 1438715114318570484L)) shouldEqual "name=nm,surname=sn age=65i school=\"Berkly\" 1438715114318570484"
wr1.write(Test1("nm", Some("sn"), 65, "Berkly", 1438715114318570484L)) shouldEqual "name=nm,surname=sn age=65i,school=\"Berkly\" 1438715114318570484"
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -4,11 +4,11 @@ import java.io.File

import com.github.fsanaulla.chronicler.async.InfluxAsyncHttpClient
import com.github.fsanaulla.chronicler.async.api.Database
import com.github.fsanaulla.chronicler.macros.Macros
import com.github.fsanaulla.chronicler.macros.annotations.{field, tag}
import com.github.fsanaulla.chronicler.testing.{FutureHandler, TestSpec}
import com.github.fsanaulla.core.model.{InfluxFormatter, Point}
import com.github.fsanaulla.core.testing.configurations.InfluxUDPConf
import com.github.fsanaulla.macros.Macros
import com.github.fsanaulla.macros.annotations.{field, tag}
import com.github.fsanaulla.scalatest.EmbeddedInfluxDB

import scala.concurrent.ExecutionContext.Implicits.global
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2,9 +2,9 @@ package com.github.fsanaulla.chronicler.urlhttp.utils

import java.net.URLEncoder

import com.github.fsanaulla.chronicler.macros.Macros
import com.github.fsanaulla.chronicler.macros.annotations.{field, tag}
import com.github.fsanaulla.core.model._
import com.github.fsanaulla.macros.Macros
import com.github.fsanaulla.macros.annotations.{field, tag}

/**
* Created by fayaz on 11.07.17.
Expand Down
2 changes: 1 addition & 1 deletion version.sbt
Original file line number Diff line number Diff line change
@@ -1 +1 @@
version in ThisBuild := "0.2.4"
version in ThisBuild := "0.2.5"

0 comments on commit b9bf2e8

Please sign in to comment.