oracle

type Data struct {
	Timestamp     int64         `json:"timestamp"`
	AssetID       string        `json:"asset_id"`
	SignatureType string        `json:"signature_type"`
	Trigger       string        `json:"trigger"`
	Price         string        `json:"price"`
	SignedPrices  []SignedPrice `json:"signed_prices"`
}

type FeedConfig struct {
	ProviderName      string `toml:"provider"`
	Ticker            string `toml:"ticker"`
	PullInterval      string `toml:"pullInterval"`
	ObservationSource string `toml:"observationSource"`
	OracleType        string `toml:"oracleType"`
}

type FeedProvider string

type PriceData struct {
	// Ticker is BASE/QUOTE pair name
	Ticker Ticker

	// ProviderName is the name of the feed
	ProviderName string

	// Symbol is provider-specific
	Symbol string

	// Price is the reported price by feed integarion
	Price decimal.Decimal

	// Asset pair - for Stork Oracle
	AssetPair *oracletypes.AssetPair

	// Timestamp of the report
	Timestamp time.Time

	OracleType oracletypes.OracleType
}

type PriceFeedConfig struct {
	Symbol        string
	FeedProvider  FeedProvider
	PullInterval  time.Duration
	DynamicConfig *FeedConfig
}

type PricePuller interface {
	Provider() FeedProvider
	ProviderName() string
	Symbol() string
	Interval() time.Duration

	// PullPrice method must be implemented in order to get a price
	// from external source, handled by PricePuller.
	PullPrice(ctx context.Context) (priceData *PriceData, err error)
	OracleType() oracletypes.OracleType
}

type Service interface {
	Start(ctx context.Context) error
	Close()
}

type Signature struct {
	R string `json:"r"`
	S string `json:"s"`
	V string `json:"v"`
}

type SignedPrice struct {
	PublisherKey         string               `json:"publisher_key"`
	ExternalAssetID      string               `json:"external_asset_id"`
	SignatureType        string               `json:"signature_type"`
	Price                math.LegacyDec       `json:"price"`
	TimestampedSignature TimestampedSignature `json:"timestamped_signature"`
}

type StorkConfig struct {
	WebsocketUrl    string
	WebsocketHeader string
	Message         string
}

type StorkFetcher interface {
	Start(ctx context.Context, conn *websocket.Conn) error
	AssetPair(ticker string) *oracletypes.AssetPair
}

type Ticker string

type TimestampedSignature struct {
	Signature Signature `json:"signature"`
	Timestamp uint64    `json:"timestamp"`
	MsgHash   string    `json:"msg_hash"`
}