ibc

type Connection struct {
	Transfer      *Transfer
	SourcePrefix  string
	DestPrefix    string
	ForwardPrefix string
}

type ConnectionRegistry struct {
	// contains filtered or unexported fields
}

type DefaultTransferProvider struct {
	// contains filtered or unexported fields
}

type Forward struct {
	ChainID  string // Chain ID of the middle chain
	Receiver string // TODO: remove this and just use the receiver address
	Port     string
	Channel  string
}

type ForwardInfo struct {
	Channel  string           `json:"channel"`
	Next     *ForwardNextInfo `json:"next,omitempty"`
	Port     string           `json:"port"`
	Receiver string           `json:"receiver"`
	Retries  *int             `json:"retries,omitempty"`
	Timeout  *int64           `json:"timeout,omitempty"`
}

type ForwardMemo struct {
	Forward ForwardInfo `json:"forward"`
}

type ForwardNextInfo struct {
	Wasm WasmExecInfo `json:"wasm"`
}

type MessageHandler func(chainID string, msgs []sdk.Msg, isFeeClient bool, wrapAuthz bool) (*cosmosclient.Response, error)

type Transfer struct {
	SourceChainID string   // Chain ID of the source chain (e.g., "osmosis-1")
	DestChainID   string   // Chain ID of the destination chain (e.g., "neutron-1")
	Channel       string   // Channel ID on the source chain
	Port          string   // Port ID on the source chain (usually "transfer")
	Forward       *Forward // Forwarding address on the destination chain (optional)
}

type TransferProvider interface {
	// Transfer initiates an IBC transfer between chains.
	// If the WaitForCompletion flag is set to true in the request, this method will block
	// until the transfer is completed or the timeout is reached.
	Transfer(ctx context.Context, request *TransferRequest) (*TransferResult, error)

	// CreateTransferMsg creates an IBC transfer message
	CreateTransferMsg(ctx context.Context, request *TransferRequest) (sdk.Msg, error)

	// ProcessTransferMsg processes a transfer message
	ProcessTransferMsg(ctx context.Context, request *TransferRequest, transferMsg sdk.Msg) (*TransferResult, error)
}

type TransferRequest struct {
	SourceChain       string        // Source chain ID
	DestinationChain  string        // Destination chain ID
	Sender            string        // Sender address on source chain
	Receiver          string        // Receiver address on destination chain
	Amount            sdk.Coin      // Amount to transfer
	RecvDenom         string        // Denom of the token to receive
	Timeout           uint64        // Timeout in blocks
	Fee               sdk.Coins     // Optional fee for the transfer
	CompletionTimeout time.Duration // Maximum time to wait for transfer completion
}

type TransferResult struct {
	SourceTxHash   string                 // Hash of the source chain transaction
	DestTxHash     string                 // Hash of the destination chain transaction if available
	Error          error                  // Error if transfer failed
	SourceResponse *cosmosclient.Response // Source chain response
	DestResponse   *cosmosclient.Response // Destination chain response (if available)
}

type WasmExecInfo struct {
	Contract string          `json:"contract"`
	Msg      json.RawMessage `json:"msg"`
}

type WasmExecMemo struct {
	Wasm WasmExecInfo `json:"wasm"`
}