Ticket

Author: qzhongwood

chaincode/modules/ticket/adapter_caller.go

@@ -0,0 +1,70 @@
+package ticket
+
+import (
+	txgen "hyperledger.abchain.org/chaincode/lib/txgen"
+	ccpb "hyperledger.abchain.org/chaincode/modules/ticket/protos"
+	pb "hyperledger.abchain.org/chaincode/modules/ticket/protos"
+	txutil "hyperledger.abchain.org/core/tx"
+)
+
+type GeneralCall struct {
+	txgen.TxCaller
+}
+
+const (
+
+	Method_Add      = "TICKET.UPDATE"
+	Method_Apply    = "TICKET.QUERY"
+	Method_Query    = "TICKET.CONTRACT"
+)
+
+func (i *GeneralCall) Add(owner []byte, id []byte, ticketCat int, desc string) error {
+
+	ct := new(ccpb.Ticket)
+	ct.Id = id
+	ct.Owner = txutil.NewAddressFromHash(owner).PBMessage()
+	ct.TicketCat = int32(ticketCat)
+	ct.Desc = desc
+
+
+	if err := i.Invoke(Method_Add, ct); err != nil {
+		return err
+	}
+
+	return nil
+}
+
+
+func (i *GeneralCall) Apply(owner []byte, id []byte) error {
+
+	ct := new(ccpb.ApplyTicket)
+	ct.Id = id
+	ct.Owner = txutil.NewAddressFromHash(owner).PBMessage()
+
+	return i.Invoke(Method_Apply, ct)
+}
+
+func (i *GeneralCall) Query(owner []byte, id []byte) (int, string) {
+
+	msg := &pb.QueryTicket{
+		Owner: txutil.NewAddressFromHash(owner).PBMessage(),
+		Id: id,
+	}
+
+	data, err := i.TxCaller.Query(Method_Query, msg)
+	if err != nil {
+		return -1, ""
+	}
+
+	d := &pb.Ticket{}
+	err = txgen.SyncQueryResult(d, data)
+	if err != nil {
+		return -1, ""
+	}
+
+	ret := new(pb.Ticket_s)
+	ret.LoadFromPB(d)
+	return int(ret.TicketCat), ret.Dest
+}
+
+

chaincode/modules/ticket/adapter_handler.go

@@ -0,0 +1,64 @@
+package ticket
+
+import (
+	"github.com/golang/protobuf/proto"
+	rpc "hyperledger.abchain.org/chaincode/lib/caller"
+	pb "hyperledger.abchain.org/chaincode/modules/ticket/protos"
+	"hyperledger.abchain.org/chaincode/shim"
+	txutil "hyperledger.abchain.org/core/tx"
+)
+
+
+type addHandler struct{ TicketConfig }
+type applyHandler struct{ TicketConfig }
+type queryHandler struct{ TicketConfig }
+
+func AddHandler(cfg TicketConfig) addHandler {
+	return addHandler{TicketConfig: cfg}
+}
+func ApplyHandler(cfg TicketConfig) applyHandler {
+	return applyHandler{TicketConfig: cfg}
+}
+func QueryHandler(cfg TicketConfig) queryHandler {
+	return queryHandler{TicketConfig: cfg}
+}
+
+func (h addHandler) Msg() proto.Message     { return new(pb.Ticket) }
+func (h applyHandler) Msg() proto.Message   { return new(pb.ApplyTicket) }
+func (h queryHandler) Msg() proto.Message   { return new(pb.QueryTicket) }
+
+
+func (h addHandler) Call(stub shim.ChaincodeStubInterface, parser txutil.Parser) ([]byte, error) {
+
+	msg := parser.GetMessage().(*pb.Ticket)
+
+	addr := msg.GetOwner().GetHash()
+
+	err := h.NewTx(stub, parser.GetNonce()).Add(addr, msg.Id, int(msg.TicketCat), msg.Desc)
+	if err != nil {
+		return nil, err
+	}
+	return []byte("done"), nil
+}
+
+func (h applyHandler) Call(stub shim.ChaincodeStubInterface, parser txutil.Parser) ([]byte, error) {
+	msg := parser.GetMessage().(*pb.ApplyTicket)
+
+	err := h.NewTx(stub, parser.GetNonce()).Apply(msg.GetOwner().GetHash(), msg.Id)
+	if err != nil {
+		return nil, err
+	}
+	return []byte("done"), nil
+}
+
+func (h queryHandler) Call(stub shim.ChaincodeStubInterface, parser txutil.Parser) ([]byte, error)  {
+
+	msg := parser.GetMessage().(*pb.QueryTicket)
+	catalogy, desc := h.NewTx(stub, parser.GetNonce()).Query(msg.GetOwner().GetHash(), msg.Id)
+
+	data := &pb.Ticket_s{}
+	data.TicketCat = int32(catalogy)
+	data.Dest = desc
+	return rpc.EncodeRPCResult(data.ToPB())
+}
+

chaincode/modules/ticket/cc.go

@@ -1,6 +1,13 @@
 package ticket
 
+import (
+	"hyperledger.abchain.org/chaincode/lib/runtime"
+	txgen "hyperledger.abchain.org/chaincode/lib/txgen"
+	"hyperledger.abchain.org/chaincode/shim"
+)
+
 type TicketTx interface {
+
 	//add an ticket belong to the owner, which MUST has an unique id,
 	//or error will be returned if the id is duplicated
 	//ticket catalogy MUST start from 1 (0 or less is not allowed)
@@ -12,3 +19,41 @@ type TicketTx interface {
 	//ticket is not exist
 	Query(owner []byte, id []byte) (int, string)
 }
+
+type TicketConfig interface {
+	NewTx(shim.ChaincodeStubInterface, []byte) TicketTx
+}
+
+type StandardTicketConfig struct {
+	Root string
+	*runtime.Config
+}
+
+func NewConfig(tag string) *StandardTicketConfig {
+	cfg := runtime.NewConfig()
+
+	return &StandardTicketConfig{ticket_tag_prefix + tag, cfg}
+}
+
+type baseTicketTx struct {
+	*runtime.ChaincodeRuntime
+	nonce    []byte
+}
+
+
+const (
+	ticket_tag_prefix = "Ticket_"
+)
+
+func (cfg *StandardTicketConfig) NewTx(stub shim.ChaincodeStubInterface, nonce []byte) TicketTx {
+	return &baseTicketTx{runtime.NewRuntime(cfg.Root, stub, cfg.Config), nonce}
+}
+
+type InnerInvokeConfig struct {
+	txgen.InnerChaincode
+}
+
+func (c InnerInvokeConfig) NewTx(stub shim.ChaincodeStubInterface, nc []byte) TicketTx {
+	return &GeneralCall{c.NewInnerTxInterface(stub, nc)}
+}
+