db

package
v0.0.0-...-3a1e09c Latest Latest
Warning

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

 Go to latest Published: Aug 24, 2025 License: AGPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Pool *pgxpool.Pool

Functions

func Close 

func Close()

func Migrate 

func Migrate(ctx context.Context) error

func NullString 

func NullString(s string) pgtype.Text

func Setup 

func Setup(ctx context.Context) (err error)

Types

type AddGroupToInviteCodeParams 

type AddGroupToInviteCodeParams struct {
	Code      int32
	GroupName string
}

type CreateInviteCodeParams 

type CreateInviteCodeParams struct {
	Name   string
	Code   string
	UserID int32
}

type CreatePendingAccountParams 

type CreatePendingAccountParams struct {
	Password string
	Email    pgtype.Text
}

type CreateUserParams 

type CreateUserParams struct {
	Username       string
	IdpSub         string
	StripeCustomer pgtype.Text
	InvitedBy      pgtype.Int4
}

type DBTX 

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 DeleteInviteCodeForUserParams 

type DeleteInviteCodeForUserParams struct {
	ID     int32
	UserID int32
}

type EditNewsItemParams 

type EditNewsItemParams struct {
	ID                int32
	Content           string
	ThumbnailURL      pgtype.Text
	ThumbnailURLSmall pgtype.Text
	TracTicketID      pgtype.Int4
}

type GetInviteCodeForUserParams 

type GetInviteCodeForUserParams struct {
	ID     int32
	UserID int32
}

type InviteCode 

type InviteCode struct {
	ID      int32
	Code    string
	UserID  int32
	Name    string
	Expires pgtype.Timestamptz
}

type InviteCodeGroup 

type InviteCodeGroup struct {
	ID        int32
	Code      int32
	GroupName string
}

type ListNewsFeedRow 

type ListNewsFeedRow struct {
	ID                int32
	CreatedAt         pgtype.Timestamptz
	EditedAt          pgtype.Timestamptz
	AuthorID          pgtype.Int4
	Content           string
	ThumbnailURL      pgtype.Text
	ThumbnailURLSmall pgtype.Text
	TracTicketID      pgtype.Int4
	AuthorUsername    pgtype.Text
	AuthorIdpSub      pgtype.Text
	AuthorMxid        pgtype.Text
}

type MatrixFilter 

type MatrixFilter struct {
	UserID   string
	FilterID string
}

type MatrixNextBatch 

type MatrixNextBatch struct {
	UserID string
	Token  string
}

type MatrixSaveFilterIDParams 

type MatrixSaveFilterIDParams struct {
	UserID   string
	FilterID string
}

type MatrixSaveNextBatchParams 

type MatrixSaveNextBatchParams struct {
	UserID string
	Token  string
}

type NewsFeed 

type NewsFeed struct {
	ID                int32
	CreatedAt         pgtype.Timestamptz
	EditedAt          pgtype.Timestamptz
	AuthorID          pgtype.Int4
	Content           string
	ThumbnailURL      pgtype.Text
	ThumbnailURLSmall pgtype.Text
	TracTicketID      pgtype.Int4
}

type NewsItemByIDRow 

type NewsItemByIDRow struct {
	ID                int32
	CreatedAt         pgtype.Timestamptz
	EditedAt          pgtype.Timestamptz
	AuthorID          pgtype.Int4
	Content           string
	ThumbnailURL      pgtype.Text
	ThumbnailURLSmall pgtype.Text
	TracTicketID      pgtype.Int4
	AuthorUsername    pgtype.Text
	AuthorIdpSub      pgtype.Text
	AuthorMxid        pgtype.Text
}

type NewsItemIsCreatedByParams 

type NewsItemIsCreatedByParams struct {
	ID       int32
	AuthorID pgtype.Int4
}

type PendingAccount 

type PendingAccount struct {
	ID          int32
	Password    string
	Email       pgtype.Text
	SubmittedAt pgtype.Timestamptz
}

type PostNewsItemParams 

type PostNewsItemParams struct {
	AuthorID          pgtype.Int4
	Content           string
	ThumbnailURL      pgtype.Text
	ThumbnailURLSmall pgtype.Text
	TracTicketID      pgtype.Int4
}

type Querier 

type Querier interface {
	AddGroupToInviteCode(ctx context.Context, arg AddGroupToInviteCodeParams) error
	ClearPendingAccount(ctx context.Context, id int32) error
	CreateInviteCode(ctx context.Context, arg CreateInviteCodeParams) (int32, error)
	CreatePendingAccount(ctx context.Context, arg CreatePendingAccountParams) (int32, error)
	CreateUser(ctx context.Context, arg CreateUserParams) (User, error)
	DeleteExpiredInvites(ctx context.Context) error
	DeleteInviteCode(ctx context.Context, id int32) error
	DeleteInviteCodeForUser(ctx context.Context, arg DeleteInviteCodeForUserParams) error
	DeleteNewsItem(ctx context.Context, id int32) error
	EditNewsItem(ctx context.Context, arg EditNewsItemParams) error
	GetAllUsers(ctx context.Context) ([]User, error)
	GetAllUsersWithMXID(ctx context.Context) ([]User, error)
	GetGroupsForInviteCode(ctx context.Context, code int32) ([]string, error)
	GetInviteCode(ctx context.Context, id int32) (InviteCode, error)
	GetInviteCodeByCode(ctx context.Context, code string) (InviteCode, error)
	GetInviteCodeForUser(ctx context.Context, arg GetInviteCodeForUserParams) (InviteCode, error)
	GetInviteCodesForUser(ctx context.Context, userID int32) ([]InviteCode, error)
	GetPendingAccount(ctx context.Context, id int32) (PendingAccount, error)
	GetUser(ctx context.Context, id int32) (User, error)
	GetUserByIDP(ctx context.Context, idpSub string) (User, error)
	GetUserByMXID(ctx context.Context, mxid pgtype.Text) (User, error)
	GetUserByStripeCustomerID(ctx context.Context, stripeCustomer pgtype.Text) (User, error)
	GetUserByUsername(ctx context.Context, username string) (User, error)
	GetUsersByInviter(ctx context.Context, invitedBy pgtype.Int4) ([]User, error)
	ListNewsFeed(ctx context.Context, afterID int32) ([]ListNewsFeedRow, error)
	MatrixLoadFilterID(ctx context.Context, userID string) (string, error)
	MatrixLoadNextBatch(ctx context.Context, userID string) (string, error)
	MatrixSaveFilterID(ctx context.Context, arg MatrixSaveFilterIDParams) error
	MatrixSaveNextBatch(ctx context.Context, arg MatrixSaveNextBatchParams) error
	NewsItemByID(ctx context.Context, id int32) (NewsItemByIDRow, error)
	NewsItemIsCreatedBy(ctx context.Context, arg NewsItemIsCreatedByParams) (bool, error)
	ObtainMatrixLock(ctx context.Context) error
	PostNewsItem(ctx context.Context, arg PostNewsItemParams) (int32, error)
	SetMXIDForUser(ctx context.Context, arg SetMXIDForUserParams) error
	SetStripeIDForUser(ctx context.Context, arg SetStripeIDForUserParams) error
}

type Queries 

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

func Get 

func Get(ctx context.Context) (*Queries, *pgxpool.Conn, error)

func New 

func New(db DBTX) *Queries

func (*Queries) AddGroupToInviteCode 

func (q *Queries) AddGroupToInviteCode(ctx context.Context, arg AddGroupToInviteCodeParams) error

func (*Queries) ClearPendingAccount 

func (q *Queries) ClearPendingAccount(ctx context.Context, id int32) error

func (*Queries) CreateInviteCode 

func (q *Queries) CreateInviteCode(ctx context.Context, arg CreateInviteCodeParams) (int32, error)

func (*Queries) CreatePendingAccount 

func (q *Queries) CreatePendingAccount(ctx context.Context, arg CreatePendingAccountParams) (int32, error)

func (*Queries) CreateUser 

func (q *Queries) CreateUser(ctx context.Context, arg CreateUserParams) (User, error)

func (*Queries) DeleteExpiredInvites 

func (q *Queries) DeleteExpiredInvites(ctx context.Context) error

func (*Queries) DeleteInviteCode 

func (q *Queries) DeleteInviteCode(ctx context.Context, id int32) error

func (*Queries) DeleteInviteCodeForUser 

func (q *Queries) DeleteInviteCodeForUser(ctx context.Context, arg DeleteInviteCodeForUserParams) error

func (*Queries) DeleteNewsItem 

func (q *Queries) DeleteNewsItem(ctx context.Context, id int32) error

func (*Queries) EditNewsItem 

func (q *Queries) EditNewsItem(ctx context.Context, arg EditNewsItemParams) error

func (*Queries) GetAllUsers 

func (q *Queries) GetAllUsers(ctx context.Context) ([]User, error)

func (*Queries) GetAllUsersWithMXID 

func (q *Queries) GetAllUsersWithMXID(ctx context.Context) ([]User, error)

func (*Queries) GetGroupsForInviteCode 

func (q *Queries) GetGroupsForInviteCode(ctx context.Context, code int32) ([]string, error)

func (*Queries) GetInviteCode 

func (q *Queries) GetInviteCode(ctx context.Context, id int32) (InviteCode, error)

func (*Queries) GetInviteCodeByCode 

func (q *Queries) GetInviteCodeByCode(ctx context.Context, code string) (InviteCode, error)

func (*Queries) GetInviteCodeForUser 

func (q *Queries) GetInviteCodeForUser(ctx context.Context, arg GetInviteCodeForUserParams) (InviteCode, error)

func (*Queries) GetInviteCodesForUser 

func (q *Queries) GetInviteCodesForUser(ctx context.Context, userID int32) ([]InviteCode, error)

func (*Queries) GetPendingAccount 

func (q *Queries) GetPendingAccount(ctx context.Context, id int32) (PendingAccount, error)

func (*Queries) GetUser 

func (q *Queries) GetUser(ctx context.Context, id int32) (User, error)

func (*Queries) GetUserByIDP 

func (q *Queries) GetUserByIDP(ctx context.Context, idpSub string) (User, error)

func (*Queries) GetUserByMXID 

func (q *Queries) GetUserByMXID(ctx context.Context, mxid pgtype.Text) (User, error)

func (*Queries) GetUserByStripeCustomerID 

func (q *Queries) GetUserByStripeCustomerID(ctx context.Context, stripeCustomer pgtype.Text) (User, error)

func (*Queries) GetUserByUsername 

func (q *Queries) GetUserByUsername(ctx context.Context, username string) (User, error)

func (*Queries) GetUsersByInviter 

func (q *Queries) GetUsersByInviter(ctx context.Context, invitedBy pgtype.Int4) ([]User, error)

func (*Queries) ListNewsFeed 

func (q *Queries) ListNewsFeed(ctx context.Context, afterID int32) ([]ListNewsFeedRow, error)

func (*Queries) MatrixLoadFilterID 

func (q *Queries) MatrixLoadFilterID(ctx context.Context, userID string) (string, error)

func (*Queries) MatrixLoadNextBatch 

func (q *Queries) MatrixLoadNextBatch(ctx context.Context, userID string) (string, error)

func (*Queries) MatrixSaveFilterID 

func (q *Queries) MatrixSaveFilterID(ctx context.Context, arg MatrixSaveFilterIDParams) error

func (*Queries) MatrixSaveNextBatch 

func (q *Queries) MatrixSaveNextBatch(ctx context.Context, arg MatrixSaveNextBatchParams) error

func (*Queries) NewsItemByID 

func (q *Queries) NewsItemByID(ctx context.Context, id int32) (NewsItemByIDRow, error)

func (*Queries) NewsItemIsCreatedBy 

func (q *Queries) NewsItemIsCreatedBy(ctx context.Context, arg NewsItemIsCreatedByParams) (bool, error)

func (*Queries) ObtainMatrixLock 

func (q *Queries) ObtainMatrixLock(ctx context.Context) error

func (*Queries) PostNewsItem 

func (q *Queries) PostNewsItem(ctx context.Context, arg PostNewsItemParams) (int32, error)

func (*Queries) SetMXIDForUser 

func (q *Queries) SetMXIDForUser(ctx context.Context, arg SetMXIDForUserParams) error

func (*Queries) SetStripeIDForUser 

func (q *Queries) SetStripeIDForUser(ctx context.Context, arg SetStripeIDForUserParams) error

func (*Queries) WithTx 

func (q *Queries) WithTx(tx pgx.Tx) *Queries

type SetMXIDForUserParams 

type SetMXIDForUserParams struct {
	Mxid pgtype.Text
	ID   int32
}

type SetStripeIDForUserParams 

type SetStripeIDForUserParams struct {
	StripeCustomer pgtype.Text
	IdpSub         string
}

type User 

type User struct {
	ID             int32
	IdpSub         string
	Username       string
	StripeCustomer pgtype.Text
	Mxid           pgtype.Text
	InvitedBy      pgtype.Int4
}

Source Files

View all Source files

Directories

Path Synopsis

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.