Add Fabric option for a global (channel-wide) batch pin listener

cmd/init_fabric.go

@@ -73,5 +73,6 @@ func init() {
 	initFabricCmd.Flags().StringArrayVar(&initOptions.MSPPaths, "msp", nil, "Path to the MSP directory for an org in your Fabric network")
 	initFabricCmd.Flags().StringVar(&initOptions.ChannelName, "channel", "", "The name of the Fabric channel on which the FireFly chaincode has been deployed")
 	initFabricCmd.Flags().StringVar(&initOptions.ChaincodeName, "chaincode", "", "The name given to the FireFly chaincode when it was deployed")
+	initFabricCmd.Flags().BoolVar(&initOptions.CustomPinSupport, "custom-pin-support", false, "Configure the blockchain listener to listen for BatchPin events from any chaincode on the channel")
 	initCmd.AddCommand(initFabricCmd)
 }

internal/stacks/stack_manager.go

@@ -111,6 +111,7 @@ func (s *StackManager) InitStack(options *types.InitOptions) (err error) {
 		IPFSMode:          fftypes.FFEnum(options.IPFSMode),
 		ChannelName:       options.ChannelName,
 		ChaincodeName:     options.ChaincodeName,
+		CustomPinSupport:  options.CustomPinSupport,
 	}
 
 	tokenProviders, err := types.FFEnumArray(s.ctx, options.TokenProviders)
@@ -911,6 +912,11 @@ func (s *StackManager) runFirstTimeSetup(options *types.StartOptions) (messages
 			} else {
 				contractLocation = contractDeploymentResult.DeployedContract.Location
 			}
+			options := make(map[string]interface{})
+			if s.Stack.CustomPinSupport {
+				options["customPinSupport"] = true
+			}
+
 			newConfig.Namespaces.Predefined[0].Multiparty = &types.MultipartyConfig{
 				Enabled: true,
 				Org:     orgConfig,
@@ -921,6 +927,7 @@ func (s *StackManager) runFirstTimeSetup(options *types.StartOptions) (messages
 					{
 						Location:   contractLocation,
 						FirstEvent: "0",
+						Options:    options,
 					},
 				},
 			}

pkg/types/namespace.go

@@ -42,6 +42,7 @@ type MultipartyConfig struct {
 type ContractConfig struct {
 	Location   interface{} `yaml:"location"`
 	FirstEvent string      `yaml:"firstEvent,omitempty"`
+	Options    interface{} `yaml:"options"`
 }
 
 type MultipartyOrgConfig struct {

pkg/types/options.go

@@ -62,6 +62,7 @@ type InitOptions struct {
 	MSPPaths                 []string
 	ChannelName              string
 	ChaincodeName            string
+	CustomPinSupport         bool
 }
 
 const IPFSMode = "ipfs_mode"

pkg/types/stack.go

@@ -48,6 +48,7 @@ type Stack struct {
 	RemoteFabricNetwork    bool             `json:"remoteFabricNetwork,omitempty"`
 	ChannelName            string           `json:"channelName,omitempty"`
 	ChaincodeName          string           `json:"chaincodeName,omitempty"`
+	CustomPinSupport       bool             `json:"customPinSupport,omitempty"`
 	InitDir                string           `json:"-"`
 	RuntimeDir             string           `json:"-"`
 	StackDir               string           `json:"-"`