asset transfer

.github/workflows/tests.yml

@@ -109,12 +109,14 @@ jobs:
           interop-fabtoken-t4,
           interop-fabtoken-t5,
           interop-fabtoken-t6,
+          interop-fabtoken-t7,
           interop-dlog-t1,
           interop-dlog-t2,
           interop-dlog-t3,
           interop-dlog-t4,
           interop-dlog-t5,
           interop-dlog-t6,
+          interop-dlog-t7,
           dlogstress-t1,
         ]
 

Makefile

@@ -3,6 +3,7 @@ FABRIC_VERSION ?= 2.5.0
 FABRIC_CA_VERSION ?= 1.5.7
 FABRIC_TWO_DIGIT_VERSION = $(shell echo $(FABRIC_VERSION) | cut -d '.' -f 1,2)
 ORION_VERSION=v0.2.10
+WEAVER_VERSION=1.2.1
 
 # need to install fabric binaries outside of fts tree for now (due to chaincode packaging issues)
 FABRIC_BINARY_BASE=$(PWD)/../fabric
@@ -48,7 +49,7 @@ install-softhsm:
 	./ci/scripts/install_softhsm.sh
 
 .PHONY: docker-images
-docker-images: fabric-docker-images orion-server-images monitoring-docker-images testing-docker-images
+docker-images: fabric-docker-images orion-server-images monitoring-docker-images testing-docker-images  weaver-docker-images
 
 .PHONY: testing-docker-images
 testing-docker-images:
@@ -76,6 +77,12 @@ orion-server-images:
 	docker pull orionbcdb/orion-server:$(ORION_VERSION)
 	docker image tag orionbcdb/orion-server:$(ORION_VERSION) orionbcdb/orion-server:latest
 
+.PHONY: weaver-docker-images
+weaver-docker-images:
+	docker pull ghcr.io/hyperledger-labs/weaver-fabric-driver:$(WEAVER_VERSION)
+	docker image tag ghcr.io/hyperledger-labs/weaver-fabric-driver:$(WEAVER_VERSION) hyperledger-labs/weaver-fabric-driver:latest
+	docker pull ghcr.io/hyperledger-labs/weaver-relay-server:$(WEAVER_VERSION)
+	docker image tag ghcr.io/hyperledger-labs/weaver-relay-server:$(WEAVER_VERSION) hyperledger-labs/weaver-relay-server:latest
 
 .PHONY: integration-tests-nft-dlog
 integration-tests-nft-dlog:

go.mod

@@ -134,6 +134,8 @@ require (
 	github.com/hashicorp/golang-lru/v2 v2.0.7 // indirect
 	github.com/hashicorp/hcl v1.0.0 // indirect
 	github.com/huin/goupnp v1.3.0 // indirect
+	github.com/hyperledger-labs/weaver-dlt-interoperability/common/protos-go v1.2.3-alpha.1 // indirect
+	github.com/hyperledger-labs/weaver-dlt-interoperability/sdks/fabric/go-sdk v1.2.3-alpha.1.0.20210812140206-37f430515b8c // indirect
 	github.com/hyperledger/fabric-amcl v0.0.0-20230602173724-9e02669dceb2 // indirect
 	github.com/hyperledger/fabric-private-chaincode v1.0.0-rc3.0.20231026135044-67a19b0fcda0 // indirect
 	github.com/inconshreveable/mousetrap v1.1.0 // indirect

integration/nwo/token/topology.go

@@ -7,9 +7,7 @@ SPDX-License-Identifier: Apache-2.0
 package token
 
 import (
-	"github.com/hyperledger-labs/fabric-smart-client/integration/nwo/fsc"
 	"github.com/hyperledger-labs/fabric-smart-client/integration/nwo/fsc/node"
-	"github.com/hyperledger-labs/fabric-smart-client/pkg/api"
 	"github.com/hyperledger-labs/fabric-token-sdk/integration/nwo/token/topology"
 	"github.com/hyperledger-labs/fabric-token-sdk/token/services/ttx"
 	. "github.com/onsi/gomega"
@@ -84,12 +82,6 @@ func (t *Topology) AddTMS(fscNodes []*node.Node, backend BackedTopology, channel
 	return tms
 }
 
-func (t *Topology) SetSDK(fscTopology *fsc.Topology, sdk api.SDK) {
-	for _, node := range fscTopology.Nodes {
-		node.AddSDK(sdk)
-	}
-}
-
 func (t *Topology) GetTMSs() []*topology.TMS {
 	return t.TMSs
 }

integration/ports.go

@@ -97,6 +97,8 @@ const (
 	ZKATDLogInteropHTLCSwapNoCrossTwoFabricNetworks
 	ZKATDLogInteropHTLCOrion
 	ZKATDLogInteropHTLCSwapNoCrossWithOrionAndFabricNetworks
+	FabTokenInteropAssetTransfer
+	ZKATDLogInteropAssetTransfer
 
 	Mixed
 )

integration/token/common/sdk/fall/sdk.go

@@ -7,13 +7,22 @@ SPDX-License-Identifier: Apache-2.0
 package fall
 
 import (
+	"context"
 	"errors"
 
 	"github.com/hyperledger-labs/fabric-smart-client/pkg/node"
 	dig2 "github.com/hyperledger-labs/fabric-smart-client/platform/common/sdk/dig"
+	digutils "github.com/hyperledger-labs/fabric-smart-client/platform/common/utils/dig"
+	"github.com/hyperledger-labs/fabric-smart-client/platform/fabric/services/weaver"
 	fabtoken "github.com/hyperledger-labs/fabric-token-sdk/token/core/fabtoken/driver"
+	fabric3 "github.com/hyperledger-labs/fabric-token-sdk/token/core/fabtoken/driver/interop/state/fabric"
 	dlog "github.com/hyperledger-labs/fabric-token-sdk/token/core/zkatdlog/nogh/driver"
+	fabric4 "github.com/hyperledger-labs/fabric-token-sdk/token/core/zkatdlog/nogh/driver/interop/state/fabric"
 	tokensdk "github.com/hyperledger-labs/fabric-token-sdk/token/sdk/dig"
+	"github.com/hyperledger-labs/fabric-token-sdk/token/services/interop/pledge"
+	"github.com/hyperledger-labs/fabric-token-sdk/token/services/interop/state"
+	"github.com/hyperledger-labs/fabric-token-sdk/token/services/interop/state/driver"
+	fabric2 "github.com/hyperledger-labs/fabric-token-sdk/token/services/interop/state/fabric"
 	"github.com/hyperledger-labs/fabric-token-sdk/token/services/network/fabric"
 	"go.uber.org/dig"
 )
@@ -40,5 +49,58 @@ func (p *SDK) Install() error {
 		return err
 	}
 
-	return p.SDK.Install()
+	fabricEnabled := p.ConfigService().GetBool("fabric.enabled")
+	if fabricEnabled {
+		err := errors.Join(
+			// weaver
+			p.Container().Provide(weaver.NewProvider, dig.As(new(fabric2.RelayProvider))),
+			// state provider
+			p.Container().Provide(state.NewServiceProvider),
+			p.Container().Provide(fabric3.NewStateDriver, dig.Group("fabric-ssp-state-drivers")),
+			p.Container().Provide(fabric4.NewStateDriver, dig.Group("fabric-ssp-state-drivers")),
+			p.Container().Provide(fabric2.NewSSPDriver, dig.Group("ssp-drivers")),
+			p.Container().Provide(pledge.NewVaultStore),
+		)
+		if err != nil {
+			return err
+		}
+	}
+
+	if err := p.SDK.Install(); err != nil {
+		return err
+	}
+
+	if fabricEnabled {
+		return errors.Join(
+			digutils.Register[fabric2.RelayProvider](p.Container()),
+			digutils.Register[*pledge.VaultStore](p.Container()),
+			digutils.Register[*state.ServiceProvider](p.Container()),
+		)
+	}
+
+	return nil
+}
+
+func (p *SDK) Start(ctx context.Context) error {
+	if err := p.SDK.Start(ctx); err != nil {
+		return err
+	}
+
+	fabricEnabled := p.ConfigService().GetBool("fabric.enabled")
+	if fabricEnabled {
+		return errors.Join(
+			p.Container().Invoke(registerInteropStateDrivers),
+		)
+	}
+	return nil
+}
+
+func registerInteropStateDrivers(in struct {
+	dig.In
+	StateServiceProvider *state.ServiceProvider
+	Drivers              []driver.NamedSSPDriver `group:"ssp-drivers"`
+}) {
+	for _, d := range in.Drivers {
+		in.StateServiceProvider.RegisterDriver(d)
+	}
 }

integration/token/fungible/mixed/mixed_test.go

@@ -18,7 +18,7 @@ import (
 )
 
 var _ = Describe("EndToEnd", func() {
-	for _, t := range integration.AllTestTypes {
+	for _, t := range integration.WebSocketNoReplicationOnly {
 		Describe("Fungible with Auditor ne Issuer", t.Label, func() {
 			ts, selector := newTestSuite(t.CommType, t.ReplicationFactor, "alice", "bob")
 			BeforeEach(ts.Setup)

integration/token/interop/dlog/dlog_test.go

@@ -13,6 +13,7 @@ import (
 	"github.com/hyperledger-labs/fabric-token-sdk/integration/nwo/token"
 	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/fall"
 	"github.com/hyperledger-labs/fabric-token-sdk/integration/token/common/sdk/fdlog"
 	"github.com/hyperledger-labs/fabric-token-sdk/integration/token/common/sdk/fodlog"
 	"github.com/hyperledger-labs/fabric-token-sdk/integration/token/common/sdk/odlog"
@@ -60,6 +61,15 @@ var _ = Describe("DLog end to end", func() {
 			It("Performed an htlc based atomic swap", Label("T6"), func() { interop.TestHTLCNoCrossClaimTwoNetworks(ts.II, selector) })
 		})
 	}
+
+	for _, t := range integration2.WebSocketWithReplicationOnly {
+		Describe("Asset Transfer With Two Fabric Networks", t.Label, func() {
+			ts, selector := newTestSuiteInteropAssetTransfer(t.CommType, t.ReplicationFactor, "alice", "bob")
+			AfterEach(ts.TearDown)
+			BeforeEach(ts.Setup)
+			It("Performed a cross network asset transfer", Label("T7"), func() { interop.TestAssetTransferWithTwoNetworks(ts.II, selector) })
+		})
+	}
 })
 
 func newTestSuiteSingleFabric(commType fsc.P2PCommunicationType, factor int, names ...string) (*token2.TestSuite, *token2.ReplicaSelector) {
@@ -118,3 +128,15 @@ func newTestSuiteNoCrossClaimOrion(commType fsc.P2PCommunicationType, factor int
 	}))
 	return ts, selector
 }
+
+func newTestSuiteInteropAssetTransfer(commType fsc.P2PCommunicationType, factor int, names ...string) (*token2.TestSuite, *token2.ReplicaSelector) {
+	opts, selector := token2.NewReplicationOptions(factor, names...)
+	ts := token2.NewTestSuite(opts.SQLConfigs, integration2.ZKATDLogInteropAssetTransfer.StartPortForNode, interop.AssetTransferTopology(common.Opts{
+		CommType:        commType,
+		ReplicationOpts: opts,
+		TokenSDKDriver:  "dlog",
+		SDKs:            []api2.SDK{&fall.SDK{}},
+		// FSCLogSpec:      "token-sdk=debug:fabric-sdk=debug:view-sdk=debug:info",
+	}))
+	return ts, selector
+}

integration/token/interop/fabtoken/fabtoken_test.go

@@ -13,6 +13,7 @@ import (
 	"github.com/hyperledger-labs/fabric-token-sdk/integration/nwo/token"
 	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/fall"
 	"github.com/hyperledger-labs/fabric-token-sdk/integration/token/common/sdk/ffabtoken"
 	"github.com/hyperledger-labs/fabric-token-sdk/integration/token/common/sdk/fofabtoken"
 	"github.com/hyperledger-labs/fabric-token-sdk/integration/token/common/sdk/ofabtoken"
@@ -60,6 +61,15 @@ var _ = Describe("FabToken end to end", func() {
 			It("Performed an htlc based atomic swap", Label("T6"), func() { interop.TestHTLCNoCrossClaimTwoNetworks(ts.II, selector) })
 		})
 	}
+
+	for _, t := range integration2.WebSocketWithReplicationOnly {
+		Describe("Asset Transfer With Two Fabric Networks", t.Label, func() {
+			ts, selector := newTestSuiteInteropAssetTransfer(t.CommType, t.ReplicationFactor, "alice", "bob")
+			AfterEach(ts.TearDown)
+			BeforeEach(ts.Setup)
+			It("Performed a cross network asset transfer", Label("T7"), func() { interop.TestAssetTransferWithTwoNetworks(ts.II, selector) })
+		})
+	}
 })
 
 func newTestSuiteSingleFabric(commType fsc.P2PCommunicationType, factor int, names ...string) (*token2.TestSuite, *token2.ReplicaSelector) {
@@ -116,3 +126,15 @@ func newTestSuiteNoCrossClaimOrion(commType fsc.P2PCommunicationType, factor int
 	}))
 	return ts, selector
 }
+
+func newTestSuiteInteropAssetTransfer(commType fsc.P2PCommunicationType, factor int, names ...string) (*token2.TestSuite, *token2.ReplicaSelector) {
+	opts, selector := token2.NewReplicationOptions(factor, names...)
+	ts := token2.NewTestSuite(opts.SQLConfigs, integration2.FabTokenInteropAssetTransfer.StartPortForNode, interop.AssetTransferTopology(common.Opts{
+		CommType:        commType,
+		ReplicationOpts: opts,
+		TokenSDKDriver:  "fabtoken",
+		SDKs:            []api2.SDK{&fall.SDK{}},
+		// FSCLogSpec:      "token-sdk=debug:fabric-sdk=debug:view-sdk=debug:info",
+	}))
+	return ts, selector
+}