Skip to content

Commit 3d9ff98

Browse files
committed
update also mixed topology
Signed-off-by: Angelo De Caro <adc@zurich.ibm.com>
1 parent 8cde931 commit 3d9ff98

File tree

1 file changed

+33
-100
lines changed

1 file changed

+33
-100
lines changed

integration/token/fungible/mixed/topology.go

Lines changed: 33 additions & 100 deletions
Original file line numberDiff line numberDiff line change
@@ -14,8 +14,9 @@ import (
1414
"github.com/hyperledger-labs/fabric-token-sdk/integration/nwo/token"
1515
fabric2 "github.com/hyperledger-labs/fabric-token-sdk/integration/nwo/token/fabric"
1616
"github.com/hyperledger-labs/fabric-token-sdk/integration/token/common"
17-
views2 "github.com/hyperledger-labs/fabric-token-sdk/integration/token/common/views"
18-
"github.com/hyperledger-labs/fabric-token-sdk/integration/token/fungible/views"
17+
auditor3 "github.com/hyperledger-labs/fabric-token-sdk/integration/token/fungible/sdk/auditor"
18+
issuer3 "github.com/hyperledger-labs/fabric-token-sdk/integration/token/fungible/sdk/issuer"
19+
"github.com/hyperledger-labs/fabric-token-sdk/integration/token/fungible/sdk/party"
1920
)
2021

2122
const (
@@ -38,25 +39,7 @@ func Topology(opts common.Opts) []api.Topology {
3839
fscTopology.P2PCommunicationType = opts.CommType
3940
fscTopology.SetLogging(opts.FSCLogSpec, "")
4041

41-
issuer := fscTopology.NewTemplate("issuer").
42-
RegisterViewFactory("issue", &views.IssueCashViewFactory{}).
43-
RegisterViewFactory("transfer", &views.TransferViewFactory{}).
44-
RegisterViewFactory("transferWithSelector", &views.TransferWithSelectorViewFactory{}).
45-
RegisterViewFactory("redeem", &views.RedeemViewFactory{}).
46-
RegisterViewFactory("balance", &views.BalanceViewFactory{}).
47-
RegisterViewFactory("historyIssuedToken", &views.ListIssuedTokensViewFactory{}).
48-
RegisterViewFactory("issuedTokenQuery", &views.ListIssuedTokensViewFactory{}).
49-
RegisterViewFactory("GetEnrollmentID", &views.GetEnrollmentIDViewFactory{}).
50-
RegisterViewFactory("acceptedTransactionHistory", &views.ListAcceptedTransactionsViewFactory{}).
51-
RegisterViewFactory("transactionInfo", &views.TransactionInfoViewFactory{}).
52-
RegisterViewFactory("CheckPublicParamsMatch", &views.CheckPublicParamsMatchViewFactory{}).
53-
RegisterViewFactory("CheckTTXDB", &views.CheckTTXDBViewFactory{}).
54-
RegisterViewFactory("RegisterIssuerIdentity", &views.RegisterIssuerIdentityViewFactory{}).
55-
RegisterViewFactory("PruneInvalidUnspentTokens", &views.PruneInvalidUnspentTokensViewFactory{}).
56-
RegisterViewFactory("WhoDeletedToken", &views.WhoDeletedTokenViewFactory{}).
57-
RegisterViewFactory("GetPublicParams", &views.GetPublicParamsViewFactory{}).
58-
RegisterViewFactory("TxFinality", &views2.TxFinalityViewFactory{})
59-
42+
issuer := fscTopology.NewTemplate("issuer")
6043
issuer1 := fscTopology.AddNodeFromTemplate("issuer1", issuer).
6144
AddOptions(
6245
fabric.WithOrganization("Org1"),
@@ -72,22 +55,7 @@ func Topology(opts common.Opts) []api.Topology {
7255
).
7356
AddOptions(opts.ReplicationOpts.For("issuer2")...)
7457

75-
auditor := fscTopology.NewTemplate("auditor").
76-
RegisterViewFactory("registerAuditor", &views.RegisterAuditorViewFactory{}).
77-
RegisterViewFactory("historyAuditing", &views.ListAuditedTransactionsViewFactory{}).
78-
RegisterViewFactory("holding", &views.CurrentHoldingViewFactory{}).
79-
RegisterViewFactory("spending", &views.CurrentSpendingViewFactory{}).
80-
RegisterViewFactory("balance", &views.BalanceViewFactory{}).
81-
RegisterViewFactory("CheckPublicParamsMatch", &views.CheckPublicParamsMatchViewFactory{}).
82-
RegisterViewFactory("SetTransactionAuditStatus", &views.SetTransactionAuditStatusViewFactory{}).
83-
RegisterViewFactory("CheckTTXDB", &views.CheckTTXDBViewFactory{}).
84-
RegisterViewFactory("PruneInvalidUnspentTokens", &views.PruneInvalidUnspentTokensViewFactory{}).
85-
RegisterViewFactory("WhoDeletedToken", &views.WhoDeletedTokenViewFactory{}).
86-
RegisterViewFactory("ListVaultUnspentTokens", &views.ListVaultUnspentTokensViewFactory{}).
87-
RegisterViewFactory("CheckIfExistsInVault", &views.CheckIfExistsInVaultViewFactory{}).
88-
RegisterViewFactory("RevokeUser", &views.RevokeUserViewFactory{}).
89-
RegisterViewFactory("TxFinality", &views2.TxFinalityViewFactory{})
90-
58+
auditor := fscTopology.NewTemplate("auditor")
9159
auditor1 := fscTopology.AddNodeFromTemplate("auditor1", auditor).
9260
AddOptions(
9361
fabric.WithOrganization("Org1"),
@@ -103,72 +71,17 @@ func Topology(opts common.Opts) []api.Topology {
10371
).
10472
AddOptions(opts.ReplicationOpts.For("auditor2")...)
10573

106-
alice := fscTopology.AddNodeByName("alice").
107-
AddOptions(
108-
fabric.WithOrganization("Org1"),
109-
fabric.WithAnonymousIdentity(),
110-
token.WithOwnerIdentity("alice"),
111-
).
112-
AddOptions(opts.ReplicationOpts.For("alice")...).
113-
RegisterResponder(&views.AcceptCashView{}, &views.IssueCashView{}).
114-
RegisterResponder(&views.AcceptCashView{}, &views.TransferView{}).
115-
RegisterResponder(&views.AcceptCashView{}, &views.TransferWithSelectorView{}).
116-
RegisterResponder(&views.AcceptPreparedCashView{}, &views.PrepareTransferView{}).
117-
RegisterViewFactory("transfer", &views.TransferViewFactory{}).
118-
RegisterViewFactory("transferWithSelector", &views.TransferWithSelectorViewFactory{}).
119-
RegisterViewFactory("redeem", &views.RedeemViewFactory{}).
120-
RegisterViewFactory("swap", &views.SwapInitiatorViewFactory{}).
121-
RegisterViewFactory("history", &views.ListUnspentTokensViewFactory{}).
122-
RegisterViewFactory("balance", &views.BalanceViewFactory{}).
123-
RegisterViewFactory("GetEnrollmentID", &views.GetEnrollmentIDViewFactory{}).
124-
RegisterViewFactory("acceptedTransactionHistory", &views.ListAcceptedTransactionsViewFactory{}).
125-
RegisterViewFactory("transactionInfo", &views.TransactionInfoViewFactory{}).
126-
RegisterViewFactory("prepareTransfer", &views.PrepareTransferViewFactory{}).
127-
RegisterViewFactory("broadcastPreparedTransfer", &views.BroadcastPreparedTransferViewFactory{}).
128-
RegisterViewFactory("CheckPublicParamsMatch", &views.CheckPublicParamsMatchViewFactory{}).
129-
RegisterViewFactory("CheckTTXDB", &views.CheckTTXDBViewFactory{}).
130-
RegisterViewFactory("SetTransactionOwnerStatus", &views.SetTransactionOwnerStatusViewFactory{}).
131-
RegisterViewFactory("PruneInvalidUnspentTokens", &views.PruneInvalidUnspentTokensViewFactory{}).
132-
RegisterViewFactory("WhoDeletedToken", &views.WhoDeletedTokenViewFactory{}).
133-
RegisterViewFactory("ListVaultUnspentTokens", &views.ListVaultUnspentTokensViewFactory{}).
134-
RegisterViewFactory("TxFinality", &views2.TxFinalityViewFactory{}).
135-
RegisterViewFactory("MaliciousTransfer", &views.MaliciousTransferViewFactory{}).
136-
RegisterViewFactory("TxStatus", &views.TxStatusViewFactory{}).
137-
RegisterViewFactory("SetSpendableFlag", &views.SetSpendableFlagViewFactory{})
74+
alice := fscTopology.AddNodeByName("alice").AddOptions(
75+
fabric.WithOrganization("Org1"),
76+
fabric.WithAnonymousIdentity(),
77+
token.WithOwnerIdentity("alice"),
78+
).AddOptions(opts.ReplicationOpts.For("alice")...)
13879

13980
bob := fscTopology.AddNodeByName("bob").AddOptions(
14081
fabric.WithOrganization("Org2"),
14182
fabric.WithAnonymousIdentity(),
14283
token.WithOwnerIdentity("bob"),
143-
).
144-
AddOptions(opts.ReplicationOpts.For("bob")...).
145-
RegisterResponder(&views.AcceptCashView{}, &views.IssueCashView{}).
146-
RegisterResponder(&views.AcceptCashView{}, &views.TransferView{}).
147-
RegisterResponder(&views.AcceptCashView{}, &views.TransferWithSelectorView{}).
148-
RegisterResponder(&views.AcceptCashView{}, &views.MaliciousTransferView{}).
149-
RegisterResponder(&views.AcceptPreparedCashView{}, &views.PrepareTransferView{}).
150-
RegisterResponder(&views.SwapResponderView{}, &views.SwapInitiatorView{}).
151-
RegisterViewFactory("transfer", &views.TransferViewFactory{}).
152-
RegisterViewFactory("transferWithSelector", &views.TransferWithSelectorViewFactory{}).
153-
RegisterViewFactory("redeem", &views.RedeemViewFactory{}).
154-
RegisterViewFactory("swap", &views.SwapInitiatorViewFactory{}).
155-
RegisterViewFactory("history", &views.ListUnspentTokensViewFactory{}).
156-
RegisterViewFactory("balance", &views.BalanceViewFactory{}).
157-
RegisterViewFactory("GetEnrollmentID", &views.GetEnrollmentIDViewFactory{}).
158-
RegisterViewFactory("acceptedTransactionHistory", &views.ListAcceptedTransactionsViewFactory{}).
159-
RegisterViewFactory("transactionInfo", &views.TransactionInfoViewFactory{}).
160-
RegisterViewFactory("CheckPublicParamsMatch", &views.CheckPublicParamsMatchViewFactory{}).
161-
RegisterViewFactory("prepareTransfer", &views.PrepareTransferViewFactory{}).
162-
RegisterViewFactory("TokenSelectorUnlock", &views.TokenSelectorUnlockViewFactory{}).
163-
RegisterViewFactory("FinalityWithTimeout", &views.FinalityWithTimeoutViewFactory{}).
164-
RegisterViewFactory("CheckTTXDB", &views.CheckTTXDBViewFactory{}).
165-
RegisterViewFactory("SetTransactionOwnerStatus", &views.SetTransactionOwnerStatusViewFactory{}).
166-
RegisterViewFactory("PruneInvalidUnspentTokens", &views.PruneInvalidUnspentTokensViewFactory{}).
167-
RegisterViewFactory("WhoDeletedToken", &views.WhoDeletedTokenViewFactory{}).
168-
RegisterViewFactory("ListVaultUnspentTokens", &views.ListVaultUnspentTokensViewFactory{}).
169-
RegisterViewFactory("GetRevocationHandle", &views.GetRevocationHandleViewFactory{}).
170-
RegisterViewFactory("TxFinality", &views2.TxFinalityViewFactory{}).
171-
RegisterViewFactory("TxStatus", &views.TxStatusViewFactory{})
84+
).AddOptions(opts.ReplicationOpts.For("bob")...)
17285

17386
// Token topology
17487
tokenTopology := token.NewTopology()
@@ -191,8 +104,28 @@ func Topology(opts common.Opts) []api.Topology {
191104
// FSC topology
192105
fscTopology.SetBootstrapNode(fscTopology.AddNodeByName("lib-p2p-bootstrap-node"))
193106

194-
for _, sdk := range opts.SDKs {
195-
fscTopology.AddSDK(sdk)
107+
// set the SDKs
108+
// auditors
109+
for _, node := range fscTopology.ListNodes("auditor1", "auditor2") {
110+
node.AddSDKWithBase(opts.SDKs[0], &auditor3.SDK{})
111+
}
112+
113+
// issuers
114+
for _, node := range fscTopology.ListNodes("issuer1", "issuer2") {
115+
node.AddSDKWithBase(opts.SDKs[0], &issuer3.SDK{})
116+
}
117+
118+
// parties
119+
for _, node := range fscTopology.ListNodes("alice", "bob") {
120+
node.AddSDKWithBase(opts.SDKs[0], &party.SDK{})
121+
}
122+
123+
// additional nodes that are backend specific
124+
fscTopology.ListNodes("lib-p2p-bootstrap-node")[0].AddSDK(opts.SDKs[0])
125+
126+
// add the rest of the SDKs
127+
for i := 1; i < len(opts.SDKs); i++ {
128+
fscTopology.AddSDK(opts.SDKs[i])
196129
}
197130

198131
return []api.Topology{backendNetwork, tokenTopology, fscTopology}

0 commit comments

Comments
 (0)