dao

Documentation

Index

• type Dao
  • func New(c config.Config) *Dao
  • func (d *Dao) BindAuthKeyUser(ctx context.Context, authKeyId int64, userId int64) int64
  • func (d *Dao) GetApiLayer(ctx context.Context, authKeyId int64) int32
  • func (d *Dao) GetAuthKey(ctx context.Context, keyId int64) (keyData *mtproto.AuthKeyInfo, err error)
  • func (d *Dao) GetAuthKeyUserId(ctx context.Context, authKeyId int64) int64
  • func (d *Dao) GetAuthorization(ctx context.Context, authKeyId int64) (*mtproto.Authorization, error)
  • func (d *Dao) GetAuthorizations(ctx context.Context, userId int64, excludeAuthKeyId int64) (authorizations []*mtproto.Authorization)
  • func (d *Dao) GetClient(ctx context.Context, authKeyId int64) string
  • func (d *Dao) GetFutureSalts(ctx context.Context, authKeyId int64, num int32) (*mtproto.TLFutureSalts, error)
  • func (d *Dao) GetLangCode(ctx context.Context, authKeyId int64) string
  • func (d *Dao) GetLangPack(ctx context.Context, authKeyId int64) string
  • func (d *Dao) GetPermAuthKeyId(ctx context.Context, authKeyId int64) int64
  • func (d *Dao) GetPushSessionId(ctx context.Context, userId int64, authKeyId int64, tokenType int32) int64
  • func (d *Dao) GetSalts(ctx context.Context, keyId int64) (salts []*mtproto.TLFutureSalt, err error)
  • func (d *Dao) InsertAuthKey(ctx context.Context, authKey *mtproto.AuthKeyInfo, salt *mtproto.TLFutureSalt, ...) (err error)
  • func (d *Dao) PutAuthKey(ctx context.Context, keyId int64, keyData *mtproto.AuthKeyInfo, ...) (err error)
  • func (d *Dao) PutSalts(ctx context.Context, keyId int64, salts []*mtproto.TLFutureSalt) (err error)
  • func (d *Dao) QueryAuthKey(ctx context.Context, authKeyId int64) (*mtproto.AuthKeyInfo, error)
  • func (d *Dao) ResetAuthorization(ctx context.Context, userId int64, authKeyId, hash int64) []int64
  • func (d *Dao) SetClientSessionInfo(ctx context.Context, session *authsession.ClientSession) bool
  • func (d *Dao) UnbindAuthUser(ctx context.Context, authKeyId int64, userId int64) bool
  • func (d *Dao) UnsafeBindKeyId(ctx context.Context, keyId int64, bindType int32, bindKeyId int64) (err error)
• type Mysql

Types

type Dao

type Dao struct {
	*Mysql
	sqlc.CachedConn

	MMDB *geoip2.Reader
	// contains filtered or unexported fields
}

func New

func New(c config.Config) *Dao

func (*Dao) BindAuthKeyUser

func (d *Dao) BindAuthKeyUser(ctx context.Context, authKeyId int64, userId int64) int64

func (*Dao) GetApiLayer

func (d *Dao) GetApiLayer(ctx context.Context, authKeyId int64) int32

func (*Dao) GetAuthKey

func (d *Dao) GetAuthKey(ctx context.Context, keyId int64) (keyData *mtproto.AuthKeyInfo, err error)

func (*Dao) GetAuthKeyUserId

func (d *Dao) GetAuthKeyUserId(ctx context.Context, authKeyId int64) int64

func (*Dao) GetAuthorization

func (d *Dao) GetAuthorization(ctx context.Context, authKeyId int64) (*mtproto.Authorization, error)

func (*Dao) GetAuthorizations

func (d *Dao) GetAuthorizations(ctx context.Context, userId int64, excludeAuthKeyId int64) (authorizations []*mtproto.Authorization)

func (*Dao) GetClient

func (d *Dao) GetClient(ctx context.Context, authKeyId int64) string

func (*Dao) GetFutureSalts

func (d *Dao) GetFutureSalts(ctx context.Context, authKeyId int64, num int32) (*mtproto.TLFutureSalts, error)

func (*Dao) GetLangCode

func (d *Dao) GetLangCode(ctx context.Context, authKeyId int64) string

func (*Dao) GetLangPack

func (d *Dao) GetLangPack(ctx context.Context, authKeyId int64) string

func (*Dao) GetPermAuthKeyId

func (d *Dao) GetPermAuthKeyId(ctx context.Context, authKeyId int64) int64

func (*Dao) GetPushSessionId

func (d *Dao) GetPushSessionId(ctx context.Context, userId int64, authKeyId int64, tokenType int32) int64

func (*Dao) GetSalts

func (d *Dao) GetSalts(ctx context.Context, keyId int64) (salts []*mtproto.TLFutureSalt, err error)

func (*Dao) InsertAuthKey

func (d *Dao) InsertAuthKey(ctx context.Context, authKey *mtproto.AuthKeyInfo, salt *mtproto.TLFutureSalt, expiredIn int32) (err error)

func (*Dao) PutAuthKey

func (d *Dao) PutAuthKey(ctx context.Context, keyId int64, keyData *mtproto.AuthKeyInfo, expiredIn int32) (err error)

func (*Dao) PutSalts

func (d *Dao) PutSalts(ctx context.Context, keyId int64, salts []*mtproto.TLFutureSalt) (err error)

func (*Dao) QueryAuthKey

func (d *Dao) QueryAuthKey(ctx context.Context, authKeyId int64) (*mtproto.AuthKeyInfo, error)

func (*Dao) ResetAuthorization

func (d *Dao) ResetAuthorization(ctx context.Context, userId int64, authKeyId, hash int64) []int64

func (*Dao) SetClientSessionInfo

func (d *Dao) SetClientSessionInfo(ctx context.Context, session *authsession.ClientSession) bool

func (*Dao) UnbindAuthUser

func (d *Dao) UnbindAuthUser(ctx context.Context, authKeyId int64, userId int64) bool

func (*Dao) UnsafeBindKeyId

func (d *Dao) UnsafeBindKeyId(ctx context.Context, keyId int64, bindType int32, bindKeyId int64) (err error)

type Mysql

type Mysql struct {
	*sqlx.DB
	*mysql_dao.AuthKeysDAO
	*mysql_dao.AuthUsersDAO
	*mysql_dao.AuthsDAO
	*mysql_dao.DevicesDAO
	*mysql_dao.AuthKeyInfosDAO
	*sqlx.CommonDAO
}