/
deploy.js
110 lines (99 loc) · 3.24 KB
/
deploy.js
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
/**
* Copyright 2016 IBM 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.
*/
// This is Sample end-to-end standalone program that focuses on exercising all
// parts of the fabric APIs in a happy-path scenario
'use strict'
var log4js = require('log4js')
var logger = log4js.getLogger('DEPLOY')
var hfc = require('fabric-client')
var utils = require('fabric-client/lib/utils.js')
var Peer = require('fabric-client/lib/Peer.js')
var Orderer = require('fabric-client/lib/Orderer.js')
var EventHub = require('fabric-client/lib/EventHub.js')
var config = require('./config.json')
var helper = require('./helper.js')
logger.setLevel('DEBUG')
var client = new hfc()
var chain
var eventhub
var tx_id = null
if (!process.env.GOPATH) {
process.env.GOPATH = config.goPath
}
init()
function init () {
chain = client.newChain(config.chainName)
chain.addOrderer(new Orderer(config.orderer.orderer_url))
eventhub = new EventHub()
eventhub.setPeerAddr(config.events[0].event_url)
eventhub.connect()
for (var i = 0; i < config.peers.length; i++) {
chain.addPeer(new Peer(config.peers[i].peer_url))
}
}
hfc.newDefaultKeyValueStore({
path: config.keyValueStore
}).then(function (store) {
client.setStateStore(store)
return helper.getSubmitter(client)
}).then(
function (admin) {
logger.info('Successfully obtained enrolled user to deploy the chaincode')
logger.info('Executing Deploy')
tx_id = helper.getTxId()
var nonce = utils.getNonce()
var args = helper.getArgs(config.deployRequest.args)
// send proposal to endorser
var request = {
chaincodePath: config.chaincodePath,
chaincodeId: config.chaincodeID,
fcn: config.deployRequest.functionName,
args: args,
chainId: config.channelID,
txId: tx_id,
nonce: nonce,
'dockerfile-contents': config.dockerfile_contents
}
return chain.sendDeploymentProposal(request)
}
).then(
function (results) {
logger.info('Successfully obtained proposal responses from endorsers')
return helper.processProposal(chain, results, 'deploy')
}
).then(
function (response) {
if (response.status === 'SUCCESS') {
logger.info('Successfully sent deployment transaction to the orderer.')
var handle = setTimeout(() => {
logger.error('Failed to receive transaction notification within the timeout period')
process.exit(1)
}, parseInt(config.waitTime))
eventhub.registerTxEvent(tx_id.toString(), (tx) => {
logger.info('The chaincode transaction has been successfully committed')
clearTimeout(handle)
eventhub.disconnect()
})
} else {
logger.error('Failed to order the deployment endorsement. Error code: ' + response.status)
}
}
).catch(
function (err) {
eventhub.disconnect()
logger.error(err.stack ? err.stack : err)
}
)