-
Notifications
You must be signed in to change notification settings - Fork 707
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
FAB-4088 Determine which proposals are consistent
Utility to determine which proposals are consistent Move ChainUtils and rename to SDKUtils so it with other public classes. Rename SDKUtils to just Utils for internal usage. Fix typo tansaction to transaction Change-Id: I0d39dc2a89dc4c57ffee035d0ec3a73b8c32b78d Signed-off-by: rickr <cr22rc@gmail.com>
- Loading branch information
Showing
24 changed files
with
220 additions
and
149 deletions.
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
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
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,104 @@ | ||
| /* | ||
| * | ||
| * Copyright 2016,2017 DTCC, Fujitsu Australia Software Technology, IBM - All Rights Reserved. | ||
| * | ||
| * Licensed under the Apache License, Version 2.0 (the "License"); | ||
| * you may not use this file except in compliance with the License. | ||
| * You may obtain a copy of the License at | ||
| * http://www.apache.org/licenses/LICENSE-2.0 | ||
| * Unless required by applicable law or agreed to in writing, software | ||
| * distributed under the License is distributed on an "AS IS" BASIS, | ||
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| * See the License for the specific language governing permissions and | ||
| * limitations under the License. | ||
| * | ||
| */ | ||
|
|
||
| package org.hyperledger.fabric.sdk; | ||
|
|
||
| import java.io.ByteArrayOutputStream; | ||
| import java.io.IOException; | ||
| import java.util.Collection; | ||
| import java.util.HashMap; | ||
| import java.util.HashSet; | ||
| import java.util.Set; | ||
|
|
||
| import com.google.protobuf.ByteString; | ||
| import org.bouncycastle.asn1.ASN1Integer; | ||
| import org.bouncycastle.asn1.DEROctetString; | ||
| import org.bouncycastle.asn1.DERSequenceGenerator; | ||
| import org.hyperledger.fabric.sdk.exception.InvalidArgumentException; | ||
| import org.hyperledger.fabric.sdk.security.CryptoSuite; | ||
|
|
||
| public class SDKUtils { | ||
|
|
||
| public static CryptoSuite suite = null; | ||
|
|
||
| /** | ||
| * used asn1 and get hash | ||
| * | ||
| * @param blockNumber | ||
| * @param previousHash | ||
| * @param dataHash | ||
| * @return byte[] | ||
| * @throws IOException | ||
| * @throws InvalidArgumentException | ||
| */ | ||
| public static byte[] calculateBlockHash(long blockNumber, byte[] previousHash, byte[] dataHash) throws IOException, InvalidArgumentException { | ||
|
|
||
| if (previousHash == null) { | ||
| throw new InvalidArgumentException("previousHash parameter is null."); | ||
| } | ||
| if (dataHash == null) { | ||
| throw new InvalidArgumentException("dataHash parameter is null."); | ||
| } | ||
|
|
||
| if (null == suite) { | ||
| suite = CryptoSuite.Factory.getCryptoSuite(); | ||
| } | ||
|
|
||
| ByteArrayOutputStream s = new ByteArrayOutputStream(); | ||
| DERSequenceGenerator seq = new DERSequenceGenerator(s); | ||
| seq.addObject(new ASN1Integer(blockNumber)); | ||
| seq.addObject(new DEROctetString(previousHash)); | ||
| seq.addObject(new DEROctetString(dataHash)); | ||
| seq.close(); | ||
| return suite.hash(s.toByteArray()); | ||
|
|
||
| } | ||
|
|
||
| /** | ||
| * Check that the proposals all have consistent read write sets | ||
| * | ||
| * @param proposalResponses | ||
| * @return A Collection of sets where each set has consistent proposals. | ||
| * @throws InvalidArgumentException | ||
| */ | ||
|
|
||
| public static Collection<Set<ProposalResponse>> getProposalConsistencySets(Collection<ProposalResponse> proposalResponses) throws InvalidArgumentException { | ||
|
|
||
| if (proposalResponses == null) { | ||
| throw new InvalidArgumentException("proposalResponses collection is null"); | ||
| } | ||
|
|
||
| if (proposalResponses.isEmpty()) { | ||
| throw new InvalidArgumentException("proposalResponses collection is empty"); | ||
| } | ||
|
|
||
| HashMap<ByteString, Set<ProposalResponse>> ret = new HashMap<>(); | ||
|
|
||
| for (ProposalResponse proposalResponse : proposalResponses) { | ||
|
|
||
| ByteString rwsetByteString = proposalResponse.getProposalResponsePayloadDeserializer() | ||
| .getExtension().getChaincodeAction().getResults(); | ||
|
|
||
| Set<ProposalResponse> set = ret.computeIfAbsent(rwsetByteString, k -> new HashSet<>()); | ||
|
|
||
| set.add(proposalResponse); | ||
|
|
||
| } | ||
|
|
||
| return ret.values(); | ||
|
|
||
| } | ||
| } |
Oops, something went wrong.