7756228356

Committed 02 Feb 2024 12:51PM UTC coverage: 31.346% (+0.05%) from 31.294%

Build Type

Committed by

Commit Message

ci: pin semantic-pull-request version to 5.2.0 to use Node 16

Signed-off-by: Benjamin Voiturier <benjamin.voiturier@iohk.io>

Pull Request Pull Request #854: docs(prism-agent): improve Connect OAS documentation

Run Details

0 of 10 new or added lines in 2 files covered. (0.0%)

334 existing lines in 72 files now uncovered.

4016 of 12812 relevant lines covered (31.35%)

0.31 hits per line

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

76.92

/shared/src/main/scala/io/iohk/atala/shared/db/ContextAwareTask.scala

package io.iohk.atala.shared.db

import doobie.*
import doobie.postgres.implicits.*
import doobie.syntax.ConnectionIOOps
import doobie.util.transactor.Transactor
import io.iohk.atala.shared.models.{WalletAccessContext, WalletId}
import zio.*
import zio.interop.catz.*

import java.util.UUID

trait ContextAware
type ContextAwareTask[T] = Task[T] with ContextAware

object Implicits {

  given walletIdGet: Get[WalletId] = Get[UUID].map(WalletId.fromUUID)
  given walletIdPut: Put[WalletId] = Put[UUID].contramap(_.toUUID)

  private val WalletIdVariableName = "app.current_wallet_id"

  extension [A](ma: ConnectionIO[A]) {
    def transactWithoutContext(xa: Transactor[ContextAwareTask]): Task[A] = {
      ConnectionIOOps(ma).transact(xa.asInstanceOf[Transactor[Task]])
    }

    def transactWallet(xa: Transactor[ContextAwareTask]): RIO[WalletAccessContext, A] = {
      def walletCxnIO(ctx: WalletAccessContext) = {
        for {
          _ <- doobie.free.connection.createStatement.map { statement =>
            statement.execute(s"SET LOCAL $WalletIdVariableName TO '${ctx.walletId}'")
          }
          result <- ma
        } yield result
      }

      for {
        ctx <- ZIO.service[WalletAccessContext]
        result <- ConnectionIOOps(walletCxnIO(ctx)).transact(xa.asInstanceOf[Transactor[Task]])
      } yield result
    }

  }

}

1	package io.iohk.atala.shared.db
2
3	import doobie.*
4	import doobie.postgres.implicits.*
5	import doobie.syntax.ConnectionIOOps
6	import doobie.util.transactor.Transactor
7	import io.iohk.atala.shared.models.{WalletAccessContext, WalletId}
8	import zio.*
9	import zio.interop.catz.*
10
11	import java.util.UUID
12
13	trait ContextAware
14	type ContextAwareTask[T] = Task[T] with ContextAware
15
16	object Implicits {
17		1✔
18	given walletIdGet: Get[WalletId] = Get[UUID].map(WalletId.fromUUID)	1✔
19	given walletIdPut: Put[WalletId] = Put[UUID].contramap(_.toUUID)
20
21	private val WalletIdVariableName = "app.current_wallet_id"
22
23	extension [A](ma: ConnectionIO[A]) {	1✔
UNCOV 24	def transactWithoutContext(xa: Transactor[ContextAwareTask]): Task[A] = {	×
25	ConnectionIOOps(ma).transact(xa.asInstanceOf[Transactor[Task]])
26	}
27		1✔
28	def transactWallet(xa: Transactor[ContextAwareTask]): RIO[WalletAccessContext, A] = {	1✔
29	def walletCxnIO(ctx: WalletAccessContext) = {	1✔
30	for {	1✔
31	_ <- doobie.free.connection.createStatement.map { statement =>	×
32	statement.execute(s"SET LOCAL $WalletIdVariableName TO '${ctx.walletId}'")
33	}	1✔
34	result <- ma
35	} yield result
36	}
37		1✔
38	for {	×
39	ctx <- ZIO.service[WalletAccessContext]	1✔
40	result <- ConnectionIOOps(walletCxnIO(ctx)).transact(xa.asInstanceOf[Transactor[Task]])
41	} yield result
42	}
43
44	}
45
46	}

input-output-hk / atala-prism-building-blocks / 7756228356

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