@@ -207,7 +207,10 @@ type mockStakeDeregistrationCert struct {
207
207
208
208
func (m * mockStakeDeregistrationCert ) Cbor () []byte { return m .cborData }
209
209
210
- func mockStakeCredentialValue (credType uint , hashBytes []byte ) common.Credential {
210
+ func mockStakeCredentialValue (
211
+ credType uint ,
212
+ hashBytes []byte ,
213
+ ) common.Credential {
211
214
var credHash common.CredentialHash
212
215
copy (credHash [:], hashBytes )
213
216
return common.Credential {
@@ -216,7 +219,10 @@ func mockStakeCredentialValue(credType uint, hashBytes []byte) common.Credential
216
219
}
217
220
}
218
221
219
- func mockStakeCredentialPtr (credType uint , hashBytes []byte ) * common.Credential {
222
+ func mockStakeCredentialPtr (
223
+ credType uint ,
224
+ hashBytes []byte ,
225
+ ) * common.Credential {
220
226
cred := mockStakeCredentialValue (credType , hashBytes )
221
227
return & cred
222
228
}
@@ -329,7 +335,9 @@ func TestFilterByPolicyId(t *testing.T) {
329
335
policyId := policyIdHash // Use the same hash as the filter
330
336
331
337
// Create a new MultiAsset with pre-populated data
332
- assetsData := make (map [common.Blake2b224 ]map [cbor.ByteString ]common.MultiAssetTypeOutput )
338
+ assetsData := make (
339
+ map [common.Blake2b224 ]map [cbor.ByteString ]common.MultiAssetTypeOutput ,
340
+ )
333
341
assetName := cbor .NewByteString ([]byte ("asset1" ))
334
342
assetsData [policyId ] = map [cbor.ByteString ]common.MultiAssetTypeOutput {
335
343
assetName : 1 , // Add asset with quantity 1
@@ -360,7 +368,12 @@ func TestFilterByPolicyId(t *testing.T) {
360
368
// Wait for the event to be processed
361
369
select {
362
370
case filteredEvt := <- cs .OutputChan ():
363
- assert .Equal (t , evt , filteredEvt , "Filtered event should match the input event" )
371
+ assert .Equal (
372
+ t ,
373
+ evt ,
374
+ filteredEvt ,
375
+ "Filtered event should match the input event" ,
376
+ )
364
377
case <- time .After (5 * time .Second ):
365
378
t .Fatal ("Test timed out waiting for filtered event" )
366
379
}
@@ -375,7 +388,9 @@ func TestFilterByAssetFingerprint(t *testing.T) {
375
388
policyId := common .Blake2b224Hash ([]byte ("policy1" ))
376
389
377
390
// Create a new MultiAsset with pre-populated data
378
- assetsData := make (map [common.Blake2b224 ]map [cbor.ByteString ]common.MultiAssetTypeOutput )
391
+ assetsData := make (
392
+ map [common.Blake2b224 ]map [cbor.ByteString ]common.MultiAssetTypeOutput ,
393
+ )
379
394
assetName := cbor .NewByteString ([]byte ("asset1" ))
380
395
assetsData [policyId ] = map [cbor.ByteString ]common.MultiAssetTypeOutput {
381
396
assetName : 1 , // Add asset with quantity 1
@@ -406,7 +421,12 @@ func TestFilterByAssetFingerprint(t *testing.T) {
406
421
// Wait for the event to be processed
407
422
select {
408
423
case filteredEvt := <- cs .OutputChan ():
409
- assert .Equal (t , evt , filteredEvt , "Filtered event should match the input event" )
424
+ assert .Equal (
425
+ t ,
426
+ evt ,
427
+ filteredEvt ,
428
+ "Filtered event should match the input event" ,
429
+ )
410
430
case <- time .After (5 * time .Second ):
411
431
t .Fatal ("Test timed out waiting for filtered event" )
412
432
}
@@ -434,7 +454,12 @@ func TestFilterByPoolId(t *testing.T) {
434
454
// Wait for the event to be processed
435
455
select {
436
456
case filteredEvt := <- cs .OutputChan ():
437
- assert .Equal (t , evt , filteredEvt , "Filtered event should match the input event" )
457
+ assert .Equal (
458
+ t ,
459
+ evt ,
460
+ filteredEvt ,
461
+ "Filtered event should match the input event" ,
462
+ )
438
463
case <- time .After (5 * time .Second ):
439
464
t .Fatal ("Test timed out waiting for filtered event" )
440
465
}
0 commit comments