repository

func (*Repository) Count ¶

func (r *Repository) Count(ctx context.Context, userID, threadID int64) (count int, err error)

func (*Repository) Create ¶

func (r *Repository) Create(ctx context.Context, id int64, text string, title string, fileIDs []int64, threadID int64, userID int64, private bool, name string) (err error)

func (*Repository) DeleteMessage ¶

func (r *Repository) DeleteMessage(ctx context.Context, userID, id int64) (err error)

*

• Delete message and move ancestor messages on current thread
• @param {[type]} r *Repository) DeleteMessage(ctx context.Context, userID, id, parentThreadID int64) (err error [description]
• @return {error} error

func (*Repository) DeleteUserMessages ¶

func (r *Repository) DeleteUserMessages(ctx context.Context, userID int64) (err error)

func (*Repository) Private ¶

func (r *Repository) Private(ctx context.Context, userID int64, ids []int64) (err error)

func (*Repository) Publish ¶

func (r *Repository) Publish(ctx context.Context, userID int64, ids []int64) (err error)

func (*Repository) Read ¶

func (r *Repository) Read(ctx context.Context, userIDs []int64, id int64, name string) (message *model.Message, err error)

func (*Repository) ReadBatchMessages ¶

func (r *Repository) ReadBatchMessages(ctx context.Context, userID int64, messageIDs []int64) (messages []*model.Message, err error)

func (*Repository) ReadMessages ¶

func (r *Repository) ReadMessages(ctx context.Context, userID int64, limit, offset int32) (messages []*model.Message, isLastPage bool, err error)

*

• Read all user messages from all threads
• @param {[type]} r *Repository) ReadMessages(ctx context.Context, userID int64, limit, offset int32) (messages []*model.Message, isLastPage bool, err error [description]
• @return {[type]} [description]

func (*Repository) ReadMessagesAround ¶

func (r *Repository) ReadMessagesAround(ctx context.Context, userID, threadID, id int64, limit int32) (messages []*model.Message, isLastPage bool, offset int, err error)

func (*Repository) ReadPath ¶

func (r *Repository) ReadPath(ctx context.Context, userID, id int64) (path []*model.Message, err error)

func (*Repository) ReadThreadMessages ¶

func (r *Repository) ReadThreadMessages(ctx context.Context, userID, threadID int64, limit, offset int32) (messages []*model.Message, isLastPage bool, err error)

*

• @param {[type]} r *Repository) ReadThreadMessages(ctx context.Context, userID, threadID int64, limit, offset int32) (messages []*model.Message, isLastPage bool, err error [description]
• @return {[type]} [description]

func (*Repository) Truncate ¶

func (r *Repository) Truncate(ctx context.Context) (err error)

func (*Repository) Update ¶

func (r *Repository) Update(ctx context.Context, userID, id int64, newText, newTitle, newName string, newThreadID int64, newFileIDs []int64, newPrivate int) (err error)

*

• newText == "" : left as is
• newThreadID == -1 : left as is
• newPrivate == -1 : left as is
• @param {[type]} r *Repository) Update(ctx context.Context, userID, id int64, text, title, name string, threadID int64, fileIDs []int64, private int) (error [description]
• @return {error} error