dbx

package
v0.0.0-...-decc4aa Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 12, 2025 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrNoRows = pgx.ErrNoRows

Functions

This section is empty.

Types

type Config 

type Config struct {
	User string `yaml:"user"`
	Pass string `yaml:"pass"`
	Addr string `yaml:"addr"`
	Name string `yaml:"name"`
}

func (*Config) Validate 

func (cfg *Config) Validate() error

type DB 

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

func Connect 

func Connect(ctx context.Context, cfg Config) (*DB, error)

func (*DB) CheckTonTxByHash 

func (db *DB) CheckTonTxByHash(ctx context.Context, txHash string) (exist bool, err error)

func (*DB) Close 

func (db *DB) Close()

func (*DB) CreateTask 

func (db *DB) CreateTask(ctx context.Context, t *common.FullTask) error

func (*DB) CreateUser 

func (db *DB) CreateUser(ctx context.Context, joinAt time.Time, u tgu.User, refID int64, ipAddress, userAgent string) error

func (*DB) DeleteBotChat 

func (db *DB) DeleteBotChat(ctx context.Context, chatID int64) error

func (*DB) DeleteProduct 

func (db *DB) DeleteProduct(ctx context.Context, productID int64) error

func (*DB) DeleteTask 

func (db *DB) DeleteTask(ctx context.Context, taskID int64) error

func (*DB) GetAllBotChats 

func (db *DB) GetAllBotChats(ctx context.Context) (chats []tgu.Chat, err error)

func (*DB) GetAllProducts 

func (db *DB) GetAllProducts(ctx context.Context) (products []*common.Product, err error)

func (*DB) GetAllTasks 

func (db *DB) GetAllTasks(ctx context.Context) (tasks []*common.FullTask, err error)

func (*DB) GetAllUsersPoints 

func (db *DB) GetAllUsersPoints(ctx context.Context, walk func(userID, points int64) error) error

func (*DB) GetBotChatByID 

func (db *DB) GetBotChatByID(ctx context.Context, chatID int64) (c tgu.Chat, err error)

func (*DB) GetKeyNum 

func (db *DB) GetKeyNum(ctx context.Context, key string) (n int, err error)

func (*DB) GetKeyStr 

func (db *DB) GetKeyStr(ctx context.Context, key string) (s string, err error)

func (*DB) GetProduct 

func (db *DB) GetProduct(ctx context.Context, productID int64) (*common.Product, error)

func (*DB) GetProductTicketStatus 

func (db *DB) GetProductTicketStatus(ctx context.Context, ticketID int64) (status string, err error)

func (*DB) GetUserPoints 

func (db *DB) GetUserPoints(ctx context.Context, userID int64) (points int64, err error)

func (*DB) GetUserRefID 

func (db *DB) GetUserRefID(ctx context.Context, userID int64) (refID int64, err error)

func (*DB) GetUserRefs 

func (db *DB) GetUserRefs(ctx context.Context, userID int64) (refPoints, refCount int64, err error)

func (*DB) IncUserPoints 

func (db *DB) IncUserPoints(ctx context.Context, userID, incPoints int64) error

func (*DB) IncUserPointsFromRef 

func (db *DB) IncUserPointsFromRef(ctx context.Context, userID, incPoints int64) error

func (*DB) IncUserRefCount 

func (db *DB) IncUserRefCount(ctx context.Context, userID int64) error

func (*DB) SaveBotChat 

func (db *DB) SaveBotChat(ctx context.Context, chat tgu.Chat) error

func (*DB) SaveProduct 

func (db *DB) SaveProduct(ctx context.Context, p *common.Product) error

func (*DB) SaveProductTicket 

func (db *DB) SaveProductTicket(ctx context.Context, userID int64, claimAt time.Time, p *common.Product) (ticketID int64, err error)

func (*DB) SaveStarsTransaction 

func (db *DB) SaveStarsTransaction(ctx context.Context, txID string, userID, taskID int64, starsAmount int) error

func (*DB) SaveTaskFinish 

func (db *DB) SaveTaskFinish(ctx context.Context, userID, taskID, subID, taskPoints int64, finishAt time.Time) error

func (*DB) SaveTaskPartnerEvent 

func (db *DB) SaveTaskPartnerEvent(ctx context.Context, userID, taskID, subID int64, payout float64, receivedAt time.Time) error

func (*DB) SaveTaskStateClaim 

func (db *DB) SaveTaskStateClaim(
	ctx context.Context, userID, taskID, subID, taskPoints int64, claimAt time.Time,
) (ok bool, err error)

func (*DB) SaveTaskStateDone 

func (db *DB) SaveTaskStateDone(ctx context.Context, userID, taskID, subID int64, doneAt time.Time) error

func (*DB) SaveTaskStatePending 

func (db *DB) SaveTaskStatePending(ctx context.Context, userID, taskID, subID int64, startAt time.Time) error

func (*DB) SaveTonTx 

func (db *DB) SaveTonTx(ctx context.Context, userID, taskID int64, tx *tonu.Transaction) error

func (*DB) SaveUserRefferal 

func (db *DB) SaveUserRefferal(ctx context.Context, fromUserID, toUserID, points int64, level int) error

func (*DB) SetKeyNum 

func (db *DB) SetKeyNum(ctx context.Context, key string, newNum int) error

func (*DB) SetKeyStr 

func (db *DB) SetKeyStr(ctx context.Context, key, newStr string) error

func (*DB) SetProductTicketSent 

func (db *DB) SetProductTicketSent(ctx context.Context, ticketID int64, newStatus string) error

func (*DB) SetProductTicketStatus 

func (db *DB) SetProductTicketStatus(ctx context.Context, ticketID int64, newStatus string) error

func (*DB) SetUserInit 

func (db *DB) SetUserInit(ctx context.Context, userID int64) error

func (*DB) SetUserPoints 

func (db *DB) SetUserPoints(ctx context.Context, userID, newPoints int64) error

func (*DB) SetUserUsername 

func (db *DB) SetUserUsername(ctx context.Context, userID int64, newUsername string) error

func (*DB) Tx 

func (db *DB) Tx(ctx context.Context, callback func(tx *DB) error) error

func (*DB) UpdateBotChatTitle 

func (db *DB) UpdateBotChatTitle(ctx context.Context, chatID int64, newChatTitle string) error

func (*DB) UpdateTask 

func (db *DB) UpdateTask(ctx context.Context, t *common.FullTask) error

func (*DB) WithdrawUserPoints 

func (db *DB) WithdrawUserPoints(ctx context.Context, userID, decPoints int64) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.