mirror of
https://github.com/planetmint/planetmint-go.git
synced 2025-03-30 15:08:28 +00:00
1383d0aaa6
* Fix package and domain name Signed-off-by: Julian Strobl <jmastr@mailbox.org> * Add extended public key as `IssuerPlanetmint` This patch introduces parts of the `chaincfg` for Planetmint and especially the magic bytes that produces extended keys with the prefix `pmpr` for a Planetmint extended private key and `pmpb` for a Planetmint extended public key. // Closes https://github.com/rddl-network/issues/issues/30 Signed-off-by: Julian Strobl <jmastr@mailbox.org> * Validate Planetmint extended public key during machine attestation Signed-off-by: Julian Strobl <jmastr@mailbox.org> * [lint] Fix error return value is not checked Signed-off-by: Julian Strobl <jmastr@mailbox.org> --------- Signed-off-by: Julian Strobl <jmastr@mailbox.org>
76 lines
2.1 KiB
Go
76 lines
2.1 KiB
Go
package keeper
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"strconv"
|
|
|
|
config "planetmint-go/config"
|
|
"planetmint-go/x/machine/types"
|
|
|
|
"github.com/btcsuite/btcd/btcutil/hdkeychain"
|
|
"github.com/btcsuite/btcd/chaincfg"
|
|
"github.com/crgimenes/go-osc"
|
|
|
|
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)
|
|
|
|
isValidIssuerPlanetmint := validateExtendedPublicKey(msg.Machine.IssuerPlanetmint, config.PlmntNetParams)
|
|
if !isValidIssuerPlanetmint {
|
|
return nil, errors.New("invalid planetmint key")
|
|
}
|
|
isValidIssuerLiquid := validateExtendedPublicKey(msg.Machine.IssuerLiquid, chaincfg.MainNetParams)
|
|
if !isValidIssuerLiquid {
|
|
return nil, errors.New("invalid liquid key")
|
|
}
|
|
if k.isNFTCreationRequest(msg.Machine) {
|
|
err := k.issueMachineNFT(msg.Machine)
|
|
if err != nil {
|
|
return nil, errors.New("an error occurred while issuing the machine NFT")
|
|
}
|
|
}
|
|
|
|
k.StoreMachine(ctx, *msg.Machine)
|
|
k.StoreMachineIndex(ctx, *msg.Machine)
|
|
|
|
return &types.MsgAttestMachineResponse{}, nil
|
|
}
|
|
|
|
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)
|
|
|
|
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())
|
|
err := client.Send(msg)
|
|
|
|
return err
|
|
}
|