Remove cross-chain requests

go.mod

@@ -10,7 +10,7 @@ require (
 	github.com/DataDog/zstd v1.5.2
 	github.com/NYTimes/gziphandler v1.1.1
 	github.com/antithesishq/antithesis-sdk-go v0.3.8
-	github.com/ava-labs/coreth v0.13.8-0.20240802110637-b3e5088d062d
+	github.com/ava-labs/coreth v0.13.8-fixed-genesis-upgrade.0.20240808160839-82b63707d309
 	github.com/ava-labs/ledger-avalanche/go v0.0.0-20240610153809-9c955cc90a95
 	github.com/btcsuite/btcd/btcutil v1.1.3
 	github.com/cockroachdb/pebble v0.0.0-20230928194634-aa077af62593
@@ -34,7 +34,7 @@ require (
 	github.com/nbutton23/zxcvbn-go v0.0.0-20180912185939-ae427f1e4c1d
 	github.com/onsi/ginkgo/v2 v2.13.1
 	github.com/pires/go-proxyproto v0.6.2
-	github.com/prometheus/client_golang v1.14.0
+	github.com/prometheus/client_golang v1.16.0
 	github.com/prometheus/client_model v0.3.0
 	github.com/prometheus/common v0.42.0
 	github.com/rs/cors v1.7.0
@@ -156,7 +156,7 @@ require (
 	github.com/zondax/ledger-go v0.14.3 // indirect
 	go.opentelemetry.io/otel/metric v1.22.0 // indirect
 	go.opentelemetry.io/proto/otlp v1.0.0 // indirect
-	go.uber.org/multierr v1.10.0 // indirect
+	go.uber.org/multierr v1.11.0 // indirect
 	golang.org/x/sys v0.18.0 // indirect
 	golang.org/x/text v0.14.0 // indirect
 	golang.org/x/tools v0.17.0 // indirect

go.sum

@@ -62,8 +62,8 @@ github.com/allegro/bigcache v1.2.1-0.20190218064605-e24eb225f156/go.mod h1:Cb/ax
 github.com/antithesishq/antithesis-sdk-go v0.3.8 h1:OvGoHxIcOXFJLyn9IJQ5DzByZ3YVAWNBc394ObzDRb8=
 github.com/antithesishq/antithesis-sdk-go v0.3.8/go.mod h1:IUpT2DPAKh6i/YhSbt6Gl3v2yvUZjmKncl7U91fup7E=
 github.com/armon/consul-api v0.0.0-20180202201655-eb2c6b5be1b6/go.mod h1:grANhF5doyWs3UAsr3K4I6qtAmlQcZDesFNEHPZAzj8=
-github.com/ava-labs/coreth v0.13.8-0.20240802110637-b3e5088d062d h1:klPTcKVvqfA2KSKaRvQAO56Pd4XAqGhwgMTQ6/W+w7w=
-github.com/ava-labs/coreth v0.13.8-0.20240802110637-b3e5088d062d/go.mod h1:tXDujonxXFOF6oK5HS2EmgtSXJK3Gy6RpZxb5WzR9rM=
+github.com/ava-labs/coreth v0.13.8-fixed-genesis-upgrade.0.20240808160839-82b63707d309 h1:+FKQUlP39qAVRGm/5a3gfYnh5Gunbxm4by2ssi7BbIA=
+github.com/ava-labs/coreth v0.13.8-fixed-genesis-upgrade.0.20240808160839-82b63707d309/go.mod h1:z0JE84/uawhLD6pJ37f4Chopw5OsGWa10PV+a27z1tI=
 github.com/ava-labs/ledger-avalanche/go v0.0.0-20240610153809-9c955cc90a95 h1:dOVbtdnZL++pENdTCNZ1nu41eYDQkTML4sWebDnnq8c=
 github.com/ava-labs/ledger-avalanche/go v0.0.0-20240610153809-9c955cc90a95/go.mod h1:pJxaT9bUgeRNVmNRgtCHb7sFDIRKy7CzTQVi8gGNT6g=
 github.com/aymerick/raymond v2.0.3-0.20180322193309-b565731e1464+incompatible/go.mod h1:osfaiScAUVup+UC9Nfq76eWqDhXlp+4UYaA8uhTBO6g=
@@ -498,8 +498,8 @@ github.com/pkg/sftp v1.13.1/go.mod h1:3HaPG6Dq1ILlpPZRO0HVMrsydcdLt6HRDccSgb87qR
 github.com/pmezard/go-difflib v0.0.0-20151028094244-d8ed2627bdf0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
-github.com/prometheus/client_golang v1.14.0 h1:nJdhIvne2eSX/XRAFV9PcvFFRbrjbcTUj0VP62TMhnw=
-github.com/prometheus/client_golang v1.14.0/go.mod h1:8vpkKitgIVNcqrRBWh1C4TIUQgYNtG/XQE4E/Zae36Y=
+github.com/prometheus/client_golang v1.16.0 h1:yk/hx9hDbrGHovbci4BY+pRMfSuuat626eFsHb7tmT8=
+github.com/prometheus/client_golang v1.16.0/go.mod h1:Zsulrv/L9oM40tJ7T815tM89lFEugiJ9HzIqaAx4LKc=
 github.com/prometheus/client_model v0.0.0-20190812154241-14fe0d1b01d4/go.mod h1:xMI15A0UPsDsEKsMN9yxemIoYk6Tm2C1GtYGdfGttqA=
 github.com/prometheus/client_model v0.3.0 h1:UBgGFHqYdG/TPFD1B1ogZywDqEkwp3fBMvqdiQ7Xew4=
 github.com/prometheus/client_model v0.3.0/go.mod h1:LDGWKZIo7rky3hgvBe+caln+Dr3dPggB5dvjtD7w9+w=
@@ -644,8 +644,8 @@ go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto=
 go.uber.org/goleak v1.3.0/go.mod h1:CoHD4mav9JJNrW/WLlf7HGZPjdw8EucARQHekz1X6bE=
 go.uber.org/mock v0.4.0 h1:VcM4ZOtdbR4f6VXfiOpwpVJDL6lCReaZ6mw31wqh7KU=
 go.uber.org/mock v0.4.0/go.mod h1:a6FSlNadKUHUa9IP5Vyt1zh4fC7uAwxMutEAscFbkZc=
-go.uber.org/multierr v1.10.0 h1:S0h4aNzvfcFsC3dRF1jLoaov7oRaKqRGC/pUEJ2yvPQ=
-go.uber.org/multierr v1.10.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y=
+go.uber.org/multierr v1.11.0 h1:blXXJkSxSSfBVBlC76pxqeO+LN3aDfLQo+309xJstO0=
+go.uber.org/multierr v1.11.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y=
 go.uber.org/zap v1.26.0 h1:sI7k6L95XOKS281NhVKOFCUNIvv9e0w4BF8N3u+tCRo=
 go.uber.org/zap v1.26.0/go.mod h1:dtElttAiwGvoJ/vj4IwHBS/gXsEu/pZ50mUIRWuG0so=
 golang.org/x/crypto v0.0.0-20170613210332-850760c427c5/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=

message/internal_msg_builder.go

@@ -6,7 +6,6 @@ package message
 
 import (
 	"fmt"
-	"time"
 
 	"github.com/ava-labs/avalanchego/ids"
 	"github.com/ava-labs/avalanchego/proto/pb/p2p"
@@ -48,21 +47,6 @@ var (
 	_ chainIDGetter   = (*QueryFailed)(nil)
 	_ requestIDGetter = (*QueryFailed)(nil)
 
-	_ fmt.Stringer        = (*CrossChainAppRequest)(nil)
-	_ sourceChainIDGetter = (*CrossChainAppRequest)(nil)
-	_ chainIDGetter       = (*CrossChainAppRequest)(nil)
-	_ requestIDGetter     = (*CrossChainAppRequest)(nil)
-
-	_ fmt.Stringer        = (*CrossChainAppRequestFailed)(nil)
-	_ sourceChainIDGetter = (*CrossChainAppRequestFailed)(nil)
-	_ chainIDGetter       = (*CrossChainAppRequestFailed)(nil)
-	_ requestIDGetter     = (*CrossChainAppRequestFailed)(nil)
-
-	_ fmt.Stringer        = (*CrossChainAppResponse)(nil)
-	_ sourceChainIDGetter = (*CrossChainAppResponse)(nil)
-	_ chainIDGetter       = (*CrossChainAppResponse)(nil)
-	_ requestIDGetter     = (*CrossChainAppResponse)(nil)
-
 	_ fmt.Stringer = (*Disconnected)(nil)
 
 	_ fmt.Stringer = (*GossipRequest)(nil)
@@ -329,148 +313,6 @@ func InternalQueryFailed(
 	}
 }
 
-type CrossChainAppRequest struct {
-	SourceChainID      ids.ID `json:"source_chain_id,omitempty"`
-	DestinationChainID ids.ID `json:"destination_chain_id,omitempty"`
-	RequestID          uint32 `json:"request_id,omitempty"`
-	Message            []byte `json:"message,omitempty"`
-}
-
-func (m *CrossChainAppRequest) String() string {
-	return fmt.Sprintf(
-		"SourceChainID: %s DestinationChainID: %s RequestID: %d Message: 0x%x",
-		m.SourceChainID, m.DestinationChainID, m.RequestID, m.Message,
-	)
-}
-
-func (m *CrossChainAppRequest) GetSourceChainID() ids.ID {
-	return m.SourceChainID
-}
-
-func (m *CrossChainAppRequest) GetChainId() []byte {
-	return m.DestinationChainID[:]
-}
-
-func (m *CrossChainAppRequest) GetRequestId() uint32 {
-	return m.RequestID
-}
-
-func InternalCrossChainAppRequest(
-	nodeID ids.NodeID,
-	sourceChainID ids.ID,
-	destinationChainID ids.ID,
-	requestID uint32,
-	deadline time.Duration,
-	msg []byte,
-) InboundMessage {
-	return &inboundMessage{
-		nodeID: nodeID,
-		op:     CrossChainAppRequestOp,
-		message: &CrossChainAppRequest{
-			SourceChainID:      sourceChainID,
-			DestinationChainID: destinationChainID,
-			RequestID:          requestID,
-			Message:            msg,
-		},
-		expiration: time.Now().Add(deadline),
-	}
-}
-
-type CrossChainAppRequestFailed struct {
-	SourceChainID      ids.ID `json:"source_chain_id,omitempty"`
-	DestinationChainID ids.ID `json:"destination_chain_id,omitempty"`
-	RequestID          uint32 `json:"request_id,omitempty"`
-	ErrorCode          int32  `json:"error_code,omitempty"`
-	ErrorMessage       string `json:"error_message,omitempty"`
-}
-
-func (m *CrossChainAppRequestFailed) String() string {
-	return fmt.Sprintf(
-		"SourceChainID: %s DestinationChainID: %s RequestID: %d",
-		m.SourceChainID, m.DestinationChainID, m.RequestID,
-	)
-}
-
-func (m *CrossChainAppRequestFailed) GetSourceChainID() ids.ID {
-	return m.SourceChainID
-}
-
-func (m *CrossChainAppRequestFailed) GetChainId() []byte {
-	return m.DestinationChainID[:]
-}
-
-func (m *CrossChainAppRequestFailed) GetRequestId() uint32 {
-	return m.RequestID
-}
-
-func InternalCrossChainAppError(
-	nodeID ids.NodeID,
-	sourceChainID ids.ID,
-	destinationChainID ids.ID,
-	requestID uint32,
-	errorCode int32,
-	errorMessage string,
-) InboundMessage {
-	return &inboundMessage{
-		nodeID: nodeID,
-		op:     CrossChainAppErrorOp,
-		message: &CrossChainAppRequestFailed{
-			SourceChainID:      sourceChainID,
-			DestinationChainID: destinationChainID,
-			RequestID:          requestID,
-			ErrorCode:          errorCode,
-			ErrorMessage:       errorMessage,
-		},
-		expiration: mockable.MaxTime,
-	}
-}
-
-type CrossChainAppResponse struct {
-	SourceChainID      ids.ID `json:"source_chain_id,omitempty"`
-	DestinationChainID ids.ID `json:"destination_chain_id,omitempty"`
-	RequestID          uint32 `json:"request_id,omitempty"`
-	Message            []byte `json:"message,omitempty"`
-}
-
-func (m *CrossChainAppResponse) String() string {
-	return fmt.Sprintf(
-		"SourceChainID: %s DestinationChainID: %s RequestID: %d Message: 0x%x",
-		m.SourceChainID, m.DestinationChainID, m.RequestID, m.Message,
-	)
-}
-
-func (m *CrossChainAppResponse) GetSourceChainID() ids.ID {
-	return m.SourceChainID
-}
-
-func (m *CrossChainAppResponse) GetChainId() []byte {
-	return m.DestinationChainID[:]
-}
-
-func (m *CrossChainAppResponse) GetRequestId() uint32 {
-	return m.RequestID
-}
-
-func InternalCrossChainAppResponse(
-	nodeID ids.NodeID,
-	sourceChainID ids.ID,
-	destinationChainID ids.ID,
-	requestID uint32,
-	msg []byte,
-) InboundMessage {
-	return &inboundMessage{
-		nodeID: nodeID,
-		op:     CrossChainAppResponseOp,
-		message: &CrossChainAppResponse{
-			SourceChainID:      sourceChainID,
-			DestinationChainID: destinationChainID,
-			RequestID:          requestID,
-			Message:            msg,
-		},
-		expiration: mockable.MaxTime,
-	}
-}
-
 type Connected struct {
 	NodeVersion *version.Application `json:"node_version,omitempty"`
 }

message/ops.go

@@ -54,10 +54,6 @@ const (
 	AppErrorOp
 	AppResponseOp
 	AppGossipOp
-	// Cross chain:
-	CrossChainAppRequestOp
-	CrossChainAppErrorOp
-	CrossChainAppResponseOp
 	// Internal:
 	ConnectedOp
 	ConnectedSubnetOp
@@ -116,9 +112,6 @@ var (
 		GetAncestorsFailedOp,
 		GetFailedOp,
 		QueryFailedOp,
-		CrossChainAppRequestOp,
-		CrossChainAppErrorOp,
-		CrossChainAppResponseOp,
 		ConnectedOp,
 		ConnectedSubnetOp,
 		DisconnectedOp,
@@ -168,10 +161,6 @@ var (
 		AppErrorOp,
 		AppGossipOp,
 		AppResponseOp,
-		// Cross chain
-		CrossChainAppRequestOp,
-		CrossChainAppErrorOp,
-		CrossChainAppResponseOp,
 	}
 
 	FailedToResponseOps = map[Op]Op{
@@ -183,7 +172,6 @@ var (
 		GetFailedOp:                     PutOp,
 		QueryFailedOp:                   ChitsOp,
 		AppErrorOp:                      AppResponseOp,
-		CrossChainAppErrorOp:            CrossChainAppResponseOp,
 	}
 	UnrequestedOps = set.Of(
 		GetAcceptedFrontierOp,
@@ -194,7 +182,6 @@ var (
 		PullQueryOp,
 		AppRequestOp,
 		AppGossipOp,
-		CrossChainAppRequestOp,
 		GetStateSummaryFrontierOp,
 		GetAcceptedStateSummaryOp,
 	)
@@ -271,14 +258,7 @@ func (op Op) String() string {
 		return "app_response"
 	case AppGossipOp:
 		return "app_gossip"
-	// Cross chain
-	case CrossChainAppRequestOp:
-		return "cross_chain_app_request"
-	case CrossChainAppErrorOp:
-		return "cross_chain_app_error"
-	case CrossChainAppResponseOp:
-		return "cross_chain_app_response"
-		// Internal
+	// Internal
 	case ConnectedOp:
 		return "connected"
 	case ConnectedSubnetOp:

network/p2p/client.go

@@ -31,16 +31,6 @@ type AppResponseCallback func(
 	err error,
 )
 
-// CrossChainAppResponseCallback is called upon receiving an
-// CrossChainAppResponse for a CrossChainAppRequest issued by Client.
-// Callers should check [err] to see whether the AppRequest failed or not.
-type CrossChainAppResponseCallback func(
-	ctx context.Context,
-	chainID ids.ID,
-	responseBytes []byte,
-	err error,
-)
-
 type Client struct {
 	handlerID     uint64
 	handlerIDStr  string
@@ -140,58 +130,6 @@ func (c *Client) AppGossip(
 	)
 }
 
-// CrossChainAppRequest sends a cross chain app request to another vm.
-// [onResponse] is invoked upon an error or a response.
-func (c *Client) CrossChainAppRequest(
-	ctx context.Context,
-	chainID ids.ID,
-	appRequestBytes []byte,
-	onResponse CrossChainAppResponseCallback,
-) error {
-	// Cancellation is removed from this context to avoid erroring unexpectedly.
-	// SendCrossChainAppRequest should be non-blocking and any error other than
-	// context cancellation is unexpected.
-	//
-	// This guarantees that the router should never receive an unexpected
-	// CrossChainAppResponse.
-	ctxWithoutCancel := context.WithoutCancel(ctx)
-
-	c.router.lock.Lock()
-	defer c.router.lock.Unlock()
-
-	requestID := c.router.requestID
-	if _, ok := c.router.pendingCrossChainAppRequests[requestID]; ok {
-		return fmt.Errorf(
-			"failed to issue request with request id %d: %w",
-			requestID,
-			ErrRequestPending,
-		)
-	}
-
-	if err := c.sender.SendCrossChainAppRequest(
-		ctxWithoutCancel,
-		chainID,
-		requestID,
-		PrefixMessage(c.handlerPrefix, appRequestBytes),
-	); err != nil {
-		c.router.log.Error("unexpected error when sending message",
-			zap.Stringer("op", message.CrossChainAppRequestOp),
-			zap.Stringer("chainID", chainID),
-			zap.Uint32("requestID", requestID),
-			zap.Error(err),
-		)
-		return err
-	}
-
-	c.router.pendingCrossChainAppRequests[requestID] = pendingCrossChainAppRequest{
-		handlerID: c.handlerIDStr,
-		callback:  onResponse,
-	}
-	c.router.requestID += 2
-
-	return nil
-}
-
 // PrefixMessage prefixes the original message with the protocol identifier.
 //
 // Only gossip and request messages need to be prefixed.