package com.hu;

import java.util.List;
import org.bouncycastle.util.Strings;
import org.hyperledger.fabric.shim.ChaincodeBase;
import org.hyperledger.fabric.shim.ChaincodeStub;

public class ChaincodeDemo extends ChaincodeBase {

	public static void main(String[] args) {
		// TODO Auto-generated method stub
		new ChaincodeDemo().start(args);
	}

	@Override
	public Response init(ChaincodeStub stub) {
		// TODO Auto-generated method stub
		// 获取初始化参数
		List<String> parameters = stub.getParameters();
		System.out.println("Chaincode init success. args: " + parameters.toString());
		return new Response(200, "success", null);
	}

	@Override
	public Response invoke(ChaincodeStub stub) {
		// TODO Auto-generated method stub
		//获取方法名
		String function = stub.getFunction();
		//获取参数
		List<String> parameters = stub.getParameters();
		System.out.println("function: " + function + " args:" + parameters.toString());
		return new Response(200, "success", Strings.toByteArray("链码调用成功"));
	}

}

package com.hu.entity;

import java.nio.file.Files;
import java.nio.file.Paths;
import java.security.PrivateKey;
import java.util.Set;

import org.hyperledger.fabric.sdk.Enrollment;
import org.hyperledger.fabric.sdk.User;
import org.hyperledger.fabric.sdk.identity.X509Enrollment;
import org.hyperledger.fabric.sdk.security.CryptoPrimitives;

public class MyUser implements User {

	private String name;
	private String mspId;
	private Enrollment enrollment;

	public MyUser(String name, String mspId, String keyFile, String certFile) throws Exception {
		this.name = name;
		this.mspId = mspId;
		enrollment = loadFromPemFile(keyFile, certFile);
	}

	private Enrollment loadFromPemFile(String keyFile, String certFile) throws Exception {
		byte[] keyPem = Files.readAllBytes(Paths.get(keyFile)); // 载入私钥PEM文本
		byte[] certPem = Files.readAllBytes(Paths.get(certFile)); // 载入证书PEM文本
		CryptoPrimitives suite = new CryptoPrimitives(); // 载入密码学套件
		PrivateKey privateKey = suite.bytesToPrivateKey(keyPem); // 将PEM文本转换为私钥对象
		return new X509Enrollment(privateKey, new String(certPem)); // 创建并返回X509Enrollment对象
	}

	public String getName() {
		// TODO Auto-generated method stub
		return name;
	}

	public Set<String> getRoles() {
		// TODO Auto-generated method stub
		return null;
	}

	public String getAccount() {
		// TODO Auto-generated method stub
		return null;
	}

	public String getAffiliation() {
		// TODO Auto-generated method stub
		return null;
	}

	public Enrollment getEnrollment() {
		// TODO Auto-generated method stub
		return enrollment;
	}

	public String getMspId() {
		// TODO Auto-generated method stub
		return mspId;
	}

}

package com.hu.demo;

import org.hyperledger.fabric.sdk.User;
import org.hyperledger.fabric.sdk.exception.CryptoException;
import org.hyperledger.fabric.sdk.exception.InvalidArgumentException;
import org.hyperledger.fabric.sdk.HFClient;
import org.hyperledger.fabric.sdk.Channel;
import org.hyperledger.fabric.sdk.Peer;
import org.hyperledger.fabric.sdk.Orderer;
import org.hyperledger.fabric.sdk.security.CryptoSuite;

import com.hu.entity.MyUser;

import org.hyperledger.fabric.sdk.ChaincodeID;
import org.hyperledger.fabric.sdk.ChaincodeResponse;
import org.hyperledger.fabric.sdk.QueryByChaincodeRequest;
import org.hyperledger.fabric.sdk.ProposalResponse;
import org.hyperledger.fabric.sdk.TransactionProposalRequest;
import org.hyperledger.fabric.sdk.BlockEvent;
import org.hyperledger.fabric.sdk.BlockEvent.TransactionEvent;

import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.util.Collection;
import java.util.Properties;
import java.util.concurrent.CompletableFuture;

public class Demo {
	public static void main(String[] args) throws Exception {
		// 创建User实例
		String keyFile = "crypto-config/peerOrganizations/org1.example.com/users/Admin@org1.example.com/msp/keystore/e81bbfd91136ca08060ee3bd7ae8a104d916a8557a62722571ff801aacab41db_sk";
		String certFile = "crypto-config/peerOrganizations/org1.example.com/users/Admin@org1.example.com/msp/signcerts/Admin@org1.example.com-cert.pem";
		MyUser user;
		try {
			user = new MyUser("admin", "Org1MSP", keyFile, certFile);
		} catch (Exception e) {
			// TODO: handle exception
			System.out.println("创建用户失败:" + e.toString());
			return;
		}
		// 创建HFClient实例
		HFClient client = HFClient.createNewInstance();
		try {
			client.setCryptoSuite(CryptoSuite.Factory.getCryptoSuite());
			client.setUserContext(user);
		} catch (Exception e) {
			// TODO: handle exception
			System.out.println("创建客户端失败:" + e.toString());
			return;
		}

		// 创建通道实例
		Channel channel = client.newChannel("mychannel");
		// 设置节点信息
		Peer peer = client.newPeer("peer0.org1.example.com", "grpcs://localhost:7051",
				loadTLSFile("crypto-config/peerOrganizations/org1.example.com/tlsca/tlsca.org1.example.com-cert.pem",
						"peer0.org1.example.com"));
		try {
			channel.addPeer(peer);
		} catch (Exception e) {
			// TODO: handle exception
			System.out.println("添加节点失败:" + e.toString());
			return;
		}
//		Peer peer1 = client.newPeer("peer1.org1.example.com", "grpcs://localhost:9051",
//				loadTLSFile("crypto-config/peerOrganizations/org2.example.com/tlsca/tlsca.org2.example.com-cert.pem",
//						"peer0.org2.example.com"));
//		channel.addPeer(peer1);
		Orderer orderer = client.newOrderer("orderer.example.com", "grpcs://localhost:7050",
				loadTLSFile("crypto-config/ordererOrganizations/example.com/orderers/orderer.example.com/tls/ca.crt",
						"orderer.example.com"));
		try {
			channel.addOrderer(orderer);
			channel.initialize();
		} catch (Exception e) {
			// TODO: handle exception
			System.out.println("添加节点失败:" + e.toString());
			return;
		}

		// 设置链码名
		ChaincodeID cid = ChaincodeID.newBuilder().setName("chaincode2").build();
		System.out.println("================================调用链码==============================");
		// 调用链码
		TransactionProposalRequest invoke = client.newTransactionProposalRequest();
		invoke.setChaincodeID(cid);
		invoke.setFcn("test");
		invoke.setArgs("test invoke");
		invoke.setProposalWaitTime(3000);
		try {
			Collection<ProposalResponse> transactionProposal = channel.sendTransactionProposal(invoke);
			for (ProposalResponse pres : transactionProposal) {
				if (pres.getStatus() != ChaincodeResponse.Status.SUCCESS) {
					System.out.println("链码调用失败："+pres.getMessage());
					return;
				}
				System.out.println(pres.getProposalResponse().getResponse().getPayload().toStringUtf8());
			}
			TransactionEvent event = channel.sendTransaction(transactionProposal).get();
			System.out.format("交易ID: %s\n", event.getTransactionID());
		    System.out.format("有效性: %b\n", event.isValid());
		} catch (Exception e) {
			// TODO: handle exception
			System.out.println("链码调用失败：" + e.toString());
			return;
		}
	}

	private static Properties loadTLSFile(String rootTLSCert, String hostName) throws IOException {
		Properties properties = new Properties();
		properties.put("pemBytes", Files.readAllBytes(Paths.get(rootTLSCert)));
		properties.setProperty("sslProvider", "openSSL");
		properties.setProperty("negotiationType", "TLS");
		properties.setProperty("trustServerCertificate", "true");
		properties.setProperty("hostnameOverride", hostName);
		return properties;
	}
}