mirrors/bitcoin-s
1
0
Fork 0
mirror of https://github.com/bitcoin-s/bitcoin-s.git synced 2024-11-19 18:02:54 +01:00
Code Issues Packages Projects Releases Wiki Activity

Compute sigPoints eagerly but asynchronously (#2642)

Browse Source 
* OracleOutcome sigPoints are now eagerly but asynchronously computed

* Increased the timeout for sigpoint computation just to be paranoid
This commit is contained in:
Nadav Kohen 2021-02-15 09:28:22 -06:00 committed by GitHub
parent 85087b0f70
commit bcd2df6051
1 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
core/src/main/scala/org/bitcoins/core/protocol/dlc/OracleOutcome.scala
View File

@ -7,6 +7,9 @@ import org.bitcoins.core.protocol.tlv.{
}
import org.bitcoins.crypto.{ECPublicKey, SchnorrNonce}
import scala.concurrent.duration.DurationInt
import scala.concurrent.{Await, ExecutionContext, Future}
/** OracleOutcomes are in one-to-one correspondence with Contract
* Execution Transactions (CETs) and are defined by a set of oracles
* needed to execute with a given CET, representing a certain outcome
@ -39,8 +42,12 @@ case class EnumOracleOutcome(
outcome: EnumOutcome)
extends OracleOutcome {
override lazy val sigPoint: ECPublicKey = {
private val sigPointF = Future {
oracles.map(_.sigPoint(outcome)).reduce(_.add(_))
}(ExecutionContext.global)
override lazy val sigPoint: ECPublicKey = {
Await.result(sigPointF, 10.seconds)
}
override lazy val aggregateNonce: SchnorrNonce = {
@ -70,12 +77,16 @@ case class NumericOracleOutcome(oraclesAndOutcomes: Vector[
def outcomes: Vector[UnsignedNumericOutcome] =
oraclesAndOutcomes.map(_._2)
override lazy val sigPoint: ECPublicKey = {
private val sigPointF = Future {
oraclesAndOutcomes
.map { case (oracle, outcome) =>
oracle.sigPoint(outcome)
}
.reduce(_.add(_))
}(ExecutionContext.global)
override lazy val sigPoint: ECPublicKey = {
Await.result(sigPointF, 20.seconds)
}
override lazy val aggregateNonce: SchnorrNonce = {