nqsdbclient

type Comparison struct {
	Threshold *interface{} `json:"threshold"`
	Operator  *string      `json:"operator"` //comparison operator
}

type DatabaseClient interface {
	CreateConnection() error
	CloseConnection()
	CreateRequest(requestID string, ofiID string, LimitMaxOfi decimal.Decimal, LimitMinOfi decimal.Decimal, sourceAsset []byte, targetAsset []byte, timeRequest int64, timeExpireOfi int64) error
	GetRequest(requestID string, ofiID string) ([]RequestDB, error)
	CreateQuote(requestID string, quoteID string, rfiID string, ofiID string, maxLimit decimal.Decimal, minLimit decimal.Decimal, sourceAsset []byte, targetAsset []byte, timeOfRequest int64, quoteStatus int, timeExpireOfi int64) error
	GetQuotes(requestID string, ofiID string) ([]QuoteDB, error)
	GetQuotesByAttributes(query *Query) ([]QuoteDB, error)
	CancelQuotesByAttributes(query *Query, TimeCancel int64) ([]QuoteDB, error)
	UpdateQuote(quote QuoteDB, timeOfQuote int64) error
	CancelQuote(quoteID string, rfiID string, TimeCancel int64) error
	ExecutingQuote(quoteID string, ofiID string, quoteResponse []byte, executingTime int64, amount decimal.Decimal) error
	ExecutedQuote(quoteID string, ofiID string, timeExecute int64) error
	FailedQuote(quoteID string, ofiID string) error
	GetQuoteByQuoteID(QuoteID string, rfiID string) ([]QuoteDB, error)
}

type PostgreDatabaseClient struct {
	Host     string
	Port     int
	User     string
	Password string
	Dbname   string
	// contains filtered or unexported fields
}

type Query struct {
	DeleteAllQuotes   *bool            `json:"delete_all_quotes,omitempty"`
	RequestID         *string          `json:"request_id,omitempty" db:"requestid"`
	QuoteID           *string          `json:"quote_id,omitempty"`
	RfiID             *string          `json:"rfi_id,omitempty"`
	OfiID             *string          `json:"ofi_id,omitempty"`
	LimitMaxOfi       *decimal.Decimal `json:"limit_max_ofi,omitempty"`
	LimitMinOfi       *decimal.Decimal `json:"limit_min_ofi,omitempty"`
	ExchangeRate      *Comparison      `json:"exchange_rate,omitempty"`
	SourceAsset       *types.JSONText  `json:"source_asset,omitempty"`
	TargetAsset       *types.JSONText  `json:"target_asset,omitempty"`
	TimeRequest       *int64           `json:"time_request,omitempty"`
	TimeQuote         *int64           `json:"time_quote,omitempty"`
	TimeExpireRfi     *Comparison      `json:"time_expire_rfi,omitempty"`
	StatusQuote       *Comparison      `json:"status_quote,omitempty"`
	TimeExecuted      *int64           `json:"time_executed,omitempty"`
	TimeCancel        *int64           `json:"time_cancel,omitempty"`
	AddressReceiveRfi *string          `json:"address_receive_rfi,omitempty"`
	AddressSendRfi    *string          `json:"address_send_rfi,omitempty"`
}

type QuoteDB struct {
	RequestID         *string          `json:"request_id,omitempty" db:"requestid"`
	QuoteID           *string          `json:"quote_id,omitempty" db:"quoteid"`
	RfiId             *string          `json:"rfi_id,omitempty" db:"rfiid"`
	OfiId             *string          `json:"ofi_id,omitempty" db:"ofiid"`
	LimitMaxOfi       *decimal.Decimal `json:"limit_max_ofi,omitempty" db:"limitmaxofi"`
	LimitMinOfi       *decimal.Decimal `json:"limit_min_ofi,omitempty" db:"limitminofi"`
	LimitMaxRfi       *decimal.Decimal `json:"limit_max_rfi,omitempty" db:"limitmaxrfi"`
	LimitMinRfi       *decimal.Decimal `json:"limit_min_rfi,omitempty" db:"limitminrfi"`
	Amount            *decimal.Decimal `json:"amount,omitempty" db:"amount"`
	ExchangeRate      *decimal.Decimal `json:"exchange_rate,omitempty" db:"exchangerate"`
	SourceAsset       *types.JSONText  `json:"source_asset,omitempty" db:"sourceasset"`
	TargetAsset       *types.JSONText  `json:"target_asset,omitempty" db:"targetasset"`
	TimeRequest       *int64           `json:"time_request,omitempty" db:"timerequest"`
	TimeQuote         *int64           `json:"time_quote,omitempty" db:"timequote"`
	TimeExpireOfi     *int64           `json:"time_expire_ofi,omitempty" db:"timeexpireofi"`
	TimeStartRfi      *int64           `json:"time_start_rfi,omitempty" db:"timestartrfi"`
	TimeExpireRfi     *int64           `json:"time_expire_rfi,omitempty" db:"timeexpirerfi"`
	StatusQuote       *int             `json:"status_quote,omitempty" db:"statusquote"`
	TimeExecuted      *int64           `json:"time_executed,omitempty" db:"timeexecuted"`
	TimeCancel        *int64           `json:"time_cancel,omitempty" db:"timecancel"`
	AddressReceiveRfi *string          `json:"address_receive_rfi,omitempty" db:"addressreceiverfi"`
	AddressSendRfi    *string          `json:"address_send_rfi,omitempty" db:"addresssendrfi"`
	// QuoteRequest           *types.JSONText `json:"quote_request,omitempty" db:"quoterequest"`
	QuoteRequestSignature  *string         `json:"quote_request_signature,omitempty" db:"quoterequestsignature"`
	QuoteResponse          *types.JSONText `json:"quote_response,omitempty" db:"quoteresponse"`
	QuoteResponseBase64    *string         `json:"quote_response_base64,omitempty" db:"quoteresponsebase64"`
	QuoteResponseSignature *string         `json:"quote_response_signature,omitempty" db:"quoteresponsesignature"`
}

type RequestDB struct {
	RequestID     *string          `json:"request_id,omitempty" db:"requestid"`
	TimeExpireOfi *int64           `json:"time_expire_ofi,omitempty" db:"timeexpireofi"`
	LimitMaxOfi   *decimal.Decimal `json:"limit_max_rfi,omitempty" db:"limitmaxrfi"`
	LimitMinOfi   *decimal.Decimal `json:"limit_min_rfi,omitempty" db:"limitminrfi"`
	SourceAsset   *types.JSONText  `json:"source_asset,omitempty" db:"sourceasset"`
	TargetAsset   *types.JSONText  `json:"target_asset,omitempty" db:"targetasset"`
	TimeRequest   *int64           `json:"time_request,omitempty" db:"timerequest"`
	OfiId         *string          `json:"ofi_id,omitempty" db:"ofiid"`
}