application

package
v0.3.20 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 15, 2026 License: MIT Imports: 43 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	WalletInit   = "init"
	WalletUnlock = "unlock"
	WalletReset  = "reset"
)

Variables

View Source 
var ErrorNoVtxosFound = fmt.Errorf("no vtxos found for the given vhtlc opts")

Functions

func NewServices added in v0.3.14 

func NewServices(
	buildInfo BuildInfo,
	datadir string,
	dbSvc ports.RepoManager,
	schedulerSvc ports.SchedulerService,
	esploraUrl, boltzUrl, boltzWSUrl string, swapTimeout uint32,
	connectionOpts *domain.LnConnectionOpts,
	refreshDbInterval int64,
	delegatorConfig DelegatorConfig,
) (*Service, *DelegatorService, error)

Types

type BuildInfo 

type BuildInfo struct {
	Version string
	Commit  string
	Date    string
}

type DelegateInfo added in v0.3.14 

type DelegateInfo struct {
	DelegatorPublicKey string
	Fee                uint64
	DelegatorAddress   string
}

type DelegatorConfig added in v0.3.14 

type DelegatorConfig struct {
	Enabled bool
	Fee     uint64
}

type DelegatorService added in v0.3.14 

type DelegatorService struct {
	// contains filtered or unexported fields
}

func (*DelegatorService) Delegate added in v0.3.14 

func (s *DelegatorService) Delegate(
	ctx context.Context,
	intentMessage intent.RegisterMessage, intentProof intent.Proof, forfeitTxs []*psbt.Packet,
	allowReplace bool,
) error

Delegate creates a delegate task, then schedules it for execution if valid

func (*DelegatorService) GetDelegatorInfo added in v0.3.14 

func (s *DelegatorService) GetDelegatorInfo(ctx context.Context) (*DelegateInfo, error)

GetDelegatorInfo returns the data needed to create the intent & forfeit tx for a delegate task.

func (*DelegatorService) Stop added in v0.3.14 

func (s *DelegatorService) Stop()

type Notification 

type Notification struct {
	indexer.TxData
	Addrs       []string
	NewVtxos    []clientTypes.Vtxo
	SpentVtxos  []clientTypes.Vtxo
	Checkpoints map[string]indexer.TxData
}

type Service 

type Service struct {
	BuildInfo BuildInfo

	arksdk.ArkClient
	// contains filtered or unexported fields
}

func (*Service) AddDefaultSettings 

func (s *Service) AddDefaultSettings(ctx context.Context) error

func (*Service) ClaimVHTLC 

func (s *Service) ClaimVHTLC(
	ctx context.Context, preimage []byte, vhtlc_id string, outpoint *clientTypes.Outpoint,
) (string, error)

func (*Service) ConnectLN 

func (s *Service) ConnectLN(ctx context.Context, lnUrl string) error

func (*Service) CreateBtcToArkChainSwap added in v0.3.16 

func (s *Service) CreateBtcToArkChainSwap(
	ctx context.Context,
	amount uint64,
) (*domain.ChainSwap, error)

CreateBtcToArkChainSwap initiates BTC → Ark chain swap

func (*Service) CreateChainSwapArkToBtc added in v0.3.16 

func (s *Service) CreateChainSwapArkToBtc(
	_ context.Context,
	amount uint64,
	btcAddress string,
) (*domain.ChainSwap, error)

CreateChainSwapArkToBtc initiates Ark → BTC chain swap

func (*Service) DisconnectLN 

func (s *Service) DisconnectLN()

func (*Service) GetAddress 

func (s *Service) GetAddress(
	ctx context.Context, sats uint64,
) (bip21Addr, offchainAddr, boardingAddr, invoice, pubkey string, err error)

func (*Service) GetBalanceLN 

func (s *Service) GetBalanceLN(ctx context.Context) (balance uint64, err error)

func (*Service) GetDelegateTaskByID added in v0.3.14 

func (s *Service) GetDelegateTaskByID(
	ctx context.Context, id string,
) (*domain.DelegateTask, error)

func (*Service) GetDelegateTasks added in v0.3.14 

func (s *Service) GetDelegateTasks(
	ctx context.Context, status domain.DelegateTaskStatus, limit, offset int,
) ([]domain.DelegateTask, error)

func (*Service) GetInvoice 

func (s *Service) GetInvoice(ctx context.Context, amount uint64) (*SwapResponse, error)

func (*Service) GetLnConnectUrl added in v0.3.0 

func (s *Service) GetLnConnectUrl() string

func (*Service) GetRound 

func (s *Service) GetRound(ctx context.Context, roundId string) (*indexer.CommitmentTx, error)

func (*Service) GetSettings 

func (s *Service) GetSettings(ctx context.Context) (*domain.Settings, error)

func (*Service) GetSwapHistory added in v0.1.12 

func (s *Service) GetSwapHistory(ctx context.Context) ([]domain.Swap, error)

func (*Service) GetSwapVHTLC added in v0.3.8 

func (s *Service) GetSwapVHTLC(
	ctx context.Context,
	receiverPubkey, senderPubkey *btcec.PublicKey,
	preimageHash []byte,
	refundLocktimeParam *arklib.AbsoluteLocktime,
	unilateralClaimDelayParam *arklib.RelativeLocktime,
	unilateralRefundDelayParam *arklib.RelativeLocktime,
	unilateralRefundWithoutReceiverDelayParam *arklib.RelativeLocktime,
) (string, string, *vhtlc.VHTLCScript, error)

func (*Service) GetSyncedUpdate added in v0.3.0 

func (s *Service) GetSyncedUpdate() <-chan types.SyncEvent

func (*Service) GetTotalBalance 

func (s *Service) GetTotalBalance(ctx context.Context) (uint64, error)

func (*Service) GetVirtualTxs added in v0.3.0 

func (s *Service) GetVirtualTxs(ctx context.Context, txids []string) ([]string, error)

func (*Service) GetVtxoNotifications 

func (s *Service) GetVtxoNotifications(ctx context.Context) <-chan Notification

func (*Service) GetVtxos added in v0.3.12 

func (s *Service) GetVtxos(ctx context.Context, filterType string) ([]clientTypes.Vtxo, error)

func (*Service) GetWalletUpdates added in v0.1.12 

func (s *Service) GetWalletUpdates() <-chan WalletUpdate

func (*Service) IncreaseInboundCapacity 

func (s *Service) IncreaseInboundCapacity(ctx context.Context, amount uint64) (string, error)

ln -> ark (reverse submarine swap)

func (*Service) IncreaseOutboundCapacity 

func (s *Service) IncreaseOutboundCapacity(
	ctx context.Context, amount uint64,
) (SwapResponse, error)

ark -> ln (submarine swap)

func (*Service) IsConnectedLN 

func (s *Service) IsConnectedLN() bool

func (*Service) IsInitialized added in v0.3.0 

func (s *Service) IsInitialized() bool

func (*Service) IsInvoiceSettled 

func (s *Service) IsInvoiceSettled(ctx context.Context, invoice string) (bool, error)

func (*Service) IsLocked added in v0.1.8 

func (s *Service) IsLocked(ctx context.Context) bool

func (*Service) IsPreConfiguredLN added in v0.3.0 

func (s *Service) IsPreConfiguredLN() bool

func (*Service) IsSynced added in v0.3.0 

func (s *Service) IsSynced() (bool, error)

func (*Service) ListChainSwaps added in v0.3.16 

func (s *Service) ListChainSwaps(
	ctx context.Context, swapIDs []string,
) ([]domain.ChainSwap, error)

func (*Service) ListVHTLC 

func (s *Service) ListVHTLC(
	ctx context.Context, vhtlc_id string,
) ([]clientTypes.Vtxo, []domain.Vhtlc, error)

func (*Service) ListVHTLCs added in v0.3.19 

func (s *Service) ListVHTLCs(
	ctx context.Context, vhtlcIds []string,
) ([]clientTypes.Vtxo, []domain.Vhtlc, error)

func (*Service) LockNode 

func (s *Service) LockNode(ctx context.Context) error

func (*Service) NewSettings 

func (s *Service) NewSettings(ctx context.Context, settings domain.Settings) error

func (*Service) PayInvoice 

func (s *Service) PayInvoice(ctx context.Context, invoice string) (*SwapResponse, error)

func (*Service) PayOffer added in v0.3.0 

func (s *Service) PayOffer(ctx context.Context, offer string) (*SwapResponse, error)

func (*Service) RefundChainSwap added in v0.3.16 

func (s *Service) RefundChainSwap(ctx context.Context, id string) error

func (*Service) RefundVHTLC added in v0.1.4 

func (s *Service) RefundVHTLC(
	ctx context.Context, swapId, vhtlc_id string, withReceiver bool, outpoint *clientTypes.Outpoint,
) (string, error)

func (*Service) ResetWallet added in v0.1.8 

func (s *Service) ResetWallet(ctx context.Context) error

func (*Service) SendOnChain added in v0.3.0 

func (s *Service) SendOnChain(ctx context.Context, addr string, amount uint64) (string, error)

func (*Service) Settle added in v0.1.6 

func (s *Service) Settle(ctx context.Context) (string, error)

func (*Service) SettleVHTLCWithClaimPath added in v0.3.11 

func (s *Service) SettleVHTLCWithClaimPath(
	ctx context.Context, vhtlcId string, preimage []byte, outpoint *clientTypes.Outpoint,
) (string, error)

SettleVHTLCWithClaimPath settles a VHTLC via claim path (revealing preimage) in a batch session.

func (*Service) SettleVHTLCWithCollaborativeRefundPath added in v0.3.11 

func (s *Service) SettleVHTLCWithCollaborativeRefundPath(
	ctx context.Context, vhtlcId, intentProof, intentMessage, partialForfeitTx string,
	outpoint *clientTypes.Outpoint,
) (string, error)

SettleVHTLCWithCollaborativeRefundPath settles a VHTLC via delegate refund path. The counterparty creates the intent and partial forfeit, and Fulmine acts as delegate to complete the batch session.

func (*Service) SettleVHTLCWithRefundPath added in v0.3.11 

func (s *Service) SettleVHTLCWithRefundPath(
	ctx context.Context, vhtlcId string, outpoint *clientTypes.Outpoint,
) (string, error)

SettleVHTLCWithRefundPath settles a VHTLC via refund path in a batch session.

func (*Service) Setup 

func (s *Service) Setup(ctx context.Context, serverUrl, password, privateKey string) (err error)

func (*Service) SetupFromMnemonic 

func (s *Service) SetupFromMnemonic(
	ctx context.Context, serverUrl, password, mnemonic string,
) error

func (*Service) SubscribeForAddresses 

func (s *Service) SubscribeForAddresses(ctx context.Context, addresses []string) error

func (*Service) UnlockNode 

func (s *Service) UnlockNode(ctx context.Context, password string) error

func (*Service) UnsubscribeForAddresses 

func (s *Service) UnsubscribeForAddresses(ctx context.Context, addresses []string) error

func (*Service) UpdateSettings 

func (s *Service) UpdateSettings(ctx context.Context, settings domain.Settings) error

func (*Service) WhenNextSettlement added in v0.1.8 

func (s *Service) WhenNextSettlement(ctx context.Context) time.Time

type SwapResponse added in v0.3.0 

type SwapResponse struct {
	TxId       string
	SwapStatus domain.SwapStatus
	Invoice    string
}

type WalletUpdate added in v0.1.12 

type WalletUpdate struct {
	Type     string
	Password string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.