8898291527

Committed 30 Apr 2024 04:24PM UTC coverage: 49.277% (-0.3%) from 49.553%

Build Type

Committed by

Commit Message

Merge branch 'fix-scala-steward-2' into fix-scala-steward

Pull Request Pull Request #993: ci: fix scala-steward after moving repo to hyperledger

Run Details

7 of 29 new or added lines in 3 files covered. (24.14%)

255 existing lines in 77 files now uncovered.

7296 of 14806 relevant lines covered (49.28%)

0.49 hits per line

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

52.33

/pollux/core/src/main/scala/org/hyperledger/identus/pollux/core/service/MockCredentialService.scala

package org.hyperledger.identus.pollux.core.service

import io.circe.Json
import org.hyperledger.identus.castor.core.model.did.CanonicalPrismDID
import org.hyperledger.identus.mercury.model.DidId
import org.hyperledger.identus.mercury.protocol.issuecredential.{IssueCredential, OfferCredential, RequestCredential}
import org.hyperledger.identus.pollux.core.model.error.CredentialServiceError
import org.hyperledger.identus.pollux.core.model.{DidCommID, IssueCredentialRecord}
import org.hyperledger.identus.shared.models.WalletAccessContext
import zio.mock.{Mock, Proxy}
import zio.{IO, URLayer, ZIO, ZLayer, mock}

import java.util.UUID

object MockCredentialService extends Mock[CredentialService] {

  object CreateJWTIssueCredentialRecord
      extends Effect[
        (
            DidId,
            DidId,
            DidCommID,
            Option[String],
            Json,
            Option[Double],
            Option[Boolean],
            CanonicalPrismDID
        ),
        CredentialServiceError,
        IssueCredentialRecord
      ]

  object CreateAnonCredsIssueCredentialRecord
      extends Effect[
        (
            DidId,
            DidId,
            DidCommID,
            UUID,
            Json,
            Option[Double],
            Option[Boolean],
            String
        ),
        CredentialServiceError,
        IssueCredentialRecord
      ]

  object ReceiveCredentialOffer extends Effect[OfferCredential, CredentialServiceError, IssueCredentialRecord]
  object AcceptCredentialOffer
      extends Effect[(DidCommID, Option[String]), CredentialServiceError, IssueCredentialRecord]
  object GenerateJWTCredentialRequest extends Effect[DidCommID, CredentialServiceError, IssueCredentialRecord]
  object GenerateAnonCredsCredentialRequest extends Effect[DidCommID, CredentialServiceError, IssueCredentialRecord]
  object ReceiveCredentialRequest extends Effect[RequestCredential, CredentialServiceError, IssueCredentialRecord]
  object AcceptCredentialRequest extends Effect[DidCommID, CredentialServiceError, IssueCredentialRecord]
  object GenerateJWTCredential extends Effect[(DidCommID, String), CredentialServiceError, IssueCredentialRecord]
  object GenerateAnonCredsCredential extends Effect[DidCommID, CredentialServiceError, IssueCredentialRecord]
  object ReceiveCredentialIssue extends Effect[IssueCredential, CredentialServiceError, IssueCredentialRecord]
  object MarkOfferSent extends Effect[DidCommID, CredentialServiceError, IssueCredentialRecord]
  object MarkRequestSent extends Effect[DidCommID, CredentialServiceError, IssueCredentialRecord]
  object MarkCredentialSent extends Effect[DidCommID, CredentialServiceError, IssueCredentialRecord]
  object MarkCredentialPublicationPending extends Effect[DidCommID, CredentialServiceError, IssueCredentialRecord]
  object MarkCredentialPublicationQueued extends Effect[DidCommID, CredentialServiceError, IssueCredentialRecord]
  object MarkCredentialPublished extends Effect[DidCommID, CredentialServiceError, IssueCredentialRecord]
  object ReportProcessingFailure extends Effect[(DidCommID, Option[String]), CredentialServiceError, Unit]

  override val compose: URLayer[mock.Proxy, CredentialService] = ZLayer {
    for {
      proxy <- ZIO.service[Proxy]
    } yield new CredentialService {

      override def createJWTIssueCredentialRecord(
          pairwiseIssuerDID: DidId,
          pairwiseHolderDID: DidId,
          thid: DidCommID,
          maybeSchemaId: Option[String],
          claims: Json,
          validityPeriod: Option[Double],
          automaticIssuance: Option[Boolean],
          issuingDID: CanonicalPrismDID
      ): IO[CredentialServiceError, IssueCredentialRecord] =
        proxy(
          CreateJWTIssueCredentialRecord,
          pairwiseIssuerDID,
          pairwiseHolderDID,
          thid,
          maybeSchemaId,
          claims,
          validityPeriod,
          automaticIssuance,
          issuingDID
        )

      override def createAnonCredsIssueCredentialRecord(
          pairwiseIssuerDID: DidId,
          pairwiseHolderDID: DidId,
          thid: DidCommID,
          credentialDefinitionGUID: UUID,
          credentialDefinitionId: String,
          claims: Json,
          validityPeriod: Option[Double],
          automaticIssuance: Option[Boolean]
      ): ZIO[WalletAccessContext, CredentialServiceError, IssueCredentialRecord] =
        proxy(
          CreateAnonCredsIssueCredentialRecord,
          pairwiseIssuerDID,
          pairwiseHolderDID,
          thid,
          credentialDefinitionGUID,
          claims,
          validityPeriod,
          automaticIssuance,
          credentialDefinitionId
        )

      override def receiveCredentialOffer(offer: OfferCredential): IO[CredentialServiceError, IssueCredentialRecord] =
        proxy(ReceiveCredentialOffer, offer)

      override def acceptCredentialOffer(
          recordId: DidCommID,
          subjectId: Option[String]
      ): IO[CredentialServiceError, IssueCredentialRecord] =
        proxy(AcceptCredentialOffer, recordId, subjectId)

      override def generateJWTCredentialRequest(
          recordId: DidCommID
      ): IO[CredentialServiceError, IssueCredentialRecord] =
        proxy(GenerateJWTCredentialRequest, recordId)

      override def generateAnonCredsCredentialRequest(
          recordId: DidCommID
      ): ZIO[WalletAccessContext, CredentialServiceError, IssueCredentialRecord] =
        proxy(GenerateAnonCredsCredentialRequest, recordId)

      override def receiveCredentialRequest(
          request: RequestCredential
      ): IO[CredentialServiceError, IssueCredentialRecord] =
        proxy(ReceiveCredentialRequest, request)

      override def acceptCredentialRequest(recordId: DidCommID): IO[CredentialServiceError, IssueCredentialRecord] =
        proxy(AcceptCredentialRequest, recordId)

      override def generateJWTCredential(
          recordId: DidCommID,
          statusListRegistryUrl: String,
      ): IO[CredentialServiceError, IssueCredentialRecord] =
        proxy(GenerateJWTCredential, recordId, statusListRegistryUrl)

      override def generateAnonCredsCredential(
          recordId: DidCommID
      ): ZIO[WalletAccessContext, CredentialServiceError, IssueCredentialRecord] =
        proxy(GenerateAnonCredsCredential, recordId)

      override def receiveCredentialIssue(
          issueCredential: IssueCredential
      ): IO[CredentialServiceError, IssueCredentialRecord] =
        proxy(ReceiveCredentialIssue, issueCredential)

      override def markOfferSent(recordId: DidCommID): IO[CredentialServiceError, IssueCredentialRecord] =
        proxy(MarkOfferSent, recordId)

      override def markRequestSent(recordId: DidCommID): IO[CredentialServiceError, IssueCredentialRecord] =
        proxy(MarkRequestSent, recordId)

      override def markCredentialSent(recordId: DidCommID): IO[CredentialServiceError, IssueCredentialRecord] =
        proxy(MarkCredentialSent, recordId)

      override def reportProcessingFailure(
          recordId: DidCommID,
          failReason: Option[String]
      ): IO[CredentialServiceError, Unit] =
        proxy(ReportProcessingFailure, recordId, failReason)

      override def getIssueCredentialRecords(
          ignoreWithZeroRetries: Boolean,
          offset: Option[Int] = None,
          limit: Option[Int] = None
      ): IO[CredentialServiceError, (Seq[IssueCredentialRecord], Int)] =
        ???

      override def getIssueCredentialRecordsByStates(
          ignoreWithZeroRetries: Boolean,
          limit: Int,
          states: IssueCredentialRecord.ProtocolState*
      ): IO[CredentialServiceError, Seq[IssueCredentialRecord]] =
        ???

      override def getIssueCredentialRecordsByStatesForAllWallets(
          ignoreWithZeroRetries: Boolean,
          limit: Int,
          states: IssueCredentialRecord.ProtocolState*
      ): IO[CredentialServiceError, Seq[IssueCredentialRecord]] =
        ???

      override def getIssueCredentialRecord(
          recordId: DidCommID
      ): IO[CredentialServiceError, Option[IssueCredentialRecord]] =
        ???

      override def getIssueCredentialRecordByThreadId(
          thid: DidCommID,
          ignoreWithZeroRetries: Boolean
      ): IO[CredentialServiceError, Option[IssueCredentialRecord]] = ???
    }
  }
}

1	package org.hyperledger.identus.pollux.core.service
2
3	import io.circe.Json
4	import org.hyperledger.identus.castor.core.model.did.CanonicalPrismDID
5	import org.hyperledger.identus.mercury.model.DidId
6	import org.hyperledger.identus.mercury.protocol.issuecredential.{IssueCredential, OfferCredential, RequestCredential}
7	import org.hyperledger.identus.pollux.core.model.error.CredentialServiceError
8	import org.hyperledger.identus.pollux.core.model.{DidCommID, IssueCredentialRecord}
9	import org.hyperledger.identus.shared.models.WalletAccessContext
10	import zio.mock.{Mock, Proxy}
11	import zio.{IO, URLayer, ZIO, ZLayer, mock}
12
13	import java.util.UUID
14
15	object MockCredentialService extends Mock[CredentialService] {
16
17	object CreateJWTIssueCredentialRecord
18	extends Effect[
19	(
20	DidId,
21	DidId,
22	DidCommID,
23	Option[String],
24	Json,
25	Option[Double],
26	Option[Boolean],
27	CanonicalPrismDID
28	),
29	CredentialServiceError,
30	IssueCredentialRecord
31	]
32
33	object CreateAnonCredsIssueCredentialRecord
34	extends Effect[
35	(
36	DidId,
37	DidId,
38	DidCommID,
39	UUID,
40	Json,
41	Option[Double],
42	Option[Boolean],
43	String
44	),	1✔
45	CredentialServiceError,
46	IssueCredentialRecord	1✔
47	]
48		1✔
49	object ReceiveCredentialOffer extends Effect[OfferCredential, CredentialServiceError, IssueCredentialRecord]	1✔
50	object AcceptCredentialOffer	×
51	extends Effect[(DidCommID, Option[String]), CredentialServiceError, IssueCredentialRecord]
52	object GenerateJWTCredentialRequest extends Effect[DidCommID, CredentialServiceError, IssueCredentialRecord]
53	object GenerateAnonCredsCredentialRequest extends Effect[DidCommID, CredentialServiceError, IssueCredentialRecord]
54	object ReceiveCredentialRequest extends Effect[RequestCredential, CredentialServiceError, IssueCredentialRecord]
55	object AcceptCredentialRequest extends Effect[DidCommID, CredentialServiceError, IssueCredentialRecord]
56	object GenerateJWTCredential extends Effect[(DidCommID, String), CredentialServiceError, IssueCredentialRecord]
57	object GenerateAnonCredsCredential extends Effect[DidCommID, CredentialServiceError, IssueCredentialRecord]
58	object ReceiveCredentialIssue extends Effect[IssueCredential, CredentialServiceError, IssueCredentialRecord]
59	object MarkOfferSent extends Effect[DidCommID, CredentialServiceError, IssueCredentialRecord]
60	object MarkRequestSent extends Effect[DidCommID, CredentialServiceError, IssueCredentialRecord]
61	object MarkCredentialSent extends Effect[DidCommID, CredentialServiceError, IssueCredentialRecord]
62	object MarkCredentialPublicationPending extends Effect[DidCommID, CredentialServiceError, IssueCredentialRecord]
63	object MarkCredentialPublicationQueued extends Effect[DidCommID, CredentialServiceError, IssueCredentialRecord]
64	object MarkCredentialPublished extends Effect[DidCommID, CredentialServiceError, IssueCredentialRecord]
65	object ReportProcessingFailure extends Effect[(DidCommID, Option[String]), CredentialServiceError, Unit]
66
67	override val compose: URLayer[mock.Proxy, CredentialService] = ZLayer {	1✔
68	for {	1✔
69	proxy <- ZIO.service[Proxy]	1✔
70	} yield new CredentialService {
71
72	override def createJWTIssueCredentialRecord(	1✔
73	pairwiseIssuerDID: DidId,
74	pairwiseHolderDID: DidId,
75	thid: DidCommID,
76	maybeSchemaId: Option[String],
77	claims: Json,
78	validityPeriod: Option[Double],
79	automaticIssuance: Option[Boolean],
80	issuingDID: CanonicalPrismDID	1✔
81	): IO[CredentialServiceError, IssueCredentialRecord] =
82	proxy(	1✔
83	CreateJWTIssueCredentialRecord,
84	pairwiseIssuerDID,
85	pairwiseHolderDID,
86	thid,
87	maybeSchemaId,
88	claims,	1✔
89	validityPeriod,
90	automaticIssuance,
91	issuingDID
92	)
93		×
94	override def createAnonCredsIssueCredentialRecord(	×
95	pairwiseIssuerDID: DidId,
96	pairwiseHolderDID: DidId,
97	thid: DidCommID,
98	credentialDefinitionGUID: UUID,
99	credentialDefinitionId: String,
100	claims: Json,	×
101	validityPeriod: Option[Double],
102	automaticIssuance: Option[Boolean]
103	): ZIO[WalletAccessContext, CredentialServiceError, IssueCredentialRecord] =
104	proxy(	×
105	CreateAnonCredsIssueCredentialRecord,
106	pairwiseIssuerDID,	1✔
107	pairwiseHolderDID,
108	thid,
109	credentialDefinitionGUID,
110	claims,	1✔
111	validityPeriod,
112	automaticIssuance,	×
113	credentialDefinitionId
114	)
115
116	override def receiveCredentialOffer(offer: OfferCredential): IO[CredentialServiceError, IssueCredentialRecord] =	1✔
117	proxy(ReceiveCredentialOffer, offer)	1✔
118		1✔
119	override def acceptCredentialOffer(	1✔
120	recordId: DidCommID,
121	subjectId: Option[String]	1✔
122	): IO[CredentialServiceError, IssueCredentialRecord] =	1✔
123	proxy(AcceptCredentialOffer, recordId, subjectId)	1✔
124		1✔
125	override def generateJWTCredentialRequest(	1✔
126	recordId: DidCommID
127	): IO[CredentialServiceError, IssueCredentialRecord] =	1✔
128	proxy(GenerateJWTCredentialRequest, recordId)	1✔
129
130	override def generateAnonCredsCredentialRequest(	1✔
131	recordId: DidCommID
132	): ZIO[WalletAccessContext, CredentialServiceError, IssueCredentialRecord] =
133	proxy(GenerateAnonCredsCredentialRequest, recordId)	×
134		1✔
135	override def receiveCredentialRequest(	1✔
136	request: RequestCredential	1✔
137	): IO[CredentialServiceError, IssueCredentialRecord] =	1✔
138	proxy(ReceiveCredentialRequest, request)	1✔
139		×
140	override def acceptCredentialRequest(recordId: DidCommID): IO[CredentialServiceError, IssueCredentialRecord] =	×
141	proxy(AcceptCredentialRequest, recordId)	1✔
142		×
UNCOV 143	override def generateJWTCredential(	×
144	recordId: DidCommID,
145	statusListRegistryUrl: String,	1✔
146	): IO[CredentialServiceError, IssueCredentialRecord] =	1✔
147	proxy(GenerateJWTCredential, recordId, statusListRegistryUrl)	1✔
148		×
149	override def generateAnonCredsCredential(	×
150	recordId: DidCommID
151	): ZIO[WalletAccessContext, CredentialServiceError, IssueCredentialRecord] =
152	proxy(GenerateAnonCredsCredential, recordId)	×
153		×
154	override def receiveCredentialIssue(	1✔
155	issueCredential: IssueCredential	1✔
156	): IO[CredentialServiceError, IssueCredentialRecord] =
157	proxy(ReceiveCredentialIssue, issueCredential)	1✔
158
159	override def markOfferSent(recordId: DidCommID): IO[CredentialServiceError, IssueCredentialRecord] =	1✔
160	proxy(MarkOfferSent, recordId)	1✔
161		1✔
162	override def markRequestSent(recordId: DidCommID): IO[CredentialServiceError, IssueCredentialRecord] =	1✔
163	proxy(MarkRequestSent, recordId)	1✔
164		1✔
165	override def markCredentialSent(recordId: DidCommID): IO[CredentialServiceError, IssueCredentialRecord] =	1✔
166	proxy(MarkCredentialSent, recordId)	1✔
167		×
168	override def reportProcessingFailure(	×
169	recordId: DidCommID,	×
170	failReason: Option[String]
171	): IO[CredentialServiceError, Unit] =	×
172	proxy(ReportProcessingFailure, recordId, failReason)	×
173		×
174	override def getIssueCredentialRecords(	×
175	ignoreWithZeroRetries: Boolean,
176	offset: Option[Int] = None,	×
177	limit: Option[Int] = None	×
178	): IO[CredentialServiceError, (Seq[IssueCredentialRecord], Int)] =
179	???	×
180
181	override def getIssueCredentialRecordsByStates(	×
182	ignoreWithZeroRetries: Boolean,
183	limit: Int,	×
184	states: IssueCredentialRecord.ProtocolState*
185	): IO[CredentialServiceError, Seq[IssueCredentialRecord]] =	×
186	???	×
187
188	override def getIssueCredentialRecordsByStatesForAllWallets(	×
189	ignoreWithZeroRetries: Boolean,
190	limit: Int,	×
191	states: IssueCredentialRecord.ProtocolState*
192	): IO[CredentialServiceError, Seq[IssueCredentialRecord]] =	×
193	???	×
194
195	override def getIssueCredentialRecord(	×
196	recordId: DidCommID	×
197	): IO[CredentialServiceError, Option[IssueCredentialRecord]] =
198	???	×
199
200	override def getIssueCredentialRecordByThreadId(	×
201	thid: DidCommID,
202	ignoreWithZeroRetries: Boolean	×
203	): IO[CredentialServiceError, Option[IssueCredentialRecord]] = ???	×
204	}	×
205	}
206	}	×

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

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