optionscrapers

type AllOKExOptionsScrapers struct {
	Scrapers []*OKExOptionsScraper
	Markets  []string
	// contains filtered or unexported fields
}

type DeribitETHOptionScraper struct {
	PollFrequency      int8
	ScraperIsRunning   bool
	ScraperIsRunningMu sync.Mutex

	DataStore *models.DB

	Ratelimiter *rate.Limiter
	// contains filtered or unexported fields
}

type DeribitInstrument struct {
	TickSize                 float64 `json:"tick_size"`
	TakerCommission          float64 `json:"taker_commission"`
	Strike                   float64 `json:"strike,omitempty"`
	SettlementPeriod         string  `json:"settlement_period"`
	QuoteCurrency            string  `json:"quote_currency"`
	OptionType               string  `json:"option_type,omitempty"`
	MinTradeAmount           int     `json:"min_trade_amount"`
	MakerCommission          float64 `json:"maker_commission"`
	Kind                     string  `json:"kind"`
	IsActive                 bool    `json:"is_active"`
	InstrumentName           string  `json:"instrument_name"`
	ExpirationTimestamp      int64   `json:"expiration_timestamp"`
	CreationTimestamp        int64   `json:"creation_timestamp"`
	ContractSize             float64 `json:"contract_size"`
	BlockTradeCommission     float64 `json:"block_trade_commission"`
	BaseCurrency             string  `json:"base_currency"`
	MaxLiquidationCommission float64 `json:"max_liquidation_commission,omitempty"`
	MaxLeverage              int     `json:"max_leverage,omitempty"`
}

type DeribitInstrumentsResponse struct {
	Jsonrpc string              `json:"jsonrpc"`
	Result  []DeribitInstrument `json:"result"`
	UsIn    int64               `json:"usIn"`
	UsOut   int64               `json:"usOut"`
	UsDiff  int                 `json:"usDiff"`
	Testnet bool                `json:"testnet"`
}

type DeribitOptionResponse struct {
	Jsonrpc string `json:"jsonrpc"`
	Method  string `json:"method"`
	Params  struct {
		Channel string `json:"channel"`
		Data    struct {
			Asks           [][]interface{} `json:"asks,omitempty"`
			Bids           [][]interface{} `json:"bids,omitempty"`
			ChangeID       int64           `json:"change_id"`
			InstrumentName string          `json:"instrument_name"`
			PrevChangeID   int64           `json:"prev_change_id"`
			Timestamp      int64           `json:"timestamp"`
			Type           string          `json:"type"`
		} `json:"data"`
	} `json:"params"`
}

type DeribitOptionsResponse struct {
	Jsonrpc string              `json:"jsonrpc"`
	Result  []DeribitInstrument `json:"result"`
	UsIn    int64               `json:"usIn"`
	UsOut   int64               `json:"usOut"`
	UsDiff  int                 `json:"usDiff"`
	Testnet bool                `json:"testnet"`
}

type DeribitParam struct {
	Channels []string `json:"channels"`
}

type DeribitRequest struct {
	Jsonrpc string      `json:"jsonrpc"`
	ID      int         `json:"id"`
	Method  string      `json:"method"`
	Params  interface{} `json:"params"`
}

type OKExInstrument struct {
	InstrumentName        string `json:"instrument_id"`
	Underlying            string `json:"underlying"`
	SettlementCurrency    string `json:"settlement_currency"`
	MinTradeAmount        string `json:"contract_val"`
	OptionType            string `json:"option_type"`
	Strike                string `json:"strike"`
	TickSize              string `json:"tick_size"`
	LotSize               string `json:"lot_size"`
	Listing               string `json:"listing"`
	Expiration            string `json:"delivery"`
	State                 string `json:"state"`
	TradingStartTimestamp string `json:"trading_start_time"`
}

type OKExInstrumentDetail struct {
	Category           string    `json:"category"`
	ContractVal        string    `json:"contract_val"`
	Delivery           time.Time `json:"delivery"`
	InstrumentID       string    `json:"instrument_id"`
	Listing            time.Time `json:"listing"`
	LotSize            string    `json:"lot_size"`
	OptionType         string    `json:"option_type"`
	SettlementCurrency string    `json:"settlement_currency"`
	State              string    `json:"state"`
	Strike             string    `json:"strike"`
	TickSize           string    `json:"tick_size"`
	Timestamp          time.Time `json:"timestamp"`
	TradingStartTime   time.Time `json:"trading_start_time"`
	Underlying         string    `json:"underlying"`
}

type OKExInstrumentDetails []OKExInstrumentDetail

type OKExInstruments struct {
	Result []OKExInstrument `json:"result"`
}

type OKExOptionState int

type OKExOptionsScraper struct {
	Markets []string

	// OKEx Options endpoint is a REST one and you are limited to 20 requests per 2 seconds. So you have
	// to throttle your polling frequency. This is in seconds. So you can have at most 10
	// markets running at the same time on the same ip address
	PollFrequency      int8
	ScraperIsRunning   bool
	ScraperIsRunningMu sync.Mutex
	// optionsWaitGroup   *sync.WaitGroup
	DataStore *models.DB

	Ratelimiter *rate.Limiter
	// contains filtered or unexported fields
}

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

type OptionsScraper interface {
	//io.Closer
	FetchInstruments()
	Scrape()
	// Channel returns a channel that can be used to receive trades
	Channel() chan *dia.OptionOrderbookDatum
}

type OpynInstrumentsResponse struct {
	Bids struct {
		Total   int `json:"total"`
		Page    int `json:"page"`
		PerPage int `json:"perPage"`
		Records []struct {
			Order struct {
				Signature struct {
					SignatureType int    `json:"signatureType"`
					R             string `json:"r"`
					S             string `json:"s"`
					V             int    `json:"v"`
				} `json:"signature"`
				Sender              string `json:"sender"`
				Maker               string `json:"maker"`
				Taker               string `json:"taker"`
				TakerTokenFeeAmount string `json:"takerTokenFeeAmount"`
				MakerAmount         string `json:"makerAmount"`
				TakerAmount         string `json:"takerAmount"`
				MakerToken          string `json:"makerToken"`
				TakerToken          string `json:"takerToken"`
				Salt                string `json:"salt"`
				VerifyingContract   string `json:"verifyingContract"`
				FeeRecipient        string `json:"feeRecipient"`
				Expiry              string `json:"expiry"`
				ChainID             int    `json:"chainId"`
				Pool                string `json:"pool"`
			} `json:"order"`
			MetaData struct {
				OrderHash                    string    `json:"orderHash"`
				RemainingFillableTakerAmount string    `json:"remainingFillableTakerAmount"`
				CreatedAt                    time.Time `json:"createdAt"`
			} `json:"metaData"`
		} `json:"records"`
	} `json:"bids"`
	Asks struct {
		Total   int `json:"total"`
		Page    int `json:"page"`
		PerPage int `json:"perPage"`
		Records []struct {
			Order struct {
				Signature struct {
					SignatureType int    `json:"signatureType"`
					R             string `json:"r"`
					S             string `json:"s"`
					V             int    `json:"v"`
				} `json:"signature"`
				Sender              string `json:"sender"`
				Maker               string `json:"maker"`
				Taker               string `json:"taker"`
				TakerTokenFeeAmount string `json:"takerTokenFeeAmount"`
				MakerAmount         string `json:"makerAmount"`
				TakerAmount         string `json:"takerAmount"`
				MakerToken          string `json:"makerToken"`
				TakerToken          string `json:"takerToken"`
				Salt                string `json:"salt"`
				VerifyingContract   string `json:"verifyingContract"`
				FeeRecipient        string `json:"feeRecipient"`
				Expiry              string `json:"expiry"`
				ChainID             int    `json:"chainId"`
				Pool                string `json:"pool"`
			} `json:"order"`
			MetaData struct {
				OrderHash                    string    `json:"orderHash"`
				RemainingFillableTakerAmount string    `json:"remainingFillableTakerAmount"`
				CreatedAt                    time.Time `json:"createdAt"`
			} `json:"metaData"`
		} `json:"records"`
	} `json:"asks"`
}

type OpynOptionScraper struct {
	WsClient   *ethclient.Client
	RestClient *ethclient.Client

	PollFrequency      int8
	ScraperIsRunning   bool
	ScraperIsRunningMu sync.Mutex

	DataStore *models.DB

	Ratelimiter *rate.Limiter
	// contains filtered or unexported fields
}

type PremiaScraper struct {
	WsClient   *ethclient.Client
	RestClient *ethclient.Client

	PollFrequency      int8
	ScraperIsRunning   bool
	ScraperIsRunningMu sync.Mutex

	DataStore *models.DB

	Ratelimiter *rate.Limiter
	// contains filtered or unexported fields
}