-
Notifications
You must be signed in to change notification settings - Fork 4
/
manager.go
45 lines (36 loc) · 1.44 KB
/
manager.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
/*
Copyright IBM Corp. All Rights Reserved.
SPDX-License-Identifier: Apache-2.0
*/
package manager
import (
"github.com/hyperledger/fabric/msp/mgmt"
"github.com/hyperledger/fabric/token/identity"
"github.com/hyperledger/fabric/token/tms/plain"
"github.com/hyperledger/fabric/token/transaction"
"github.com/pkg/errors"
)
//go:generate counterfeiter -o mock/identity_deserializer_manager.go -fake-name DeserializerManager . DeserializerManager
// FabricIdentityDeserializerManager implements an DeserializerManager
// by routing the call to the msp/mgmt package
type FabricIdentityDeserializerManager struct {
}
func (*FabricIdentityDeserializerManager) Deserializer(channel string) (identity.Deserializer, error) {
id, ok := mgmt.GetDeserializers()[channel]
if !ok {
return nil, errors.New("channel not found")
}
return id, nil
}
// Manager is used to access TMS components.
type Manager struct {
IdentityDeserializerManager identity.DeserializerManager
}
// GetTxProcessor returns a TMSTxProcessor that is used to process token transactions.
func (m *Manager) GetTxProcessor(channel string) (transaction.TMSTxProcessor, error) {
identityDeserializerManager, err := m.IdentityDeserializerManager.Deserializer(channel)
if err != nil {
return nil, errors.Wrapf(err, "failed getting identity deserialiser manager for channel '%s'", channel)
}
return &plain.Verifier{IssuingValidator: &AllIssuingValidator{Deserializer: identityDeserializerManager}}, nil
}