setup update
This commit is contained in:
parent
153e046928
commit
91ef184868
Binary file not shown.
|
@ -36,7 +36,8 @@ public class FabricClientWrapper {
|
||||||
public Set<String> queryForChannels() throws InvalidArgumentException, IllegalArgumentException, ProposalException {
|
public Set<String> queryForChannels() throws InvalidArgumentException, IllegalArgumentException, ProposalException {
|
||||||
client.newChannel(Config.CHANNEL_NAME);
|
client.newChannel(Config.CHANNEL_NAME);
|
||||||
client.newOrderer(Config.ORDERER_NAME,Config.ORDERER_URL);
|
client.newOrderer(Config.ORDERER_NAME,Config.ORDERER_URL);
|
||||||
Peer peer = client.newPeer(Config.ORG_PEER,Config.ORG_PEER_URL);
|
//Peer peer = client.newPeer(Config.ORG_PEER,Config.ORG_PEER_URL);
|
||||||
|
Peer peer = client.newPeer(Config.ORG1_PEER_0,Config.ORG1_PEER_0_URL);
|
||||||
return client.queryChannels(peer);
|
return client.queryChannels(peer);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
48
src/test/java/blockchain/query/CreateChaincodeUserTest.java
Normal file
48
src/test/java/blockchain/query/CreateChaincodeUserTest.java
Normal file
|
@ -0,0 +1,48 @@
|
||||||
|
package blockchain.query;
|
||||||
|
|
||||||
|
import blockchain.client.ChannelClientWrapper;
|
||||||
|
import blockchain.client.FabricClientWrapper;
|
||||||
|
import blockchain.configuration.Config;
|
||||||
|
import blockchain.user.UserContext;
|
||||||
|
import blockchain.utility.Util;
|
||||||
|
import org.apache.log4j.BasicConfigurator;
|
||||||
|
import org.hyperledger.fabric.sdk.Channel;
|
||||||
|
import org.hyperledger.fabric.sdk.EventHub;
|
||||||
|
import org.hyperledger.fabric.sdk.Orderer;
|
||||||
|
import org.hyperledger.fabric.sdk.Peer;
|
||||||
|
import org.junit.Test;
|
||||||
|
|
||||||
|
import java.util.ArrayList;
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
public class CreateChaincodeUserTest {
|
||||||
|
@Test
|
||||||
|
public void TestCreateUser(){
|
||||||
|
BasicConfigurator.configure();
|
||||||
|
UserContext user = Util.readUserContext(Config.ORG1,Config.ADMIN);
|
||||||
|
|
||||||
|
try{
|
||||||
|
String chaincode = Config.CHAINCODE_NAME;
|
||||||
|
FabricClientWrapper fabricClientWrapper = new FabricClientWrapper(user);
|
||||||
|
ChannelClientWrapper channelClientWrapper = fabricClientWrapper.createChannelClient(Config.CHANNEL_NAME);
|
||||||
|
|
||||||
|
Channel channel = channelClientWrapper.getChannel();
|
||||||
|
Peer peer = fabricClientWrapper.getClient().newPeer(Config.ORG_PEER,Config.ORG_PEER_URL);
|
||||||
|
EventHub eventHub = fabricClientWrapper.getClient().newEventHub("eventhub01", Config.ORG_PEER_EVENT_URL);
|
||||||
|
Orderer orderer = fabricClientWrapper.getClient().newOrderer(Config.ORDERER_NAME,Config.ORDERER_URL);
|
||||||
|
channel.addPeer(peer);
|
||||||
|
channel.addEventHub(eventHub);
|
||||||
|
channel.addOrderer(orderer);
|
||||||
|
channel.initialize();
|
||||||
|
|
||||||
|
List<String> args = new ArrayList<>();
|
||||||
|
args.add("user1");
|
||||||
|
args.add("200");
|
||||||
|
args.add("user2");
|
||||||
|
args.add("150");
|
||||||
|
|
||||||
|
}catch (Exception e){
|
||||||
|
e.printStackTrace();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
|
@ -16,13 +16,13 @@ import java.util.Set;
|
||||||
|
|
||||||
public class QueryTest {
|
public class QueryTest {
|
||||||
private static Logger logger = Logger.getLogger(QueryTest.class);
|
private static Logger logger = Logger.getLogger(QueryTest.class);
|
||||||
//DON'T WORK
|
|
||||||
@Test
|
@Test
|
||||||
public void TestAQueryChannels() {
|
public void TestAQueryChannels() {
|
||||||
BasicConfigurator.configure();
|
BasicConfigurator.configure();
|
||||||
|
|
||||||
UserContext user = Util.readUserContext(Config.ORG1,Config.ADMIN);
|
//UserContext user = Util.readUserContext(Config.ORG1,Config.ADMIN);
|
||||||
//UserContext user = Util.readUserContext(Config.ORG1,"User-org1");
|
UserContext user = Util.readUserContext(Config.ORG1,"User-org1");
|
||||||
|
|
||||||
try{
|
try{
|
||||||
|
|
||||||
|
@ -44,10 +44,10 @@ public class QueryTest {
|
||||||
ChannelClientWrapper channelClientWrapper = fabricClientWrapper.createChannelClient(Config.CHANNEL_NAME);
|
ChannelClientWrapper channelClientWrapper = fabricClientWrapper.createChannelClient(Config.CHANNEL_NAME);
|
||||||
|
|
||||||
Channel channel = channelClientWrapper.getChannel();
|
Channel channel = channelClientWrapper.getChannel();
|
||||||
//Peer peer = fabricClientWrapper.getClient().newPeer(Config.ORG1_PEER_0,Config.ORG1_PEER_0_URL);
|
Peer peer = fabricClientWrapper.getClient().newPeer(Config.ORG1_PEER_0,Config.ORG1_PEER_0_URL);
|
||||||
Peer peer = fabricClientWrapper.getClient().newPeer(Config.ORG_PEER,Config.ORG_PEER_URL);
|
//Peer peer = fabricClientWrapper.getClient().newPeer(Config.ORG_PEER,Config.ORG_PEER_URL);
|
||||||
//EventHub eventHub = fabricClientWrapper.getClient().newEventHub("eventhub01", "grpc://vps577432.ovh.net:8053");
|
EventHub eventHub = fabricClientWrapper.getClient().newEventHub("eventhub01", "grpc://vps577432.ovh.net:8053");
|
||||||
EventHub eventHub = fabricClientWrapper.getClient().newEventHub("eventhub01", Config.ORG_PEER_EVENT_URL);
|
//EventHub eventHub = fabricClientWrapper.getClient().newEventHub("eventhub01", Config.ORG_PEER_EVENT_URL);
|
||||||
Orderer orderer = fabricClientWrapper.getClient().newOrderer(Config.ORDERER_NAME,Config.ORDERER_URL);
|
Orderer orderer = fabricClientWrapper.getClient().newOrderer(Config.ORDERER_NAME,Config.ORDERER_URL);
|
||||||
channel.addPeer(peer);
|
channel.addPeer(peer);
|
||||||
channel.addEventHub(eventHub);
|
channel.addEventHub(eventHub);
|
||||||
|
|
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Loading…
Reference in a new issue