subscription_calls.go

// Code generated by bin/generate_call.go, DO NOT EDIT.
package deriv

import (
	"context"

	"github.com/ksysoev/deriv-api/schema"
)

// SubscribeBalance Get user account balance
func (api *Client) SubscribeBalance(ctx context.Context, r schema.Balance) (rsp schema.BalanceResp, s *Subsciption[schema.BalanceResp, schema.BalanceResp], err error) {
	id := api.getNextRequestID()
	var f schema.BalanceSubscribe = 1
	r.ReqId = &id
	r.Subscribe = &f
	s = NewSubcription[schema.BalanceResp, schema.BalanceResp](ctx, api)
	rsp, err = s.Start(id, r)
	return
}

// SubscribeBuy Buy a Contract
func (api *Client) SubscribeBuy(ctx context.Context, r schema.Buy) (rsp schema.BuyResp, s *Subsciption[schema.BuyResp, schema.ProposalOpenContractResp], err error) {
	id := api.getNextRequestID()
	var f schema.BuySubscribe = 1
	r.ReqId = &id
	r.Subscribe = &f
	s = NewSubcription[schema.BuyResp, schema.ProposalOpenContractResp](ctx, api)
	rsp, err = s.Start(id, r)
	return
}

// SubscribeCryptoEstimations Get the current estimations for cryptocurrencies. E.g. Withdrawal fee.
func (api *Client) SubscribeCryptoEstimations(ctx context.Context, r schema.CryptoEstimations) (rsp schema.CryptoEstimationsResp, s *Subsciption[schema.CryptoEstimationsResp, schema.CryptoEstimationsResp], err error) {
	id := api.getNextRequestID()
	var f schema.CryptoEstimationsSubscribe = 1
	r.ReqId = &id
	r.Subscribe = &f
	s = NewSubcription[schema.CryptoEstimationsResp, schema.CryptoEstimationsResp](ctx, api)
	rsp, err = s.Start(id, r)
	return
}

// SubscribeExchangeRates Retrieves the exchange rate from a base currency to a target currency supported by the system.
func (api *Client) SubscribeExchangeRates(ctx context.Context, r schema.ExchangeRates) (rsp schema.ExchangeRatesResp, s *Subsciption[schema.ExchangeRatesResp, schema.ExchangeRatesResp], err error) {
	id := api.getNextRequestID()
	var f schema.ExchangeRatesSubscribe = 1
	r.ReqId = &id
	r.Subscribe = &f
	s = NewSubcription[schema.ExchangeRatesResp, schema.ExchangeRatesResp](ctx, api)
	rsp, err = s.Start(id, r)
	return
}

// SubscribeP2PAdvertInfo Retrieve information about a P2P advert.
func (api *Client) SubscribeP2PAdvertInfo(ctx context.Context, r schema.P2PAdvertInfo) (rsp schema.P2PAdvertInfoResp, s *Subsciption[schema.P2PAdvertInfoResp, schema.P2PAdvertInfoResp], err error) {
	id := api.getNextRequestID()
	var f schema.P2PAdvertInfoSubscribe = 1
	r.ReqId = &id
	r.Subscribe = &f
	s = NewSubcription[schema.P2PAdvertInfoResp, schema.P2PAdvertInfoResp](ctx, api)
	rsp, err = s.Start(id, r)
	return
}

// SubscribeP2PAdvertiserCreate Registers the client as a P2P advertiser.
func (api *Client) SubscribeP2PAdvertiserCreate(ctx context.Context, r schema.P2PAdvertiserCreate) (rsp schema.P2PAdvertiserCreateResp, s *Subsciption[schema.P2PAdvertiserCreateResp, schema.P2PAdvertInfoResp], err error) {
	id := api.getNextRequestID()
	var f schema.P2PAdvertiserCreateSubscribe = 1
	r.ReqId = &id
	r.Subscribe = &f
	s = NewSubcription[schema.P2PAdvertiserCreateResp, schema.P2PAdvertInfoResp](ctx, api)
	rsp, err = s.Start(id, r)
	return
}

// SubscribeP2PAdvertiserInfo Retrieve information about a P2P advertiser.
func (api *Client) SubscribeP2PAdvertiserInfo(ctx context.Context, r schema.P2PAdvertiserInfo) (rsp schema.P2PAdvertiserInfoResp, s *Subsciption[schema.P2PAdvertiserInfoResp, schema.P2PAdvertiserInfoResp], err error) {
	id := api.getNextRequestID()
	var f schema.P2PAdvertiserInfoSubscribe = 1
	r.ReqId = &id
	r.Subscribe = &f
	s = NewSubcription[schema.P2PAdvertiserInfoResp, schema.P2PAdvertiserInfoResp](ctx, api)
	rsp, err = s.Start(id, r)
	return
}

// SubscribeP2POrderCreate Creates a P2P order for the specified advert.
func (api *Client) SubscribeP2POrderCreate(ctx context.Context, r schema.P2POrderCreate) (rsp schema.P2POrderCreateResp, s *Subsciption[schema.P2POrderCreateResp, schema.P2POrderInfoResp], err error) {
	id := api.getNextRequestID()
	var f schema.P2POrderCreateSubscribe = 1
	r.ReqId = &id
	r.Subscribe = &f
	s = NewSubcription[schema.P2POrderCreateResp, schema.P2POrderInfoResp](ctx, api)
	rsp, err = s.Start(id, r)
	return
}

// SubscribeP2POrderInfo Retrieves the information about a P2P order.
func (api *Client) SubscribeP2POrderInfo(ctx context.Context, r schema.P2POrderInfo) (rsp schema.P2POrderInfoResp, s *Subsciption[schema.P2POrderInfoResp, schema.P2POrderInfoResp], err error) {
	id := api.getNextRequestID()
	var f schema.P2POrderInfoSubscribe = 1
	r.ReqId = &id
	r.Subscribe = &f
	s = NewSubcription[schema.P2POrderInfoResp, schema.P2POrderInfoResp](ctx, api)
	rsp, err = s.Start(id, r)
	return
}

// SubscribeP2POrderList List active orders.
func (api *Client) SubscribeP2POrderList(ctx context.Context, r schema.P2POrderList) (rsp schema.P2POrderListResp, s *Subsciption[schema.P2POrderListResp, schema.P2POrderInfoResp], err error) {
	id := api.getNextRequestID()
	var f schema.P2POrderListSubscribe = 1
	r.ReqId = &id
	r.Subscribe = &f
	s = NewSubcription[schema.P2POrderListResp, schema.P2POrderInfoResp](ctx, api)
	rsp, err = s.Start(id, r)
	return
}

// SubscribeP2PSettings Request P2P Settings information.
func (api *Client) SubscribeP2PSettings(ctx context.Context, r schema.P2PSettings) (rsp schema.P2PSettingsResp, s *Subsciption[schema.P2PSettingsResp, schema.P2PSettingsResp], err error) {
	id := api.getNextRequestID()
	var f schema.P2PSettingsSubscribe = 1
	r.ReqId = &id
	r.Subscribe = &f
	s = NewSubcription[schema.P2PSettingsResp, schema.P2PSettingsResp](ctx, api)
	rsp, err = s.Start(id, r)
	return
}

// SubscribeProposal Gets latest price for a specific contract.
func (api *Client) SubscribeProposal(ctx context.Context, r schema.Proposal) (rsp schema.ProposalResp, s *Subsciption[schema.ProposalResp, schema.ProposalResp], err error) {
	id := api.getNextRequestID()
	var f schema.ProposalSubscribe = 1
	r.ReqId = &id
	r.Subscribe = &f
	s = NewSubcription[schema.ProposalResp, schema.ProposalResp](ctx, api)
	rsp, err = s.Start(id, r)
	return
}

// SubscribeProposalOpenContract Get latest price (and other information) for a contract in the user's portfolio
func (api *Client) SubscribeProposalOpenContract(ctx context.Context, r schema.ProposalOpenContract) (rsp schema.ProposalOpenContractResp, s *Subsciption[schema.ProposalOpenContractResp, schema.ProposalOpenContractResp], err error) {
	id := api.getNextRequestID()
	var f schema.ProposalOpenContractSubscribe = 1
	r.ReqId = &id
	r.Subscribe = &f
	s = NewSubcription[schema.ProposalOpenContractResp, schema.ProposalOpenContractResp](ctx, api)
	rsp, err = s.Start(id, r)
	return
}

// SubscribeTicks Initiate a continuous stream of spot price updates for a given symbol.
func (api *Client) SubscribeTicks(ctx context.Context, r schema.Ticks) (rsp schema.TicksResp, s *Subsciption[schema.TicksResp, schema.TicksResp], err error) {
	id := api.getNextRequestID()
	var f schema.TicksSubscribe = 1
	r.ReqId = &id
	r.Subscribe = &f
	s = NewSubcription[schema.TicksResp, schema.TicksResp](ctx, api)
	rsp, err = s.Start(id, r)
	return
}

// SubscribeTicksBatch Initiate a continuous stream of spot price updates for a group symbols.
func (api *Client) SubscribeTicksBatch(ctx context.Context, r schema.TicksBatch) (rsp schema.TicksBatchResp, s *Subsciption[schema.TicksBatchResp, schema.TicksBatchResp], err error) {
	id := api.getNextRequestID()
	var f schema.TicksBatchSubscribe = 1
	r.ReqId = &id
	r.Subscribe = &f
	s = NewSubcription[schema.TicksBatchResp, schema.TicksBatchResp](ctx, api)
	rsp, err = s.Start(id, r)
	return
}

// SubscribeWebsiteStatus Request server status.
func (api *Client) SubscribeWebsiteStatus(ctx context.Context, r schema.WebsiteStatus) (rsp schema.WebsiteStatusResp, s *Subsciption[schema.WebsiteStatusResp, schema.WebsiteStatusResp], err error) {
	id := api.getNextRequestID()
	var f schema.WebsiteStatusSubscribe = 1
	r.ReqId = &id
	r.Subscribe = &f
	s = NewSubcription[schema.WebsiteStatusResp, schema.WebsiteStatusResp](ctx, api)
	rsp, err = s.Start(id, r)
	return
}