waku-org/go-waku

Similar blocks of code found in 6 locations. Consider refactoring.

Open

func (s *FilterTestSuite) TestValidPayloadsUTF8() {

    // Subscribe
    s.subscribe(s.TestTopic, s.TestContentTopic, s.FullNodeHost.ID())

• Read up
  Read up

Similar blocks of code found in 6 locations. Consider refactoring.

Open

func (s *FilterTestSuite) TestValidPayloadsJSON() {

    // Subscribe
    s.subscribe(s.TestTopic, s.TestContentTopic, s.FullNodeHost.ID())

• Read up
  Read up

Similar blocks of code found in 6 locations. Consider refactoring.

Open

func (s *FilterTestSuite) TestValidPayloadsSQL() {

    // Subscribe
    s.subscribe(s.TestTopic, s.TestContentTopic, s.FullNodeHost.ID())

• Read up
  Read up

Function save has 8 return statements (exceeds 4 allowed).

Open

func save(keystore *AppKeystore, path string) error {
    // We first backup the current keystore
    _, err := os.Stat(path)
    if err == nil {
        err := os.Rename(path, path+".bkp")

Method WakuNode.setupRLNRelay has 8 return statements (exceeds 4 allowed).

Open

func (w *WakuNode) setupRLNRelay() error {
    var err error

    if !w.opts.enableRLN {
        return nil

Function BuildConfig has 8 return statements (exceeds 4 allowed).

Open

func BuildConfig(ctx context.Context, ethClientAddress string, registryAddress common.Address) (*Config, error) {
    ethClient, err := ethclient.DialContext(ctx, ethClientAddress)
    if err != nil {
        return nil, err
    }

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

Open

func execute(options Options) {
    var err error
    hostAddr, _ := net.ResolveTCPAddr("tcp", fmt.Sprintf("0.0.0.0:%d", options.Port))

    if options.NodeKey == nil {

Function extractIPAddressForENR has 8 return statements (exceeds 4 allowed).

Open

func extractIPAddressForENR(addr ma.Multiaddr) (*net.TCPAddr, error) {
    // It's a p2p-circuit address. We shouldnt use these
    // for building the ENR record default keys
    _, err := addr.ValueForProtocol(ma.P_CIRCUIT)
    if err == nil {

Method WakuStore.Request has 8 return statements (exceeds 4 allowed).

Open

func (s *WakuStore) Request(ctx context.Context, criteria Criteria, opts ...RequestOption) (Result, error) {
    params := new(Parameters)

    optList := DefaultOptions()
    optList = append(optList, opts...)

Function EncodeAsymmetric has 8 return statements (exceeds 4 allowed).

Open

func EncodeAsymmetric(messageJSON string, publicKey string, optionalSigningKey string) (string, error) {
    msg, err := wakuMessage(messageJSON)
    if err != nil {
        return "", err
    }

Function Multiaddress has 8 return statements (exceeds 4 allowed).

Open

func Multiaddress(node *enode.Node) (peer.ID, []multiaddr.Multiaddr, error) {
    pubKey := utils.EcdsaPubKeyToSecp256k1PublicKey(node.Pubkey())
    peerID, err := peer.IDFromPublicKey(pubKey)
    if err != nil {
        return "", nil, err

Method StoreQueryRequest.Validate has 8 return statements (exceeds 4 allowed).

Open

func (x *StoreQueryRequest) Validate() error {
    if x.RequestId == "" {
        return errMissingRequestID
    }

Function register has 8 return statements (exceeds 4 allowed).

Open

func register(ctx context.Context, web3Config *web3.Config, idComm rln.IDCommitment) (rln.MembershipIndex, error) {
    // check if the contract exists by calling a static function
    membershipFee, err := getMembershipFee(ctx, web3Config.RLNContract)
    if err != nil {
        return 0, err

Method WakuFilterLightNode.IncorrectSubscribe has 8 return statements (exceeds 4 allowed).

Open

func (wf *WakuFilterLightNode) IncorrectSubscribe(ctx context.Context, contentFilter protocol.ContentFilter, opts ...FilterSubscribeOption) ([]*subscription.SubscriptionDetails, error) {
    wf.RLock()
    defer wf.RUnlock()
    if err := wf.ErrOnNotRunning(); err != nil {
        return nil, err

Method WakuFilterLightNode.request has 8 return statements (exceeds 4 allowed).

Open

func (wf *WakuFilterLightNode) request(ctx context.Context, requestID []byte,
    reqType pb.FilterSubscribeRequest_FilterSubscribeType, contentFilter protocol.ContentFilter, peerID peer.ID) error {
    request := &pb.FilterSubscribeRequest{
        RequestId:           hex.EncodeToString(requestID),
        FilterSubscribeType: reqType,

Method WakuPeerExchange.Request has 8 return statements (exceeds 4 allowed).

Open

func (wakuPX *WakuPeerExchange) Request(ctx context.Context, numPeers int, opts ...RequestOption) error {
    params := new(PeerExchangeRequestParameters)
    params.host = wakuPX.h
    params.log = wakuPX.log
    params.pm = wakuPX.pm

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

Open

func waku_decode_asymmetric(messageJSON *C.char, privateKey *C.char, cb C.WakuCallBack, userData unsafe.Pointer) C.int {
    return singleFnExecNoCtx(func() (string, error) {
        return library.DecodeAsymmetric(C.GoString(messageJSON), C.GoString(privateKey))
    }, cb, userData)
}

• Read up
  Read up

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

Open

                lbl.text =
                    (lbl.text.toString() + ">>> Addresses: " + it.addrs.joinToString(",") + "\n")

• Read up
  Read up

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

Open

func (m UI) View() string {
    spinnerStr := ""
    inputStr := ""
    if m.isSending {
        spinnerStr = m.spinner.View() + " Sending message..."

• Read up
  Read up

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

Open

func waku_decode_symmetric(messageJSON *C.char, symmetricKey *C.char, cb C.WakuCallBack, userData unsafe.Pointer) C.int {
    return singleFnExecNoCtx(func() (string, error) {
        return library.DecodeSymmetric(C.GoString(messageJSON), C.GoString(symmetricKey))
    }, cb, userData)
}

• Read up
  Read up