[WIP] Adds a cosmos signer to the SDK

examples/cosmos/sign_transaction.go

@@ -0,0 +1,191 @@
+package main
+
+import (
+	"context"
+	"encoding/hex"
+	"fmt"
+	"os"
+
+	bankv1beta1 "cosmossdk.io/api/cosmos/bank/v1beta1"
+	basev1beta1 "cosmossdk.io/api/cosmos/base/v1beta1"
+	cosmosSecp "cosmossdk.io/api/cosmos/crypto/secp256k1"
+	signingv1beta1 "cosmossdk.io/api/cosmos/tx/signing/v1beta1"
+	txv1beta1 "cosmossdk.io/api/cosmos/tx/v1beta1"
+	"github.com/cosmos/cosmos-proto/anyutil"
+	"github.com/davecgh/go-spew/spew"
+	tendermintClient "github.com/tendermint/tendermint/rpc/client/http"
+	"github.com/tkhq/go-sdk"
+	"github.com/tkhq/go-sdk/pkg/api/client"
+	"github.com/tkhq/go-sdk/pkg/api/client/private_keys"
+	"github.com/tkhq/go-sdk/pkg/api/models"
+	"github.com/tkhq/go-sdk/pkg/apikey"
+	"github.com/tkhq/go-sdk/pkg/signer/cosmos"
+	"google.golang.org/protobuf/proto"
+	"google.golang.org/protobuf/types/known/anypb"
+)
+
+func getPublicKey(turnkeyClient *client.TurnkeyPublicAPI, orgID string, privateKeyID string, apiKey *apikey.Key) ([]byte, error) {
+	getSenderPrivateKeyRequest := private_keys.NewPublicAPIServiceGetPrivateKeyParams().WithBody(&models.V1GetPrivateKeyRequest{
+		OrganizationID: &orgID,
+		PrivateKeyID:   &privateKeyID,
+	})
+
+	getSenderPrivateKeyResponse, err := turnkeyClient.PrivateKeys.PublicAPIServiceGetPrivateKey(getSenderPrivateKeyRequest, &sdk.Authenticator{Key: apiKey})
+	if err != nil {
+		return nil, err
+	}
+
+	publicKeyBytes, err := hex.DecodeString(*getSenderPrivateKeyResponse.Payload.PrivateKey.PublicKey)
+	if err != nil {
+		return nil, err
+	}
+
+	return cosmos.CompressPublicKey(publicKeyBytes), nil
+}
+
+func main() {
+	receiverPrivateKeyID := os.Getenv("RECEIVER_PRIVATE_KEY_ID")
+	senderPrivateKeyID := os.Getenv("SENDER_PRIVATE_KEY_ID")
+	apiPrivateKey := os.Getenv("API_PRIVATE_KEY")
+	apiHost := os.Getenv("TURNKEY_BASE_URL")
+	orgID := os.Getenv("ORGANIZATION_ID")
+
+	ctx := context.Background()
+
+	apiKey, err := apikey.FromTurnkeyPrivateKey(apiPrivateKey)
+	if err != nil {
+		panic(err)
+	}
+
+	publicApiClient := client.NewHTTPClientWithConfig(nil, &client.TransportConfig{
+		Host: apiHost,
+	})
+
+	signer := cosmos.NewSigner(cosmos.SignerParams{
+		TurnkeyClient:  *publicApiClient,
+		OrganizationID: orgID,
+		ApiHost:        apiHost,
+		ApiKey:         apiKey,
+	})
+
+	fromPublicKey, err := getPublicKey(publicApiClient, orgID, senderPrivateKeyID, apiKey)
+	if err != nil {
+		panic(err)
+	}
+
+	toPublicKey, err := getPublicKey(publicApiClient, orgID, receiverPrivateKeyID, apiKey)
+	if err != nil {
+		panic(err)
+	}
+
+	toAddress := cosmos.CosmosAddressFromPublicKey(toPublicKey)
+	fromAddress := cosmos.CosmosAddressFromPublicKey(fromPublicKey)
+
+	fmt.Println("Sending from: ")
+	fmt.Println(fromAddress)
+	fmt.Println("Sending to: ")
+	fmt.Println(toAddress)
+
+	pk, err := anyutil.New(&cosmosSecp.PubKey{Key: fromPublicKey})
+	if err != nil {
+		panic(err)
+	}
+
+	signerInfo := []*txv1beta1.SignerInfo{
+		{
+			PublicKey: pk,
+			ModeInfo: &txv1beta1.ModeInfo{
+				Sum: &txv1beta1.ModeInfo_Single_{
+					Single: &txv1beta1.ModeInfo_Single{
+						Mode: signingv1beta1.SignMode_SIGN_MODE_DIRECT,
+					},
+				},
+			},
+			Sequence: 2,
+		},
+	}
+
+	fee := &txv1beta1.Fee{
+		Amount: []*basev1beta1.Coin{
+			{
+				Denom:  "uatom",
+				Amount: "1000",
+			},
+		},
+		GasLimit: 200000,
+	}
+
+	msg, err := anyutil.New(&bankv1beta1.MsgSend{
+		FromAddress: fromAddress,
+		ToAddress:   toAddress,
+		Amount: []*basev1beta1.Coin{
+			{
+				Denom:  "uatom",
+				Amount: "1",
+			},
+		},
+	})
+	if err != nil {
+		panic(err)
+	}
+
+	txBody := &txv1beta1.TxBody{
+		Messages: []*anypb.Any{msg},
+		Memo:     "Turnkey demo",
+	}
+
+	authInfo := &txv1beta1.AuthInfo{
+		Fee:         fee,
+		SignerInfos: signerInfo,
+	}
+
+	bodyBz, err := proto.Marshal(txBody)
+	if err != nil {
+		panic(err)
+	}
+
+	authInfoBz, err := proto.Marshal(authInfo)
+	if err != nil {
+		panic(err)
+	}
+
+	signBytes, err := proto.Marshal(&txv1beta1.SignDoc{
+		BodyBytes:     bodyBz,
+		AuthInfoBytes: authInfoBz,
+		ChainId:       "cosmoshub-4",
+		AccountNumber: 1878048,
+	})
+	if err != nil {
+		panic(err)
+	}
+
+	c, err := tendermintClient.New("https://cosmos-rpc.publicnode.com:443")
+	if err != nil {
+		panic(err)
+	}
+
+	signature, err := signer.Sign(senderPrivateKeyID, signBytes)
+	if err != nil {
+		panic(err)
+	}
+
+	tx := txv1beta1.Tx{
+		Body:     txBody,
+		AuthInfo: authInfo,
+		Signatures: [][]byte{
+			signature,
+		},
+	}
+
+	txBytes, err := proto.Marshal(&tx)
+	if err != nil {
+		panic(err)
+	}
+
+	result, err := c.BroadcastTxSync(ctx, txBytes)
+	if err != nil {
+		panic(err)
+	}
+
+	spew.Dump(result)
+}

go.mod

@@ -1,8 +1,14 @@
 module github.com/tkhq/go-sdk
 
-go 1.20
+go 1.21
 
 require (
+	cosmossdk.io/api v0.7.2-0.20230927090904-9dd34510e273
+	cosmossdk.io/x/tx v0.10.0
+	github.com/cosmos/btcutil v1.0.5
+	github.com/cosmos/cosmos-proto v1.0.0-beta.3
+	github.com/cosmos/cosmos-sdk v0.47.5
+	github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc
 	github.com/go-openapi/errors v0.20.4
 	github.com/go-openapi/runtime v0.26.0
 	github.com/go-openapi/strfmt v0.21.7
@@ -11,29 +17,56 @@ require (
 	github.com/google/uuid v1.3.1
 	github.com/pkg/errors v0.9.1
 	github.com/stretchr/testify v1.8.4
+	github.com/tendermint/tendermint v0.35.9
+	golang.org/x/crypto v0.14.0
+	google.golang.org/protobuf v1.31.0
 )
 
 require (
+	cosmossdk.io/core v0.12.0 // indirect
 	github.com/asaskevich/govalidator v0.0.0-20230301143203-a9d515a09cc2 // indirect
-	github.com/davecgh/go-spew v1.1.1 // indirect
+	github.com/btcsuite/btcd v0.22.1 // indirect
+	github.com/cometbft/cometbft v0.38.0 // indirect
+	github.com/cosmos/gogoproto v1.4.11 // indirect
+	github.com/ethereum/go-ethereum v1.13.2 // indirect
 	github.com/go-logr/logr v1.2.4 // indirect
 	github.com/go-logr/stdr v1.2.2 // indirect
 	github.com/go-openapi/analysis v0.21.4 // indirect
 	github.com/go-openapi/jsonpointer v0.20.0 // indirect
 	github.com/go-openapi/jsonreference v0.20.2 // indirect
 	github.com/go-openapi/loads v0.21.2 // indirect
 	github.com/go-openapi/spec v0.20.9 // indirect
+	github.com/gogo/protobuf v1.3.2 // indirect
+	github.com/golang/protobuf v1.5.3 // indirect
+	github.com/google/go-cmp v0.6.0 // indirect
+	github.com/gorilla/websocket v1.5.0 // indirect
 	github.com/josharian/intern v1.0.0 // indirect
+	github.com/klauspost/compress v1.17.0 // indirect
 	github.com/mailru/easyjson v0.7.7 // indirect
+	github.com/mattn/go-colorable v0.1.13 // indirect
+	github.com/mattn/go-isatty v0.0.19 // indirect
 	github.com/mitchellh/mapstructure v1.5.0 // indirect
+	github.com/oasisprotocol/curve25519-voi v0.0.0-20230110094441-db37f07504ce // indirect
 	github.com/oklog/ulid v1.3.1 // indirect
 	github.com/opentracing/opentracing-go v1.2.0 // indirect
-	github.com/pmezard/go-difflib v1.0.0 // indirect
-	github.com/rogpeppe/go-internal v1.11.0 // indirect
+	github.com/petermattis/goid v0.0.0-20230808133559-b036b712a89b // indirect
+	github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect
+	github.com/prometheus/client_golang v1.17.0 // indirect
+	github.com/rcrowley/go-metrics v0.0.0-20201227073835-cf1acfcdf475 // indirect
+	github.com/rs/zerolog v1.31.0 // indirect
+	github.com/sasha-s/go-deadlock v0.3.1 // indirect
 	go.mongodb.org/mongo-driver v1.12.1 // indirect
 	go.opentelemetry.io/otel v1.17.0 // indirect
 	go.opentelemetry.io/otel/metric v1.17.0 // indirect
 	go.opentelemetry.io/otel/trace v1.17.0 // indirect
+	golang.org/x/exp v0.0.0-20231006140011-7918f672742d // indirect
+	golang.org/x/net v0.15.0 // indirect
+	golang.org/x/sys v0.13.0 // indirect
+	golang.org/x/text v0.13.0 // indirect
+	google.golang.org/genproto v0.0.0-20230913181813-007df8e322eb // indirect
+	google.golang.org/genproto/googleapis/api v0.0.0-20230913181813-007df8e322eb // indirect
+	google.golang.org/genproto/googleapis/rpc v0.0.0-20230920204549-e6e6cdab5c13 // indirect
+	google.golang.org/grpc v1.58.2 // indirect
 	gopkg.in/yaml.v2 v2.4.0 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
 )