build policy manager

Signed-off-by: May.Buzaglo <May.Buzaglo@ibm.com>

Author: MayRosenbaum

common/policy/policy.go

@@ -0,0 +1,68 @@
+/*
+Copyright IBM Corp. All Rights Reserved.
+
+SPDX-License-Identifier: Apache-2.0
+*/
+
+package policy
+
+import (
+	"github.com/hyperledger/fabric-lib-go/bccsp"
+	cb "github.com/hyperledger/fabric-protos-go-apiv2/common"
+	"github.com/hyperledger/fabric-x-common/common/channelconfig"
+	"github.com/hyperledger/fabric-x-common/common/configtx"
+	"github.com/hyperledger/fabric-x-common/common/policies"
+	"github.com/hyperledger/fabric-x-common/protoutil"
+	"github.com/pkg/errors"
+)
+
+// BuildPolicyManagerFromBlock builds a new policy manager from block.
+func BuildPolicyManagerFromBlock(configTX *cb.Envelope, bccsp bccsp.BCCSP) (policies.Manager, error) {
+	payload, err := protoutil.UnmarshalPayload(configTX.Payload)
+	if err != nil {
+		return nil, errors.WithMessage(err, "error unmarshaling envelope to payload")
+	}
+
+	if payload.Header == nil {
+		return nil, errors.New("missing channel header")
+	}
+
+	chdr, err := protoutil.UnmarshalChannelHeader(payload.Header.ChannelHeader)
+	if err != nil {
+		return nil, errors.WithMessage(err, "error unmarshalling channel header")
+	}
+
+	configEnvelope, err := configtx.UnmarshalConfigEnvelope(payload.Data)
+	if err != nil {
+		return nil, errors.WithMessage(err, "error umarshaling config envelope from payload data")
+	}
+
+	bundle, err := channelconfig.NewBundle(chdr.ChannelId, configEnvelope.Config, bccsp)
+	if err != nil {
+		return nil, errors.WithMessage(err, "error creating channelconfig bundle")
+	}
+
+	err = checkResources(bundle)
+	if err != nil {
+		return nil, errors.WithMessagef(err, "error checking bundle for channel: %s", chdr.ChannelId)
+	}
+
+	policyManager := bundle.PolicyManager()
+	return policyManager, nil
+}
+
+// checkResources makes sure that the channel config is compatible with this binary and logs sanity checks
+func checkResources(res channelconfig.Resources) error {
+	channelconfig.LogSanityChecks(res)
+	oc, ok := res.OrdererConfig()
+	if !ok {
+		return errors.New("config does not contain orderer config")
+	}
+	if err := oc.Capabilities().Supported(); err != nil {
+		return errors.WithMessagef(err, "config requires unsupported orderer capabilities: %s", err)
+	}
+	if err := res.ChannelConfig().Capabilities().Supported(); err != nil {
+		return errors.WithMessagef(err, "config requires unsupported channel capabilities: %s", err)
+	}
+	return nil
+}

common/policy/policy_test.go

@@ -0,0 +1,51 @@
+/*
+Copyright IBM Corp. All Rights Reserved.
+
+SPDX-License-Identifier: Apache-2.0
+*/
+
+package policy
+
+import (
+	"testing"
+
+	"github.com/hyperledger/fabric-lib-go/bccsp/factory"
+	"github.com/hyperledger/fabric-x-common/common/policies"
+	"github.com/hyperledger/fabric-x-common/protoutil"
+	"github.com/hyperledger/fabric-x-orderer/config/generate"
+	"github.com/hyperledger/fabric-x-orderer/testutil"
+	"github.com/hyperledger/fabric-x-orderer/testutil/fabric"
+	"github.com/stretchr/testify/require"
+)
+
+func TestBuildPolicyManagerFromBlock(t *testing.T) {
+	dir := t.TempDir()
+
+	sharedConfigYaml, sharedConfigPath := testutil.PrepareSharedConfigBinary(t, dir)
+
+	block, err := generate.CreateGenesisBlock(dir, sharedConfigYaml, sharedConfigPath, fabric.GetDevConfigDir())
+	require.NoError(t, err)
+	require.NotNil(t, block)
+
+	require.True(t, block.Data != nil)
+	require.NotEqual(t, len(block.Data.Data), 0)
+
+	env, err := protoutil.GetEnvelopeFromBlock(block.Data.Data[0])
+	require.NoError(t, err)
+	require.NotNil(t, env)
+
+	policyManager, err := BuildPolicyManagerFromBlock(env, factory.GetDefault())
+	require.NotNil(t, policyManager)
+
+	policy, exists := policyManager.GetPolicy(policies.ChannelWriters)
+	require.True(t, exists)
+	require.NotNil(t, policy)
+
+	policy, exists = policyManager.GetPolicy(policies.ChannelReaders)
+	require.True(t, exists)
+	require.NotNil(t, policy)
+
+	policy, exists = policyManager.GetPolicy(policies.ChannelOrdererAdmins)
+	require.True(t, exists)
+	require.NotNil(t, policy)
+}