11571116967

Committed 29 Oct 2024 09:37AM UTC coverage: 48.438% (-0.3%) from 48.741%

Build Type

Committed by

Commit Message

Merge branch 'main' into chore/tapir-upgrade

Pull Request Pull Request #1417: chore: upgrade to latest Tapir version

Run Details

1 of 1 new or added line in 1 file covered. (100.0%)

243 existing lines in 57 files now uncovered.

8018 of 16553 relevant lines covered (48.44%)

0.48 hits per line

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

0.0

/shared/core/src/main/scala/org/hyperledger/identus/shared/messaging/Serde.scala

package org.hyperledger.identus.shared.messaging

import org.hyperledger.identus.shared.models.WalletId

import java.nio.charset.StandardCharsets
import java.nio.ByteBuffer
import java.util.UUID

case class ByteArrayWrapper(ba: Array[Byte])

trait Serde[T] {
  def serialize(t: T): Array[Byte]
  def deserialize(ba: Array[Byte]): T
}

object Serde {
  given byteArraySerde: Serde[ByteArrayWrapper] = new Serde[ByteArrayWrapper] {
    override def serialize(t: ByteArrayWrapper): Array[Byte] = t.ba
    override def deserialize(ba: Array[Byte]): ByteArrayWrapper = ByteArrayWrapper(ba)
  }

  given stringSerde: Serde[String] = new Serde[String] {
    override def serialize(t: String): Array[Byte] = t.getBytes()
    override def deserialize(ba: Array[Byte]): String = new String(ba, StandardCharsets.UTF_8)
  }

  given intSerde: Serde[Int] = new Serde[Int] {
    override def serialize(t: Int): Array[Byte] = {
      val buffer = java.nio.ByteBuffer.allocate(4)
      buffer.putInt(t)
      buffer.array()
    }
    override def deserialize(ba: Array[Byte]): Int = ByteBuffer.wrap(ba).getInt()
  }

  given uuidSerde: Serde[UUID] = new Serde[UUID] {
    override def serialize(t: UUID): Array[Byte] = {
      val buffer = java.nio.ByteBuffer.allocate(16)
      buffer.putLong(t.getMostSignificantBits)
      buffer.putLong(t.getLeastSignificantBits)
      buffer.array()
    }
    override def deserialize(ba: Array[Byte]): UUID = {
      val byteBuffer = ByteBuffer.wrap(ba)
      val high = byteBuffer.getLong
      val low = byteBuffer.getLong
      new UUID(high, low)
    }
  }

  given walletIdSerde(using uuidSerde: Serde[UUID]): Serde[WalletId] = new Serde[WalletId] {
    override def serialize(w: WalletId): Array[Byte] = uuidSerde.serialize(w.toUUID)
    override def deserialize(ba: Array[Byte]): WalletId = WalletId.fromUUID(uuidSerde.deserialize(ba))
  }
}

1	package org.hyperledger.identus.shared.messaging
2
3	import org.hyperledger.identus.shared.models.WalletId
4
5	import java.nio.charset.StandardCharsets
6	import java.nio.ByteBuffer
7	import java.util.UUID
8
9	case class ByteArrayWrapper(ba: Array[Byte])
10
11	trait Serde[T] {
12	def serialize(t: T): Array[Byte]
13	def deserialize(ba: Array[Byte]): T
UNCOV 14	}	×
UNCOV 15		×
UNCOV 16	object Serde {	×
17	given byteArraySerde: Serde[ByteArrayWrapper] = new Serde[ByteArrayWrapper] {
UNCOV 18	override def serialize(t: ByteArrayWrapper): Array[Byte] = t.ba	×
UNCOV 19	override def deserialize(ba: Array[Byte]): ByteArrayWrapper = ByteArrayWrapper(ba)	×
20	}
21
22	given stringSerde: Serde[String] = new Serde[String] {
UNCOV 23	override def serialize(t: String): Array[Byte] = t.getBytes()	×
UNCOV 24	override def deserialize(ba: Array[Byte]): String = new String(ba, StandardCharsets.UTF_8)	×
25	}
26
27	given intSerde: Serde[Int] = new Serde[Int] {
UNCOV 28	override def serialize(t: Int): Array[Byte] = {	×
UNCOV 29	val buffer = java.nio.ByteBuffer.allocate(4)	×
UNCOV 30	buffer.putInt(t)	×
UNCOV 31	buffer.array()	×
32	}
UNCOV 33	override def deserialize(ba: Array[Byte]): Int = ByteBuffer.wrap(ba).getInt()	×
34	}
35
36	given uuidSerde: Serde[UUID] = new Serde[UUID] {
UNCOV 37	override def serialize(t: UUID): Array[Byte] = {	×
UNCOV 38	val buffer = java.nio.ByteBuffer.allocate(16)	×
UNCOV 39	buffer.putLong(t.getMostSignificantBits)	×
UNCOV 40	buffer.putLong(t.getLeastSignificantBits)	×
UNCOV 41	buffer.array()	×
42	}
UNCOV 43	override def deserialize(ba: Array[Byte]): UUID = {	×
UNCOV 44	val byteBuffer = ByteBuffer.wrap(ba)	×
UNCOV 45	val high = byteBuffer.getLong	×
UNCOV 46	val low = byteBuffer.getLong	×
UNCOV 47	new UUID(high, low)	×
48	}
49	}
50
51	given walletIdSerde(using uuidSerde: Serde[UUID]): Serde[WalletId] = new Serde[WalletId] {	×
UNCOV 52	override def serialize(w: WalletId): Array[Byte] = uuidSerde.serialize(w.toUUID)	×
UNCOV 53	override def deserialize(ba: Array[Byte]): WalletId = WalletId.fromUUID(uuidSerde.deserialize(ba))	×
54	}
55	}

hyperledger / identus-cloud-agent / 11571116967

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