ローカル Kubernetes に Hyperledger Fabric ネットワークを迅速にデプロイする

Hyperledger (or the Hyperledger project) is an umbrella project of open source blockchains and related tools, started in December 2015 by the Linux Foundation, to support the collaborative development of blockchain-based distributed ledgers.

brew cask install docker

kubectl create -f https://raw.githubusercontent.com/kubernetes/dashboard/master/src/deploy/recommended/kubernetes-dashboard.yaml

# token を取得し、どれか 1 行をコピーすればよい
kubectl -n kube-system describe secret `kubectl -n kube-system get secret|grep admin-token|cut -d " " -f1`|grep "token:"|tr -s " "|cut -d " " -f2
# プロキシを起動する
kubectl proxy

git clone git@github.com:IBM/blockchain-network-on-kubernetes.git
chmod +x setup_blockchainNetwork.sh
chmod +x deleteNetwork.sh
./setup_blockchainNetwork.sh

$ kubectl get pods
NAME                                    READY     STATUS      RESTARTS   AGE
blockchain-ca-77459f9b84-zd8qt          1/1       Running     0          2m
blockchain-orderer-5c88f8cf95-25862     1/1       Running     0          2m
blockchain-org1peer1-7d95cbfd64-wcvz6   1/1       Running     0          2m
blockchain-org2peer1-d85dfcfc7-4kpmz    1/1       Running     0          2m
blockchain-org3peer1-6cffb6cbc7-stnj5   1/1       Running     0          2m
blockchain-org4peer1-84486f557c-pmvq8   1/1       Running     0          2m
chaincodeinstall-skd26                  0/4       Completed   0          1m
chaincodeinstantiate-jm85m              0/1       Completed   0          1m
copyartifacts-kmcp9                     0/1       Completed   0          3m
createchannel-p6ggq                     0/2       Completed   0          2m
joinchannel-lhqnx                       0/4       Completed   0          2m
utils-vr8fr                             0/2       Completed   0          2m

kubectl exec -it blockchain-org1peer1-7d95cbfd64-wcvz6 bash #进入org1节点的bash
root@blockchain-org1peer1-7d95cbfd64-wcvz6:/# peer chaincode query -C channel1 -n cc -c '{"Args":["query","a"]}'

peer chaincode invoke -o blockchain-orderer:31010 -C channel1 -n cc -c '{"Args":["invoke","b","a","51"]}'

command: ["sh", "-c", "echo $GOPATH; cp -r /shared/artifacts/chaincode $GOPATH/src/; ls $GOPATH/src; peer chaincode install -n ${CHAINCODE_NAME} -v ${CHAINCODE_VERSION} -p chaincode_example02/"]

peer chaincode instantiate -o blockchain-orderer:31010 -C ${CHANNEL_NAME} -n ${CHAINCODE_NAME} -v ${CHAINCODE_VERSION} -c '{\"Args\":[\"init\",\"a\",\"100\",\"b\",\"200\"]}'

func (t *SimpleChaincode) Init(stub shim.ChaincodeStubInterface) pb.Response;
func (t *SimpleChaincode) Invoke(stub shim.ChaincodeStubInterface) pb.Response;
func main()；

./deleteNetwork.sh

package main

import (
	"errors"
	"fmt"
	"strconv"

	"github.com/hyperledger/fabric/core/chaincode/shim"
	pb "github.com/hyperledger/fabric/protos/peer"
)

type GameChainCode struct {
}

func (cc *GameChainCode) Init(stub shim.ChaincodeStubInterface) pb.Response {

	var sum string // Sum of asset holdings across accounts. Initially 0
	var sumVal int // Sum of holdings
	var err error
	_, args := stub.GetFunctionAndParameters()
	if len(args) != 1 {
		return shim.Error("Incorrect number of arguments. Expecting 1")
	}
	// Initialize the chaincode
	sum = args[0]
	sumVal, err = strconv.Atoi(sum)
	if err != nil {
		return shim.Error("Expecting integer value for sum")
	}
	fmt.Printf("sumVal = %d\n", sumVal)
	if sumVal < 100 {
		return shim.Error("init value must bigger than 100")
	}
	// Write the state to the ledger
	err = stub.PutState("total", []byte(strconv.Itoa(sumVal)))
	if err != nil {
		return shim.Error(err.Error())
	}
	return shim.Success(nil)
}

func (cc *GameChainCode) Invoke(stub shim.ChaincodeStubInterface) pb.Response {
	function, args := stub.GetFunctionAndParameters()
	if function == "query" {
		return cc.query(stub, args)
	} else if function == "lottery" {
		return cc.lottery(stub, args)
	} else if function == "create_user" {
		return cc.create_user(stub, args)
	}
	return shim.Error("Invalid invoke function name. Expecting query uid,lottery uid token,create_user uid")
}

func (cc *GameChainCode) create_user(stub shim.ChaincodeStubInterface, args []string) pb.Response {
	if len(args) != 1 {
		return shim.Error("params error")
	}
	uId := args[0]
	balance, err := cc.getBalance(stub, uId)
	if balance < 0 || err != nil {
		stub.PutState(uId, []byte("1000"))
		return shim.Success([]byte("1000"))
	} else {
		return shim.Error("uid has been registed")
	}
}

func (cc *GameChainCode) query(stub shim.ChaincodeStubInterface, args []string) pb.Response {
	if len(args) == 0 {
		t, err := cc.getTotal(stub)
		if err != nil {
			return shim.Error("get total error!")
		}
		if t < 100 {
			return shim.Success([]byte("false"))
		} else {
			return shim.Success([]byte("true"))
		}
	} else {
		t, err := cc.getBalance(stub, args[0])
		if err != nil {
			return shim.Error("get balance error!")
		} else {
			return shim.Success([]byte(strconv.Itoa(t)))
		}
	}

}

func (cc *GameChainCode) lottery(stub shim.ChaincodeStubInterface, args []string) pb.Response {
	if len(args) != 2 {
		return shim.Error("params error")
	}
	t, err := cc.getTotal(stub)
	if err != nil {
		return shim.Error("get total error!")
	}
	uId := args[0]
	uWager, err := strconv.Atoi(args[1])
	if err != nil {
		return shim.Error("wager error!")
	}
	err = cc.plus(stub, uId, -uWager)
	if err != nil {
		return shim.Error("balance not enough")
	}

	if (uWager - t) == 0 {
		//hit
		err = cc.plus(stub, uId, uWager+t)
		return shim.Success([]byte("you win! game over!"))
	} else if ((t - uWager) > t>>2) && ((t - uWager) < t>>2+t>>3) {
		err = cc.plus(stub, uId, uWager>>1)
		return shim.Success([]byte("congratulation!!!!"))
	} else {
		err = cc.plus(stub, "total", uWager)
		return shim.Success([]byte("Good Luck Next Time!"))
	}
	return shim.Error("bet error")

}

//plus or minus value of key
func (cc *GameChainCode) plus(stub shim.ChaincodeStubInterface, k string, v int) error {
	Avalbytes, err := stub.GetState(k)
	if err != nil {
		return err
	}
	TotalV, err := strconv.Atoi(string(Avalbytes))
	if err != nil {
		return err
	}
	TotalV += v
	if TotalV < 0 {
		return errors.New("balance not enough")
	}
	stub.PutState(k, []byte(strconv.Itoa(TotalV)))
	return nil
}

func (cc *GameChainCode) getBalance(stub shim.ChaincodeStubInterface, k string) (int, error) {
	Avalbytes, err := stub.GetState(k)
	if err != nil {
		return -1, err
	}
	TotalV, err := strconv.Atoi(string(Avalbytes))
	if err != nil {
		return -1, err
	}
	return TotalV, nil
}

func (cc *GameChainCode) getTotal(stub shim.ChaincodeStubInterface) (int, error) {
	return cc.getBalance(stub, "total")
}

func main() {
	err := shim.Start(new(GameChainCode))
	if err != nil {
		fmt.Printf("Error starting game chaincode: %s", err)
	}
}

peer chaincode instantiate -o blockchain-orderer:31010 -C ${CHANNEL_NAME} -n ${CHAINCODE_NAME} -v ${CHAINCODE_VERSION} -c '{\"Args\":[\"init\",\"1024\"]}'

kubectl exec -it $(kubectl get pods | grep org1peer | awk '{ print $1 }')  -- peer chaincode invoke -C channel1 -n cc -c '{"Args":["create_user","paper"]}'
# 残高を確認し、1000 になっているか見てみる
kubectl exec -it $(kubectl get pods | grep org1peer | awk '{ print $1 }')  -- peer chaincode invoke -C channel1 -n cc -c '{"Args":["query","paper"]}'
# 50 を投資して試してみる
kubectl exec -it $(kubectl get pods | grep org1peer | awk '{ print $1 }')  -- peer chaincode invoke -C channel1 -n cc -c '{"Args":["lottery","paper","50"]}'
# 結果を取得 result: status:200 payload:"Good Luck Next Time!"

# もう一度、今度は 800 で大きく賭ける
kubectl exec -it $(kubectl get pods | grep org1peer | awk '{ print $1 }')  -- peer chaincode invoke -C channel1 -n cc -c '{"Args":["lottery","paper","800"]}'
#result: status:200 payload:"congratulation!!!!"
# やった、当たりだ