/
chaincode2xscripts.go
164 lines (130 loc) · 4.89 KB
/
chaincode2xscripts.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
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
package main
import (
"bytes"
"encoding/json"
"fmt"
"os"
"strings"
)
//GenerateNewLifecycleCCScripts generated version 2.2.x compliant chaincode scripts
func GenerateNewLifecycleCCScripts(confBytes []byte) bool {
fmt.Println("Generating 2.2.x compatible cc scripts")
var netConf NetworkConfig
err := json.Unmarshal(confBytes, &netConf)
if err != nil {
fmt.Println("Parsing error in network configuration")
return false
}
orgMap := netConf.GetOrgMap()
orderer := fmt.Sprintf("%s:7050", netConf.Orderer.GetFQDNList()[0])
for _, ccDetails := range netConf.Chaincodes {
var sfBuf bytes.Buffer
var updBuf bytes.Buffer
part1 := fmt.Sprintf(ccInstallPart1, ccDetails.Channel, ccDetails.CCID, 1)
sfBuf.WriteString(part1)
updPart1 := fmt.Sprintf(ccInstallPart2, ccDetails.Channel, ccDetails.CCID, ccDetails.Participants[0])
updBuf.WriteString(updPart1)
instShFileName := fmt.Sprintf("./%s_install.sh", ccDetails.CCID)
updateShFileName := fmt.Sprintf("./%s_update.sh", ccDetails.CCID)
shFileInstall, _ := os.Create(instShFileName)
shFileUpdate, _ := os.Create(updateShFileName)
//Package the chaincode
packageStr := fmt.Sprintf(ccInstallPartCCPakage, ccDetails.Participants[0], ccDetails.SrcPath)
sfBuf.WriteString(packageStr)
updBuf.WriteString(packageStr)
var peerConnBuf bytes.Buffer
for _, participantOrg := range ccDetails.Participants {
orgDetails := orgMap[participantOrg]
for peerIndex := 0; peerIndex < orgDetails.Peers; peerIndex++ {
installPkg := fmt.Sprintf(ccInstallCC, participantOrg, peerIndex)
sfBuf.WriteString(installPkg)
updBuf.WriteString(installPkg)
}
peerConnBuf.WriteString(fmt.Sprintf(" --peerAddresses peer0.%s:7051 --tlsRootCertFiles ${%s_PEER0_CA} ", orgDetails.Domain, strings.ToUpper(orgDetails.Name)))
}
endorseentPolicy := ccDetails.GetCCEndorsementPolicy(orgMap)
for _, participantOrg := range ccDetails.Participants {
approve := fmt.Sprintf(ccApprove, participantOrg, participantOrg, participantOrg, participantOrg, orderer, endorseentPolicy)
sfBuf.WriteString(approve)
updBuf.WriteString(approve)
}
//Commit phase
ccComit := fmt.Sprintf(ccCommit, peerConnBuf.String(), orderer, endorseentPolicy)
sfBuf.WriteString(ccComit)
updBuf.WriteString(ccComit)
//Query the commited chaincode
for _, participantOrg := range ccDetails.Participants {
querycommitted := fmt.Sprintf(ccQueryCommit, participantOrg, participantOrg)
sfBuf.WriteString(querycommitted)
updBuf.WriteString(querycommitted)
}
//Now init the chaincode
ccInitInvoke := fmt.Sprintf(ccInvokeInit, orderer)
sfBuf.WriteString(ccInitInvoke)
updBuf.WriteString(ccInitInvoke)
shFileInstall.WriteString(sfBuf.String())
shFileUpdate.WriteString(updBuf.String())
shFileInstall.Close()
shFileUpdate.Close()
os.Chmod(instShFileName, 0777)
os.Chmod(updateShFileName, 0777)
}
return true
}
const ccInstallPart1 = `
#!/bin/sh
export CHANNEL_NAME="%s"
export CC_NAME="%s"
export CC_VERSION="%d.0"
export CC_SEQ=1
`
const ccInstallPart2 = `
#!/bin/sh
export CHANNEL_NAME="%s"
export CC_NAME="%s"
export CC_VERSION="2.0"
export CC_SEQ=2
# Retrive last version
. setpeer.sh %s peer0
peer lifecycle chaincode querycommitted --channelID $CHANNEL_NAME --name ${CC_NAME} >&clog.txt
export SEQ=$(tail -n 1 clog.txt | awk -F ',' '{ print $2 }'| awk -F ':' '{print $2}')
export NEWSEQ=$((SEQ+1))
export CC_VERSION="${NEWSEQ}.0"
export CC_SEQ=$NEWSEQ
echo "Going to upgrade ${CC_NAME} on ${CHANNEL_NAME} to version ${CC_VERSION} sequence ${CC_SEQ} "
`
const ccInstallPartCCPakage = `
. setpeer.sh %s peer0
# Package the chaincode
cd chaincode/%s
peer lifecycle chaincode package /opt/ws/${CC_NAME}.tar.gz --path . --lang golang --label ${CC_NAME}_${CC_VERSION}
cd /opt/ws
`
const ccInstallCC = `
# Install the chaincode package
. setpeer.sh %s peer%d
peer lifecycle chaincode install ${CC_NAME}.tar.gz
`
const ccApprove = `
# Approve Organization %s
. setpeer.sh %s peer0
peer lifecycle chaincode queryinstalled >&cq%slog.txt
PACKAGE_ID=$(sed -n "/${CC_NAME}_${CC_VERSION}/{s/^Package ID: //; s/, Label:.*$//; p;}" cq%slog.txt)
echo $PACKAGE_ID
peer lifecycle chaincode approveformyorg -o %s --tls --cafile $ORDERER_CA --channelID $CHANNEL_NAME --name $CC_NAME --version $CC_VERSION --package-id $PACKAGE_ID --sequence $CC_SEQ --init-required --signature-policy " %s "
`
const ccCommit = `
#Commit chaincode installation
export PEER_CONN="%s"
peer lifecycle chaincode commit -o %s --tls --cafile $ORDERER_CA --channelID $CHANNEL_NAME --name $CC_NAME --version $CC_VERSION --sequence $CC_SEQ --init-required --signature-policy " %s" $PEER_CONN
`
const ccQueryCommit = `
#Query commited in Org %s
. setpeer.sh %s peer0
peer lifecycle chaincode querycommitted --channelID $CHANNEL_NAME --name ${CC_NAME}
`
const ccInvokeInit = `
sleep 2
#Invoke init
peer chaincode invoke -o %s --tls --cafile $ORDERER_CA -C $CHANNEL_NAME -n ${CC_NAME} $PEER_CONN --isInit -c '{"Args":[""]}'
`