send.go

package arksdk

import (
	"context"

	client "github.com/arkade-os/arkd/pkg/client-lib"
	clientTypes "github.com/arkade-os/arkd/pkg/client-lib/types"
)

func (a *arkClient) SendOffChain(
	ctx context.Context, receivers []clientTypes.Receiver,
) (string, error) {
	if err := a.safeCheck(); err != nil {
		return "", err
	}

	vtxos, err := a.getSpendableVtxos(ctx, false)
	if err != nil {
		return "", err
	}

	res, err := a.ArkClient.SendOffChain(ctx, receivers, client.WithVtxos(vtxos))
	if err != nil {
		return "", err
	}

	// mark vtxos as spent and add transaction to DB before unlocking the mutex
	if err := a.saveSendTransaction(ctx, *res); err != nil {
		return "", err
	}

	return res.Txid, nil
}

func (a *arkClient) getSpendableVtxos(
	ctx context.Context, withRecoverable bool,
) ([]clientTypes.VtxoWithTapTree, error) {
	a.dbMu.Lock()
	spendableVtxos, err := a.store.VtxoStore().GetSpendableVtxos(ctx)
	a.dbMu.Unlock()
	if err != nil {
		return nil, err
	}
	_, offchainAddrs, _, _, err := a.Wallet().GetAddresses(ctx)
	if err != nil {
		return nil, err
	}
	cfg, err := a.GetConfigData(ctx)
	if err != nil {
		return nil, err
	}

	vtxos := make([]clientTypes.VtxoWithTapTree, 0, len(spendableVtxos))
	for _, offchainAddr := range offchainAddrs {
		for _, v := range spendableVtxos {
			if v.Unrolled || (!withRecoverable && v.IsRecoverable()) {
				continue
			}

			vtxoAddr, err := v.Address(cfg.SignerPubKey, cfg.Network)
			if err != nil {
				return nil, err
			}

			if vtxoAddr == offchainAddr.Address {
				vtxos = append(vtxos, clientTypes.VtxoWithTapTree{
					Vtxo:       v,
					Tapscripts: offchainAddr.Tapscripts,
				})
			}
		}
	}

	return vtxos, nil
}