Fabric Gateway 使用示例

//合约代表智能合约，并允许应用程序：
//
//-使用 EvaluateTransaction() 方法评估从账本查询状态的交易。
//
//-使用 SubmitTransaction() 方法将存储状态的交易提交到分类帐。
//
//对于更复杂的事务调用，例如包含瞬态数据，可以分别使用 Evaluate() 或 Submit() 方法评估或提交事务。可以使用 SubmitAsync() 在提交到分类帐之前访问已提交事务的结果。
//
//使用 NewProposal() 可以采用更细粒度的交易流程。这允许重试流程中的各个步骤以响应错误。
//
//默认情况下，提案、事务和提交状态消息将使用连接网关时指定的签名实现进行签名。如果外部客户端持有签名凭据，则在连接网关时可以省略签名实现，并且可以通过以下方式执行离线签名：
//
//1. 将序列化的提案、事务或提交状态消息及其摘要返回给客户端
//他们生成签名。
//
//2. 使用从客户端收到的序列化消息和签名来创建签名提案、交易或
//分别使用网关的 NewSignedProposal()、NewSignedTransaction() 或 NewSignedCommit() 方法进行提交。
type Contract struct {
	client        *gatewayClient
	signingID     *signingIdentity
	channelName   string
	chaincodeName string
	contractName  string
}

//EvaluateTransaction 将评估交易函数并返回其结果。交易提案将在背书节点上进行评估，但交易不会发送到排序服务，因此不会提交到分类账。这可用于查询世界状态。
func (contract *Contract) EvaluateTransaction(name string, args ...string) ([]byte, error) 

//SubmitTransaction 会将一笔交易提交到账本，只有在提交到账本后才返回其结果。交易功能将在背书节点上进行评估，然后提交给排序服务以提交到分类账中。
//此方法可能会返回不同的错误类型，具体取决于事务调用中发生故障的点。可以使用errors.Is 或errors.As 检查错误。
func (contract *Contract) SubmitTransaction(name string, args ...string) ([]byte, error)

func newGRPCConnetcion() (*grpc.ClientConn, error) {
	certificate, err := loadCertificate(tlsCertPath)
	if err != nil {
		panic(err)
	}

	certPool := x509.NewCertPool()
	certPool.AddCert(certificate)
	transportCredentials := credentials.NewClientTLSFromCert(certPool, gatewayPeer)

	return grpc.Dial(peerEndpoint, grpc.WithTransportCredentials(transportCredentials))
}

func loadCertificate(filename string) (*x509.Certificate, error) {
	certificatePEM, err := os.ReadFile(filename)
	if err != nil {
		return nil, fmt.Errorf("failed to read certificate file: %w", err)
	}
	return identity.CertificateFromPEM(certificatePEM)
}

gw, err := client.Connect(
	id,
	client.WithSign(sign),
	client.WithClientConnection(clientConn),
	// Default timeouts for different gRPC calls
	client.WithEvaluateTimeout(5*time.Second),
	client.WithEndorseTimeout(15*time.Second),
	client.WithSubmitTimeout(5*time.Second),
	client.WithCommitStatusTimeout(1*time.Minute),
)

network := gw.GetNetwork(channelName)
contract := network.GetContract(chaincodeName)