support for scala2.13.

takayahilton · takayahilton · commit 15a3c51eb2cd · 2019-07-30T17:37:36.000+09:00
Signed-off-by: ta.tanaka &lt;takayahilton@gmail.com&gt;
diff --git a/.gitignore b/.gitignore
@@ -8,3 +8,4 @@ project/target/
 *~
 .idea
 .idea_modules
+*.iml
diff --git a/.travis.yml b/.travis.yml
@@ -1,7 +1,8 @@
 language: scala
 scala:
-  - 2.11.8
-  - 2.12.1
+  - 2.11.12
+  - 2.12.8
+  - 2.13.0
 
 sudo: false
 
@@ -14,3 +15,9 @@ before_install:
 
 jdk:
  - oraclejdk8
+
+cache:
+  directories:
+    - $HOME/.ivy2/cache
+    - $HOME/.sbt
+    - $HOME/.coursier
diff --git a/build.sbt b/build.sbt
@@ -4,16 +4,16 @@ organization := "org.fluentd"
 name := "fluent-logger-scala"
 
 publishMavenStyle := true
-scalaVersion := "2.12.1"
-crossScalaVersions := Seq("2.11.8", scalaVersion.value)
+scalaVersion := "2.12.8"
+crossScalaVersions := Seq("2.11.12", scalaVersion.value, "2.13.0")
 scalacOptions ++= Seq("-deprecation", "-feature", "-language:implicitConversions")
 logBuffered in Test := false
 libraryDependencies ++= Seq(
-  "org.fluentd" % "fluent-logger" % "0.3.2",
-  "org.json4s" %% "json4s-native" % "3.5.0",
+  "org.fluentd" % "fluent-logger" % "0.3.4",
+  "org.json4s" %% "json4s-native" % "3.6.7",
   "junit" % "junit" % "4.12" % Test,
-  "org.xerial" %% "fluentd-standalone" % "0.14.11" % Test,
-  "org.scalatest" %% "scalatest" % "3.0.1" % Test
+  "org.xerial" %% "fluentd-standalone" % "1.6.2" % Test,
+  "org.scalatest" %% "scalatest" % "3.0.8" % Test
 )
 
 // Release settings
diff --git a/project/build.properties b/project/build.properties
@@ -1 +1 @@
-sbt.version=0.13.13
+sbt.version=1.2.8
diff --git a/project/plugin.sbt b/project/plugin.sbt
@@ -1,7 +1,9 @@
-addSbtPlugin("com.github.gseitz" % "sbt-release" % "1.0.3")
-addSbtPlugin("org.xerial.sbt" % "sbt-sonatype" % "1.1")
-addSbtPlugin("com.jsuereth" % "sbt-pgp" % "1.0.0")
-addSbtPlugin("io.get-coursier" % "sbt-coursier" % "1.0.0-M15")
-addSbtPlugin("net.virtual-void" % "sbt-dependency-graph" % "0.7.5")
+addSbtCoursier
+
+addSbtPlugin("com.github.gseitz" % "sbt-release" % "1.0.11")
+addSbtPlugin("org.xerial.sbt" % "sbt-sonatype" % "2.3")
+addSbtPlugin("com.jsuereth" % "sbt-pgp" % "1.1.2")
+addSbtPlugin("net.virtual-void" % "sbt-dependency-graph" % "0.10.0-RC1")
+addSbtPlugin("com.timushev.sbt" % "sbt-updates" % "0.4.2")
 
 scalacOptions ++= Seq("-deprecation", "-feature")
diff --git a/project/project/plugin.sbt b/project/project/plugin.sbt
@@ -0,0 +1 @@
+addSbtPlugin("io.get-coursier" % "sbt-coursier" % "2.0.0-RC2")
diff --git a/src/main/scala/org/fluentd/logger/scala/FluentLogger.scala b/src/main/scala/org/fluentd/logger/scala/FluentLogger.scala
@@ -3,7 +3,7 @@ package org.fluentd.logger.scala
 import org.fluentd.logger.scala.sender.Sender
 import scala.collection.Map
 
-case class FluentLogger(tag :String, sender: Sender) {
+case class FluentLogger(tag: String, sender: Sender) {
 
   def log(label: String, key: String, value: Any): Boolean = {
     log(label, key, value, 0)
@@ -41,7 +41,7 @@ case class FluentLogger(tag :String, sender: Sender) {
 
   def getName: String = sender.getName()
 
-  override def toString: String = sender.toString()
+  override def toString: String = sender.toString
 
   override def finalize(): Unit = sender.close()
 
diff --git a/src/main/scala/org/fluentd/logger/scala/FluentLoggerFactory.scala b/src/main/scala/org/fluentd/logger/scala/FluentLoggerFactory.scala
@@ -25,7 +25,6 @@ object FluentLoggerFactory {
   val senderPropertyName = JavaConstants.FLUENT_SENDER_CLASS
   val scalaSenderName = "ScalaRawSocketSender"
   val senderClassName = System.getProperty(senderPropertyName, scalaSenderName)
-  val factory = new FluentLoggerFactory()
   val loggers: WeakHashMap[String, FluentLogger] = new WeakHashMap
   
   def getLogger(tag: String): FluentLogger = {
@@ -39,7 +38,7 @@ object FluentLoggerFactory {
   def getLogger(tag: String, host: String, port: Int,
       timeout: Int, bufferCapacity: Int): FluentLogger = {
     val sender = new ScalaRawSocketSender(host, port, timeout, bufferCapacity)
-    val logger = new FluentLogger(tag, sender)
+    val logger = FluentLogger(tag, sender)
     loggers.put(tag, logger)
     logger
   }
@@ -55,9 +54,4 @@ object FluentLoggerFactory {
       logger.close()
     }
   }
-
-}
-
-class FluentLoggerFactory {
-  
 }
diff --git a/src/main/scala/org/fluentd/logger/scala/sender/EventSerializer.scala b/src/main/scala/org/fluentd/logger/scala/sender/EventSerializer.scala
@@ -15,9 +15,9 @@ object EventSerializer extends Serializer[Event] {
   def deserialize(implicit format: Formats): PartialFunction[(TypeInfo, JValue), Event] = {
     case (TypeInfo(EventClass, _), json) => json match {
       case JArray(JString(tag) :: JInt(time) :: JObject(obj) :: Nil) =>
-        new Event(tag, time.toLong, null)
+        Event(tag, time.toLong, null)
       case JNothing =>
-        new Event(null, 0, null)
+        Event(null, 0, null)
       case x => throw new MappingException(s"Can't convert $x to Event")
     }
   }
diff --git a/src/main/scala/org/fluentd/logger/scala/sender/MapSerializer.scala b/src/main/scala/org/fluentd/logger/scala/sender/MapSerializer.scala
@@ -16,7 +16,7 @@ object MapSerializer extends Serializer[Map[String, Any]] {
         },
         Extraction.decompose(
           v match {
-            case vs: MutableMap[_,_] => vs.toMap
+            case vs: MutableMap[_, _] => vs.toMap
             case _ => v
           }
         )
diff --git a/src/main/scala/org/fluentd/logger/scala/sender/ScalaRawSocketSender.scala b/src/main/scala/org/fluentd/logger/scala/sender/ScalaRawSocketSender.scala
@@ -8,20 +8,20 @@ import org.json4s._
 import org.json4s.native.Serialization
 import scala.collection.Map
 
-class ScalaRawSocketSender(h:String, p:Int, to:Int, bufCap:Int) 
+class ScalaRawSocketSender(h: String, p: Int, to: Int, bufCap: Int)
     extends Sender {
-  implicit val formats = DefaultFormats + EventSerializer + MapSerializer
+  implicit val formats: Formats = DefaultFormats + EventSerializer + MapSerializer
   val LOG = java.util.logging.Logger.getLogger("ScalaRawSocketSender")
   val host = h
   val port = p
-  val bufferCapacity= bufCap
+  val bufferCapacity = bufCap
   val timeout = to
   val name = "%s_%d_%d_%d".format(host, port, timeout, bufferCapacity)
   val pendings = ByteBuffer.allocate(bufferCapacity)
   val server = new InetSocketAddress(host, port)
   val reconnector = new ExponentialDelayReconnector()
-  var socket:Socket = null
-  var out:BufferedOutputStream = null
+  var socket: Socket = null
+  var out: BufferedOutputStream = null
   open()
 
   def this(host:String, port:Int) {
@@ -96,7 +96,7 @@ class ScalaRawSocketSender(h:String, p:Int, to:Int, bufCap:Int)
   }
 
   def emit(tag: String, timestamp: Long, data: Map[String, Any]): Boolean = {
-    emit(new Event(tag, timestamp, data))
+    emit(Event(tag, timestamp, data))
   }
 
   def emit(event: Event): Boolean = {
@@ -107,7 +107,7 @@ class ScalaRawSocketSender(h:String, p:Int, to:Int, bufCap:Int)
     try {
       // serialize tag, timestamp and data
       val json = Serialization.write(event)
-      return send(json.getBytes("UTF-8"))
+      send(json.getBytes("UTF-8"))
     } catch {
       case e: IOException =>
         LOG.severe(s"Cannot serialize event: $event")
@@ -155,14 +155,14 @@ class ScalaRawSocketSender(h:String, p:Int, to:Int, bufCap:Int)
       clearBuffer()
     } catch {
       case e: IOException =>
-        LOG.throwing(this.getClass().getName(), "flush", e)
+        LOG.throwing(this.getClass.getName, "flush", e)
         reconnector.addErrorHistory(System.currentTimeMillis())
     }
   }
 
   def getName(): String = name
 
-  override def toString(): String = {
+  override def toString: String = {
     getName()
   }
 }
diff --git a/src/main/scala/org/fluentd/logger/scala/sender/Sender.scala b/src/main/scala/org/fluentd/logger/scala/sender/Sender.scala
@@ -7,11 +7,11 @@ trait Sender {
 
   def emit(tag: String, timestamp: Long, data: Map[String, Any]): Boolean
 
-  def flush()
+  def flush(): Unit
 
   def getBuffer(): Array[Byte]
 
-  def close()
+  def close(): Unit
 
   def getName(): String
 }
diff --git a/src/test/java/org/fluentd/logger/util/MockFluentd.java b/src/test/java/org/fluentd/logger/util/MockFluentd.java
diff --git a/src/test/scala/org/fluentd/logger/scala/FluentLoggerSuite.scala b/src/test/scala/org/fluentd/logger/scala/FluentLoggerSuite.scala
@@ -22,7 +22,7 @@ import org.junit.runner.RunWith
 import org.json4s.NoTypeHints
 import org.json4s.native.Serialization
 import org.scalatest.{BeforeAndAfterAll, Tag, FunSuite}
-import org.scalatest.junit.JUnitRunner
+import org.scalatestplus.junit.JUnitRunner
 import scala.collection.mutable.HashMap
 import xerial.fluentd.FluentdStandalone
 
@@ -36,7 +36,6 @@ class FluentLoggerSuite extends FunSuite with BeforeAndAfterAll {
   override def beforeAll(): Unit = {
     // Start local fluentd server
     fluentd = Some(FluentdStandalone.start())
-    val port = fluentd.get.port
     logger = fluentd.map(fd => FluentLoggerFactory.getLogger("debug", "localhost", fd.port)).getOrElse {
       fail("Failed to start fluentd")
     }
diff --git a/src/test/scala/org/fluentd/logger/scala/util/Verifier.scala b/src/test/scala/org/fluentd/logger/scala/util/Verifier.scala

-Original file line number
+Diff line change
 *~
 .idea
 .idea_modules
 +*.iml
Original file line number	Diff line number	Diff line change
`@@ -1 +1 @@`
`1`		`-sbt.version=0.13.13`
	`1`	`+sbt.version=1.2.8`
Original file line number	Diff line number	Diff line change
`@@ -0,0 +1 @@`
	`1`	`+addSbtPlugin("io.get-coursier" % "sbt-coursier" % "2.0.0-RC2")`
Original file line number	Diff line number	Diff line change
`@@ -25,7 +25,6 @@ object FluentLoggerFactory {`
`25`	`25`	`val senderPropertyName = JavaConstants.FLUENT_SENDER_CLASS`
`26`	`26`	`val scalaSenderName = "ScalaRawSocketSender"`
`27`	`27`	`val senderClassName = System.getProperty(senderPropertyName, scalaSenderName)`
`28`		`- val factory = new FluentLoggerFactory()`
`29`	`28`	`val loggers: WeakHashMap[String, FluentLogger] = new WeakHashMap`
`30`	`29`
`31`	`30`	`def getLogger(tag: String): FluentLogger = {`
`@@ -39,7 +38,7 @@ object FluentLoggerFactory {`
`39`	`38`	`def getLogger(tag: String, host: String, port: Int,`
`40`	`39`	`timeout: Int, bufferCapacity: Int): FluentLogger = {`
`41`	`40`	`val sender = new ScalaRawSocketSender(host, port, timeout, bufferCapacity)`
`42`		`- val logger = new FluentLogger(tag, sender)`
	`41`	`+ val logger = FluentLogger(tag, sender)`
`43`	`42`	`loggers.put(tag, logger)`
`44`	`43`	`logger`
`45`	`44`	`}`
`@@ -55,9 +54,4 @@ object FluentLoggerFactory {`
`55`	`54`	`logger.close()`
`56`	`55`	`}`
`57`	`56`	`}`
`58`		`-`
`59`		`-}`
`60`		`-`
`61`		`-class FluentLoggerFactory {`
`62`		`-`
`63`	`57`	`}`
Original file line number	Diff line number	Diff line change
`@@ -15,9 +15,9 @@ object EventSerializer extends Serializer[Event] {`
`15`	`15`	`def deserialize(implicit format: Formats): PartialFunction[(TypeInfo, JValue), Event] = {`
`16`	`16`	`case (TypeInfo(EventClass, _), json) => json match {`
`17`	`17`	`case JArray(JString(tag) :: JInt(time) :: JObject(obj) :: Nil) =>`
`18`		`- new Event(tag, time.toLong, null)`
	`18`	`+ Event(tag, time.toLong, null)`
`19`	`19`	`case JNothing =>`
`20`		`- new Event(null, 0, null)`
	`20`	`+ Event(null, 0, null)`
`21`	`21`	`case x => throw new MappingException(s"Can't convert $x to Event")`
`22`	`22`	`}`
`23`	`23`	`}`
Original file line number	Diff line number	Diff line change
`@@ -16,7 +16,7 @@ object MapSerializer extends Serializer[Map[String, Any]] {`
`16`	`16`	`},`
`17`	`17`	`Extraction.decompose(`
`18`	`18`	`v match {`
`19`		`- case vs: MutableMap[_,_] => vs.toMap`
	`19`	`+ case vs: MutableMap[_, _] => vs.toMap`
`20`	`20`	`case _ => v`
`21`	`21`	`}`
`22`	`22`	`)`