db

package
v0.0.0-...-88fbdb7 Latest Latest
Warning

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

Go to latest
Published: Apr 20, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
const (
	UserAlreadyExists = "user already exists"
	UserNotFound      = "user not found"
	UserDeleted       = "user deleted"
	UserBlocked       = "user blocked"

	GroupAlreadyExists = "group already exists"
	GroupNotFound      = "group not found"
	GroupDeleted       = "group deleted"

	GroupChatAlreadyExists = "groupchat already exists"
	GroupChatNotFound      = "groupchat not found"

	Deleted = "deleted"
	Blocked = "blocked"
	Active  = "active"

	New    = "new"
	Member = "member"
	Admin  = "admin"
	Owner  = "owner"
)

Variables

This section is empty.

Functions

func AddGroupGroupChatIfNotExist

func AddGroupGroupChatIfNotExist(db *sql.DB, group *Group, groupchat *Groupchat) (bool, error)

AddGroupGroupChatIfNotExist ...

func AddGroupUserIfNotExist

func AddGroupUserIfNotExist(db *sql.DB, group *Group, user *User) (bool, error)

AddGroupUserIfNotExist ...

func DeleteGroupGroupChat

func DeleteGroupGroupChat(db *sql.DB, group *Group, groupchat *Groupchat) (bool, error)

DeleteGroupGroupChat ...

func DeleteGroupUser

func DeleteGroupUser(db *sql.DB, group *Group, user *User) (bool, error)

DeleteGroupUser ...

func ExecSQL

func ExecSQL(db *sql.DB, sql string) error

ExecSQL ...

func GroupChatDelete

func GroupChatDelete(db *sql.DB, groupchat *Groupchat) (bool, error)

GroupChatDelete ...

func InitDB

func InitDB() (*sql.DB, error)

InitDB ...

func QuerySQLList

func QuerySQLList(db *sql.DB, returnModel interface{}, sql string, args ...interface{}) ([]reflect.Value, error)

QuerySQLList ...

func QuerySQLObject

func QuerySQLObject(db *sql.DB, returnModel interface{}, sql string, args ...interface{}) (reflect.Value, error)

QuerySQLObject ...

func StoreTelegramMessage

func StoreTelegramMessage(db *sql.DB, message *TelegramMessage) error

StoreTelegramMessage ...

func UpdateGroupChatInviteLink(db *sql.DB, groupchat *Groupchat) (int64, error)

UpdateGroupChatInviteLink ...

func UpdateGroupChatTitle

func UpdateGroupChatTitle(db *sql.DB, groupchat *Groupchat) (int64, error)

UpdateGroupChatTitle ...

func UpdateGroupName

func UpdateGroupName(db *sql.DB, oldName, newName string) (int64, error)

UpdateGroupName ...

func UpdateGroupState

func UpdateGroupState(db *sql.DB, group *Group) (int64, error)

UpdateGroupState ...

func UpdatePluginState

func UpdatePluginState(db *sql.DB, plugin *Plugin) (int64, error)

UpdatePluginState ...

func UpdateUserBirthday

func UpdateUserBirthday(db *sql.DB, user *User) (int64, error)

UpdateUserBirthday ...

func UpdateUserRole

func UpdateUserRole(db *sql.DB, user *User) (int64, error)

UpdateUserRole ...

Types

type Group

type Group struct {
	ID        int64     `sql:"id"`
	Name      string    `sql:"name"`
	State     string    `sql:"state"`
	CreatedAt time.Time `sql:"created_at"`
}

Group ...

func AddGroupIfNotExist

func AddGroupIfNotExist(db *sql.DB, group *Group) (*Group, error)

AddGroupIfNotExist ...

func GetGroupByName

func GetGroupByName(db *sql.DB, group *Group) (*Group, error)

GetGroupByName ...

func GetGroups

func GetGroups(db *sql.DB, states []string) (groups []*Group, err error)

GetGroups ...

func (*Group) String

func (g *Group) String() string

type Groupchat

type Groupchat struct {
	ID         int64     `sql:"id"`
	Title      string    `sql:"title"`
	TelegramID int64     `sql:"telegram_id"`
	State      string    `sql:"state"`
	InviteLink string    `sql:"invite_link"`
	CreatedAt  time.Time `sql:"created_at"`
}

Groupchat ...

func AddGroupChatIfNotExist

func AddGroupChatIfNotExist(db *sql.DB, groupchat *Groupchat) (*Groupchat, error)

AddGroupChatIfNotExist ...

func GetGroupChatByTelegramID

func GetGroupChatByTelegramID(db *sql.DB, groupchat *Groupchat) (*Groupchat, error)

GetGroupChatByTelegramID ...

func GetGroupchats

func GetGroupchats(db *sql.DB, states []string) (groupchats []*Groupchat, err error)

GetGroupchats ...

func GetGroupchatsByGroupID

func GetGroupchatsByGroupID(db *sql.DB, groupID int64) (groupchats []*Groupchat, err error)

GetGroupchatsByGroupID ...

func (*Groupchat) String

func (gc *Groupchat) String() string

type Plugin

type Plugin struct {
	ID        int64     `sql:"id"`
	Name      string    `sql:"name"`
	State     string    `sql:"state"`
	CreatedAt time.Time `sql:"created_at"`
}

User ...

func AddPluginIfNotExist

func AddPluginIfNotExist(db *sql.DB, plugin *Plugin) (*Plugin, error)

AddPluginIfNotExist ...

func GetPlugins

func GetPlugins(db *sql.DB) (plugins []*Plugin, err error)

GetPlugins ...

func (*Plugin) IsEnabled

func (p *Plugin) IsEnabled() bool

func (*Plugin) String

func (p *Plugin) String() string

type TelegramMessage

type TelegramMessage struct {
	ID         int
	TelegramID int64
	FirstName  string
	LastName   string
	UserName   string
	Message    string
	IsBot      bool
	IsIncoming bool
	Date       time.Time
}

TelegramMessage ...

type User

type User struct {
	ID         int64     `sql:"id"`
	FirstName  string    `sql:"first_name"`
	LastName   string    `sql:"last_name"`
	UserName   string    `sql:"user_name"`
	TelegramID int64     `sql:"telegram_id"`
	IsBot      bool      `sql:"is_bot"`
	Role       string    `sql:"role"`
	Birthday   time.Time `sql:"birthday"`
	CreatedAt  time.Time `sql:"created_at"`
}

User ...

func AddUserIfNotExist

func AddUserIfNotExist(db *sql.DB, user *User) (*User, error)

AddUserIfNotExist ...

func GetUserByTelegramID

func GetUserByTelegramID(db *sql.DB, user *User) (*User, error)

GetUserByTelegramID ...

func GetUsers

func GetUsers(db *sql.DB, roles []string) (users []*User, err error)

GetUsers ...

func (*User) Paragraph

func (u *User) Paragraph() string

func (*User) String

func (u *User) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL