repo_wallets_processing

type ColumnName string

type ColumnNames []ColumnName

type CreateParams struct {
	Blockchain wconstants.BlockchainType `db:"blockchain" json:"blockchain" validate:"required"`
	Address    string                    `db:"address" json:"address" validate:"required"`
	OwnerID    uuid.UUID                 `db:"owner_id" json:"owner_id" validate:"required,uuid4"`
	Sequence   int32                     `db:"sequence" json:"sequence"`
	IsActive   bool                      `db:"is_active" json:"is_active"`
}

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
	Address    *string
	Blockchain *wconstants.BlockchainType
	storecmn.CommonFindParams
}

type GetAllNotCreatedWalletsRow struct {
	OwnerID    uuid.UUID `db:"owner_id" json:"owner_id"`
	Blockchain string    `db:"blockchain" json:"blockchain"`
}

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

type Querier interface {
	Create(ctx context.Context, arg CreateParams) (*models.ProcessingWallet, error)
	Get(ctx context.Context, blockchain wconstants.BlockchainType, address string) (*models.ProcessingWallet, error)
	GetAllByOwnerID(ctx context.Context, ownerID uuid.UUID) ([]*models.ProcessingWallet, error)
	GetAllNotCreatedWallets(ctx context.Context, blockchains []string) ([]*GetAllNotCreatedWalletsRow, error)
	GetByBlockchain(ctx context.Context, ownerID uuid.UUID, blockchain wconstants.BlockchainType) (*models.ProcessingWallet, error)
	GetByBlockchainAndAddress(ctx context.Context, blockchain wconstants.BlockchainType, address string) (*models.ProcessingWallet, error)
	GetByOwnerID(ctx context.Context, ownerID uuid.UUID, blockchain wconstants.BlockchainType, address string) (*models.ProcessingWallet, error)
	IsTakenByAnotherOwner(ctx context.Context, ownerID uuid.UUID, address string) (bool, error)
}

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

type TableName string