Documentation ¶
Index ¶
- func AddValidationSession(ctx context.Context, db models.Query, medium, address, clientSecret string, ...) (int64, error)
- func GetAllPeers(ctx context.Context, db models.Query) ([]models.Peer, error)
- func GetAssociationsAfterID(ctx context.Context, db models.Query, afterID int64, limit int64) ([]models.Association, error)
- func GetOrCreateTokenSession(ctx context.Context, db models.Query, medium, address, clientSecret string) (*models.ValidationSession, error)
- func GetPeerByName(ctx context.Context, db models.Query, name string) (*models.Peer, error)
- func GetSenderForToken(ctx context.Context, db models.Query, token string) (string, error)
- func GetSessionByID(ctx context.Context, db models.Query, sid int64) (*models.ValidationSession, error)
- func GetTokenSessionByID(ctx context.Context, db models.Query, sid int64) (*models.TokenSession, error)
- func GetTokens(ctx context.Context, db models.Query, medium, address string) ([]models.InviteToken, error)
- func GetValidatedSession(ctx context.Context, db models.Query, sid int64, clientSecret string) (*models.ValidationSession, error)
- func GlobalAddAssociation(ctx context.Context, db models.Query, as *models.Association, ...) error
- func GlobalGetMxid(ctx context.Context, db models.Query, medium, address string) (string, error)
- func GlobalGetMxids(ctx context.Context, db models.Query, ids [][]string) ([]models.Association, error)
- func GlobalLastIDFromServer(ctx context.Context, db models.Query, originServer string) (int64, error)
- func GlobalRemoveAssociation(ctx context.Context, db models.Query, medium, address string) error
- func LocalAddOrUpdateAssociation(ctx context.Context, db models.Query, as *models.Association) error
- func LocalRemoveAssociation(ctx context.Context, db models.Query, as *models.Association) error
- func MarkTokensAsSent(ctx context.Context, db models.Query, medium, address string) error
- func SetLastSentVersionAndPokeSucceeded(ctx context.Context, db models.Query, ...) error
- func SetMtime(ctx context.Context, db models.Query, sid int64, mtime int64) error
- func SetSendAttemptNumber(ctx context.Context, db models.Query, sid int64, attemptNo int64) error
- func SetValidated(ctx context.Context, db models.Query, sid string, validated int) error
- func SignedAssociationStringForThreepid(ctx context.Context, db models.Query, medium, address string) (string, error)
- func StoreEphemeralPublicKey(ctx context.Context, db models.Query, publicKey string) error
- func StoreToken(ctx context.Context, db models.Query, token models.InviteToken) error
- func ValidateEphemeralPublicKey(ctx context.Context, db models.Query, publicKey string) error
- type Identity
- func (id *Identity) GetAllPeers(ctx context.Context) (peers []models.Peer, err error)
- func (id *Identity) GetAssociationsAfterID(ctx context.Context, afterID int64, limit int64) (as []models.Association, err error)
- func (id *Identity) GetOrCreateTokenSession(ctx context.Context, medium, address, clientSecret string) (session *models.ValidationSession, err error)
- func (id *Identity) GetPeerByName(ctx context.Context, name string) (peer *models.Peer, err error)
- func (id *Identity) GetSenderForToken(ctx context.Context, token string) (tokenInfo string, err error)
- func (id *Identity) GetSessionByID(ctx context.Context, sid int64) (session *models.ValidationSession, err error)
- func (id *Identity) GetTokenSessionByID(ctx context.Context, sid int64) (tokenSession *models.TokenSession, err error)
- func (id *Identity) GetTokens(ctx context.Context, medium, address string) (tokens []models.InviteToken, err error)
- func (id *Identity) GetValidatedSession(ctx context.Context, sid int64, clientSecret string) (session *models.ValidationSession, err error)
- func (id *Identity) GlobalAddAssociation(ctx context.Context, as *models.Association, originServer string, ...) (err error)
- func (id *Identity) GlobalGetMxid(ctx context.Context, medium, address string) (mxid string, err error)
- func (id *Identity) GlobalGetMxids(ctx context.Context, ids [][]string) (mxids []models.Association, err error)
- func (id *Identity) GlobalLastIDFromServer(ctx context.Context, originServer string) (lastID int64, err error)
- func (id *Identity) GlobalRemoveAssociation(ctx context.Context, medium, address string) (err error)
- func (id *Identity) LocalAddOrUpdateAssociation(ctx context.Context, as *models.Association) (err error)
- func (id *Identity) LocalRemoveAssociation(ctx context.Context, as *models.Association) (err error)
- func (id *Identity) MarkTokensAsSent(ctx context.Context, medium, address string) (err error)
- func (id *Identity) SetLastSentVersionAndPokeSucceeded(ctx context.Context, peerName, lastSentVersion, lastPokeSucceeded string) (err error)
- func (id *Identity) SetMtime(ctx context.Context, sid int64, mtime int64) (err error)
- func (id *Identity) SetSendAttemptNumber(ctx context.Context, sid int64, attemptNo int64) (err error)
- func (id *Identity) SetValidated(ctx context.Context, sid string, validated int) (err error)
- func (id *Identity) SignedAssociationStringForThreepid(ctx context.Context, medium, address string) (ass string, err error)
- func (id *Identity) StoreEphemeralPublicKey(ctx context.Context, publicKey string) (err error)
- func (id *Identity) StoreToken(ctx context.Context, token models.InviteToken) (err error)
- func (id *Identity) ValidateEphemeralPublicKey(ctx context.Context, publicKey string) (err error)
- type Matrix
- type Metric
- type Store
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddValidationSession ¶
func GetAssociationsAfterID ¶
func GetOrCreateTokenSession ¶
func GetPeerByName ¶
func GetSenderForToken ¶
func GetSessionByID ¶
func GetTokenSessionByID ¶
func GetValidatedSession ¶
func GetValidatedSession(ctx context.Context, db models.Query, sid int64, clientSecret string) (*models.ValidationSession, error)
GetValidatedSession returns a validated session with ma matching clientSecret
func GlobalAddAssociation ¶
func GlobalGetMxid ¶
func GlobalGetMxids ¶
func GlobalLastIDFromServer ¶
func GlobalRemoveAssociation ¶
func LocalRemoveAssociation ¶
func MarkTokensAsSent ¶
func SetSendAttemptNumber ¶
func SetValidated ¶
func StoreEphemeralPublicKey ¶
func StoreToken ¶
Types ¶
type Identity ¶
type Identity struct {
// contains filtered or unexported fields
}
Identity contains all identity service database facing routines.
func (*Identity) GetAllPeers ¶
func (*Identity) GetAssociationsAfterID ¶
func (*Identity) GetOrCreateTokenSession ¶
func (*Identity) GetPeerByName ¶
func (*Identity) GetSenderForToken ¶
func (*Identity) GetSessionByID ¶
func (*Identity) GetTokenSessionByID ¶
func (*Identity) GetValidatedSession ¶
func (*Identity) GlobalAddAssociation ¶
func (*Identity) GlobalGetMxid ¶
func (*Identity) GlobalGetMxids ¶
func (*Identity) GlobalLastIDFromServer ¶
func (*Identity) GlobalRemoveAssociation ¶
func (*Identity) LocalAddOrUpdateAssociation ¶
func (*Identity) LocalRemoveAssociation ¶
func (*Identity) MarkTokensAsSent ¶
func (*Identity) SetLastSentVersionAndPokeSucceeded ¶
func (*Identity) SetSendAttemptNumber ¶
func (*Identity) SetValidated ¶
func (*Identity) SignedAssociationStringForThreepid ¶
func (*Identity) StoreEphemeralPublicKey ¶
func (*Identity) StoreToken ¶
type Matrix ¶
type Matrix struct { *Identity // contains filtered or unexported fields }
Matrix universal database handler for the matrix services.
type Metric ¶
type Metric struct { Enabled bool Vec *prometheus.HistogramVec }
func NewMetric ¶
func NewMetric(opts prometheus.Opts) Metric
type Store ¶
type Store interface { StoreToken(ctx context.Context, token models.InviteToken) error GetTokens(ctx context.Context, medium, address string) ([]models.InviteToken, error) MarkTokensAsSent(ctx context.Context, medium, address string) error StoreEphemeralPublicKey(ctx context.Context, publicKey string) error ValidateEphemeralPublicKey(ctx context.Context, publicKey string) error GetSenderForToken(ctx context.Context, token string) (string, error) SignedAssociationStringForThreepid(ctx context.Context, medium, address string) (string, error) GlobalGetMxid(ctx context.Context, medium, address string) (string, error) GlobalGetMxids(ctx context.Context, ids [][]string) ([]models.Association, error) GlobalRemoveAssociation(ctx context.Context, medium, address string) error GlobalAddAssociation(ctx context.Context, as *models.Association, originServer string, originID int64, rawSgnAssoc string) error LocalAddOrUpdateAssociation(ctx context.Context, as *models.Association) error LocalRemoveAssociation(ctx context.Context, as *models.Association) error GetAssociationsAfterID(ctx context.Context, afterID int64, limit int64) ([]models.Association, error) GetPeerByName(ctx context.Context, name string) (*models.Peer, error) GetAllPeers(ctx context.Context) ([]models.Peer, error) SetLastSentVersionAndPokeSucceeded(ctx context.Context, peerName, lastSentVersion, lastPokeSucceeded string) error SetSendAttemptNumber(ctx context.Context, sid int64, attemptNo int64) error SetValidated(ctx context.Context, sid string, validated int) error SetMtime(ctx context.Context, sid int64, mtime int64) error GetSessionByID(ctx context.Context, sid int64) (*models.ValidationSession, error) GetTokenSessionByID(ctx context.Context, sid int64) (*models.TokenSession, error) GlobalLastIDFromServer(ctx context.Context, originServer string) (int64, error) GetOrCreateTokenSession(ctx context.Context, medium, address, clientSecret string) (*models.ValidationSession, error) GetValidatedSession(ctx context.Context, sid int64, clientSecret string) (*models.ValidationSession, error) DB() models.SQL Metric() Metric }
Source Files ¶
Click to show internal directories.
Click to hide internal directories.