@@ -25,7 +25,7 @@ import (
25
25
topology2 "github.com/hyperledger-labs/fabric-token-sdk/integration/nwo/token/topology"
26
26
"github.com/hyperledger-labs/fabric-token-sdk/token"
27
27
"github.com/hyperledger-labs/fabric-token-sdk/token/services/logging"
28
- . "github.com/onsi/gomega"
28
+ "github.com/onsi/gomega"
29
29
)
30
30
31
31
var logger = logging .MustGetLogger ("token-sdk.integration.token.fabric" )
@@ -70,11 +70,11 @@ func (p *NetworkHandler) GenerateArtifacts(tms *topology2.TMS) {
70
70
71
71
// Generate crypto material
72
72
cmGenerator := p .CryptoMaterialGenerators [tms .Driver ]
73
- Expect (cmGenerator ).NotTo (BeNil (), "Crypto material generator for driver %s not found" , tms .Driver )
73
+ gomega . Expect (cmGenerator ).NotTo (gomega . BeNil (), "Crypto material generator for driver %s not found" , tms .Driver )
74
74
75
75
// - Setup
76
76
root , err := cmGenerator .Setup (tms )
77
- Expect (err ).NotTo (HaveOccurred ())
77
+ gomega . Expect (err ).NotTo (gomega . HaveOccurred ())
78
78
79
79
// - Generate crypto material for each FSC node
80
80
fscTopology := p .TokenPlatform .GetContext ().TopologyByName (fsc .TopologyName ).(* fsc.Topology )
@@ -85,7 +85,7 @@ func (p *NetworkHandler) GenerateArtifacts(tms *topology2.TMS) {
85
85
// Generate public parameters
86
86
var ppRaw []byte
87
87
ppGenerator := p .TokenPlatform .GetPublicParamsGenerators (tms .Driver )
88
- Expect (ppGenerator ).NotTo (BeNil (), "No public params generator for driver %s" , tms .Driver )
88
+ gomega . Expect (ppGenerator ).NotTo (gomega . BeNil (), "No public params generator for driver %s" , tms .Driver )
89
89
args := []interface {}{root }
90
90
for _ , arg := range tms .PublicParamsGenArgs {
91
91
args = append (args , arg )
@@ -99,11 +99,11 @@ func (p *NetworkHandler) GenerateArtifacts(tms *topology2.TMS) {
99
99
wallets .Certifiers = append (wallets .Certifiers , w .Certifiers ... )
100
100
}
101
101
ppRaw , err = ppGenerator .Generate (tms , wallets , args ... )
102
- Expect (err ).ToNot (HaveOccurred ())
102
+ gomega . Expect (err ).ToNot (gomega . HaveOccurred ())
103
103
104
104
// - Store pp
105
- Expect (os .MkdirAll (p .TokenPlatform .PublicParametersDir (), 0766 )).ToNot (HaveOccurred ())
106
- Expect (os .WriteFile (p .TokenPlatform .PublicParametersFile (tms ), ppRaw , 0766 )).ToNot (HaveOccurred ())
105
+ gomega . Expect (os .MkdirAll (p .TokenPlatform .PublicParametersDir (), 0766 )).ToNot (gomega . HaveOccurred ())
106
+ gomega . Expect (os .WriteFile (p .TokenPlatform .PublicParametersFile (tms ), ppRaw , 0766 )).ToNot (gomega . HaveOccurred ())
107
107
108
108
// Prepare namespace
109
109
p .Backend .PrepareNamespace (tms )
@@ -113,17 +113,17 @@ func (p *NetworkHandler) GenerateArtifacts(tms *topology2.TMS) {
113
113
caFactory , found := p .CASupports [tms .Driver ]
114
114
if found {
115
115
ca , err := caFactory (p .TokenPlatform , tms , root )
116
- Expect (err ).ToNot (HaveOccurred (), "failed to instantiate CA for [%s]" , tms .ID ())
116
+ gomega . Expect (err ).ToNot (gomega . HaveOccurred (), "failed to instantiate CA for [%s]" , tms .ID ())
117
117
entry .CA = ca
118
118
}
119
119
}
120
120
}
121
121
122
122
func (p * NetworkHandler ) GenerateExtension (tms * topology2.TMS , node * sfcnode.Node , uniqueName string ) string {
123
- Expect (os .MkdirAll (p .TTXDBSQLDataSourceDir (uniqueName ), 0775 )).ToNot (HaveOccurred (), "failed to create [%s]" , p .TTXDBSQLDataSourceDir (uniqueName ))
124
- Expect (os .MkdirAll (p .TokensDBSQLDataSourceDir (uniqueName ), 0775 )).ToNot (HaveOccurred (), "failed to create [%s]" , p .TokensDBSQLDataSourceDir (uniqueName ))
125
- Expect (os .MkdirAll (p .AuditDBSQLDataSourceDir (uniqueName ), 0775 )).ToNot (HaveOccurred (), "failed to create [%s]" , p .AuditDBSQLDataSourceDir (uniqueName ))
126
- Expect (os .MkdirAll (p .IdentityDBSQLDataSourceDir (uniqueName ), 0775 )).ToNot (HaveOccurred (), "failed to create [%s]" , p .IdentityDBSQLDataSourceDir (uniqueName ))
123
+ gomega . Expect (os .MkdirAll (p .TTXDBSQLDataSourceDir (uniqueName ), 0775 )).ToNot (gomega . HaveOccurred (), "failed to create [%s]" , p .TTXDBSQLDataSourceDir (uniqueName ))
124
+ gomega . Expect (os .MkdirAll (p .TokensDBSQLDataSourceDir (uniqueName ), 0775 )).ToNot (gomega . HaveOccurred (), "failed to create [%s]" , p .TokensDBSQLDataSourceDir (uniqueName ))
125
+ gomega . Expect (os .MkdirAll (p .AuditDBSQLDataSourceDir (uniqueName ), 0775 )).ToNot (gomega . HaveOccurred (), "failed to create [%s]" , p .AuditDBSQLDataSourceDir (uniqueName ))
126
+ gomega . Expect (os .MkdirAll (p .IdentityDBSQLDataSourceDir (uniqueName ), 0775 )).ToNot (gomega . HaveOccurred (), "failed to create [%s]" , p .IdentityDBSQLDataSourceDir (uniqueName ))
127
127
128
128
persistence := node .Options .GetPersistence ("token" )
129
129
if persistence == nil {
@@ -144,11 +144,11 @@ func (p *NetworkHandler) GenerateExtension(tms *topology2.TMS, node *sfcnode.Nod
144
144
"Endorser" : func () bool { return topology2 .ToOptions (node .Options ).Endorser () },
145
145
"OnlyUnity" : func () bool { return common2 .IsOnlyUnity (tms ) },
146
146
}).Parse (Extension )
147
- Expect (err ).NotTo (HaveOccurred ())
147
+ gomega . Expect (err ).NotTo (gomega . HaveOccurred ())
148
148
149
149
ext := bytes .NewBufferString ("" )
150
150
err = t .Execute (io .MultiWriter (ext ), p )
151
- Expect (err ).NotTo (HaveOccurred ())
151
+ gomega . Expect (err ).NotTo (gomega . HaveOccurred ())
152
152
153
153
return ext .String ()
154
154
}
@@ -168,7 +168,7 @@ func (p *NetworkHandler) PostRun(load bool, tms *topology2.TMS) {
168
168
// Start the CA, if available
169
169
entry := p .GetEntry (tms )
170
170
if entry .CA != nil {
171
- Expect (entry .CA .Start ()).ToNot (HaveOccurred (), "failed to start CA for [%s]" , tms .ID ())
171
+ gomega . Expect (entry .CA .Start ()).ToNot (gomega . HaveOccurred (), "failed to start CA for [%s]" , tms .ID ())
172
172
}
173
173
}
174
174
}
@@ -187,7 +187,7 @@ func (p *NetworkHandler) UpdatePublicParams(tms *topology2.TMS, ppRaw []byte) {
187
187
188
188
func (p * NetworkHandler ) GenIssuerCryptoMaterial (tms * topology2.TMS , nodeID string , walletID string ) string {
189
189
cmGenerator := p .CryptoMaterialGenerators [tms .Driver ]
190
- Expect (cmGenerator ).NotTo (BeNil (), "Crypto material generator for driver %s not found" , tms .Driver )
190
+ gomega . Expect (cmGenerator ).NotTo (gomega . BeNil (), "Crypto material generator for driver %s not found" , tms .Driver )
191
191
192
192
fscTopology := p .TokenPlatform .GetContext ().TopologyByName (fsc .TopologyName ).(* fsc.Topology )
193
193
for _ , node := range fscTopology .Nodes {
@@ -196,7 +196,7 @@ func (p *NetworkHandler) GenIssuerCryptoMaterial(tms *topology2.TMS, nodeID stri
196
196
return ids [0 ].Path
197
197
}
198
198
}
199
- Expect (false ).To (BeTrue (), "cannot find FSC node [%s:%s]" , tms .Network , nodeID )
199
+ gomega . Expect (false ).To (gomega . BeTrue (), "cannot find FSC node [%s:%s]" , tms .Network , nodeID )
200
200
return ""
201
201
}
202
202
@@ -209,14 +209,14 @@ func (p *NetworkHandler) GenOwnerCryptoMaterial(tms *topology2.TMS, nodeID strin
209
209
// return the path where the credential is stored
210
210
logger .Infof ("generate owner crypto material using ca" )
211
211
ic , err := ca .Gen (walletID )
212
- Expect (err ).ToNot (HaveOccurred (), "failed to generate owner crypto material using ca [%s]" , tms .ID ())
212
+ gomega . Expect (err ).ToNot (gomega . HaveOccurred (), "failed to generate owner crypto material using ca [%s]" , tms .ID ())
213
213
return ic
214
214
}
215
215
// continue without the ca
216
216
}
217
217
218
218
cmGenerator := p .CryptoMaterialGenerators [tms .Driver ]
219
- Expect (cmGenerator ).NotTo (BeNil (), "Crypto material generator for driver %s not found" , tms .Driver )
219
+ gomega . Expect (cmGenerator ).NotTo (gomega . BeNil (), "Crypto material generator for driver %s not found" , tms .Driver )
220
220
221
221
fscTopology := p .TokenPlatform .GetContext ().TopologyByName (fsc .TopologyName ).(* fsc.Topology )
222
222
for _ , node := range fscTopology .Nodes {
@@ -228,7 +228,7 @@ func (p *NetworkHandler) GenOwnerCryptoMaterial(tms *topology2.TMS, nodeID strin
228
228
return
229
229
}
230
230
}
231
- Expect (false ).To (BeTrue (), "cannot find FSC node [%s:%s]" , tms .Network , nodeID )
231
+ gomega . Expect (false ).To (gomega . BeTrue (), "cannot find FSC node [%s:%s]" , tms .Network , nodeID )
232
232
return
233
233
}
234
234
0 commit comments