fabtoken_test.go

/*
Copyright IBM Corp All Rights Reserved.

SPDX-License-Identifier: Apache-2.0
*/

package fabtoken

import (
	"math"

	"github.com/hyperledger-labs/fabric-smart-client/integration"
	"github.com/hyperledger-labs/fabric-smart-client/integration/nwo/fsc"
	"github.com/hyperledger-labs/fabric-smart-client/pkg/api"
	integration2 "github.com/hyperledger-labs/fabric-token-sdk/integration"
	token2 "github.com/hyperledger-labs/fabric-token-sdk/integration/token"
	"github.com/hyperledger-labs/fabric-token-sdk/integration/token/common"
	"github.com/hyperledger-labs/fabric-token-sdk/integration/token/common/sdk/ffabtoken"
	"github.com/hyperledger-labs/fabric-token-sdk/integration/token/fungible"
	"github.com/hyperledger-labs/fabric-token-sdk/integration/token/fungible/topology"
	fabtokenv1 "github.com/hyperledger-labs/fabric-token-sdk/token/core/fabtoken/v1/core"
	"github.com/hyperledger-labs/fabric-token-sdk/token/driver"
	. "github.com/onsi/ginkgo/v2"
	. "github.com/onsi/gomega"
)

var _ = Describe("EndToEnd", func() {
	for _, t := range integration2.AllTestTypes {
		Describe("Fungible", t.Label, func() {
			ts, selector := newTestSuite(t.CommType, t.ReplicationFactor, "alice", "bob", "charlie")
			BeforeEach(ts.Setup)
			AfterEach(ts.TearDown)
			It("succeeded", Label("T1"), func() { fungible.TestAll(ts.II, "auditor", nil, true, false, selector) })
			It("Update public params", Label("T2"), func() { UpdatePublicParams(ts.II, selector) })
			It("Test Identity Revocation", Label("T3"), func() { fungible.TestRevokeIdentity(ts.II, "auditor", selector) })
			It("Test Remote Wallet (GRPC)", Label("T4"), func() { fungible.TestRemoteOwnerWallet(ts.II, "auditor", selector, false) })
			It("Test Remote Wallet (WebSocket)", Label("T5"), func() { fungible.TestRemoteOwnerWallet(ts.II, "auditor", selector, true) })
			It("Test redeem flow", Label("T6"), func() { fungible.TestRedeem(ts.II, selector, "default") })
		})
	}
})

func UpdatePublicParams(network *integration.Infrastructure, selector *token2.ReplicaSelector) {
	tms := fungible.GetTMSByNetworkName(network, "default")
	auditorId := fungible.GetAuditorIdentity(tms, "newAuditor")
	issuerId := fungible.GetIssuerIdentity(tms, "newIssuer")
	publicParam := fabtokenv1.PublicParams{
		Label:             "fabtoken",
		QuantityPrecision: uint64(64),
		Auditor:           auditorId,
		IssuerIDs:         []driver.Identity{issuerId},
		MaxToken:          math.MaxUint64,
	}
	ppBytes, err := publicParam.Serialize()
	Expect(err).NotTo(HaveOccurred())

	fungible.TestPublicParamsUpdate(network, "newAuditor", ppBytes, "default", false, selector)
}

func newTestSuite(commType fsc.P2PCommunicationType, factor int, names ...string) (*token2.TestSuite, *token2.ReplicaSelector) {
	opts, selector := token2.NewReplicationOptions(factor, names...)
	ts := token2.NewTestSuite(StartPortDlog, topology.Topology(
		common.Opts{
			Backend:         "fabric",
			CommType:        commType,
			DefaultTMSOpts:  common.TMSOpts{TokenSDKDriver: "fabtoken", Aries: true},
			SDKs:            []api.SDK{&ffabtoken.SDK{}},
			ReplicationOpts: opts,
			WebEnabled:      true, // Needed for the Remote Wallet with websockets
			// FSCLogSpec:      "token-sdk=debug:fabric-sdk=debug:info",
			OnlyUnity: true,
		},
	))
	return ts, selector
}