status-im/status-go

Peer has 42 methods (exceeds 21 allowed). Consider refactoring.

Open

type Peer struct {
    host    common.WakuHost
    rw      p2p.MsgReadWriter
    p2pPeer *p2p.Peer
    logger  *zap.Logger

Identical blocks of code found in 2 locations. Consider refactoring.

Open

func (p *Peer) handlePacket(packet p2p.Msg) error {
    switch packet.Code {
    case messagesCode:
        if err := p.handleMessagesCode(packet); err != nil {
            p.logger.Warn("failed to handle messagesCode message, peer will be disconnected", zap.String("peerID", types.EncodeHex(p.ID())), zap.Error(err))

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

func (p *Peer) broadcast() error {
    envelopes := p.host.Envelopes()
    bundle := make([]*common.Envelope, 0, len(envelopes))
    for _, envelope := range envelopes {
        if !p.Marked(envelope) && envelope.PoW() >= p.powRequirement && p.topicOrBloomMatch(envelope) {

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

func (p *Peer) handleP2PRequestCode(packet p2p.Msg) error {
    // Must be processed if mail server is implemented. Otherwise ignore.
    if !p.host.Mailserver() {
        return nil
    }

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

func (p *Peer) handleMessagesCode(packet p2p.Msg) error {
    // decode the contained envelopes
    data, err := ioutil.ReadAll(packet.Payload)
    if err != nil {
        common.EnvelopesRejectedCounter.WithLabelValues("failed_read").Inc()

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

func (p *Peer) handleMessageResponseCode(packet p2p.Msg) error {
    var resp MultiVersionResponse
    if err := packet.Decode(&resp); err != nil {
        common.EnvelopesRejectedCounter.WithLabelValues("failed_read").Inc()
        return fmt.Errorf("invalid response message: %v", err)

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

func (p *Peer) update() {
    // Start the tickers for the updates
    expire := time.NewTicker(common.ExpirationCycle)
    transmit := time.NewTicker(common.TransmissionCycle)

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

func NewPeer(host common.WakuHost, p2pPeer *p2p.Peer, rw p2p.MsgReadWriter, logger *zap.Logger, stats *common.StatsTracker) common.Peer {
    if logger == nil {
        logger = zap.NewNop()
    }

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

func (p *Peer) expire() {
    unmark := make(map[gethcommon.Hash]struct{})
    p.known.Each(func(v interface{}) bool {
        if !p.host.IsEnvelopeCached(v.(gethcommon.Hash)) {
            unmark[v.(gethcommon.Hash)] = struct{}{}

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

func (p *Peer) setTopicInterest(topicInterest []common.TopicType) {
    p.topicInterestMu.Lock()
    defer p.topicInterestMu.Unlock()
    if topicInterest == nil {
        p.topicInterest = nil

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

func (p *Peer) handleStatusUpdateCode(packet p2p.Msg) error {
    var StatusOptions StatusOptions
    err := packet.Decode(&StatusOptions)
    if err != nil {
        p.logger.Error("failed to decode status-options", zap.Error(err))

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

func (p *Peer) handleP2PMessageCode(packet p2p.Msg) error {
    // peer-to-peer message, sent directly to peer bypassing PoW checks, etc.
    // this message is not supposed to be forwarded to other peers, and
    // therefore might not satisfy the PoW, expiry and other requirements.
    // these messages are only accepted from the trusted peer.

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

func (p *Peer) setBloomFilter(bloom []byte) {
    p.bloomMu.Lock()
    defer p.bloomMu.Unlock()
    p.bloomFilter = bloom
    p.fullNode = common.IsFullNode(bloom)

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

func (p *Peer) handleP2PRequestCompleteCode(packet p2p.Msg) error {
    if !p.trusted {
        return nil
    }

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

    if peerOptions.TopicInterest != nil {
        p.setTopicInterest(peerOptions.TopicInterest)
    } else if peerOptions.BloomFilter != nil {
        // Validate and save peer's bloom filters.
        bloom := peerOptions.BloomFilter

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

func (p *Peer) topicOrBloomMatch(env *common.Envelope) bool {
    p.topicInterestMu.Lock()
    topicInterestMode := p.topicInterest != nil
    p.topicInterestMu.Unlock()

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

func (p *Peer) handleBatchAcknowledgeCode(packet p2p.Msg) error {
    var batchHash gethcommon.Hash
    if err := packet.Decode(&batchHash); err != nil {
        return fmt.Errorf("invalid batch ack message: %v", err)
    }

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

func (p *Peer) Start() error {
    if err := p.handshake(); err != nil {
        return err
    }
    go p.update()

• Read up
  Read up