11837553250

Committed 14 Nov 2024 12:50PM CUT coverage: 83.298% (+0.2%) from 83.145%

Build Type

Committed by

Commit Message

Merge 1de7acaf5 into 916090a2c

Pull Request Pull Request #697: make `version` non-optional

Run Details

7 of 10 new or added lines in 5 files covered. (70.0%)

7 existing lines in 7 files now uncovered.

3167 of 3802 relevant lines covered (83.3%)

1.41 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

81.82

/core/src/main/scala/com/evolutiongaming/kafka/journal/Key.scala

package com.evolutiongaming.kafka.journal

import cats.kernel.Eq
import cats.syntax.all.*
import cats.{Functor, Order, Show}
import com.datastax.driver.core.{GettableByNameData, SettableData}
import com.evolutiongaming.catshelper.RandomIdOf
import com.evolutiongaming.scassandra.syntax.*
import com.evolutiongaming.scassandra.{DecodeRow, EncodeRow}
import com.evolutiongaming.skafka.Topic

final case class Key(id: String, topic: Topic) {

  override def toString = s"$topic:$id"
}

object Key {

  implicit val eqKey: Eq[Key] = Eq.fromUniversalEquals

  implicit val showKey: Show[Key] = Show.fromToString

  implicit val orderKey: Order[Key] = Order.whenEqual(Order.by { (a: Key) => a.topic }, Order.by { (a: Key) => a.id })

  implicit val orderingKey: Ordering[Key] = orderKey.toOrdering

  implicit val encodeRowKey: EncodeRow[Key] = new EncodeRow[Key] {

    def apply[B <: SettableData[B]](data: B, value: Key): B = {
      data
        .encode("id", value.id)
        .encode("topic", value.topic)
    }
  }

  implicit val decodeRowKey: DecodeRow[Key] = new DecodeRow[Key] {

    def apply(data: GettableByNameData): Key = {
      Key(id = data.decode[String]("id"), topic = data.decode[Topic]("topic"))
    }
  }

  def random[F[_]: Functor: RandomIdOf](topic: Topic): F[Key] = {
    for {
      randomId <- RandomIdOf[F].apply
    } yield {
      Key(id = randomId.value, topic = topic)
    }
  }
}

1	package com.evolutiongaming.kafka.journal
2
3	import cats.kernel.Eq
4	import cats.syntax.all.*
5	import cats.{Functor, Order, Show}
6	import com.datastax.driver.core.{GettableByNameData, SettableData}
7	import com.evolutiongaming.catshelper.RandomIdOf
8	import com.evolutiongaming.scassandra.syntax.*
9	import com.evolutiongaming.scassandra.{DecodeRow, EncodeRow}
10	import com.evolutiongaming.skafka.Topic
11
12	final case class Key(id: String, topic: Topic) {
13
14	override def toString = s"$topic:$id"
15	}
16
17	object Key {
18
19	implicit val eqKey: Eq[Key] = Eq.fromUniversalEquals	1✔
20
21	implicit val showKey: Show[Key] = Show.fromToString	1✔
22
UNCOV 23	implicit val orderKey: Order[Key] = Order.whenEqual(Order.by { (a: Key) => a.topic }, Order.by { (a: Key) => a.id })	×
24
25	implicit val orderingKey: Ordering[Key] = orderKey.toOrdering	1✔
26
27	implicit val encodeRowKey: EncodeRow[Key] = new EncodeRow[Key] {	1✔
28
29	def apply[B <: SettableData[B]](data: B, value: Key): B = {
30	data
31	.encode("id", value.id)	1✔
32	.encode("topic", value.topic)	1✔
33	}
34	}
35
36	implicit val decodeRowKey: DecodeRow[Key] = new DecodeRow[Key] {	1✔
37
38	def apply(data: GettableByNameData): Key = {
39	Key(id = data.decode[String]("id"), topic = data.decode[Topic]("topic"))	×
40	}
41	}
42
43	def random[F[_]: Functor: RandomIdOf](topic: Topic): F[Key] = {
44	for {
45	randomId <- RandomIdOf[F].apply	1✔
46	} yield {
47	Key(id = randomId.value, topic = topic)	1✔
48	}
49	}
50	}

evolution-gaming / kafka-journal / 11837553250

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous