aergoio/aergo

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

Open

func (c *delb) parse(args string) (uint64, string, error) {
    splitArgs := context.SplitSpaceAndAccent(args, false)
    if len(splitArgs) < 2 {
        return 0, "", fmt.Errorf("need 2 arguments. usage: %s", c.Usage())
    }

• Read up
  Read up

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

Open

func (c *setb) parse(args string) (uint64, string, error) {
    splitArgs := context.SplitSpaceAndAccent(args, false)
    if len(splitArgs) < 2 {
        return 0, "", fmt.Errorf("need 2 arguments. usage: %s", c.Usage())
    }

• Read up
  Read up

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

Open

func (m *MockAergoRPCServiceClient) ListBlockMetadataStream(arg0 context.Context, arg1 *types.Empty, arg2 ...grpc.CallOption) (types.AergoRPCService_ListBlockMetadataStreamClient, error) {
    m.ctrl.T.Helper()
    varargs := []interface{}{arg0, arg1}
    for _, a := range arg2 {
        varargs = append(varargs, a)

• Read up
  Read up

Method raftServer.serveChannels has 68 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (rs *raftServer) serveChannels() {
    defer RecoverExit()

    snapshot, err := rs.raftStorage.Snapshot()
    if err != nil {

Method BlockFetcher.Start has 68 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (bf *BlockFetcher) Start() {
    bf.waitGroup = &sync.WaitGroup{}
    bf.waitGroup.Add(1)

    schedTicker := time.NewTicker(schedTick)

Function Call has 68 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func Call(
    contractState *statedb.ContractState,
    payload, contractAddress []byte,
    ctx *vmContext,
) (string, []*types.Event, *big.Int, error) {

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

Open

func (m *MockNetworkTransport) NewStream(arg0 context.Context, arg1 peer.ID, arg2 ...protocol.ID) (network.Stream, error) {
    m.ctrl.T.Helper()
    varargs := []interface{}{arg0, arg1}
    for _, a := range arg2 {
        varargs = append(varargs, a)

• Read up
  Read up

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

Open

func (m *MockNetworkTransport) GetOrCreateStreamWithTTL(arg0 p2pcommon.PeerMeta, arg1 time.Duration, arg2 ...protocol.ID) (network.Stream, error) {
    m.ctrl.T.Helper()
    varargs := []interface{}{arg0, arg1}
    for _, a := range arg2 {
        varargs = append(varargs, a)

• Read up
  Read up

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

Open

func (m *MockHost) NewStream(arg0 context.Context, arg1 peer.ID, arg2 ...protocol.ID) (network.Stream, error) {
    m.ctrl.T.Helper()
    varargs := []interface{}{arg0, arg1}
    for _, a := range arg2 {
        varargs = append(varargs, a)

• Read up
  Read up

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

Open

func (h *V030Handshaker) handleGoAway(peerID types.PeerID, data p2pcommon.Message) (*types.Status, error) {
    goAway := &types.GoAwayNotice{}
    if err := p2putil.UnmarshalMessageBody(data.Payload(), goAway); err != nil {
        h.logger.Warn().Stringer(p2putil.LogPeerID, types.LogPeerShort(peerID)).Err(err).Msg("Remote peer sent goAway but failed to decode internal message")
        return nil, err

• Read up
  Read up

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

Open

func (h *V200Handshaker) handleGoAway(peerID types.PeerID, data p2pcommon.Message) (*types.Status, error) {
    goAway := &types.GoAwayNotice{}
    if err := p2putil.UnmarshalMessageBody(data.Payload(), goAway); err != nil {
        h.logger.Warn().Stringer(p2putil.LogPeerID, types.LogPeerShort(peerID)).Err(err).Msg("Remote peer sent goAway but failed to decode internal message")
        return nil, err

• Read up
  Read up

Function LoadDummyChainEx has 67 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func LoadDummyChainEx(chainType ChainType) (*DummyChain, error) {
    var err error
    var gasPrice *big.Int

    switch chainType {

Function luaDelegateCallContract has 67 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func luaDelegateCallContract(L *LState, service C.int, contractId *C.char,
    fname *C.char, args *C.char, gas uint64) (C.int, *C.char) {
    contractIdStr := C.GoString(contractId)
    fnameStr := C.GoString(fname)
    argsStr := C.GoString(args)

Function ValidateSystemTx has 18 return statements (exceeds 4 allowed).

Open

func ValidateSystemTx(account []byte, txBody *types.TxBody, sender *state.AccountState,
    scs *statedb.ContractState, blockInfo *types.BlockHeaderInfo) (*SystemContext, error) {
    var ci types.CallInfo
    if err := json.Unmarshal(txBody.Payload, &ci); err != nil {
        return nil, types.ErrTxInvalidPayload

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

Open

func (dpm *dynamicWPManager) OnPeerDisconnect(peer p2pcommon.RemotePeer) {
    // if peer is designated peer or trusted enough , try reconnect by add peermeta to waiting peer
    // TODO check by trust level is not implemented yet.
    if _, ok := dpm.pm.designatedPeers[peer.ID()]; ok {
        dpm.logger.Debug().Str(p2putil.LogPeerID, peer.Name()).Msg("server will try to reconnect designated peer after cooltime")

• Read up
  Read up

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

Open

    if data.Subprotocol() != p2pcommon.StatusRequest {
        if data.Subprotocol() == p2pcommon.GoAway {
            return h.handleGoAway(h.peerID, data)
        } else {
            h.logger.Info().Stringer(p2putil.LogPeerID, types.LogPeerShort(h.peerID)).Str("expected", p2pcommon.StatusRequest.String()).Str("actual", data.Subprotocol().String()).Msg("unexpected message type")

• Read up
  Read up

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

Open

    if data.Subprotocol() != p2pcommon.StatusRequest {
        if data.Subprotocol() == p2pcommon.GoAway {
            return h.handleGoAway(h.peerID, data)
        } else {
            h.logger.Info().Stringer(p2putil.LogPeerID, types.LogPeerShort(h.peerID)).Str("expected", p2pcommon.StatusRequest.String()).Str("actual", data.Subprotocol().String()).Msg("unexpected message type")

• Read up
  Read up

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

Open

func (spm *staticWPManager) OnPeerDisconnect(peer p2pcommon.RemotePeer) {
    // if peer is designated peer , try reconnect by add peermeta to waiting peer
    if _, ok := spm.pm.designatedPeers[peer.ID()]; ok {
        spm.logger.Debug().Str(p2putil.LogPeerID, peer.Name()).Msg("server will try to reconnect designated peer after cooltime")
        // These peers must have cool time.

• Read up
  Read up

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

Open

    case *message.UnlockAccount:
        actualAddress := msg.Account.Address
        var err error
        if len(actualAddress) == types.NameLength {
            actualAddress, err = as.resolveName(actualAddress)

• Read up
  Read up

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

Open

    case *message.LockAccount:
        actualAddress := msg.Account.Address
        var err error
        if len(actualAddress) == types.NameLength {
            actualAddress, err = as.resolveName(actualAddress)

• Read up
  Read up