core

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

type AssetService interface {
	ReadAsset(ctx context.Context, id string) (*Asset, error)
	ReadTopAssets(ctx context.Context) ([]*Asset, error)
}

type CosiSignature struct {
	blst.Signature
	Mask uint64
}

type En256CosiSignature struct {
	en256.Signature
	Mask uint64
}

type Exchange interface {
	Name() string
	GetPrice(ctx context.Context, asset *Asset) (decimal.Decimal, error)
}

type PriceData struct {
	Timestamp      int64               `json:"t,omitempty"`
	AssetID        string              `json:"a,omitempty"`
	Price          decimal.Decimal     `json:"p,omitempty"`
	Signature      *CosiSignature      `json:"s,omitempty"`
	En256Signature *En256CosiSignature `json:"es,omitempty"`
}

type PriceRequest struct {
	Asset

	TraceID   string    `json:"trace_id,omitempty"`
	Receiver  *Receiver `json:"receiver,omitempty"`
	Signers   []*Signer `json:"signers,omitempty"`
	Threshold uint8     `json:"threshold"`
}

type Proposal struct {
	PriceRequest
	ProposalRequest `json:"-"`

	Signatures      map[uint64]*blst.Signature  `json:"sigs,omitempty"`
	En256Signatures map[uint64]*en256.Signature `json:"en256_sigs,omitempty"`
}

type ProposalRequest struct {
	Asset

	TraceID   string          `json:"trace_id,omitempty"`
	Timestamp int64           `json:"timestamp,omitempty"`
	Price     decimal.Decimal `json:"price,omitempty"`
	Signers   []*Signer       `json:"signers,omitempty"`
	Signature *ProposalResp   `json:"signature,omitempty"`
}

type ProposalResp struct {
	TraceID        string           `json:"trace_id,omitempty"`
	Index          uint64           `json:"index"`
	Signature      *blst.Signature  `json:"signature,omitempty"`
	En256Signature *en256.Signature `json:"en256_signature,omitempty"`
}

type Receiver struct {
	Members   []string `json:"members,omitempty"`
	Threshold uint8    `json:"threshold"`
}

type Signer struct {
	Index          uint64           `json:"index,omitempty"`
	VerifyKey      *blst.PublicKey  `json:"verify_key,omitempty"`
	En256VerifyKey *en256.PublicKey `json:"en256_verify_key,omitempty"`
}

type Subscriber struct {
	ID         uint       `sql:"PRIMARY_KEY" json:"id"`
	CreatedAt  time.Time  `json:"created_at"`
	UpdatedAt  time.Time  `json:"updated_at"`
	DeletedAt  *time.Time `sql:"index" json:"deleted_at"`
	Name       string     `sql:"SIZE:255;" json:"name,omitempty"`
	RequestURL string     `sql:"SIZE:255;" json:"request_url,omitempty"`
}

type SubscriberStore interface {
	Save(ctx context.Context, f *Subscriber) error
	All(ctx context.Context) ([]*Subscriber, error)
}

type System struct {
	ConversationID string
	GasAsset       string
	GasAmount      decimal.Decimal
	SignKey        *blst.PrivateKey
	VerifyKey      *blst.PublicKey

	En256SignKey   *en256.PrivateKey
	En256VerifyKey *en256.PublicKey
}

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
}