repository

Documentation

Index

• func DeleteDBFile(filesDir string) error
• type DB
  • func OpenDB(filesDir string, key int) (*DB, error)
  • func (db *DB) RunMigrations() error
• type LatestMsgs
• type LocalConversationRepository
  • func NewLocalConversationRepository(db *DB) LocalConversationRepository
  • func (r LocalConversationRepository) DeleteAllConversations() error
  • func (r LocalConversationRepository) GetConversationByUserID(id string) (*domain.Conversation, error)
  • func (r LocalConversationRepository) GetConversations() ([]*domain.Conversation, error)
  • func (r LocalConversationRepository) SaveConversations(convos ...*domain.Conversation) error
• type LocalMessageRepository
  • func NewLocalMessageRepository(db *DB) LocalMessageRepository
  • func (r LocalMessageRepository) DeleteAllForSenderAndReceiver(senderId, receiverId string) error
  • func (r LocalMessageRepository) DeleteMsg(id string) error
  • func (r LocalMessageRepository) GetLatestMsgBodyForConvos(cui ...string) (LatestMsgs, error)
  • func (r LocalMessageRepository) GetMsgByID(id string) (*domain.Message, error)
  • func (r LocalMessageRepository) GetMsgsAsPage(sen string, fil domain.Filter) ([]*domain.Message, *domain.Metadata, error)
  • func (r LocalMessageRepository) SaveMsg(msg *domain.Message) error
  • func (r LocalMessageRepository) UpdateMsg(msg *domain.Message) error
• type LocalRepository
  • func NewLocalRepository(db *DB) *LocalRepository
• type LocalUserRepository
  • func (r LocalUserRepository) DeletePreviousUser() error
  • func (r LocalUserRepository) GetCurrentUser() (*domain.User, error)
  • func (r LocalUserRepository) SaveCurrentUser(u *domain.User) error
  • func (r LocalUserRepository) UpdateCurrentUser(u *domain.User) error

Functions

func DeleteDBFile

func DeleteDBFile(filesDir string) error

Types

type DB

type DB struct {
	*sqlx.DB
}

func OpenDB

func OpenDB(filesDir string, key int) (*DB, error)

func (*DB) RunMigrations

func (db *DB) RunMigrations() error

type LatestMsgs

type LatestMsgs map[string]*domain.LatestMsgBody

type LocalConversationRepository

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

func NewLocalConversationRepository

func NewLocalConversationRepository(db *DB) LocalConversationRepository

func (LocalConversationRepository) DeleteAllConversations

func (r LocalConversationRepository) DeleteAllConversations() error

func (LocalConversationRepository) GetConversationByUserID

func (r LocalConversationRepository) GetConversationByUserID(id string) (*domain.Conversation, error)

func (LocalConversationRepository) GetConversations

func (r LocalConversationRepository) GetConversations() ([]*domain.Conversation, error)

func (LocalConversationRepository) SaveConversations

func (r LocalConversationRepository) SaveConversations(convos ...*domain.Conversation) error

type LocalMessageRepository

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

func NewLocalMessageRepository

func NewLocalMessageRepository(db *DB) LocalMessageRepository

func (LocalMessageRepository) DeleteAllForSenderAndReceiver

func (r LocalMessageRepository) DeleteAllForSenderAndReceiver(senderId, receiverId string) error

func (LocalMessageRepository) DeleteMsg

func (r LocalMessageRepository) DeleteMsg(id string) error

func (LocalMessageRepository) GetLatestMsgBodyForConvos

func (r LocalMessageRepository) GetLatestMsgBodyForConvos(cui ...string) (LatestMsgs, error)

func (LocalMessageRepository) GetMsgByID

func (r LocalMessageRepository) GetMsgByID(id string) (*domain.Message, error)

func (LocalMessageRepository) GetMsgsAsPage

func (r LocalMessageRepository) GetMsgsAsPage(
	sen string,
	fil domain.Filter,
) ([]*domain.Message, *domain.Metadata, error)

func (LocalMessageRepository) SaveMsg

func (r LocalMessageRepository) SaveMsg(msg *domain.Message) error

func (LocalMessageRepository) UpdateMsg

func (r LocalMessageRepository) UpdateMsg(msg *domain.Message) error

type LocalRepository

type LocalRepository struct {
	LocalUserRepository
	LocalConversationRepository
	LocalMessageRepository
}

func NewLocalRepository

func NewLocalRepository(db *DB) *LocalRepository

type LocalUserRepository

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

func (LocalUserRepository) DeletePreviousUser

func (r LocalUserRepository) DeletePreviousUser() error

func (LocalUserRepository) GetCurrentUser

func (r LocalUserRepository) GetCurrentUser() (*domain.User, error)

func (LocalUserRepository) SaveCurrentUser

func (r LocalUserRepository) SaveCurrentUser(u *domain.User) error

func (LocalUserRepository) UpdateCurrentUser

func (r LocalUserRepository) UpdateCurrentUser(u *domain.User) error