cranberry

1
package gossip
2

3
import (
4
	gossip "gitverse.ru/IvanTimofeev/cranberry/internal/gossip"
5
	pbapi "gitverse.ru/IvanTimofeev/cranberry/pkg/grpc"
6
)
7

8
func (s *GossipServiceHandler) SendBlock(stream pbapi.GossipService_SendBlockServer) error {
9
	//инициализируем создание пира
10
	peerClient, err := gossip.NewPeerClient(stream)
11
	if err != nil {
12
		return err
13
	}
14
	s.peerService.AddPeer(peerClient)
15
	// стартуем пир
16
	return peerClient.Start()
17
}
18