mirror of
https://github.com/planetmint/planetmint-go.git
synced 2025-05-22 14:56:39 +00:00
1e1138d026
* [ci] Switch from `nosnakecase` to `revive` * [revive] Fix findings Signed-off-by: Julian Strobl <jmastr@mailbox.org>
122 lines
3.7 KiB
Go
122 lines
3.7 KiB
Go
package keeper
|
|
|
|
import (
|
|
"bytes"
|
|
"context"
|
|
"os/exec"
|
|
"strings"
|
|
|
|
config "github.com/planetmint/planetmint-go/config"
|
|
"github.com/planetmint/planetmint-go/util"
|
|
"github.com/planetmint/planetmint-go/x/machine/types"
|
|
|
|
"github.com/btcsuite/btcd/btcutil/hdkeychain"
|
|
"github.com/btcsuite/btcd/chaincfg"
|
|
|
|
errorsmod "cosmossdk.io/errors"
|
|
sdk "github.com/cosmos/cosmos-sdk/types"
|
|
)
|
|
|
|
func (k msgServer) isNFTCreationRequest(machine *types.Machine) bool {
|
|
if !machine.GetReissue() && machine.GetAmount() == 1 && machine.GetPrecision() == 8 {
|
|
return true
|
|
}
|
|
return false
|
|
}
|
|
func (k msgServer) AttestMachine(goCtx context.Context, msg *types.MsgAttestMachine) (*types.MsgAttestMachineResponse, error) {
|
|
ctx := sdk.UnwrapSDKContext(goCtx)
|
|
|
|
// the ante handler verifies that the MachineID exists. Additional result checks got moved to the ante-handler
|
|
// and removed from here due to inconsistency or checking the same thing over and over again.
|
|
ta, _, _ := k.GetTrustAnchor(ctx, msg.Machine.MachineId)
|
|
|
|
isValidMachineID, err := util.ValidateSignature(msg.Machine.MachineId, msg.Machine.MachineIdSignature, msg.Machine.MachineId)
|
|
if !isValidMachineID {
|
|
return nil, err
|
|
}
|
|
|
|
isValidIssuerPlanetmint := validateExtendedPublicKey(msg.Machine.IssuerPlanetmint, config.PlmntNetParams)
|
|
if !isValidIssuerPlanetmint {
|
|
return nil, errorsmod.Wrap(types.ErrInvalidKey, "planetmint")
|
|
}
|
|
isValidIssuerLiquid := validateExtendedPublicKey(msg.Machine.IssuerLiquid, config.LiquidNetParams)
|
|
if !isValidIssuerLiquid {
|
|
return nil, errorsmod.Wrap(types.ErrInvalidKey, "liquid")
|
|
}
|
|
|
|
if k.isNFTCreationRequest(msg.Machine) && util.IsValidatorBlockProposer(ctx, ctx.BlockHeader().ProposerAddress) {
|
|
_ = k.issueMachineNFT(ctx, msg.Machine)
|
|
//TODO create NFTCreationMessage to be stored by all nodes
|
|
// if err != nil {
|
|
// return nil, types.ErrNFTIssuanceFailed
|
|
// }
|
|
}
|
|
|
|
if msg.Machine.GetType() == 0 { // 0 == RDDL_MACHINE_UNDEFINED
|
|
return nil, types.ErrMachineTypeUndefined
|
|
}
|
|
|
|
k.StoreMachine(ctx, *msg.Machine)
|
|
k.StoreMachineIndex(ctx, *msg.Machine)
|
|
err = k.StoreTrustAnchor(ctx, ta, true)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return &types.MsgAttestMachineResponse{}, err
|
|
}
|
|
|
|
func validateExtendedPublicKey(issuer string, cfg chaincfg.Params) bool {
|
|
xpubKey, err := hdkeychain.NewKeyFromString(issuer)
|
|
if err != nil {
|
|
return false
|
|
}
|
|
isValidExtendedPublicKey := xpubKey.IsForNet(&cfg)
|
|
return isValidExtendedPublicKey
|
|
}
|
|
|
|
func (k msgServer) issueNFTAsset(ctx sdk.Context, name string, machineAddress string) (assetID string, contract string, err error) {
|
|
conf := config.GetConfig()
|
|
logger := ctx.Logger()
|
|
|
|
cmdName := "poetry"
|
|
cmdArgs := []string{"run", "python", "issuer_service/issue2liquid.py", name, machineAddress}
|
|
|
|
// Create a new command
|
|
cmd := exec.Command(cmdName, cmdArgs...)
|
|
|
|
// If you want to set the working directory
|
|
cmd.Dir = conf.IssuanceServiceDir
|
|
|
|
// Capture the output
|
|
var stdout, stderr bytes.Buffer
|
|
cmd.Stdout = &stdout
|
|
cmd.Stderr = &stderr
|
|
|
|
// Execute the command
|
|
err = cmd.Run()
|
|
if err != nil {
|
|
logger.Error("cmd.Run() failed with %s\n", err)
|
|
err = errorsmod.Wrap(types.ErrMachineNFTIssuance, stderr.String())
|
|
} else {
|
|
lines := strings.Split(stdout.String(), "\n")
|
|
if len(lines) == 3 {
|
|
assetID = lines[0]
|
|
contract = lines[1]
|
|
} else {
|
|
err = errorsmod.Wrap(types.ErrMachineNFTIssuanceNoOutput, stderr.String())
|
|
}
|
|
}
|
|
return assetID, contract, err
|
|
}
|
|
|
|
func (k msgServer) issueMachineNFT(ctx sdk.Context, machine *types.Machine) error {
|
|
_, _, err := k.issueNFTAsset(ctx, machine.Name, machine.Address)
|
|
return err
|
|
// asset registration is not performed in case of NFT issuance for machines
|
|
//assetID, contract, err := k.issueNFTAsset(machine.Name, machine.Address)
|
|
// if err != nil {
|
|
// return err
|
|
// }
|
|
//return k.registerAsset(assetID, contract)
|
|
}
|