node/vms/example/xsvm/cmd/issue/importtx/cmd.go

// Copyright (C) 2019-2025, Lux Industries Inc. All rights reserved.
// See the file LICENSE for licensing terms.

package importtx

import (
	"context"
	"fmt"
	"log"
	"time"

	"github.com/spf13/cobra"

	"github.com/luxfi/crypto/bls"
	"github.com/luxfi/formatting"
	"github.com/luxfi/math/set"
	"github.com/luxfi/node/vms/example/xsvm/api"
	"github.com/luxfi/node/vms/example/xsvm/cmd/issue/status"
	"github.com/luxfi/node/vms/example/xsvm/tx"
	"github.com/luxfi/node/vms/platformvm/warp"
	"github.com/luxfi/sdk/info"
)

func Command() *cobra.Command {
	c := &cobra.Command{
		Use:   "import",
		Short: "Issues an import transaction",
		RunE:  importFunc,
	}
	flags := c.Flags()
	AddFlags(flags)
	return c
}

func importFunc(c *cobra.Command, args []string) error {
	flags := c.Flags()
	config, err := ParseFlags(flags, args)
	if err != nil {
		return err
	}

	txStatus, err := Import(c.Context(), config)
	if err != nil {
		return err
	}
	log.Print(txStatus)

	return nil
}

func Import(ctx context.Context, config *Config) (*status.TxIssuance, error) {
	var (
		// Note: here we assume the unsigned message is correct from the last
		//       URI in sourceURIs. In practice this shouldn't be done.
		unsignedMessage *warp.UnsignedMessage
		// Note: assumes that sourceURIs are all of the validators of the chain
		//       and that they do not share public keys.
		signatures = make([]*bls.Signature, len(config.SourceURIs))
	)
	for i, uri := range config.SourceURIs {
		xsClient := api.NewClient(uri, config.SourceChainID)

		fetchStartTime := time.Now()
		var (
			rawSignature []byte
			err          error
		)
		unsignedMessage, rawSignature, err = xsClient.Message(ctx, config.TxID)
		if err != nil {
			return nil, fmt.Errorf("failed to fetch BLS signature from %s with: %w", uri, err)
		}

		sig, err := bls.SignatureFromBytes(rawSignature)
		if err != nil {
			return nil, fmt.Errorf("failed to parse BLS signature from %s with: %w", uri, err)
		}

		// Note: the public key should not be fetched from the node in practice.
		//       The public key should be fetched from the P-chain directly.
		infoClient := info.NewClient(uri)
		_, nodePOP, err := infoClient.GetNodeID(ctx)
		if err != nil {
			return nil, fmt.Errorf("failed to fetch BLS public key from %s with: %w", uri, err)
		}
		if nodePOP == nil {
			return nil, fmt.Errorf("node proof of possession missing from %s", uri)
		}

		pkBytes, err := formatting.Decode(formatting.HexNC, nodePOP.PublicKey)
		if err != nil {
			return nil, fmt.Errorf("failed to decode BLS public key from %s: %w", uri, err)
		}
		pk, err := bls.PublicKeyFromCompressedBytes(pkBytes)
		if err != nil {
			return nil, fmt.Errorf("failed to parse BLS public key from %s: %w", uri, err)
		}
		if !bls.Verify(pk, sig, unsignedMessage.Bytes()) {
			return nil, fmt.Errorf("failed to verify BLS signature against public key from %s", uri)
		}

		log.Printf("fetched BLS signature from %s in %s\n", uri, time.Since(fetchStartTime))
		signatures[i] = sig
	}

	signers := set.NewBits()
	for i := range signatures {
		signers.Add(i)
	}
	signature := &warp.BitSetSignature{
		Signers: signers.Bytes(),
	}

	aggSignature, err := bls.AggregateSignatures(signatures)
	if err != nil {
		return nil, err
	}

	aggSignatureBytes := bls.SignatureToBytes(aggSignature)
	copy(signature.Signature[:], aggSignatureBytes)

	message, err := warp.NewMessage(
		unsignedMessage,
		signature,
	)
	if err != nil {
		return nil, err
	}

	client := api.NewClient(config.URI, config.DestinationChainID)

	address := config.PrivateKey.Address()
	nonce, err := client.Nonce(ctx, address)
	if err != nil {
		return nil, err
	}

	utx := &tx.Import{
		Nonce:   nonce,
		MaxFee:  config.MaxFee,
		Message: message.Bytes(),
	}
	stx, err := tx.Sign(utx, config.PrivateKey)
	if err != nil {
		return nil, err
	}

	issueTxStartTime := time.Now()
	txID, err := client.IssueTx(ctx, stx)
	if err != nil {
		return nil, err
	}

	if err := api.AwaitTxAccepted(ctx, client, address, nonce, api.DefaultPollingInterval); err != nil {
		return nil, err
	}

	return &status.TxIssuance{
		Tx:        stx,
		TxID:      txID,
		Nonce:     nonce,
		StartTime: issueTxStartTime,
	}, nil
}