Makes all feeds traits

Author: fernandomora

src/main/scala/com/intenthq/action_processor/integrationsV2/feeds/HiveFeed.scala

@@ -6,7 +6,8 @@ import doobie.util.transactor.{Strategy, Transactor}
 
 import scala.util.Properties
 
-abstract class HiveFeed[I, O] extends SQLFeed[I, O]("org.apache.hive.jdbc.HiveDriver") with TimeMeta with JavaLegacyTimeMeta {
+trait HiveFeed[I, O] extends SQLFeed[I, O] with TimeMeta with JavaLegacyTimeMeta {
+  override protected val driver: String = "org.apache.hive.jdbc.HiveDriver"
   override protected lazy val transactor: Transactor[IO] = Transactor.strategy.set(createTransactor, Strategy.void)
   override protected val jdbcUrl: String = Properties.envOrElse("HIVE_JDBC_URL", "jdbc:hive2://localhost:10000")
 }

src/main/scala/com/intenthq/action_processor/integrationsV2/feeds/SQLFeed.scala

@@ -6,8 +6,9 @@ import doobie.util.query.Query0
 import doobie.util.transactor.Transactor
 import doobie.util.transactor.Transactor.Aux
 
-abstract class SQLFeed[I, O](driver: String) extends Feed[I, O] with DoobieImplicits {
+trait SQLFeed[I, O] extends Feed[I, O] with DoobieImplicits {
 
+  protected val driver: String
   protected val jdbcUrl: String
   protected def query(sourceContext: SourceContext[IO]): Query0[I]
 

src/test/scala/com/intenthq/action_processor/integrations/SQLFeedSpec.scala

@@ -105,7 +105,8 @@ case class ExampleCsvFeedRow(integer: Int,
                              timestamp: Instant
 )
 
-abstract class H2Source[I, O] extends SQLFeed[I, O]("org.h2.Driver") with TimeMeta with JavaTimeMeta {
+abstract class H2Source[I, O] extends SQLFeed[I, O] with TimeMeta with JavaTimeMeta {
+  override protected val driver: String = "org.h2.Driver"
   override protected val jdbcUrl: String = "jdbc:h2:mem:test;DB_CLOSE_DELAY=-1;USER=sa;PASSWORD="
 }