trade

Documentation

Index

• Variables
• type Service
  • func NewService(walletSvc *wallet.Service, pubsubSvc *pubsub.Service, ...) (*Service, error)
  • func (s *Service) GetMarketBalance(ctx context.Context, market ports.Market) (ports.MarketInfo, error)
  • func (s *Service) GetMarketPrice(ctx context.Context, market ports.Market) (decimal.Decimal, uint64, error)
  • func (s *Service) GetTradableMarkets(ctx context.Context) ([]ports.MarketInfo, error)
  • func (s *Service) TradeComplete(ctx context.Context, swapComplete ports.SwapComplete, swapFail ports.SwapFail) (txidRes string, swapFailRes ports.SwapFail, err error)
  • func (s *Service) TradePreview(ctx context.Context, market ports.Market, tradeType ports.TradeType, ...) (ports.TradePreview, error)
  • func (s *Service) TradePropose(ctx context.Context, market ports.Market, tradeType ports.TradeType, ...) (ports.SwapAccept, ports.SwapFail, int64, error)

Variables

var (
	ErrServiceUnavailable = fmt.Errorf("service is unavailable, retry later")
	ErrMarketUnavailable  = fmt.Errorf("market is closed, retry later")
)

Types

type Service

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

func NewService

func NewService(
	walletSvc *wallet.Service,
	pubsubSvc *pubsub.Service,
	repoManager ports.RepoManager,
	priceSlippage, satsPerByte decimal.Decimal,
) (*Service, error)

func (*Service) GetMarketBalance

func (s *Service) GetMarketBalance(
	ctx context.Context, market ports.Market,
) (ports.MarketInfo, error)

func (*Service) GetMarketPrice

func (s *Service) GetMarketPrice(
	ctx context.Context, market ports.Market,
) (decimal.Decimal, uint64, error)

func (*Service) GetTradableMarkets

func (s *Service) GetTradableMarkets(ctx context.Context) ([]ports.MarketInfo, error)

func (*Service) TradeComplete

func (s *Service) TradeComplete(
	ctx context.Context,
	swapComplete ports.SwapComplete, swapFail ports.SwapFail,
) (txidRes string, swapFailRes ports.SwapFail, err error)

func (*Service) TradePreview

func (s *Service) TradePreview(
	ctx context.Context, market ports.Market,
	tradeType ports.TradeType, amount uint64, asset, feeAsset string,
) (ports.TradePreview, error)

func (*Service) TradePropose

func (s *Service) TradePropose(
	ctx context.Context, market ports.Market,
	tradeType ports.TradeType, swapRequest ports.SwapRequest,
) (ports.SwapAccept, ports.SwapFail, int64, error)