postgres

Documentation

Index

• type Store
  • func NewStore(db *sql.DB, redis *redis.Client) *Store
  • func (s *Store) AddGroupMember(groupID, userID string) error
  • func (s *Store) AddKyberPreKeys(userID string, prekeys []models.KyberPreKey) error
  • func (s *Store) AddOneTimePreKeys(userID string, prekeys []models.OneTimePreKey) error
  • func (s *Store) CreateDMSpace(spaceID, user1ID, user2ID string, enableE2E bool) error
  • func (s *Store) CreateE2EGroupSpace(spaceID, createdBy string, memberIDs []string) error
  • func (s *Store) CreateGroup(groupID string, creatorID string) error
  • func (s *Store) DeleteDMForUser(messageID, userID string) error
  • func (s *Store) DeleteDMsBetweenUsers(user1, user2 string) error
  • func (s *Store) EnableE2EForSpace(spaceID string) error
  • func (s *Store) FindDMSpace(user1ID, user2ID string) (*models.DMSpace, error)
  • func (s *Store) GetDMsBetweenUsers(userID1, userID2 string, limit int) ([]models.EncryptedDM, error)
  • func (s *Store) GetDMsForUser(userID string, messageType string, limit int) ([]models.EncryptedDM, error)
  • func (s *Store) GetE2ESpace(spaceID string) (*models.E2ESpace, error)
  • func (s *Store) GetGroupMembers(groupID string) ([]string, error)
  • func (s *Store) GetGroupMessages(groupID string, limit int) ([]models.EncryptedGroupMessage, error)
  • func (s *Store) GetGroupSenderKeys(groupID string) ([]models.SenderKey, error)
  • func (s *Store) GetPreKeyBundle(userID string) (*models.PreKeyBundle, error)
  • func (s *Store) GetUnusedKyberPreKey(userID string) (*models.KyberPreKey, error)
  • func (s *Store) GetUnusedKyberPreKeyCount(userID string) (int, error)
  • func (s *Store) GetUnusedPreKeyCount(userID string) (int, error)
  • func (s *Store) GetUserDMSpaces(userID string) ([]models.DMSpace, error)
  • func (s *Store) IncrementKeyVersion(groupID string) error
  • func (s *Store) IsSpaceMember(spaceID, userID string) (bool, error)
  • func (s *Store) MarkDMAsRead(messageID, userID string) error
  • func (s *Store) MarkKyberPreKeyUsed(userID string, keyID int) error
  • func (s *Store) MarkPreKeyUsed(userID string, keyID int) error
  • func (s *Store) Migrate() error
  • func (s *Store) RemoveGroupMember(groupID, userID string) error
  • func (s *Store) SaveDM(dm models.EncryptedDM) error
  • func (s *Store) SaveGroupMessage(msg models.EncryptedGroupMessage) error
  • func (s *Store) SaveIdentityKey(userID string, registration models.KeyRegistration) error
  • func (s *Store) SaveSenderKey(key models.SenderKey) error
  • func (s *Store) SessionExists(userID, peerID string) (bool, error)
  • func (s *Store) UpdateLastMessage(spaceID string) error

Types

type Store

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

func NewStore

func NewStore(db *sql.DB, redis *redis.Client) *Store

func (*Store) AddGroupMember

func (s *Store) AddGroupMember(groupID, userID string) error

func (*Store) AddKyberPreKeys

func (s *Store) AddKyberPreKeys(userID string, prekeys []models.KyberPreKey) error

func (*Store) AddOneTimePreKeys

func (s *Store) AddOneTimePreKeys(userID string, prekeys []models.OneTimePreKey) error

func (*Store) CreateDMSpace

func (s *Store) CreateDMSpace(spaceID, user1ID, user2ID string, enableE2E bool) error

CreateDMSpace creates a new DM space between two users

func (*Store) CreateE2EGroupSpace

func (s *Store) CreateE2EGroupSpace(spaceID, createdBy string, memberIDs []string) error

CreateE2EGroupSpace creates a new E2E encrypted group space

func (*Store) CreateGroup

func (s *Store) CreateGroup(groupID string, creatorID string) error

func (*Store) DeleteDMForUser

func (s *Store) DeleteDMForUser(messageID, userID string) error

func (*Store) DeleteDMsBetweenUsers

func (s *Store) DeleteDMsBetweenUsers(user1, user2 string) error

func (*Store) EnableE2EForSpace

func (s *Store) EnableE2EForSpace(spaceID string) error

EnableE2EForSpace enables E2E encryption for a space

func (*Store) FindDMSpace

func (s *Store) FindDMSpace(user1ID, user2ID string) (*models.DMSpace, error)

FindDMSpace finds an existing DM space between two users

func (*Store) GetDMsBetweenUsers

func (s *Store) GetDMsBetweenUsers(userID1, userID2 string, limit int) ([]models.EncryptedDM, error)

func (*Store) GetDMsForUser

func (s *Store) GetDMsForUser(userID string, messageType string, limit int) ([]models.EncryptedDM, error)

func (*Store) GetE2ESpace

func (s *Store) GetE2ESpace(spaceID string) (*models.E2ESpace, error)

GetE2ESpace gets information about an E2E space

func (*Store) GetGroupMembers

func (s *Store) GetGroupMembers(groupID string) ([]string, error)

func (*Store) GetGroupMessages

func (s *Store) GetGroupMessages(groupID string, limit int) ([]models.EncryptedGroupMessage, error)

func (*Store) GetGroupSenderKeys

func (s *Store) GetGroupSenderKeys(groupID string) ([]models.SenderKey, error)

func (*Store) GetPreKeyBundle

func (s *Store) GetPreKeyBundle(userID string) (*models.PreKeyBundle, error)

func (*Store) GetUnusedKyberPreKey

func (s *Store) GetUnusedKyberPreKey(userID string) (*models.KyberPreKey, error)

func (*Store) GetUnusedKyberPreKeyCount

func (s *Store) GetUnusedKyberPreKeyCount(userID string) (int, error)

func (*Store) GetUnusedPreKeyCount

func (s *Store) GetUnusedPreKeyCount(userID string) (int, error)

func (*Store) GetUserDMSpaces

func (s *Store) GetUserDMSpaces(userID string) ([]models.DMSpace, error)

GetUserDMSpaces gets all DM spaces for a user

func (*Store) IncrementKeyVersion

func (s *Store) IncrementKeyVersion(groupID string) error

func (*Store) IsSpaceMember

func (s *Store) IsSpaceMember(spaceID, userID string) (bool, error)

IsSpaceMember checks if a user is a member of a space

func (*Store) MarkDMAsRead

func (s *Store) MarkDMAsRead(messageID, userID string) error

func (*Store) MarkKyberPreKeyUsed

func (s *Store) MarkKyberPreKeyUsed(userID string, keyID int) error

func (*Store) MarkPreKeyUsed

func (s *Store) MarkPreKeyUsed(userID string, keyID int) error

func (*Store) Migrate

func (s *Store) Migrate() error

func (*Store) RemoveGroupMember

func (s *Store) RemoveGroupMember(groupID, userID string) error

func (*Store) SaveDM

func (s *Store) SaveDM(dm models.EncryptedDM) error

func (*Store) SaveGroupMessage

func (s *Store) SaveGroupMessage(msg models.EncryptedGroupMessage) error

func (*Store) SaveIdentityKey

func (s *Store) SaveIdentityKey(userID string, registration models.KeyRegistration) error

func (*Store) SaveSenderKey

func (s *Store) SaveSenderKey(key models.SenderKey) error

func (*Store) SessionExists

func (s *Store) SessionExists(userID, peerID string) (bool, error)

SessionExists checks if a Signal session exists between two users

func (*Store) UpdateLastMessage

func (s *Store) UpdateLastMessage(spaceID string) error

UpdateLastMessage updates the last message timestamp for a DM