repo_transfers

type ColumnName string

type ColumnNames []ColumnName

type CreateParams struct {
	Status           constants.TransferStatus  `db:"status" json:"status"`
	ClientID         uuid.UUID                 `db:"client_id" json:"client_id"`
	OwnerID          uuid.UUID                 `db:"owner_id" json:"owner_id"`
	RequestID        string                    `db:"request_id" json:"request_id"`
	Blockchain       wconstants.BlockchainType `db:"blockchain" json:"blockchain"`
	FromAddresses    []string                  `db:"from_addresses" json:"from_addresses"`
	ToAddresses      []string                  `db:"to_addresses" json:"to_addresses"`
	WalletFromType   constants.WalletType      `db:"wallet_from_type" json:"wallet_from_type"`
	AssetIdentifier  string                    `db:"asset_identifier" json:"asset_identifier"`
	Kind             pgtype.Text               `db:"kind" json:"kind"`
	WholeAmount      bool                      `db:"whole_amount" json:"whole_amount"`
	Amount           decimal.NullDecimal       `db:"amount" json:"amount"`
	Fee              decimal.NullDecimal       `db:"fee" json:"fee"`
	FeeMax           decimal.NullDecimal       `db:"fee_max" json:"fee_max"`
	TxHash           pgtype.Text               `db:"tx_hash" json:"tx_hash"`
	StateData        map[string]any            `db:"state_data" json:"state_data"`
	WorkflowSnapshot workflow.Snapshot         `db:"workflow_snapshot" json:"workflow_snapshot"`
}

type CustomQuerier struct {
	*Queries
	// contains filtered or unexported fields
}

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
}

type FindParams struct {
	OwnerID       *uuid.UUID
	StatusesIn    []string
	StatusesNotIn []string
	FromAddress   *string
	ToAddress     *string
	Blockchain    *wconstants.BlockchainType
	Limit         *int
}

type GetActiveTronTransfersBurnRow struct {
	Trx                 decimal.Decimal `db:"trx" json:"trx"`
	ActivationEnergy    decimal.Decimal `db:"activation_energy" json:"activation_energy"`
	ActivationBandwidth decimal.Decimal `db:"activation_bandwidth" json:"activation_bandwidth"`
	ActivationTrx       decimal.Decimal `db:"activation_trx" json:"activation_trx"`
}

type GetActiveTronTransfersResourcesRow struct {
	Energy              decimal.Decimal `db:"energy" json:"energy"`
	Bandwidth           decimal.Decimal `db:"bandwidth" json:"bandwidth"`
	ActivationEnergy    decimal.Decimal `db:"activation_energy" json:"activation_energy"`
	ActivationBandwidth decimal.Decimal `db:"activation_bandwidth" json:"activation_bandwidth"`
}

type ICustomQuerier interface {
	Querier
	Find(ctx context.Context, params FindParams) ([]*models.Transfer, error)
}

type Querier interface {
	Create(ctx context.Context, arg CreateParams) (*models.Transfer, error)
	ExistsByTxHashAndOwnerID(ctx context.Context, txHash pgtype.Text, ownerID uuid.UUID) (bool, error)
	FindAllNewTransfers(ctx context.Context) ([]*models.Transfer, error)
	GetActiveTronTransfersBurn(ctx context.Context) (*GetActiveTronTransfersBurnRow, error)
	GetActiveTronTransfersResources(ctx context.Context) (*GetActiveTronTransfersResourcesRow, error)
	GetByID(ctx context.Context, id uuid.UUID) (*models.Transfer, error)
	GetByRequestID(ctx context.Context, requestID string) (*models.Transfer, error)
	GetByTxHashAndOwnerID(ctx context.Context, txHash pgtype.Text, ownerID uuid.UUID) (*models.Transfer, error)
	GetStateData(ctx context.Context, id uuid.UUID) (map[string]any, error)
	GetWorkflowSnapshot(ctx context.Context, id uuid.UUID) (workflow.Snapshot, error)
	SetStateData(ctx context.Context, iD uuid.UUID, stateData map[string]any) error
	SetStatus(ctx context.Context, iD uuid.UUID, status constants.TransferStatus) error
	SetTxHash(ctx context.Context, iD uuid.UUID, txHash pgtype.Text) (*models.Transfer, error)
	SetWorkflowSnapshot(ctx context.Context, iD uuid.UUID, workflowSnapshot workflow.Snapshot) error
}

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

type TableName string