Showing 400 of 400 total issues
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) {
Function waku_add_peer
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func waku_add_peer(ctx unsafe.Pointer, address *C.char, protocolID *C.char, cb C.WakuCallBack, userData unsafe.Pointer) C.int {
Function waku_encode_asymmetric
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func waku_encode_asymmetric(messageJSON *C.char, publicKey *C.char, optionalSigningKey *C.char, cb C.WakuCallBack, userData unsafe.Pointer) C.int {
Function NewContentTopic
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func NewContentTopic(applicationName string, applicationVersion string,
contentTopicName string, encoding string, opts ...ContentTopicOption) (ContentTopic, error) {
Method WakuFilterFullNode.reply
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func (wf *WakuFilterFullNode) reply(ctx context.Context, stream network.Stream, request *pb.FilterSubscribeRequest, statusCode int, description ...string) {
Function NewWakuLightPush
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func NewWakuLightPush(relay *relay.WakuRelay, pm *peermanager.PeerManager, reg prometheus.Registerer, log *zap.Logger, opts ...Option) *WakuLightPush {
Function waku_connect_peerid
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func waku_connect_peerid(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(instanceID uint, messageJSON string, topic string, peerID string, ms int) string {
Function NewWakuStore
has 5 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func NewWakuStore(p MessageProvider, pm *peermanager.PeerManager, timesource timesource.Timesource, reg prometheus.Registerer, log *zap.Logger) *WakuStore {
Method MessageSender.Send
has 5 return statements (exceeds 4 allowed). Open
Open
func (ms *MessageSender) Send(req *Request) error {
logger := ms.logger.With(
zap.Stringer("envelopeHash", req.envelope.Hash()),
zap.String("pubsubTopic", req.envelope.PubsubTopic()),
zap.String("contentTopic", req.envelope.Message().ContentTopic),
Function MakeHost
has 5 return statements (exceeds 4 allowed). Open
Open
func MakeHost(ctx context.Context, port int, randomness io.Reader) (host.Host, error) {
// Creates a new RSA key pair for this host.
prvKey, _, err := crypto.GenerateKeyPairWithReader(crypto.RSA, 2048, randomness)
if err != nil {
log.Error(err.Error())
Function RetrieveNodes
has 5 return statements (exceeds 4 allowed). Open
Open
func RetrieveNodes(ctx context.Context, url string, opts ...DNSDiscoveryOption) ([]DiscoveredNode, error) {
var discoveredNodes []DiscoveredNode
params := new(dnsDiscoveryParameters)
for _, opt := range opts {
Method DB.Register
has 5 return statements (exceeds 4 allowed). Open
Open
func (db *DB) Register(p peer.ID, ns string, signedPeerRecord []byte, ttl int) (uint64, error) {
pid := p.String()
expire := time.Now().Unix() + int64(ttl)
tx, err := db.db.Begin()