Merge pull request #49 from cloudstruct/feature/parse-tx-for-type

Parse transaction to determine type/era

Author: agaffney

go.mod

@@ -4,6 +4,7 @@ go 1.17
 
 require (
 	github.com/Bitrue-exchange/libada-go v0.0.1-rc.0.20220817020305-79d8b4c4dd9c
+	github.com/cloudstruct/go-cardano-ledger v0.2.1
 	github.com/cloudstruct/go-ouroboros-network v0.14.0
 	github.com/fxamacker/cbor/v2 v2.4.0
 	github.com/gin-contrib/zap v0.0.2

go.sum

@@ -61,6 +61,8 @@ github.com/chzyer/logex v1.1.10/go.mod h1:+Ywpsq7O8HXn0nuIou7OrIPyXbp3wmkHB+jjWR
 github.com/chzyer/readline v0.0.0-20180603132655-2972be24d48e/go.mod h1:nSuG5e5PlCu98SY8svDHJxuZscDgtXS6KTTbou5AhLI=
 github.com/chzyer/test v0.0.0-20180213035817-a1ea475d72b1/go.mod h1:Q3SI9o4m/ZMnBNeIyt5eFwwo7qiLfzFZmjNmxjkiQlU=
 github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw=
+github.com/cloudstruct/go-cardano-ledger v0.2.1 h1:J5DAs5GiP4iROwnukEgQhRdSh94cFFGifjnFNnFBSgU=
+github.com/cloudstruct/go-cardano-ledger v0.2.1/go.mod h1:EBB9JG+3nBs3IV0p751yz1468XYkzJce1/A2X+xH8L8=
 github.com/cloudstruct/go-ouroboros-network v0.14.0 h1:1X56wtgo2a8BLYNuCADjWH1mC6Z0NjkkYrfNtXbyzE0=
 github.com/cloudstruct/go-ouroboros-network v0.14.0/go.mod h1:06ggUMerJLwKJkVi5DLX1QMDz8r+R8o92rht7Z4ss9k=
 github.com/cncf/udpa/go v0.0.0-20191209042840-269d4d468f6f/go.mod h1:M8M6+tZqaGXZJjfX53e64911xZQV5JYwmTeXPW+k8Sc=
@@ -349,6 +351,7 @@ golang.org/x/crypto v0.0.0-20210711020723-a769d52b0f97/go.mod h1:GvvjBRRGRdwPK5y
 golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc=
 golang.org/x/crypto v0.0.0-20211215153901-e495a2d5b3d3/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4=
 golang.org/x/crypto v0.0.0-20220131195533-30dcbda58838/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4=
+golang.org/x/crypto v0.0.0-20220824171710-5757bc0c5503/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4=
 golang.org/x/crypto v0.0.0-20220826181053-bd7e27e6170d h1:3qF+Z8Hkrw9sOhrFHti9TlB1Hkac1x+DNRkv0XQiFjo=
 golang.org/x/crypto v0.0.0-20220826181053-bd7e27e6170d/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4=
 golang.org/x/exp v0.0.0-20190121172915-509febef88a4/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA=

internal/api/api.go

@@ -3,10 +3,10 @@ package api
 import (
 	"encoding/hex"
 	"fmt"
+	"github.com/cloudstruct/go-cardano-ledger"
 	"github.com/cloudstruct/go-cardano-submit-api/internal/config"
 	"github.com/cloudstruct/go-cardano-submit-api/internal/logging"
 	ouroboros "github.com/cloudstruct/go-ouroboros-network"
-	"github.com/cloudstruct/go-ouroboros-network/block"
 	"github.com/cloudstruct/go-ouroboros-network/protocol/localtxsubmission"
 	"github.com/fxamacker/cbor/v2"
 	ginzap "github.com/gin-contrib/zap"
@@ -54,8 +54,8 @@ func Start(cfg *config.Config) error {
 	}
 	router.Use(ginzap.GinzapWithConfig(accessLogger, &ginzap.Config{
 		TimeFormat: time.RFC3339,
-		UTC: true,
-		SkipPaths: skipPaths,
+		UTC:        true,
+		SkipPaths:  skipPaths,
 	}))
 	router.Use(ginzap.RecoveryWithZap(accessLogger, true))
 
@@ -235,12 +235,44 @@ func handleSubmitTx(c *gin.Context) {
 		},
 	}
 	oConn.LocalTxSubmission.Start(localTxSubmissionCallbackConfig)
-	// TODO: figure out better way to determine era
-	if err = oConn.LocalTxSubmission.SubmitTx(block.TX_TYPE_ALONZO, txRawBytes); err != nil {
+	// Determine transaction type (era)
+	txType, err := determineTransactionType(txRawBytes)
+	if err != nil {
+		c.String(400, "could not parse transaction to determine type")
+		return
+	}
+	// Submit the transaction
+	if err := oConn.LocalTxSubmission.SubmitTx(txType, txRawBytes); err != nil {
 		logger.Errorf("failure submitting transaction: %s", err)
 		c.String(500, "failure communicating with node")
 		return
 	}
 	// Wait for async process to finish
 	<-doneChan
 }
+
+func determineTransactionType(data []byte) (uint16, error) {
+	// TODO: uncomment this once the following issue is resolved:
+	// https://github.com/cloudstruct/go-cardano-ledger/issues/9
+	/*
+		if _, err := ledger.NewByronTransactionFromCbor(data); err == nil {
+			return ledger.TX_TYPE_BYRON, nil
+		}
+	*/
+	if _, err := ledger.NewShelleyTransactionFromCbor(data); err == nil {
+		return ledger.TX_TYPE_SHELLEY, nil
+	}
+	if _, err := ledger.NewAllegraTransactionFromCbor(data); err == nil {
+		return ledger.TX_TYPE_ALLEGRA, nil
+	}
+	if _, err := ledger.NewMaryTransactionFromCbor(data); err == nil {
+		return ledger.TX_TYPE_MARY, nil
+	}
+	if _, err := ledger.NewAlonzoTransactionFromCbor(data); err == nil {
+		return ledger.TX_TYPE_ALONZO, nil
+	}
+	if _, err := ledger.NewBabbageTransactionFromCbor(data); err == nil {
+		return ledger.TX_TYPE_BABBAGE, nil
+	}
+	return 0, fmt.Errorf("unknown transaction type")
+}