waku-org/go-waku

Function FilterUnsubscribe has 7 return statements (exceeds 4 allowed).

Open

func FilterUnsubscribe(instance *WakuInstance, filterJSON string, peerID string, ms int) error {
    cf, err := toContentFilter(filterJSON)
    if err != nil {
        return err
    }

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

Open

    sub := SimulateSubscription([]*protocol.Envelope{
        protocol.NewEnvelope(msg1, *utils.GetUnixEpoch(), pubsubTopic1),
        protocol.NewEnvelope(msg2, *utils.GetUnixEpoch(), pubsubTopic1),
        protocol.NewEnvelope(msg3, *utils.GetUnixEpoch(), pubsubTopic1),
        protocol.NewEnvelope(msg4, *utils.GetUnixEpoch(), pubsubTopic1),

• Read up
  Read up

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

Open

    sub := SimulateSubscription([]*protocol.Envelope{
        protocol.NewEnvelope(msg1, *utils.GetUnixEpoch(), pubsubTopic1),
        protocol.NewEnvelope(msg2, *utils.GetUnixEpoch(), pubsubTopic1),
        protocol.NewEnvelope(msg3, *utils.GetUnixEpoch(), pubsubTopic1),
        protocol.NewEnvelope(msg4, *utils.GetUnixEpoch(), pubsubTopic1),

• Read up
  Read up

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

Open

                result, err = m.storeQueryWithRetry(interest.ctx, func(ctx context.Context) (common.StoreRequestResult, error) {
                    if err = result.Next(ctx); err != nil {
                        return nil, err
                    }
                    return result, nil

• Read up
  Read up

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

Open

        result, err = m.storeQueryWithRetry(interest.ctx, func(ctx context.Context) (common.StoreRequestResult, error) {
            if err = result.Next(ctx); err != nil {
                return nil, err
            }
            return result, nil

• Read up
  Read up

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

Open

            if ip4 == nil && ip6 != nil && !ip6.IsUnspecified() {
                localnode.Set(enr.IPv6(ip6))
                localnode.Set(enr.TCP6(ipAddr.Port))
            } else {
                localnode.Delete(enr.IPv6{})

• Read up
  Read up

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

Open

        if ip4 == nil && ip6 != nil && !ip6.IsUnspecified() {
            localnode.Set(enr.IPv6(ip6))
            localnode.Set(enr.TCP6(ipAddr.Port))
        } else {
            localnode.Delete(enr.IPv6{})

• Read up
  Read up

Method DynamicGroupManager.loadCredential has 6 return statements (exceeds 4 allowed).

Open

func (gm *DynamicGroupManager) loadCredential(ctx context.Context) error {
    if gm.appKeystore == nil {
        gm.log.Warn("no credentials were loaded. Node will only validate messages, but wont be able to generate proofs and attach them to messages")
        return nil
    }

Function Execute has 6 return statements (exceeds 4 allowed).

Open

func Execute() error {

    var cTopic, err = protocol.NewContentTopic("basic-relay", "1", "test", "proto")
    if err != nil {
        fmt.Println("Invalid contentTopic")

Function main has 6 return statements (exceeds 4 allowed).

Open

func main() {
    // Removing noisy logs
    lvl, err := logging.LevelFromString("error")
    if err != nil {
        panic(err)

Method AppKeystore.AddMembershipCredentials has 6 return statements (exceeds 4 allowed).

Open

func (k *AppKeystore) AddMembershipCredentials(newCredential MembershipCredentials, password string) error {
    credentials, err := k.GetMembershipCredentials(password, &newCredential.TreeIndex, newCredential.MembershipContractInfo)
    if err != nil {
        return err
    }

Method DynamicGroupManager.Start has 6 return statements (exceeds 4 allowed).

Open

func (gm *DynamicGroupManager) Start(ctx context.Context) error {
    if gm.cancel != nil {
        return errors.New("already started")
    }

Function Execute has 6 return statements (exceeds 4 allowed).

Open

func Execute() error {

    var cTopic, err = protocol.NewContentTopic("basic-light-client", "1", "test", "proto")
    if err != nil {
        return errors.New("invalid contentTopic")

Function generateSecureRandomData has 6 return statements (exceeds 4 allowed).

Open

func generateSecureRandomData(length int) ([]byte, error) {
    x := make([]byte, length)
    y := make([]byte, length)
    res := make([]byte, length)

Method WakuLightPush.request has 6 return statements (exceeds 4 allowed).

Open

func (wakuLP *WakuLightPush) request(ctx context.Context, req *pb.PushRequest, params *lightPushRequestParameters, peerID peer.ID) (*pb.PushResponse, error) {

    logger := wakuLP.log.With(logging.HostID("peer", peerID))

    stream, err := wakuLP.h.NewStream(ctx, peerID, LightPushID_v20beta1)

Function SetBootnodes has 6 return statements (exceeds 4 allowed).

Open

func SetBootnodes(instance *WakuInstance, bootnodes string) error {
    if err := validateInstance(instance, MustBeStarted); err != nil {
        return err
    }

Function validateAndParse has 6 return statements (exceeds 4 allowed).

Open

func validateAndParse(input []byte) (*DecodedPayload, error) {
    end := len(input)
    if end < 1 {
        return nil, errors.New("invalid message length")
    }

Function DecodeSymmetric has 6 return statements (exceeds 4 allowed).

Open

func DecodeSymmetric(messageJSON string, symmetricKey string) (string, error) {
    var msg pb.WakuMessage
    err := json.Unmarshal([]byte(messageJSON), &msg)
    if err != nil {
        return "", err

Function execute has 6 return statements (exceeds 4 allowed).

Open

func execute(ctx context.Context) error {
    rlnInstance, err := rln.NewRLN()
    if err != nil {
        return err
    }

Method WakuMetadata.Connected has 6 return statements (exceeds 4 allowed).

Open

func (wakuM *WakuMetadata) Connected(n network.Network, cc network.Conn) {
    go func() {
        defer utils.LogOnPanic()
        wakuM.log.Debug("peer connected", zap.Stringer("peer", cc.RemotePeer()))
        // Metadata verification is done only if a clusterID is specified