-
Notifications
You must be signed in to change notification settings - Fork 2
/
app2.go
134 lines (104 loc) · 3.27 KB
/
app2.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
/*
Copyright IBM Corp. 2016 All Rights Reserved.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package main
import (
"os"
"time"
"github.com/hyperledger/fabric/core/crypto"
pb "github.com/hyperledger/fabric/protos"
"github.com/op/go-logging"
"google.golang.org/grpc"
)
var (
// Logging
appLogger = logging.MustGetLogger("app")
// NVP related objects
peerClientConn *grpc.ClientConn
serverClient pb.PeerClient
// Bob is the administrator
bob crypto.Client
bobCert crypto.CertificateHandler
// Charlie, Dave, and Edwina are owners
charlie crypto.Client
charlieCert crypto.CertificateHandler
dave crypto.Client
daveCert crypto.CertificateHandler
edwina crypto.Client
edwinaCert crypto.CertificateHandler
assets map[string]string
lotNums []string
)
func assignOwnership() (err error) {
appLogger.Debug("------------- Bob wants to assign the asset owners to all of the assets...")
i := 0
var ownerCert crypto.CertificateHandler
for _, lotNum := range lotNums {
assetName := assets[lotNum]
if i%3 == 0 {
appLogger.Debugf("Assigning ownership of asset '[%s]: [%s]' to '[%s]'", lotNum, assetName, "Charlie")
ownerCert = charlieCert
} else if i%3 == 1 {
appLogger.Debugf("Assigning ownership of asset '[%s]: [%s]' to '[%s]'", lotNum, assetName, "Dave")
ownerCert = daveCert
} else {
appLogger.Debugf("Assigning ownership of asset '[%s]: [%s]' to '[%s]'", lotNum, assetName, "Edwina")
ownerCert = edwinaCert
}
resp, err := assignOwnershipInternal(bob, bobCert, assetName, ownerCert)
if err != nil {
appLogger.Errorf("Failed assigning ownership [%s]", err)
return err
}
appLogger.Debugf("Resp [%s]", resp.String())
i++
}
appLogger.Debug("Wait 60 seconds...")
time.Sleep(60 * time.Second)
appLogger.Debug("------------- Done!")
return
}
func testAssetManagementChaincode() (err error) {
// Assign
err = assignOwnership()
if err != nil {
appLogger.Errorf("Failed assigning ownership [%s]", err)
return
}
appLogger.Debug("Assigned ownership!")
closeCryptoClient(bob)
closeCryptoClient(charlie)
closeCryptoClient(dave)
closeCryptoClient(edwina)
return
}
func main() {
if len(os.Args) != 2 {
appLogger.Errorf("Error -- A ChaincodeName must be specified.")
os.Exit(-1)
}
chaincodeName = os.Args[1]
// Initialize a non-validating peer whose role is to submit
// transactions to the fabric network.
// A 'core.yaml' file is assumed to be available in the working directory.
if err := initNVP(); err != nil {
appLogger.Debugf("Failed initiliazing NVP [%s]", err)
os.Exit(-1)
}
// Enable fabric 'confidentiality'
confidentiality(true)
// Exercise the 'asset_management' chaincode
if err := testAssetManagementChaincode(); err != nil {
appLogger.Debugf("Failed testing asset management chaincode [%s]", err)
os.Exit(-2)
}
}