add data_swapper

data_swapper.go

+package main
+
+import (
+	"fmt"
+	"strings"
+
+	"github.com/hyperledger/fabric/common/util"
+	"github.com/hyperledger/fabric/core/chaincode/shim"
+	pb "github.com/hyperledger/fabric/protos/peer"
+)
+
+const (
+	channelID               = "mychannel"
+	brokerContractName      = "broker"
+	emitInterchainEventFunc = "EmitInterchainEvent"
+)
+
+type DataSwapper struct{}
+
+func (s *DataSwapper) Init(stub shim.ChaincodeStubInterface) pb.Response {
+	return shim.Success(nil)
+}
+
+func (s *DataSwapper) Invoke(stub shim.ChaincodeStubInterface) pb.Response {
+	function, args := stub.GetFunctionAndParameters()
+
+	fmt.Printf("invoke: %s\n", function)
+	switch function {
+	case "register":
+		return s.register(stub)
+	case "interchainGet":
+		return s.interchainGet(stub, args)
+	case "interchainSet":
+		return s.interchainSet(stub, args)
+	case "get":
+		return s.get(stub, args)
+	case "set":
+		return s.set(stub, args)
+	default:
+		return shim.Error("invalid function: " + function + ", args: " + strings.Join(args, ","))
+	}
+}
+
+func (s *DataSwapper) register(stub shim.ChaincodeStubInterface) pb.Response {
+	args := util.ToChaincodeArgs("register")
+	response := stub.InvokeChaincode(brokerContractName, args, channelID)
+	if response.Status != shim.OK {
+		return shim.Error(fmt.Sprintf("invoke chaincode '%s' err: %s", brokerContractName, response.Message))
+	}
+	return response
+}
+
+// get is business function which will invoke the to,tid,id
+func (s *DataSwapper) get(stub shim.ChaincodeStubInterface, args []string) pb.Response {
+	switch len(args) {
+	case 1:
+		// args[0]: key
+		value, err := stub.GetState(args[0])
+		if err != nil {
+			return shim.Error(err.Error())
+		}
+
+		return shim.Success(value)
+	case 2:
+		// args[0]: destination service id
+		// args[1]: key
+		b := util.ToChaincodeArgs(emitInterchainEventFunc, args[0], "interchainGet,interchainSet,", args[1], args[1], "")
+		response := stub.InvokeChaincode(brokerContractName, b, channelID)
+		if response.Status != shim.OK {
+			return shim.Error(fmt.Errorf("invoke broker chaincode %s error: %s", brokerContractName, response.Message).Error())
+		}
+
+		return shim.Success(nil)
+	default:
+		return shim.Error("incorrect number of arguments")
+	}
+}
+
+// get is business function which will invoke the to,tid,id
+func (s *DataSwapper) set(stub shim.ChaincodeStubInterface, args []string) pb.Response {
+	if len(args) != 2 {
+		return shim.Error("incorrect number of arguments")
+	}
+
+	err := stub.PutState(args[0], []byte(args[1]))
+	if err != nil {
+		return shim.Error(err.Error())
+	}
+
+	return shim.Success(nil)
+}
+
+// interchainSet is the callback function getting data by interchain
+func (s *DataSwapper) interchainSet(stub shim.ChaincodeStubInterface, args []string) pb.Response {
+	return s.set(stub, args)
+}
+
+// interchainGet gets data by interchain
+func (s *DataSwapper) interchainGet(stub shim.ChaincodeStubInterface, args []string) pb.Response {
+	value, err := stub.GetState(args[0])
+	if err != nil {
+		return shim.Error(err.Error())
+	}
+	return shim.Success(value)
+}
+
+func main() {
+	err := shim.Start(new(DataSwapper))
+	if err != nil {
+		fmt.Printf("Error starting chaincode: %s", err)
+	}
+}

go.mod

+module gitlab.33.cn/link33/data_swapper
+
+go 1.13
+
+require (
+	github.com/Knetic/govaluate v3.0.0+incompatible // indirect
+	github.com/Shopify/sarama v1.29.1 // indirect
+	github.com/fsouza/go-dockerclient v1.7.3 // indirect
+	github.com/grpc-ecosystem/go-grpc-middleware v1.3.0 // indirect
+	github.com/hashicorp/go-version v1.3.0 // indirect
+	github.com/hyperledger/fabric v1.4.3
+	github.com/hyperledger/fabric-amcl v0.0.0-20210603140002-2670f91851c8 // indirect
+	github.com/miekg/pkcs11 v1.0.3 // indirect
+	github.com/onsi/gomega v1.14.0 // indirect
+	github.com/op/go-logging v0.0.0-20160315200505-970db520ece7 // indirect
+	github.com/spf13/viper v1.8.1 // indirect
+	github.com/sykesm/zap-logfmt v0.0.4 // indirect
+	go.uber.org/zap v1.18.1 // indirect
+	golang.org/x/crypto v0.0.0-20210711020723-a769d52b0f97 // indirect
+	google.golang.org/grpc v1.39.0 // indirect
+)
+
+replace github.com/golang/protobuf => github.com/golang/protobuf v1.3.2