core

type Asset struct {
	AssetID string `json:"asset_id,omitempty"`
	Symbol  string `json:"symbol,omitempty"`
}

type CosiSignature struct {
	blst.Signature
	Mask uint64
}

type FeedConfig struct {
	Asset
	Sources []string `json:"sources,omitempty"`
}

type Feeder struct {
	gorm.Model
	AssetID   string         `json:"asset_id,omitempty"`
	Threshold uint8          `json:"threshold,omitempty"`
	Opponents pq.StringArray `sql:"type:TEXT" json:"opponents,omitempty"`
}

type FeederStore interface {
	SaveFeeder(ctx context.Context, f *Feeder) error
	AllFeeders(ctx context.Context) ([]*Feeder, error)
	FindFeeders(ctx context.Context, assetID string) ([]*Feeder, error)
}

type MarketStore interface {
	// ticker
	SaveTicker(ctx context.Context, ticker *Ticker) error
	FindTickers(ctx context.Context, assetID string) ([]*Ticker, error)
	AggregateTickers(ctx context.Context, assetID string) (*Ticker, error)
}

type Member struct {
	ID        int64           `json:"id"`
	ClientID  string          `json:"client_id"`
	Name      string          `json:"name"`
	VerifyKey *blst.PublicKey `json:"verify_key"`
}

type PriceData struct {
	Timestamp int64           `json:"t,omitempty"`
	AssetID   string          `json:"a,omitempty"`
	Price     decimal.Decimal `gorm:"TYPE:DECIMAL(16,8);" json:"p,omitempty"`
	Signature *CosiSignature  `gorm:"TYPE:TEXT;" json:"s,omitempty"`
}

type PriceDataStore interface {
	SavePriceData(ctx context.Context, p *PriceData) error
	LatestPriceData(ctx context.Context, asset string) (*PriceData, error)
}

type PriceProposal struct {
	PriceData

	Signatures map[int64]*blst.Signature `json:"sigs,omitempty"`
}

type Snapshot struct {
	SnapshotID      string          `json:"snapshot_id"`
	CreatedAt       time.Time       `json:"created_at,omitempty"`
	TraceID         string          `json:"trace_id,omitempty"`
	AssetID         string          `json:"asset_id,omitempty"`
	OpponentID      string          `json:"opponent_id,omitempty"`
	Source          string          `json:"source,omitempty"`
	Amount          decimal.Decimal `json:"amount,omitempty"`
	Memo            string          `json:"memo,omitempty"`
	TransactionHash string          `json:"transaction_hash,omitempty"`
}

type System struct {
	Admins         []string
	ConversationID string
	ClientID       string
	Members        []*Member
	Threshold      uint8
	SignKey        *blst.PrivateKey
	Version        string
	GasAsset       string
	GasAmount      decimal.Decimal
}

type Ticker struct {
	AssetID   string          `json:"asset_id"`
	Source    string          `json:"source,omitempty"`
	Timestamp int64           `json:"timestamp,omitempty"`
	Price     decimal.Decimal `json:"price,omitempty"`
	VolumeUSD decimal.Decimal `json:"volume_usd,omitempty"`
}

type Transfer struct {
	ID        int64           `sql:"PRIMARY_KEY" json:"id,omitempty"`
	CreatedAt time.Time       `json:"created_at,omitempty"`
	UpdatedAt time.Time       `json:"updated_at,omitempty"`
	TraceID   string          `sql:"type:char(36)" json:"trace_id,omitempty"`
	AssetID   string          `sql:"type:char(36)" json:"asset_id,omitempty"`
	Amount    decimal.Decimal `sql:"type:decimal(64,8)" json:"amount,omitempty"`
	Memo      string          `sql:"size:200" json:"memo,omitempty"`
	Threshold uint8           `json:"threshold,omitempty"`
	Opponents pq.StringArray  `sql:"type:varchar(1024)" json:"opponents,omitempty"`
}

type WalletService interface {
	Transfer(ctx context.Context, transfer *Transfer) error
}

type WalletStore interface {
	ListTransfers(ctx context.Context, limit int) ([]*Transfer, error)
	CreateTransfers(ctx context.Context, transfers []*Transfer) error
	ExpireTransfers(ctx context.Context, transfers []*Transfer) error
}