synapsecns/sanguine

Method rebalanceManagerCircleCCTP.Execute has 58 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (c *rebalanceManagerCircleCCTP) Execute(parentCtx context.Context, rebalance *RebalanceData) (err error) {
    ctx, span := c.handler.Tracer().Start(parentCtx, "rebalance.Execute", trace.WithAttributes(
        attribute.Int("rebalance_origin", rebalance.OriginMetadata.ChainID),
        attribute.Int("rebalance_dest", rebalance.DestMetadata.ChainID),
        attribute.String("rebalance_amount", rebalance.Amount.String()),

Method rebalanceManagerCircleCCTP.Execute has 8 return statements (exceeds 4 allowed).

Open

func (c *rebalanceManagerCircleCCTP) Execute(parentCtx context.Context, rebalance *RebalanceData) (err error) {
    ctx, span := c.handler.Tracer().Start(parentCtx, "rebalance.Execute", trace.WithAttributes(
        attribute.Int("rebalance_origin", rebalance.OriginMetadata.ChainID),
        attribute.Int("rebalance_dest", rebalance.DestMetadata.ChainID),
        attribute.String("rebalance_amount", rebalance.Amount.String()),

Method rebalanceManagerCircleCCTP.initListeners has 7 return statements (exceeds 4 allowed).

Open

func (c *rebalanceManagerCircleCCTP) initListeners(parentCtx context.Context) (err error) {
    ctx, span := c.handler.Tracer().Start(parentCtx, "initListeners")
    defer func(err error) {
        metrics.EndSpanWithErr(span, err)
    }(err)

Function newRebalanceManagerCircleCCTP has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

func newRebalanceManagerCircleCCTP(cfg relconfig.Config, handler metrics.Handler, chainClient submitter.ClientFetcher, txSubmitter submitter.TransactionSubmitter, relayerAddress common.Address, db reldb.Service) *rebalanceManagerCircleCCTP {

Method rebalanceManagerCircleCCTP.handleDepositForBurn has 7 return statements (exceeds 4 allowed).

Open

func (c *rebalanceManagerCircleCCTP) handleDepositForBurn(ctx context.Context, log types.Log, chainID int, ethClient client.EVM) (err error) {
    ctx, span := c.handler.Tracer().Start(ctx, "rebalance.handleDepositForBurn", trace.WithAttributes(
        attribute.Int(metrics.ChainID, chainID),
    ))
    defer func(err error) {

Method rebalanceManagerCircleCCTP.Start has 7 return statements (exceeds 4 allowed).

Open

func (c *rebalanceManagerCircleCCTP) Start(ctx context.Context) (err error) {
    err = c.initContracts(ctx)
    if err != nil {
        return fmt.Errorf("could not initialize contracts: %w", err)
    }

Method rebalanceManagerCircleCCTP.listenMessageReceived has 6 return statements (exceeds 4 allowed).

Open

func (c *rebalanceManagerCircleCCTP) listenMessageReceived(parentCtx context.Context, chainID int, ethClient client.EVM) (err error) {
    listener, ok := c.transmitterListeners[chainID]
    if !ok {
        return fmt.Errorf("could not find listener for chain %d", chainID)
    }

Method rebalanceManagerCircleCCTP.listenDepositForBurn has 6 return statements (exceeds 4 allowed).

Open

func (c *rebalanceManagerCircleCCTP) listenDepositForBurn(parentCtx context.Context, chainID int, ethClient client.EVM) (err error) {
    listener, ok := c.messengerListeners[chainID]
    if !ok {
        return fmt.Errorf("could not find listener for chain %d", chainID)
    }

Method rebalanceManagerCircleCCTP.initContracts has 6 return statements (exceeds 4 allowed).

Open

func (c *rebalanceManagerCircleCCTP) initContracts(parentCtx context.Context) (err error) {
    ctx, span := c.handler.Tracer().Start(parentCtx, "initContracts")
    defer func(err error) {
        metrics.EndSpanWithErr(span, err)
    }(err)

Method rebalanceManagerCircleCCTP.handleMessageReceived has 5 return statements (exceeds 4 allowed).

Open

func (c *rebalanceManagerCircleCCTP) handleMessageReceived(ctx context.Context, log types.Log, chainID int, ethClient client.EVM) (err error) {
    ctx, span := c.handler.Tracer().Start(ctx, "rebalance.handleMessageReceived")
    defer func(err error) {
        metrics.EndSpanWithErr(span, err)
    }(err)

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

Open

func (c *rebalanceManagerCircleCCTP) listenMessageReceived(parentCtx context.Context, chainID int, ethClient client.EVM) (err error) {
    listener, ok := c.transmitterListeners[chainID]
    if !ok {
        return fmt.Errorf("could not find listener for chain %d", chainID)
    }

• Read up
  Read up

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

Open

func (c *rebalanceManagerCircleCCTP) listenDepositForBurn(parentCtx context.Context, chainID int, ethClient client.EVM) (err error) {
    listener, ok := c.messengerListeners[chainID]
    if !ok {
        return fmt.Errorf("could not find listener for chain %d", chainID)
    }

• Read up
  Read up