Showing 299 of 400 total issues
Function execute
has 6 return statements (exceeds 4 allowed). Open
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
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
Method PeerManager.DiscoverAndConnectToPeers
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func (pm *PeerManager) DiscoverAndConnectToPeers(ctx context.Context, cluster uint16,
shard uint16, serviceProtocol protocol.ID, maxCount int) error {
Method PeerManager.addPeer
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func (pm *PeerManager) addPeer(ID peer.ID, addrs []ma.Multiaddr, origin wps.Origin, pubSubTopics []string, protocols ...protocol.ID) error {
Function createHostWithDiscv5AndPM
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func createHostWithDiscv5AndPM(t *testing.T, hostName string, topic string, enrField uint8, bootnode ...*enode.Node) (host.Host, *PeerManager, *discv5.DiscoveryV5) {
Method PeerManager.discoverOnDemand
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func (pm *PeerManager) discoverOnDemand(cluster uint16,
shard uint16, wakuProtocol protocol.ID, ctx context.Context, maxCount int) ([]service.PeerData, error) {
Function WaitForTimeout
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func WaitForTimeout(t *testing.T, ctx context.Context, timeout time.Duration, wg *sync.WaitGroup, ch chan *protocol.Envelope) {
Function NewMissingMessageVerifier
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func NewMissingMessageVerifier(storenodeRequester common.StorenodeRequestor, messageTracker MessageTracker, timesource timesource.Timesource, logger *zap.Logger, options ...MissingMessageVerifierOption) *MissingMessageVerifier {
Method defaultStorenodeMessageVerifier.MessageHashesExist
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func (d *defaultStorenodeMessageVerifier) MessageHashesExist(ctx context.Context, requestID []byte, peerID peer.ID, pageSize uint64, messageHashes []pb.MessageHash) ([]pb.MessageHash, error) {
Method MissingMessageVerifier.fetchMessagesBatch
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func (m *MissingMessageVerifier) fetchMessagesBatch(c chan<- *protocol.Envelope, interest criteriaInterest, batchFrom int, batchTo int, now time.Time) error {
Function NewConnectionNotifier
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func NewConnectionNotifier(ctx context.Context, h host.Host, connNotifCh chan<- PeerConnection, metrics Metrics, log *zap.Logger) ConnectionNotifier {
Method Rendezvous.DiscoverShard
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func (r *Rendezvous) DiscoverShard(ctx context.Context, rp *RendezvousPoint, cluster uint16, shard uint16, numPeers int) {
Function waku_filter_unsubscribe_all
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func waku_filter_unsubscribe_all(ctx unsafe.Pointer, peerID *C.char, ms C.int, cb C.WakuCallBack, userData unsafe.Pointer) C.int {
Function lightpushPublish
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func lightpushPublish(instance *WakuInstance, msg *pb.WakuMessage, pubsubTopic string, peerID string, ms int) (string, error) {
Function NewPairing
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func NewPairing(myStaticKey n.Keypair, myEphemeralKey n.Keypair, opts PairingParameterOption, messenger NoiseMessenger, logger *zap.Logger) (*Pairing, error) {
Function waku_connect
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func waku_connect(ctx unsafe.Pointer, address *C.char, ms C.int, cb C.WakuCallBack, userData unsafe.Pointer) C.int {
Function waku_filter_ping
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func waku_filter_ping(ctx unsafe.Pointer, peerID *C.char, ms C.int, cb C.WakuCallBack, userData unsafe.Pointer) C.int {
Method WakuFilterLightNode.request
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func (wf *WakuFilterLightNode) request(ctx context.Context, requestID []byte,
reqType pb.FilterSubscribeRequest_FilterSubscribeType, contentFilter protocol.ContentFilter, peerID peer.ID) error {
Function waku_encode_symmetric
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func waku_encode_symmetric(messageJSON *C.char, symmetricKey *C.char, optionalSigningKey *C.char, cb C.WakuCallBack, userData unsafe.Pointer) C.int {
Function LightpushPublish
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func LightpushPublish(instance *WakuInstance, messageJSON string, pubsubTopic string, peerID string, ms int) (string, error) {