mirror of
https://github.com/planetmint/planetmint-go.git
synced 2025-05-22 14:56:39 +00:00
95 lines
3.0 KiB
Go
95 lines
3.0 KiB
Go
package keeper
|
|
|
|
import (
|
|
"context"
|
|
"strconv"
|
|
|
|
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"
|
|
"github.com/crgimenes/go-osc"
|
|
|
|
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) {
|
|
err := k.issueMachineNFT(msg.Machine)
|
|
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) issueMachineNFT(machine *types.Machine) error {
|
|
conf := config.GetConfig()
|
|
client := osc.NewClient(conf.WatchmenEndpoint, conf.WatchmenPort)
|
|
machine_precision := strconv.FormatInt(int64(machine.Precision), 10)
|
|
machine_amount := strconv.FormatInt(int64(machine.Amount), 10)
|
|
machine_type := strconv.FormatUint(uint64(machine.GetType()), 10)
|
|
|
|
msg := osc.NewMessage("/rddl/issue")
|
|
msg.Append(machine.Name)
|
|
msg.Append(machine.Ticker)
|
|
msg.Append(machine.Domain)
|
|
msg.Append(machine_amount)
|
|
msg.Append("1")
|
|
msg.Append(machine_precision)
|
|
msg.Append(machine.Metadata.GetAdditionalDataCID())
|
|
msg.Append(machine.GetIssuerPlanetmint())
|
|
msg.Append(machine_type)
|
|
err := client.Send(msg)
|
|
|
|
return err
|
|
}
|