You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
91 lines
3.3 KiB
91 lines
3.3 KiB
package services
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/coinbase/rosetta-sdk-go/types"
|
|
"github.com/pkg/errors"
|
|
|
|
hmyTypes "github.com/harmony-one/harmony/core/types"
|
|
"github.com/harmony-one/harmony/rosetta/common"
|
|
stakingTypes "github.com/harmony-one/harmony/staking/types"
|
|
)
|
|
|
|
// ConstructionHash implements the /construction/hash endpoint.
|
|
func (s *ConstructAPI) ConstructionHash(
|
|
ctx context.Context, request *types.ConstructionHashRequest,
|
|
) (*types.TransactionIdentifierResponse, *types.Error) {
|
|
if err := assertValidNetworkIdentifier(request.NetworkIdentifier, s.hmy.ShardID); err != nil {
|
|
return nil, err
|
|
}
|
|
_, tx, rosettaError := unpackWrappedTransactionFromString(request.SignedTransaction)
|
|
if rosettaError != nil {
|
|
return nil, rosettaError
|
|
}
|
|
if tx == nil {
|
|
return nil, common.NewError(common.CatchAllError, map[string]interface{}{
|
|
"message": "nil transaction",
|
|
})
|
|
}
|
|
return &types.TransactionIdentifierResponse{
|
|
TransactionIdentifier: &types.TransactionIdentifier{Hash: tx.Hash().String()},
|
|
}, nil
|
|
}
|
|
|
|
// ConstructionSubmit implements the /construction/submit endpoint.
|
|
func (s *ConstructAPI) ConstructionSubmit(
|
|
ctx context.Context, request *types.ConstructionSubmitRequest,
|
|
) (*types.TransactionIdentifierResponse, *types.Error) {
|
|
if err := assertValidNetworkIdentifier(request.NetworkIdentifier, s.hmy.ShardID); err != nil {
|
|
return nil, err
|
|
}
|
|
wrappedTransaction, tx, rosettaError := unpackWrappedTransactionFromString(request.SignedTransaction)
|
|
if rosettaError != nil {
|
|
return nil, rosettaError
|
|
}
|
|
if wrappedTransaction == nil || tx == nil {
|
|
return nil, common.NewError(common.CatchAllError, map[string]interface{}{
|
|
"message": "nil wrapped transaction or nil unwrapped transaction",
|
|
})
|
|
}
|
|
|
|
wrappedSenderAddress, err := getAddress(wrappedTransaction.From)
|
|
if err != nil {
|
|
return nil, common.NewError(common.InvalidTransactionConstructionError, map[string]interface{}{
|
|
"message": errors.WithMessage(err, "unable to get address from wrapped transaction"),
|
|
})
|
|
}
|
|
txSenderAddress, err := tx.SenderAddress()
|
|
if err != nil {
|
|
return nil, common.NewError(common.InvalidTransactionConstructionError, map[string]interface{}{
|
|
"message": errors.WithMessage(err, "unable to get sender address from transaction").Error(),
|
|
})
|
|
}
|
|
if wrappedSenderAddress != txSenderAddress {
|
|
return nil, common.NewError(common.InvalidTransactionConstructionError, map[string]interface{}{
|
|
"message": "transaction sender address does not match wrapped transaction sender address",
|
|
})
|
|
}
|
|
|
|
if stakingTx, ok := tx.(*stakingTypes.StakingTransaction); ok && wrappedTransaction.IsStaking {
|
|
if err := s.hmy.SendStakingTx(ctx, stakingTx); err != nil {
|
|
return nil, common.NewError(common.StakingTransactionSubmissionError, map[string]interface{}{
|
|
"message": err.Error(),
|
|
})
|
|
}
|
|
} else if plainTx, ok := tx.(*hmyTypes.Transaction); ok && !wrappedTransaction.IsStaking {
|
|
if err := s.hmy.SendTx(ctx, plainTx); err != nil {
|
|
return nil, common.NewError(common.TransactionSubmissionError, map[string]interface{}{
|
|
"message": err.Error(),
|
|
})
|
|
}
|
|
} else {
|
|
return nil, common.NewError(common.CatchAllError, map[string]interface{}{
|
|
"message": "invalid/inconsistent type or unknown transaction type stored in wrapped transaction",
|
|
})
|
|
}
|
|
|
|
return &types.TransactionIdentifierResponse{
|
|
TransactionIdentifier: &types.TransactionIdentifier{Hash: tx.Hash().String()},
|
|
}, nil
|
|
}
|
|
|