Add construction endpoints

server/rosetta/cosmos/client/client.go

@@ -109,6 +109,29 @@ func NewSingle(grpcEndpoint, tendermintEndpoint string, optsFunc ...OptionFunc)
 	}, nil
 }
 
+func (c *Client) AccountInfo(ctx context.Context, addr string, height *int64) (auth.AccountI, error) {
+	// if height is set, send height instruction to account
+	if height != nil {
+		strHeight := strconv.FormatInt(*height, 10)
+		ctx = metadata.AppendToOutgoingContext(ctx, grpctypes.GRPCBlockHeightHeader, strHeight)
+	}
+	// retrieve account info
+	accountInfo, err := c.auth.Account(ctx, &auth.QueryAccountRequest{
+		Address: addr,
+	})
+	if err != nil {
+		return nil, rosetta.FromGRPCToRosettaError(err)
+	}
+	// success
+	var account auth.AccountI
+	err = c.ir.UnpackAny(accountInfo.Account, &account)
+	if err != nil {
+		return nil, rosetta.WrapError(rosetta.ErrCodec, err.Error())
+	}
+
+	return account, nil
+}
+
 func (c *Client) Balances(ctx context.Context, addr string, height *int64) ([]sdk.Coin, error) {
 	if height != nil {
 		strHeight := strconv.FormatInt(*height, 10)
@@ -224,3 +247,11 @@ func (c *Client) Status(ctx context.Context) (*tmtypes.ResultStatus, error) {
 	}
 	return status, err
 }
+
+func (c *Client) GetTxConfig(ctx context.Context) client.TxConfig {
+	return c.client.TxConfig
+}
+
+func (c *Client) PostTx(ctx context.Context, txBytes []byte) (res *sdk.TxResponse, err error) {
+	return c.client.BroadcastTx(txBytes)
+}

server/rosetta/cosmos/conversion/data.go

@@ -2,6 +2,8 @@ package conversion
 
 import (
 	"fmt"
+	"strconv"
+	"strings"
 	"time"
 
 	"github.com/coinbase/rosetta-sdk-go/types"
@@ -65,7 +67,7 @@ func ResultTxSearchToTransaction(txs []*rosetta.SdkTxWithHash) []*types.Transact
 
 // SdkTxResponseToOperations converts a tx response to operations
 func SdkTxToOperations(tx sdk.Tx, hasError, withoutStatus bool) []*types.Operation {
-	return toOperations(tx.GetMsgs(), hasError, withoutStatus)
+	return ToOperations(tx.GetMsgs(), hasError, withoutStatus)
 }
 
 // TendermintTxsToTxIdentifiers converts a tendermint raw transaction into a rosetta tx identifier
@@ -85,7 +87,7 @@ func TendermintBlockToBlockIdentifier(block *tmcoretypes.ResultBlock) *types.Blo
 	}
 }
 
-func toOperations(msgs []sdk.Msg, hasError bool, withoutStatus bool) []*types.Operation {
+func ToOperations(msgs []sdk.Msg, hasError bool, withoutStatus bool) []*types.Operation {
 	var operations []*types.Operation
 	for i, msg := range msgs {
 		switch msg.Type() { // nolint
@@ -132,6 +134,41 @@ func toOperations(msgs []sdk.Msg, hasError bool, withoutStatus bool) []*types.Op
 	return operations
 }
 
+// GetTransferTxDataFromOperations extracts the from and to addresses from a list of operations.
+// We assume that it comes formated in the correct way. And that the balance of the sender is the same
+// as the receiver operations.
+func GetTransferTxDataFromOperations(ops []*types.Operation) (*banktypes.MsgSend, error) {
+	var (
+		from, to sdk.AccAddress
+		sendAmt  sdk.Coin
+		err      error
+	)
+
+	for _, op := range ops {
+		if strings.HasPrefix(op.Amount.Value, "-") {
+			from, err = sdk.AccAddressFromBech32(op.Account.Address)
+			if err != nil {
+				return nil, err
+			}
+		} else {
+			to, err = sdk.AccAddressFromBech32(op.Account.Address)
+			if err != nil {
+				return nil, err
+			}
+
+			amount, err := strconv.ParseInt(op.Amount.Value, 10, 64)
+			if err != nil {
+				return nil, fmt.Errorf("invalid amount")
+			}
+
+			sendAmt = sdk.NewCoin(op.Amount.Currency.Symbol, sdk.NewInt(amount))
+		}
+	}
+
+	msg := banktypes.NewMsgSend(from, to, sdk.NewCoins(sendAmt))
+	return msg, nil
+}
+
 // TmPeersToRosettaPeers converts tendermint peers to rosetta ones
 func TmPeersToRosettaPeers(peers []tmcoretypes.Peer) []*types.Peer {
 	converted := make([]*types.Peer, len(peers))

server/rosetta/docker-compose.integration.yaml

@@ -0,0 +1,26 @@
+version: "3"
+services:
+  cosmos:
+    build:
+      context: ../../
+      dockerfile: server/rosetta/test/docker/node.dockerfile
+    command: ["simd", "start"]
+    ports:
+    - 9090:9090
+    - 26657:26657
+
+  rosetta:
+    build:
+      context: ../../
+      dockerfile: server/rosetta/Dockerfile
+    command: [
+      "./simd",
+      "rosetta",
+      "--blockchain", "cosmos",
+      "--network", "test_network",
+      "--tendermint", "cosmos:26657",
+      "--grpc", "cosmos:9090",
+      "--addr", ":8080",
+    ]
+    ports:
+    - 8080:8080

server/rosetta/errors.go

@@ -128,7 +128,13 @@ var (
 	// ErrUnsupportedCurve is returned when the curve specified is not supported
 	ErrUnsupportedCurve = NewError(15, "unsupported curve, expected secp256k1", false)
 	// ErrInvalidPubkey is returned when the public key is invalid
-	ErrInvalidPubkey = NewError(8, "invalid pubkey", false)
+	ErrInvalidPubkey      = NewError(8, "invalid pubkey", false)
+	ErrInterpreting       = NewError(1, "error interpreting data from node", false)
+	ErrInvalidAddress     = NewError(7, "invalid address", false)
+	ErrInvalidMemo        = NewError(11, "invalid memo", false)
+	ErrInvalidOperation   = NewError(4, "invalid operation", false)
+	ErrInvalidRequest     = NewError(6, "invalid request", false)
+	ErrInvalidTransaction = NewError(5, "invalid transaction", false)
 )
 
 // AllowedErrors lists all the rosetta allowed errors