neofeeds

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

type ChainlinkFeedConfig struct {
	FeedID   string // e.g., "BTC-USD"
	Address  string // Contract address on Arbitrum
	Decimals int    // Price decimals (usually 8)
}

type Config struct {
	Marble      *marble.Marble
	DB          database.RepositoryInterface
	ConfigFile  string          // Path to YAML/JSON config file (optional)
	FeedsConfig *NeoFeedsConfig // Direct config (optional, takes precedence over file)
	ArbitrumRPC string          // Arbitrum RPC URL for Chainlink feeds

	// Chain configuration for push pattern
	ChainClient      *chain.Client
	PriceFeedAddress string // Contract address for platform PriceFeed (preferred)
	TxProxy          txproxytypes.Invoker
	UpdateInterval   time.Duration // How often to push prices on-chain (default: from config)
	EnableChainPush  bool          // Enable automatic on-chain price updates

	// GasBank client for service fee deduction (optional)
	GasBank *gasbankclient.Client

	SourceConcurrency int
}

type DataType string

type FeedConfig struct {
	ID             string        `json:"id" yaml:"id"`                                               // Feed identifier (e.g., "BTC-USD")
	Name           string        `json:"name,omitempty" yaml:"name,omitempty"`                       // Human-readable name
	DataType       DataType      `json:"data_type" yaml:"data_type"`                                 // Type of data
	Pair           string        `json:"pair,omitempty" yaml:"pair,omitempty"`                       // Trading pair for price feeds (e.g., "BTCUSDT")
	Base           string        `json:"base,omitempty" yaml:"base,omitempty"`                       // Base asset (e.g., "BTC")
	Quote          string        `json:"quote,omitempty" yaml:"quote,omitempty"`                     // Quote asset (e.g., "USD")
	Decimals       int           `json:"decimals" yaml:"decimals"`                                   // Decimal precision (default: 8)
	Sources        []string      `json:"sources" yaml:"sources"`                                     // Source IDs to use
	UpdateInterval time.Duration `json:"update_interval,omitempty" yaml:"update_interval,omitempty"` // Per-feed update interval
	Enabled        bool          `json:"enabled" yaml:"enabled"`                                     // Whether feed is active
}

type FeedSummary struct {
	ID         string `json:"id"`
	Pair       string `json:"pair"` // Canonical symbol (same as ID for price feeds).
	SourcePair string `json:"source_pair,omitempty"`
	Enabled    bool   `json:"enabled"`
	Decimals   int    `json:"decimals"`
}

type FeedsConfig struct {
	Version        string              `json:"version" yaml:"version"`
	Sources        []SourceConfig      `json:"sources" yaml:"sources"`
	Feeds          []FeedConfig        `json:"feeds" yaml:"feeds"`
	DefaultSources []string            `json:"default_sources,omitempty" yaml:"default_sources,omitempty"` // Default sources for feeds that don't specify
	UpdateInterval time.Duration       `json:"update_interval,omitempty" yaml:"update_interval,omitempty"` // Global update interval
	PublishPolicy  PublishPolicyConfig `json:"publish_policy,omitempty" yaml:"publish_policy,omitempty"`
}

type NeoFeedsConfig = FeedsConfig

type PriceResponse struct {
	FeedID    string    `json:"feed_id"`
	Pair      string    `json:"pair"`
	Price     int64     `json:"price,string"`
	Decimals  int       `json:"decimals"`
	Timestamp time.Time `json:"timestamp"`
	Sources   []string  `json:"sources"`
	Signature []byte    `json:"signature,omitempty"`
	PublicKey []byte    `json:"public_key,omitempty"`
}

type PriceSource struct {
	Name     string `json:"name"`
	URL      string `json:"url"`
	JSONPath string `json:"json_path"`
	Weight   int    `json:"weight"`
}

type PublishPolicyConfig struct {
	// ThresholdBps is the minimum relative change required to consider publishing.
	// Default: 10 bps = 0.10%.
	ThresholdBps int `json:"threshold_bps,omitempty" yaml:"threshold_bps,omitempty"`
	// HysteresisBps is used as a confirmation threshold after a spike is detected.
	// Default: 8 bps = 0.08%.
	HysteresisBps int `json:"hysteresis_bps,omitempty" yaml:"hysteresis_bps,omitempty"`
	// MinInterval is the minimum time between publishes per symbol.
	// Default: 5s (matches the platform blueprint throttle).
	MinInterval time.Duration `json:"min_interval,omitempty" yaml:"min_interval,omitempty"`
	// MaxPerMinute caps publish frequency per symbol (soft cap; enforced in-process).
	// Default: 30.
	MaxPerMinute int `json:"max_per_minute,omitempty" yaml:"max_per_minute,omitempty"`
}

type Service struct {
	*commonservice.BaseService
	// contains filtered or unexported fields
}

type SourceConfig struct {
	ID       string            `json:"id" yaml:"id"`
	Name     string            `json:"name" yaml:"name"`
	URL      string            `json:"url" yaml:"url"`             // URL template with {pair}, {base}, {quote} placeholders
	JSONPath string            `json:"json_path" yaml:"json_path"` // JSONPath to extract value
	Weight   int               `json:"weight" yaml:"weight"`       // Weight for aggregation (default: 1)
	Headers  map[string]string `json:"headers,omitempty" yaml:"headers,omitempty"`
	Timeout  time.Duration     `json:"timeout,omitempty" yaml:"timeout,omitempty"` // Request timeout (default: 10s)

	// PairTemplate optionally defines how to construct the {pair} token
	// from the feed base/quote (after applying overrides below).
	// Example: "{base}{quote}" (Binance), "{base}-{quote}" (OKX).
	PairTemplate string `json:"pair_template,omitempty" yaml:"pair_template,omitempty"`
	// BaseOverride and QuoteOverride optionally override the feed base/quote symbols
	// for this particular source (e.g., USD -> USDT on exchanges).
	BaseOverride  string `json:"base_override,omitempty" yaml:"base_override,omitempty"`
	QuoteOverride string `json:"quote_override,omitempty" yaml:"quote_override,omitempty"`
}

type SourceSummary struct {
	ID     string `json:"id"`
	Name   string `json:"name"`
	Weight int    `json:"weight"`
}