use view.WithTimeout

adecaro · adecaro · commit 0528814b5edf · 2025-07-27T06:50:13.000+02:00
clean jsession package
FSC b9bece2d0ce57e207809c748f19f431ef0457d62
remove the need to pass a timeout

Signed-off-by: Angelo De Caro &lt;angelo.decaro@gmail.com&gt;
diff --git a/go.mod b/go.mod
@@ -12,7 +12,7 @@ require (
 	github.com/gin-gonic/gin v1.10.0
 	github.com/gobuffalo/packr/v2 v2.7.1
 	github.com/hashicorp/go-uuid v1.0.3
-	github.com/hyperledger-labs/fabric-smart-client v0.5.1-0.20250717111311-f6c3bf731689
+	github.com/hyperledger-labs/fabric-smart-client v0.5.1-0.20250727044521-b9bece2d0ce5
 	github.com/hyperledger/fabric-chaincode-go/v2 v2.3.0
 	github.com/hyperledger/fabric-lib-go v1.1.3-0.20240523144151-25edd1eaf5f5
 	github.com/hyperledger/fabric-protos-go-apiv2 v0.3.7
diff --git a/go.sum b/go.sum
@@ -1057,8 +1057,8 @@ github.com/huin/goupnp v1.3.0 h1:UvLUlWDNpoUdYzb2TCn+MuTWtcjXKSza2n6CBdQ0xXc=
 github.com/huin/goupnp v1.3.0/go.mod h1:gnGPsThkYa7bFi/KWmEysQRf48l2dvR5bxr2OFckNX8=
 github.com/hyperledger-labs/SmartBFT v0.0.0-20250503203013-eb005eef8866 h1:Mu/6NJsfl9g3wM15Ue7hqPq4LtgYDoABh8MO4u8aW4g=
 github.com/hyperledger-labs/SmartBFT v0.0.0-20250503203013-eb005eef8866/go.mod h1:9aNHNXsCVy/leGz2gpTC1eOL5QecxbSAGjqsLh4T1LM=
-github.com/hyperledger-labs/fabric-smart-client v0.5.1-0.20250717111311-f6c3bf731689 h1:yR1Fv/9fVNtHNMfGO/9HDDd0Rx4LTQzUCDZsWwgVwwo=
-github.com/hyperledger-labs/fabric-smart-client v0.5.1-0.20250717111311-f6c3bf731689/go.mod h1:34dRgLomeTQYI7fffCYDTiSQSRo9LBsPuq0aWBU5EOA=
+github.com/hyperledger-labs/fabric-smart-client v0.5.1-0.20250727044521-b9bece2d0ce5 h1:niAHrlKMVqL3QBqOq4g61vQN9eKmqMMFQWM2xlArSMU=
+github.com/hyperledger-labs/fabric-smart-client v0.5.1-0.20250727044521-b9bece2d0ce5/go.mod h1:34dRgLomeTQYI7fffCYDTiSQSRo9LBsPuq0aWBU5EOA=
 github.com/hyperledger/aries-bbs-go v0.0.0-20240528084656-761671ea73bc h1:3Ykk6MtyfnlzMOQry9zkxsoLWpCWZwDPqehO/BJwArM=
 github.com/hyperledger/aries-bbs-go v0.0.0-20240528084656-761671ea73bc/go.mod h1:Kofn6A6WWea1ZM8Rys5aBW9dszwJ7Ywa0kyyYL0TPYw=
 github.com/hyperledger/fabric v1.4.0-rc1.0.20250510200036-435a7f1a780a h1:l9dE3iuE+mKj7K8Tcx904cF8zJpaNQONh3GNZdXnnyc=
diff --git a/integration/token/fungible/views/upgrade.go b/integration/token/fungible/views/upgrade.go
@@ -113,7 +113,7 @@ func (i *TokensUpgradeInitiatorView) Call(context view.Context) (interface{}, er
 			assert.NoError(err, "failed to accept new tokens")
 
 			// Before completing, the recipient waits for finality of the transaction
-			_, err = context.RunView(ttx.NewFinalityView(tx, ttx.WithTimeout(1*time.Minute)))
+			_, err = context.RunView(ttx.NewFinalityView(tx), view.WithTimeout(1*time.Minute))
 			assert.NoError(err, "new tokens were not committed")
 
 			return tx.ID(), nil
diff --git a/token/services/certifier/interactive/service.go b/token/services/certifier/interactive/service.go
@@ -9,12 +9,11 @@ package interactive
 import (
 	"fmt"
 	"sync"
-	"time"
 
 	"github.com/hyperledger-labs/fabric-smart-client/platform/view/services/metrics"
 	"github.com/hyperledger-labs/fabric-smart-client/platform/view/view"
 	token2 "github.com/hyperledger-labs/fabric-token-sdk/token"
-	"github.com/hyperledger-labs/fabric-token-sdk/token/services/utils/json/session"
+	"github.com/hyperledger-labs/fabric-token-sdk/token/services/utils/json/jsession"
 	"github.com/hyperledger-labs/fabric-token-sdk/token/token"
 	"github.com/pkg/errors"
 )
@@ -60,7 +59,7 @@ func (c *CertificationService) SetWallet(tms *token2.ManagementService, wallet s
 func (c *CertificationService) Call(context view.Context) (interface{}, error) {
 	// 1. receive request
 	logger.Debugf("receive certification request [%s]", context.ID())
-	s := session.JSON(context)
+	s := jsession.FromContext(context)
 	var cr *CertificationRequest
 	if err := s.Receive(&cr); err != nil {
 		return nil, errors.WithMessage(err, "failed receiving certification request")
@@ -162,7 +161,7 @@ func (i *CertificationRequestView) Call(context view.Context) (interface{}, erro
 		return nil, errors.Errorf("no certifiers defined")
 	}
 
-	s, err := session.NewJSON(context, i, i.certifier)
+	s, err := jsession.NewJSON(context, i, i.certifier)
 	if err != nil {
 		return nil, errors.WithMessagef(err, "failed opening session to [%s]", i.certifier)
 	}
@@ -178,7 +177,7 @@ func (i *CertificationRequestView) Call(context view.Context) (interface{}, erro
 	// 3. wait response
 	logger.Debugf("wait certification request response for [%v]", i.ids)
 	var certifications [][]byte
-	if err := s.ReceiveWithTimeout(&certifications, 60*time.Second); err != nil {
+	if err := s.Receive(&certifications); err != nil {
 		return nil, errors.WithMessagef(err, "failed receiving certifications [%v] from [%s]", i.ids, i.certifier)
 	}
 
diff --git a/token/services/identity/storage/kvs/hashicorp/go.mod b/token/services/identity/storage/kvs/hashicorp/go.mod
@@ -8,7 +8,7 @@ require (
 	github.com/docker/docker v28.0.2+incompatible
 	github.com/docker/go-connections v0.5.0
 	github.com/hashicorp/vault/api v1.16.0
-	github.com/hyperledger-labs/fabric-smart-client v0.5.1-0.20250717111311-f6c3bf731689
+	github.com/hyperledger-labs/fabric-smart-client v0.5.1-0.20250727044521-b9bece2d0ce5
 	github.com/hyperledger-labs/fabric-token-sdk v0.4.1-0.20250528165839-032fb9265504
 	github.com/pkg/errors v0.9.1
 	github.com/stretchr/testify v1.10.0
diff --git a/token/services/identity/storage/kvs/hashicorp/go.sum b/token/services/identity/storage/kvs/hashicorp/go.sum
@@ -107,8 +107,8 @@ github.com/hashicorp/hcl v1.0.0 h1:0Anlzjpi4vEasTeNFn2mLJgTSwt0+6sfsiTG8qcWGx4=
 github.com/hashicorp/hcl v1.0.0/go.mod h1:E5yfLk+7swimpb2L/Alb/PJmXilQ/rhwaUYs4T20WEQ=
 github.com/hashicorp/vault/api v1.16.0 h1:nbEYGJiAPGzT9U4oWgaaB0g+Rj8E59QuHKyA5LhwQN4=
 github.com/hashicorp/vault/api v1.16.0/go.mod h1:KhuUhzOD8lDSk29AtzNjgAu2kxRA9jL9NAbkFlqvkBA=
-github.com/hyperledger-labs/fabric-smart-client v0.5.1-0.20250717111311-f6c3bf731689 h1:yR1Fv/9fVNtHNMfGO/9HDDd0Rx4LTQzUCDZsWwgVwwo=
-github.com/hyperledger-labs/fabric-smart-client v0.5.1-0.20250717111311-f6c3bf731689/go.mod h1:34dRgLomeTQYI7fffCYDTiSQSRo9LBsPuq0aWBU5EOA=
+github.com/hyperledger-labs/fabric-smart-client v0.5.1-0.20250727044521-b9bece2d0ce5 h1:niAHrlKMVqL3QBqOq4g61vQN9eKmqMMFQWM2xlArSMU=
+github.com/hyperledger-labs/fabric-smart-client v0.5.1-0.20250727044521-b9bece2d0ce5/go.mod h1:34dRgLomeTQYI7fffCYDTiSQSRo9LBsPuq0aWBU5EOA=
 github.com/hyperledger/fabric-amcl v0.0.0-20230602173724-9e02669dceb2 h1:B1Nt8hKb//KvgGRprk0h1t4lCnwhE9/ryb1WqfZbV+M=
 github.com/hyperledger/fabric-amcl v0.0.0-20230602173724-9e02669dceb2/go.mod h1:X+DIyUsaTmalOpmpQfIvFZjKHQedrURQ5t4YqquX7lE=
 github.com/hyperledger/fabric-lib-go v1.1.3-0.20240523144151-25edd1eaf5f5 h1:RPWTL5wxAb+xDOrsCU3QYZP65305F8v3PaOyzdbPVMU=
diff --git a/token/services/interop/htlc/distribute.go b/token/services/interop/htlc/distribute.go
@@ -12,7 +12,7 @@ import (
 
 	"github.com/hyperledger-labs/fabric-smart-client/platform/view/view"
 	"github.com/hyperledger-labs/fabric-token-sdk/token"
-	"github.com/hyperledger-labs/fabric-token-sdk/token/services/utils/json/session"
+	"github.com/hyperledger-labs/fabric-token-sdk/token/services/utils/json/jsession"
 	token2 "github.com/hyperledger-labs/fabric-token-sdk/token/token"
 	"github.com/pkg/errors"
 )
@@ -95,7 +95,7 @@ func ReceiveTerms(context view.Context) (*Terms, error) {
 
 func (v *termsReceiverView) Call(context view.Context) (interface{}, error) {
 	terms := &Terms{}
-	if err := session.JSON(context).Receive(terms); err != nil {
+	if err := jsession.FromContext(context).Receive(terms); err != nil {
 		return nil, errors.Wrapf(err, "failed unmarshalling terms")
 	}
 	return terms, nil
diff --git a/token/services/network/fabric/endorsement/fsc.go b/token/services/network/fabric/endorsement/fsc.go
@@ -111,12 +111,14 @@ func (e *FSCService) Endorse(context view.Context, requestRaw []byte, signer vie
 	}
 	logger.DebugfContext(context.Context(), "request approval via fts endrosers with policy [%s]: [%d]...", e.PolicyType, len(endorsers))
 
-	envBoxed, err := e.ViewManager.InitiateView(&RequestApprovalView{
-		TMSID:      e.TmsID,
-		RequestRaw: requestRaw,
-		TxID:       txID,
-		Endorsers:  endorsers,
-	}, context.Context())
+	envBoxed, err := e.ViewManager.InitiateView(
+		context.Context(),
+		&RequestApprovalView{
+			TMSID:      e.TmsID,
+			RequestRaw: requestRaw,
+			TxID:       txID,
+			Endorsers:  endorsers,
+		})
 	if err != nil {
 		return nil, errors.WithMessagef(err, "failed to request approval")
 	}
diff --git a/token/services/network/fabric/endorsement/provider.go b/token/services/network/fabric/endorsement/provider.go
@@ -33,7 +33,7 @@ type IdentityProvider interface {
 }
 
 type ViewManager interface {
-	InitiateView(view view.View, ctx context.Context) (interface{}, error)
+	InitiateView(ctx context.Context, view view.View) (interface{}, error)
 }
 
 type ViewRegistry interface {
diff --git a/token/services/network/fabric/network.go b/token/services/network/fabric/network.go
@@ -71,7 +71,8 @@ func (l *ledger) Status(id string) (driver.ValidationCode, error) {
 }
 
 type ViewManager interface {
-	InitiateView(view view.View, ctx context.Context) (interface{}, error)
+	Context() context.Context
+	InitiateView(ctx context.Context, view view.View) (interface{}, error)
 }
 
 type ViewRegistry interface {
diff --git a/token/services/network/fabric/ppfetcher.go b/token/services/network/fabric/ppfetcher.go
@@ -7,8 +7,6 @@ SPDX-License-Identifier: Apache-2.0
 package fabric
 
 import (
-	"context"
-
 	driver2 "github.com/hyperledger-labs/fabric-smart-client/platform/common/driver"
 	"github.com/hyperledger-labs/fabric-smart-client/platform/fabric/services/chaincode"
 	"github.com/hyperledger-labs/fabric-smart-client/platform/view/services/view"
@@ -24,11 +22,11 @@ func NewChaincodePublicParamsFetcher(viewManager *view.Manager) *chaincodePublic
 
 func (f *chaincodePublicParamsFetcher) Fetch(network driver2.Network, channel driver2.Channel, namespace driver2.Namespace) ([]byte, error) {
 	ppBoxed, err := f.viewManager.InitiateView(
+		f.viewManager.Context(),
 		chaincode.NewQueryView(
 			namespace,
 			QueryPublicParamsFunction,
 		).WithNetwork(network).WithChannel(channel),
-		context.Background(),
 	)
 	if err != nil {
 		return nil, err
diff --git a/token/services/ttx/accept.go b/token/services/ttx/accept.go
@@ -8,7 +8,6 @@ package ttx
 
 import (
 	"encoding/base64"
-	"time"
 
 	"github.com/hyperledger-labs/fabric-smart-client/platform/common/utils/hash"
 	"github.com/hyperledger-labs/fabric-smart-client/platform/view/services/id"
@@ -17,7 +16,7 @@ import (
 	"github.com/hyperledger-labs/fabric-smart-client/platform/view/view"
 	"github.com/hyperledger-labs/fabric-token-sdk/token"
 	"github.com/hyperledger-labs/fabric-token-sdk/token/services/tokens"
-	session2 "github.com/hyperledger-labs/fabric-token-sdk/token/services/utils/json/session"
+	"github.com/hyperledger-labs/fabric-token-sdk/token/services/utils/json/jsession"
 	"github.com/pkg/errors"
 )
 
@@ -129,8 +128,7 @@ func (s *AcceptView) respondToSignatureRequests(context view.Context) error {
 			}
 		} else {
 			logger.DebugfContext(context.Context(), "Receiving signature request...")
-			jsonSession := session2.JSON(context)
-			err := jsonSession.ReceiveWithTimeout(signatureRequest, time.Minute)
+			err := jsession.FromContext(context).Receive(signatureRequest)
 			if err != nil {
 				return errors.Wrap(err, "failed reading signature request")
 			}
diff --git a/token/services/ttx/auditor.go b/token/services/ttx/auditor.go
@@ -9,7 +9,6 @@ package ttx
 import (
 	"context"
 	"encoding/base64"
-	"time"
 
 	"github.com/hyperledger-labs/fabric-smart-client/platform/common/utils/hash"
 	"github.com/hyperledger-labs/fabric-smart-client/platform/view/services/id"
@@ -22,7 +21,7 @@ import (
 	"github.com/hyperledger-labs/fabric-token-sdk/token/services/db/driver"
 	"github.com/hyperledger-labs/fabric-token-sdk/token/services/tokens"
 	"github.com/hyperledger-labs/fabric-token-sdk/token/services/ttxdb"
-	session2 "github.com/hyperledger-labs/fabric-token-sdk/token/services/utils/json/session"
+	"github.com/hyperledger-labs/fabric-token-sdk/token/services/utils/json/jsession"
 	view3 "github.com/hyperledger-labs/fabric-token-sdk/token/services/utils/view"
 	"github.com/pkg/errors"
 )
@@ -147,8 +146,8 @@ func (a *AuditingViewInitiator) Call(context view.Context) (interface{}, error)
 	// Receive signature
 	logger.DebugfContext(context.Context(), "Receiving signature for [%s]", a.tx.ID())
 
-	jsonSession := session2.NewFromSession(context, session)
-	signature, err := jsonSession.ReceiveRawWithTimeout(time.Minute)
+	jsonSession := jsession.NewFromSession(context, session)
+	signature, err := jsonSession.ReceiveRaw()
 	if err != nil {
 		logger.ErrorfContext(context.Context(), "failed to read audit event: %s", err)
 		return nil, errors.WithMessage(err, "failed to read audit event")
@@ -178,7 +177,7 @@ func (a *AuditingViewInitiator) startRemote(context view.Context) (view.Session,
 	if err != nil {
 		return nil, err
 	}
-	err = session.SendWithContext(context.Context(), txRaw)
+	err = session.Send(txRaw)
 	if err != nil {
 		return nil, errors.Wrap(err, "failed sending transaction")
 	}
diff --git a/token/services/ttx/collect.go b/token/services/ttx/collect.go
@@ -10,7 +10,7 @@ import (
 	"github.com/hyperledger-labs/fabric-smart-client/platform/view/services/endpoint"
 	"github.com/hyperledger-labs/fabric-smart-client/platform/view/view"
 	"github.com/hyperledger-labs/fabric-token-sdk/token"
-	session2 "github.com/hyperledger-labs/fabric-token-sdk/token/services/utils/json/session"
+	"github.com/hyperledger-labs/fabric-token-sdk/token/services/utils/json/jsession"
 	token2 "github.com/hyperledger-labs/fabric-token-sdk/token/token"
 	"github.com/pkg/errors"
 )
@@ -92,7 +92,7 @@ func (c *collectActionsView) collectRemote(context view.Context, actionTransfer
 	party := actionTransfer.From
 	logger.DebugfContext(context.Context(), "collect remote from [%s]", party)
 
-	session, err := session2.NewJSON(context, context.Initiator(), party)
+	session, err := jsession.NewJSON(context, context.Initiator(), party)
 	if err != nil {
 		return errors.Wrap(err, "failed getting session")
 	}
@@ -177,7 +177,7 @@ func (r *receiveActionsView) Call(context view.Context) (interface{}, error) {
 	}
 
 	// actions
-	s := session2.JSON(context)
+	s := jsession.FromContext(context)
 	actions := &Actions{}
 	if err := s.Receive(actions); err != nil {
 		return nil, errors.Wrap(err, "failed receiving actions")
diff --git a/token/services/ttx/endorse.go b/token/services/ttx/endorse.go
@@ -11,7 +11,6 @@ import (
 	"encoding/base64"
 	errors2 "errors"
 	"runtime/debug"
-	"time"
 
 	"github.com/hyperledger-labs/fabric-smart-client/platform/common/utils/collections"
 	"github.com/hyperledger-labs/fabric-smart-client/platform/common/utils/hash"
@@ -25,8 +24,9 @@ import (
 	"github.com/hyperledger-labs/fabric-token-sdk/token/services/logging"
 	"github.com/hyperledger-labs/fabric-token-sdk/token/services/network"
 	"github.com/hyperledger-labs/fabric-token-sdk/token/services/tokens"
-	session2 "github.com/hyperledger-labs/fabric-token-sdk/token/services/utils/json/session"
+	"github.com/hyperledger-labs/fabric-token-sdk/token/services/utils/json/jsession"
 	"github.com/pkg/errors"
+	"go.opentelemetry.io/otel/trace"
 )
 
 type distributionListEntry struct {
@@ -300,13 +300,13 @@ func (c *CollectEndorsementsView) signRemote(context view.Context, party view.Id
 	if err != nil {
 		return nil, err
 	}
-	err = session.SendWithContext(context.Context(), signatureRequestRaw)
+	err = session.Send(signatureRequestRaw)
 	if err != nil {
 		return nil, errors.Wrap(err, "failed sending transaction content")
 	}
 
-	jsonSession := session2.NewFromSession(context, session)
-	sigma, err := jsonSession.ReceiveRawWithTimeout(time.Minute)
+	jsonSession := jsession.NewFromSession(context, session)
+	sigma, err := jsonSession.ReceiveRaw()
 	if err != nil {
 		return nil, errors.Wrap(err, "failed reading message")
 	}
@@ -471,14 +471,14 @@ func (c *CollectEndorsementsView) distributeEvnToParty(context view.Context, ent
 	}
 	// Send the content
 	logger.DebugfContext(context.Context(), "Send transaction content")
-	err = session.SendWithContext(context.Context(), txRaw)
+	err = session.Send(txRaw)
 	if err != nil {
 		return errors.Wrap(err, "failed sending transaction content")
 	}
 
 	logger.DebugfContext(context.Context(), "Wait for ack")
-	jsonSession := session2.NewFromSession(context, session)
-	sigma, err := jsonSession.ReceiveRawWithTimeout(time.Minute)
+	jsonSession := jsession.NewFromSession(context, session)
+	sigma, err := jsonSession.ReceiveRaw()
 	if err != nil {
 		return errors.Wrapf(err, "failed reading message on session [%s]", session.Info().ID)
 	}
@@ -656,8 +656,11 @@ func NewReceiveTransactionView() *ReceiveTransactionView {
 }
 
 func (f *ReceiveTransactionView) Call(context view.Context) (interface{}, error) {
-	jsonSession := session2.JSON(context)
-	msg, err := jsonSession.ReceiveRawWithTimeout(time.Minute * 4)
+	span := trace.SpanFromContext(context.Context())
+	span.AddEvent("start_receive_transaction_view")
+	defer span.AddEvent("end_receive_transaction_view")
+	session := jsession.FromContext(context)
+	msg, err := session.ReceiveRaw()
 	if err != nil {
 		logger.ErrorfContext(context.Context(), err.Error())
 	}
@@ -760,8 +763,8 @@ func (s *EndorseView) Call(context view.Context) (interface{}, error) {
 			}
 		} else {
 			logger.DebugfContext(context.Context(), "Receiving signature request...")
-			jsonSession := session2.JSON(context)
-			srRaw, err = jsonSession.ReceiveRawWithTimeout(time.Minute)
+			jsonSession := jsession.FromContext(context)
+			srRaw, err = jsonSession.ReceiveRaw()
 			if err != nil {
 				return nil, errors.Wrap(err, "failed reading signature request")
 			}
@@ -785,7 +788,7 @@ func (s *EndorseView) Call(context view.Context) (interface{}, error) {
 			return nil, errors.Wrapf(err, "failed signing request")
 		}
 		logger.DebugfContext(context.Context(), "Send back signature [%s][%s]", signatureRequest.Signer, hash.Hashable(sigma))
-		err = session.SendWithContext(context.Context(), sigma)
+		err = session.Send(sigma)
 		if err != nil {
 			return nil, errors.Wrapf(err, "failed sending signature back")
 		}
@@ -822,7 +825,7 @@ func (s *EndorseView) Call(context view.Context) (interface{}, error) {
 		return nil, errors.WithMessage(err, "failed to sign ack response")
 	}
 	logger.DebugfContext(context.Context(), "ack response: [%s] from [%s]", hash.Hashable(sigma), defaultIdentity)
-	if err := session.SendWithContext(context.Context(), sigma); err != nil {
+	if err := session.Send(sigma); err != nil {
 		return nil, errors.WithMessage(err, "failed sending ack")
 	}
 
diff --git a/token/services/ttx/multisig/spend.go b/token/services/ttx/multisig/spend.go
diff --git a/token/services/ttx/recipients.go b/token/services/ttx/recipients.go
diff --git a/token/services/ttx/upgrade.go b/token/services/ttx/upgrade.go
diff --git a/token/services/ttx/withdrawal.go b/token/services/ttx/withdrawal.go
diff --git a/token/services/utils/json/jsession/session.go b/token/services/utils/json/jsession/session.go
diff --git a/token/services/utils/json/session/json.go b/token/services/utils/json/session/json.go

Original file line number	Diff line number	Diff line change
`@@ -33,7 +33,7 @@ type IdentityProvider interface {`
`33`	`33`	`}`
`34`	`34`
`35`	`35`	`type ViewManager interface {`
`36`		`- InitiateView(view view.View, ctx context.Context) (interface{}, error)`
	`36`	`+ InitiateView(ctx context.Context, view view.View) (interface{}, error)`
`37`	`37`	`}`
`38`	`38`
`39`	`39`	`type ViewRegistry interface {`
Original file line number	Diff line number	Diff line change
`@@ -71,7 +71,8 @@ func (l *ledger) Status(id string) (driver.ValidationCode, error) {`
`71`	`71`	`}`
`72`	`72`
`73`	`73`	`type ViewManager interface {`
`74`		`- InitiateView(view view.View, ctx context.Context) (interface{}, error)`
	`74`	`+ Context() context.Context`
	`75`	`+ InitiateView(ctx context.Context, view view.View) (interface{}, error)`
`75`	`76`	`}`
`76`	`77`
`77`	`78`	`type ViewRegistry interface {`