7654687041

Committed 25 Jan 2024 12:44PM UTC coverage: 31.241% (+0.7%) from 30.492%

Build Type

push

Committed by

Commit Message

feat: upgrade ZIO http client to improve performance (#850)

Signed-off-by: David Poltorak <david.poltorak@iohk.io>
Signed-off-by: Benjamin Voiturier <benjamin.voiturier@iohk.io>
Co-authored-by: Benjamin Voiturier <benjamin.voiturier@iohk.io>

Run Details

4021 of 12871 relevant lines covered (31.24%)

0.31 hits per line

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

0.0

/mercury/mercury-library/agent/src/main/scala/io/iohk/atala/mercury/InvitationPrograms.scala

package io.iohk.atala.mercury

import zio.*
import io.iohk.atala.mercury.protocol.invitation.*
import io.iohk.atala.mercury.protocol.invitation.v2.*
import io.iohk.atala.mercury.protocol.invitation.v2.Invitation.Body
import io.circe.syntax.*

object InvitationPrograms {

  def getInvitationProgram(url: String) = for {
    _ <- ZIO.log("#### Get Invitation  ####")
    client <- ZIO.service[HttpClient]
    res <- client.get(url = url)
    message = OutOfBand.parseInvitation(res.bodyAsString)
    _ <- ZIO.log(s"*******OutOfBand********${message.toString}")
  } yield (message)

  def createInvitationV2(): ZIO[DidOps & DidAgent, Nothing, String] = {
    for {
      merdiator <- ZIO.service[DidAgent]
      // _ <- ZIO.unit
      invitation = Invitation(
        "https://didcomm.org/out-of-band/2.0/invitation",
        getNewMsgId,
        merdiator.id,
        Body(Some("request-mediate"), Some("RequestMediate"), Seq("didcomm/v2", "didcomm/aip2;env=rfc587"))
      )
      _ <- ZIO.log(s"createInvitationV2 from '${merdiator.id}'")
      result = invitation.asJson.deepDropNullValues
    } yield (java.util.Base64.getUrlEncoder.encodeToString(result.noSpaces.getBytes))

  }

}

1	package io.iohk.atala.mercury
2
3	import zio.*
4	import io.iohk.atala.mercury.protocol.invitation.*
5	import io.iohk.atala.mercury.protocol.invitation.v2.*
6	import io.iohk.atala.mercury.protocol.invitation.v2.Invitation.Body
7	import io.circe.syntax.*
8
9	object InvitationPrograms {
10		×
11	def getInvitationProgram(url: String) = for {	×
12	_ <- ZIO.log("#### Get Invitation ####")	×
13	client <- ZIO.service[HttpClient]	×
14	res <- client.get(url = url)	×
15	message = OutOfBand.parseInvitation(res.bodyAsString)	×
16	_ <- ZIO.log(s"*****OutOfBand******${message.toString}")
17	} yield (message)
18		×
19	def createInvitationV2(): ZIO[DidOps & DidAgent, Nothing, String] = {	×
20	for {	×
21	merdiator <- ZIO.service[DidAgent]
22	// _ <- ZIO.unit	×
23	invitation = Invitation(
24	"https://didcomm.org/out-of-band/2.0/invitation",	×
25	getNewMsgId,	×
26	merdiator.id,	×
27	Body(Some("request-mediate"), Some("RequestMediate"), Seq("didcomm/v2", "didcomm/aip2;env=rfc587"))
28	)	×
29	_ <- ZIO.log(s"createInvitationV2 from '${merdiator.id}'")	×
30	result = invitation.asJson.deepDropNullValues	×
31	} yield (java.util.Base64.getUrlEncoder.encodeToString(result.noSpaces.getBytes))
32
33	}
34
35	}

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

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