6951017262

Committed 21 Nov 2023 11:42PM UTC coverage: 30.623% (-0.03%) from 30.652%

Build Type

Committed by

Commit Message

feat: Create Store Presentation (#788)

Signed-off-by: Bassam Riman <bassam.riman@iohk.io>

Pull Request Pull Request #792: Feat: ZKP verification

Run Details

25 of 126 new or added lines in 10 files covered. (19.84%)

315 existing lines in 107 files now uncovered.

4003 of 13072 relevant lines covered (30.62%)

0.31 hits per line

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

69.23

/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]	×
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 / 6951017262

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