Add data access #64
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,136 @@ | ||
| package io.provenance.engine.service | ||
|
|
||
| import cosmos.bank.v1beta1.Tx | ||
| import cosmos.base.abci.v1beta1.Abci | ||
| import cosmos.base.v1beta1.CoinOuterClass | ||
| import cosmos.tx.v1beta1.ServiceOuterClass | ||
| import io.p8e.crypto.Hash | ||
| import io.p8e.util.* | ||
| import io.provenance.engine.crypto.toSignerMeta | ||
| import io.provenance.engine.config.ChaincodeProperties | ||
| import io.provenance.engine.crypto.Account | ||
| import io.provenance.engine.crypto.Bech32 | ||
| import io.provenance.engine.crypto.toBech32Data | ||
| import io.provenance.p8e.shared.extension.logger | ||
| import io.provenance.metadata.v1.* | ||
| import io.provenance.p8e.shared.service.AffiliateService | ||
| import org.bouncycastle.jcajce.provider.asymmetric.ec.BCECPublicKey | ||
| import org.jetbrains.exposed.sql.transactions.transaction | ||
| import org.springframework.stereotype.Service | ||
| import p8e.Jobs | ||
| import java.security.KeyPair | ||
| import java.security.PublicKey | ||
|
|
||
| // One to One Billion ratio from hash to nhash | ||
| private const val HASH_TO_NHASH = 1000000000L | ||
|
|
||
| @Service | ||
| class DataAccessChaincodeService( | ||
| private val chaincodeProperties: ChaincodeProperties, | ||
| private val p8eAccount: Account, | ||
| private val provenanceGrpcService: ProvenanceGrpcService, | ||
| private val affiliateService: AffiliateService, | ||
| private val chaincodeInvokeService: ChaincodeInvokeService, | ||
| ) : JobHandlerService { | ||
| private val log = logger() | ||
|
|
||
| override fun handle(payload: Jobs.P8eJob) { | ||
| val msgAddScopeDataAccessRequest = MsgAddScopeDataAccessRequest.newBuilder().addAllDataAccess(payload.msgAddScopeDataAccessRequest.dataAccessList) | ||
| .addAllSigners(payload.msgAddScopeDataAccessRequest.signersList) | ||
| .setScopeId(payload.msgAddScopeDataAccessRequest.scopeId) | ||
| .build() | ||
| val publicKey = payload.msgAddScopeDataAccessRequest.publicKey.toPublicKey() | ||
|
|
||
| val affiliate = | ||
| transaction { affiliateService.get(publicKey) }.orThrowNotFound("Affiliate with public key ${publicKey.toHex()} not found") | ||
| val affiliateKeyPair = | ||
| KeyPair(affiliate.publicKey.value.toJavaPublicKey(), affiliate.privateKey.toJavaPrivateKey()) | ||
|
There was a problem hiding this comment. We may need to add SmartKey support here as well ... probably setup data under KeyRef data class (hopefully this branch goes out before mine so you don't have to worry about it) :) Essentially instead of a KeyPair, we have KeyRef that contains key information such as public key, maybe private key?, UUID (SmartKey way of identifying a private key stored on their system). |
||
|
|
||
| // Estimate transaction cost | ||
| val affiliateAddress = publicKey.toBech32Address(chaincodeProperties.mainNet) | ||
| val affiliateAccount = provenanceGrpcService.accountInfo(affiliateAddress) | ||
|
|
||
| val estimate = provenanceGrpcService.estimateTx( | ||
| msgAddScopeDataAccessRequest.toTxBody(), | ||
| affiliateAccount.accountNumber, | ||
| affiliateAccount.sequence | ||
| ) | ||
|
|
||
| // perform and wait for hash transfer to complete if account has less than 10 hash | ||
| if ((provenanceGrpcService.getAccountCoins(affiliateAddress).find {it.denom == "nhash"}?.amount?.toLong() | ||
| ?: 0L) / HASH_TO_NHASH < 10 | ||
| ) { | ||
| waitForTx { | ||
| transferHash(affiliateAccount.address, 100 * HASH_TO_NHASH) | ||
| } | ||
| } | ||
| val resp = provenanceGrpcService.batchTx( | ||
| msgAddScopeDataAccessRequest.toTxBody(), | ||
| affiliateAccount.accountNumber, | ||
| affiliateAccount.sequence, | ||
| estimate, | ||
| affiliateKeyPair.toSignerMeta() | ||
| ) | ||
| if (resp.txResponse.code != 0) { | ||
| // adding extra raw logging during exceptional cases so that we can see what typical responses look like while this interface is new | ||
| log.info("Abci.TxResponse from chain ${resp.txResponse}") | ||
|
|
||
| val errorMessage = "${resp.txResponse.code} - ${resp.txResponse.rawLog}" | ||
|
|
||
| throw IllegalStateException(errorMessage) | ||
| } | ||
| } | ||
|
|
||
| fun transferHash(toAddress: String, amount: Long) = Tx.MsgSend.newBuilder() | ||
| .addAllAmount(listOf( | ||
| CoinOuterClass.Coin.newBuilder() | ||
| .setAmount(amount.toString()) | ||
| .setDenom("nhash") | ||
| .build() | ||
| )).setFromAddress(p8eAccount.bech32Address()) | ||
| .setToAddress(toAddress) | ||
| .build().let { | ||
| chaincodeInvokeService.batchTx(it.toTxBody()) | ||
| } | ||
|
|
||
| fun waitForTx(block: () -> ServiceOuterClass.BroadcastTxResponse): Abci.TxResponse { | ||
| val txResponse = block() | ||
| val txHash = txResponse.txResponse.txhash | ||
|
|
||
| if (txResponse.txResponse.code != 0) { | ||
| throw Exception("Error submitting transaction [code = ${txResponse.txResponse.code}, codespace = ${txResponse.txResponse.codespace}, raw_log = ${txResponse.txResponse.rawLog}]") | ||
| } | ||
|
|
||
| val maxAttempts = 5 | ||
| log.info("Waiting for transaction to complete [hash = $txHash]") | ||
| for (i in 1 .. maxAttempts) { | ||
| Thread.sleep(2500) | ||
| val response = try { | ||
| provenanceGrpcService.getTx(txHash) | ||
| } catch (t: Throwable) { | ||
| log.info("Error fetching transaction [hash = $txHash, message = ${t.message}]") | ||
| continue | ||
| } | ||
|
|
||
| when { | ||
| response.code == 0 -> { | ||
| log.info("Transaction complete [hash = $txHash]") | ||
| return response | ||
| } | ||
| response.code > 0 -> throw Exception("Transaction Failed with log ${response.rawLog}") | ||
| else -> continue // todo: what are the failure conditions, non-0 code... tx not found... under which conditions might it eventually succeed, not found needs a retry? | ||
| } | ||
| } | ||
| throw Exception("Failed to fetch transaction after $maxAttempts attempts [hash = $txHash]") | ||
| } | ||
|
|
||
| // todo: this should really be somewhere more shared... but p8e-util where other key conversion extensions are doesn't have the Hash class... | ||
| private fun PublicKey.toBech32Address(mainNet: Boolean): String = | ||
| (this as BCECPublicKey).q.getEncoded(true) | ||
| .let { | ||
| Hash.sha256hash160(it) | ||
| }.let { | ||
| val prefix = if (mainNet) Bech32.PROVENANCE_MAINNET_ACCOUNT_PREFIX else Bech32.PROVENANCE_TESTNET_ACCOUNT_PREFIX | ||
| it.toBech32Data(prefix).address | ||
| } | ||
| } | ||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,18 @@ | ||
| package io.provenance.p8e.shared.service | ||
|
|
||
| import io.p8e.util.toPublicKeyProto | ||
| import io.provenance.p8e.shared.domain.JobRecord | ||
| import org.jetbrains.exposed.sql.transactions.transaction | ||
| import java.security.PublicKey | ||
| import org.springframework.stereotype.Service | ||
| import p8e.Jobs | ||
|
|
||
| @Service | ||
| class DataAccessService { | ||
| fun addDataAccess(dataAccess: Jobs.MsgAddScopeDataAccessRequest) = transaction { | ||
| JobRecord.create(Jobs.P8eJob.newBuilder() | ||
| .setMsgAddScopeDataAccessRequest(dataAccess) | ||
| .build() | ||
| ) | ||
| } | ||
| } |
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
By any chance did you test this with a multiparty contract? I'm not positive, but I think the only signer we want is the scope owner. In the case for our scopes that's always a single invoker. If you only ran single party contracts, the
envelope.data.result.signaturesListshould only contain the invoker so it's not a big deal. It would take a multiparty contract to see if this fails or not as is.