Remove anchor peers from CLI

This change set removes the anchor peers from the CLI.
and makes gossip take the organization IDs from
the configuration groups of the genesis block.

After this change set, the only way to get anchor peers
to the peer is using the configtx tool

Change-Id: I220a8a6e315fe77bc2d29c63e3d9cb2be9937247
Signed-off-by: Yacov Manevich <yacovm@il.ibm.com>

Author: yacovm

common/configvalues/channel/application/organization_test.go

@@ -70,8 +70,8 @@ func TestApplicationOrgRollback(t *testing.T) {
 
 func TestApplicationOrgAnchorPeers(t *testing.T) {
 	endVal := []*pb.AnchorPeer{
-		&pb.AnchorPeer{Host: "foo", Port: 234, Cert: []byte("foocert")},
-		&pb.AnchorPeer{Host: "bar", Port: 237, Cert: []byte("barcert")},
+		&pb.AnchorPeer{Host: "foo", Port: 234},
+		&pb.AnchorPeer{Host: "bar", Port: 237},
 	}
 	invalidMessage := makeInvalidConfigValue()
 	validMessage := TemplateAnchorPeers("id", endVal)

docs/channel-setup.md

@@ -42,16 +42,7 @@ CORE_PEER_COMMITTER_LEDGER_ORDERER=orderer:5005 peer channel create -c myc1
 ```
 
 This will create a channel genesis block file `myc1.block` to issue join commands with.
-If you want to specify anchor peers, you can create anchor peer files in the following format:
-peer-hostname
-port
-PEM file of peer certificate
 
-See CORE_PEER_COMMITTER_LEDGER_ORDERER=orderer:5005 peer channel create -h for an anchor-peer file example
-And pass the anchor peer files as a comma-separated argument with flag -a: in example:
-```
-CORE_PEER_COMMITTER_LEDGER_ORDERER=orderer:5005 peer channel create -c myc1 -a anchorPeer1.txt,anchorPeer2.txt
-```
 
 ### Join a channel
 Execute the join command to peer0 in the CLI container.

gossip/api/channel.go

@@ -52,9 +52,10 @@ type JoinChannelMessage interface {
 
 // AnchorPeer is an anchor peer's certificate and endpoint (host:port)
 type AnchorPeer struct {
-	Cert PeerIdentityType // Cert defines the certificate of the remote peer
-	Host string           // Host is the hostname/ip address of the remote peer
-	Port int              // Port is the port the remote peer is listening on
+	Host  string          // Host is the hostname/ip address of the remote peer
+	Port  int             // Port is the port the remote peer is listening on
+	OrgID OrgIdentityType // OrgID is the identity of the organization the anchor peer came from
+
 }
 
 // OrgIdentityType defines the identity of an organization

gossip/discovery/discovery_impl.go

@@ -131,11 +131,6 @@ func (d *gossipDiscoveryImpl) Connect(member NetworkMember) {
 	d.logger.Debug("Entering", member)
 	defer d.logger.Debug("Exiting")
 
-	if member.PKIid == nil {
-		d.logger.Warning("Empty PkiID, aborting")
-		return
-	}
-
 	d.lock.Lock()
 	defer d.lock.Unlock()
 

gossip/discovery/discovery_test.go

@@ -274,8 +274,6 @@ func TestConnect(t *testing.T) {
 		endpoint := fmt.Sprintf("localhost:%d", 7611+j)
 		netMember2Connect2 := NetworkMember{Endpoint: endpoint, PKIid: []byte(endpoint)}
 		inst.Connect(netMember2Connect2)
-		// Check passing nil PKI-ID doesn't crash peer
-		inst.Connect(NetworkMember{PKIid: nil, Endpoint: endpoint})
 	}
 
 	fullMembership := func() bool {

gossip/gossip/channel/channel.go

@@ -339,11 +339,7 @@ func (gc *gossipChannel) ConfigureChannel(joinMsg api.JoinChannelMessage) {
 	orgs := []api.OrgIdentityType{}
 	existingOrgInJoinChanMsg := make(map[string]struct{})
 	for _, anchorPeer := range joinMsg.AnchorPeers() {
-		orgID := gc.OrgByPeerIdentity(anchorPeer.Cert)
-		if orgID == nil {
-			gc.logger.Warning("Cannot extract org identity from certificate, aborting.")
-			return
-		}
+		orgID := anchorPeer.OrgID
 		if _, exists := existingOrgInJoinChanMsg[string(orgID)]; !exists {
 			orgs = append(orgs, orgID)
 			existingOrgInJoinChanMsg[string(orgID)] = struct{}{}

gossip/gossip/channel/channel_test.go

@@ -55,12 +55,11 @@ func init() {
 var (
 	// Organizations: {ORG1, ORG2}
 	// Channel A: {ORG1}
-	channelA           = common.ChainID("A")
-	orgInChannelA      = api.OrgIdentityType("ORG1")
-	orgNotInChannelA   = api.OrgIdentityType("ORG2")
-	anchorPeerIdentity = api.PeerIdentityType("identityInOrg1")
-	pkiIDInOrg1        = common.PKIidType("pkiIDInOrg1")
-	pkiIDinOrg2        = common.PKIidType("pkiIDinOrg2")
+	channelA         = common.ChainID("A")
+	orgInChannelA    = api.OrgIdentityType("ORG1")
+	orgNotInChannelA = api.OrgIdentityType("ORG2")
+	pkiIDInOrg1      = common.PKIidType("pkiIDInOrg1")
+	pkiIDinOrg2      = common.PKIidType("pkiIDinOrg2")
 )
 
 type joinChanMsg struct {
@@ -83,7 +82,7 @@ func (jcm *joinChanMsg) AnchorPeers() []api.AnchorPeer {
 	if jcm.anchorPeers != nil {
 		return jcm.anchorPeers()
 	}
-	return []api.AnchorPeer{{Cert: anchorPeerIdentity}}
+	return []api.AnchorPeer{{OrgID: orgInChannelA}}
 }
 
 type cryptoService struct {
@@ -200,7 +199,6 @@ func (ga *gossipAdapterMock) GetOrgOfPeer(PKIIID common.PKIidType) api.OrgIdenti
 func configureAdapter(adapter *gossipAdapterMock, members ...discovery.NetworkMember) {
 	adapter.On("GetConf").Return(conf)
 	adapter.On("GetMembership").Return(members)
-	adapter.On("OrgByPeerIdentity", anchorPeerIdentity).Return(orgInChannelA)
 	adapter.On("GetOrgOfPeer", pkiIDInOrg1).Return(orgInChannelA)
 	adapter.On("GetOrgOfPeer", pkiIDinOrg2).Return(orgNotInChannelA)
 	adapter.On("GetOrgOfPeer", mock.Anything).Return(api.OrgIdentityType(nil))
@@ -704,7 +702,7 @@ func TestChannelReconfigureChannel(t *testing.T) {
 
 	outdatedJoinChanMsg := &joinChanMsg{
 		anchorPeers: func() []api.AnchorPeer {
-			return []api.AnchorPeer{{Cert: api.PeerIdentityType(orgNotInChannelA)}}
+			return []api.AnchorPeer{{OrgID: orgNotInChannelA}}
 		},
 		getTS: func() time.Time {
 			return time.Now()
@@ -713,7 +711,7 @@ func TestChannelReconfigureChannel(t *testing.T) {
 
 	newJoinChanMsg := &joinChanMsg{
 		anchorPeers: func() []api.AnchorPeer {
-			return []api.AnchorPeer{{Cert: api.PeerIdentityType(orgInChannelA)}}
+			return []api.AnchorPeer{{OrgID: orgInChannelA}}
 		},
 		getTS: func() time.Time {
 			return time.Now().Add(time.Millisecond * 100)
@@ -722,7 +720,7 @@ func TestChannelReconfigureChannel(t *testing.T) {
 
 	updatedJoinChanMsg := &joinChanMsg{
 		anchorPeers: func() []api.AnchorPeer {
-			return []api.AnchorPeer{{Cert: api.PeerIdentityType(orgNotInChannelA)}}
+			return []api.AnchorPeer{{OrgID: orgNotInChannelA}}
 		},
 		getTS: func() time.Time {
 			return time.Now().Add(time.Millisecond * 200)

gossip/gossip/gossip_impl.go

@@ -184,7 +184,6 @@ func (g *gossipServiceImpl) JoinChan(joinMsg api.JoinChannelMessage, chainID com
 	// joinMsg is supposed to have been already verified
 	g.chanState.joinChannel(joinMsg, chainID)
 
-	selfPkiID := g.mcs.GetPKIidOfCert(g.selfIdentity)
 	for _, ap := range joinMsg.AnchorPeers() {
 		if ap.Host == "" {
 			g.logger.Warning("Got empty hostname, skipping connecting to anchor peer", ap)
@@ -194,15 +193,15 @@ func (g *gossipServiceImpl) JoinChan(joinMsg api.JoinChannelMessage, chainID com
 			g.logger.Warning("Got invalid port (0), skipping connecting to anchor peer", ap)
 			continue
 		}
-		pkiID := g.mcs.GetPKIidOfCert(ap.Cert)
+		endpoint := fmt.Sprintf("%s:%d", ap.Host, ap.Port)
 		// Skip connecting to self
-		if bytes.Equal([]byte(pkiID), []byte(selfPkiID)) {
-			g.logger.Info("Anchor peer with same PKI-ID, skipping connecting to myself")
+		if g.selfNetworkMember().Endpoint == endpoint || g.selfNetworkMember().InternalEndpoint.Endpoint == endpoint {
+			g.logger.Info("Anchor peer with same endpoint, skipping connecting to myself")
 			continue
 		}
-		endpoint := fmt.Sprintf("%s:%d", ap.Host, ap.Port)
+
 		g.disc.Connect(discovery.NetworkMember{
-			InternalEndpoint: &proto.SignedEndpoint{Endpoint: endpoint}, PKIid: pkiID})
+			InternalEndpoint: &proto.SignedEndpoint{Endpoint: endpoint}})
 	}
 }
 

gossip/gossip/gossip_test.go

@@ -53,7 +53,6 @@ func init() {
 }
 
 var orgInChannelA = api.OrgIdentityType("ORG1")
-var anchorPeerIdentity = api.PeerIdentityType("identityInOrg1")
 
 func acceptData(m interface{}) bool {
 	if dataMsg := m.(*proto.GossipMessage).GetDataMsg(); dataMsg != nil {
@@ -82,7 +81,7 @@ func (*joinChanMsg) SequenceNumber() uint64 {
 // AnchorPeers returns all the anchor peers that are in the channel
 func (jcm *joinChanMsg) AnchorPeers() []api.AnchorPeer {
 	if len(jcm.anchorPeers) == 0 {
-		return []api.AnchorPeer{{Cert: anchorPeerIdentity}}
+		return []api.AnchorPeer{{OrgID: orgInChannelA}}
 	}
 	return jcm.anchorPeers
 }
@@ -317,11 +316,10 @@ func TestConnectToAnchorPeers(t *testing.T) {
 
 	jcm := &joinChanMsg{anchorPeers: []api.AnchorPeer{}}
 	for i := 0; i < n; i++ {
-		pkiID := fmt.Sprintf("localhost:%d", portPrefix+i)
 		ap := api.AnchorPeer{
-			Port: portPrefix + i,
-			Host: "localhost",
-			Cert: []byte(pkiID),
+			Port:  portPrefix + i,
+			Host:  "localhost",
+			OrgID: orgInChannelA,
 		}
 		jcm.anchorPeers = append(jcm.anchorPeers, ap)
 	}

gossip/service/gossip_service.go

@@ -177,12 +177,12 @@ func (g *gossipServiceImpl) InitializeChannel(chainID string, committer committe
 // configUpdated constructs a joinChannelMessage and sends it to the gossipSvc
 func (g *gossipServiceImpl) configUpdated(config Config) {
 	jcm := &joinChannelMessage{seqNum: config.Sequence(), anchorPeers: []api.AnchorPeer{}}
-	for _, org := range config.Organizations() {
-		for _, ap := range org.AnchorPeers() {
+	for orgID, appOrg := range config.Organizations() {
+		for _, ap := range appOrg.AnchorPeers() {
 			anchorPeer := api.AnchorPeer{
-				Host: ap.Host,
-				Port: int(ap.Port),
-				Cert: api.PeerIdentityType(ap.Cert),
+				Host:  ap.Host,
+				Port:  int(ap.Port),
+				OrgID: api.OrgIdentityType(orgID),
 			}
 			jcm.anchorPeers = append(jcm.anchorPeers, anchorPeer)
 		}