db

type DB interface {
	GetTrades(fromBlock int64, limit uint64) ([]SolanaTradelogDB, error)
	GetTransfer(fromBlock int64, limit uint64) ([]SolanaTransferLogDb, error)
	GetMaxTradeBlockNumber() (int64, error)
	GetMaxTransferBlockNumber() (int64, error)
}

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

type SolanaTradelogDB struct {
	BlockTimestamp time.Time `db:"block_timestamp"`
	BlockNumber    uint64    `db:"block_number"`
	TxHash         string    `db:"tx_hash"`
	Sender         string    `db:"sender"`

	TokenInAddress  string  `db:"token_in_address"`
	TokenInAmount   float64 `db:"token_in_amount"`
	TokenInUsdtRate float64 `db:"token_in_usdt_rate"`

	TokenOutAddress  string  `db:"token_out_address"`
	TokenOutAmount   float64 `db:"token_out_amount"`
	TokenOutUsdtRate float64 `db:"token_out_usdt_rate"`

	SolUsdtRate float64 `db:"sol_usdt_rate"`

	Created time.Time `db:"created"`
}

type SolanaTransferLogDb struct {
	BlockTimestamp time.Time `db:"block_timestamp"`
	BlockNumber    uint64    `db:"block_number"`
	TxHash         string    `db:"tx_hash"`
	FromAddress    string    `db:"from_address"`
	ToAddress      string    `db:"to_address"`

	TokenAddress string  `db:"token_address"`
	TokenAmount  float64 `db:"token_amount"`

	IsCexIn bool      `db:"is_cex_in"`
	Created time.Time `db:"created"`
}