mirror of
https://github.com/hanzoai/team.git
synced 2026-09-30 01:57:35 +00:00
* Refactor shared channel membership sync to use ChannelMemberHistory (MM-67616) Replace the trigger-time membership sync mechanism with a cursor-based approach using ChannelMemberHistory, aligning membership sync with the established pattern used by posts and reactions. Previously, membership changes were built into SyncMsg at trigger time and sent via a separate TopicChannelMembership code path. This meant removals were lost if a remote was offline, since ChannelMembers hard-deletes rows. Now, membership changes are fetched from ChannelMemberHistory at sync time using the LastMembersSyncAt cursor, detecting both joins and leaves reliably. The data flows through the normal syncForRemote pipeline alongside posts, reactions, and other sync data. Key changes: - Add GetMembershipChanges store method for ChannelMemberHistory - Add fetchMembershipsForSync and sendMembershipSyncData to sync pipeline - Replace HandleMembershipChange with NotifyMembershipChanged (trigger-only) - Remove conflict detection (idempotent add/remove resolves naturally) - Remove per-user membership tracking (GetUserChanges, UpdateUserLastMembershipSyncAt) - Add MembershipErrors to SyncResponse - Keep TopicChannelMembership receiver for one release cycle (backward compat)
1481 lines
40 KiB
Go
1481 lines
40 KiB
Go
// Code generated by mockery v2.53.4. DO NOT EDIT.
|
|
|
|
// Regenerate this file using `make store-mocks`.
|
|
|
|
package mocks
|
|
|
|
import (
|
|
model "github.com/mattermost/mattermost/server/public/model"
|
|
request "github.com/mattermost/mattermost/server/public/shared/request"
|
|
mock "github.com/stretchr/testify/mock"
|
|
|
|
store "github.com/mattermost/mattermost/server/v8/channels/store"
|
|
)
|
|
|
|
// PostStore is an autogenerated mock type for the PostStore type
|
|
type PostStore struct {
|
|
mock.Mock
|
|
}
|
|
|
|
// AnalyticsPostCount provides a mock function with given fields: options
|
|
func (_m *PostStore) AnalyticsPostCount(options *model.PostCountOptions) (int64, error) {
|
|
ret := _m.Called(options)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for AnalyticsPostCount")
|
|
}
|
|
|
|
var r0 int64
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(*model.PostCountOptions) (int64, error)); ok {
|
|
return rf(options)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(*model.PostCountOptions) int64); ok {
|
|
r0 = rf(options)
|
|
} else {
|
|
r0 = ret.Get(0).(int64)
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(*model.PostCountOptions) error); ok {
|
|
r1 = rf(options)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// AnalyticsPostCountByTeam provides a mock function with given fields: teamID
|
|
func (_m *PostStore) AnalyticsPostCountByTeam(teamID string) (int64, error) {
|
|
ret := _m.Called(teamID)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for AnalyticsPostCountByTeam")
|
|
}
|
|
|
|
var r0 int64
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(string) (int64, error)); ok {
|
|
return rf(teamID)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(string) int64); ok {
|
|
r0 = rf(teamID)
|
|
} else {
|
|
r0 = ret.Get(0).(int64)
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(string) error); ok {
|
|
r1 = rf(teamID)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// AnalyticsPostCountsByDay provides a mock function with given fields: options
|
|
func (_m *PostStore) AnalyticsPostCountsByDay(options *model.AnalyticsPostCountsOptions) (model.AnalyticsRows, error) {
|
|
ret := _m.Called(options)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for AnalyticsPostCountsByDay")
|
|
}
|
|
|
|
var r0 model.AnalyticsRows
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(*model.AnalyticsPostCountsOptions) (model.AnalyticsRows, error)); ok {
|
|
return rf(options)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(*model.AnalyticsPostCountsOptions) model.AnalyticsRows); ok {
|
|
r0 = rf(options)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).(model.AnalyticsRows)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(*model.AnalyticsPostCountsOptions) error); ok {
|
|
r1 = rf(options)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// AnalyticsUserCountsWithPostsByDay provides a mock function with given fields: teamID
|
|
func (_m *PostStore) AnalyticsUserCountsWithPostsByDay(teamID string) (model.AnalyticsRows, error) {
|
|
ret := _m.Called(teamID)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for AnalyticsUserCountsWithPostsByDay")
|
|
}
|
|
|
|
var r0 model.AnalyticsRows
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(string) (model.AnalyticsRows, error)); ok {
|
|
return rf(teamID)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(string) model.AnalyticsRows); ok {
|
|
r0 = rf(teamID)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).(model.AnalyticsRows)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(string) error); ok {
|
|
r1 = rf(teamID)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// ClearCaches provides a mock function with no fields
|
|
func (_m *PostStore) ClearCaches() {
|
|
_m.Called()
|
|
}
|
|
|
|
// Delete provides a mock function with given fields: rctx, postID, timestamp, deleteByID
|
|
func (_m *PostStore) Delete(rctx request.CTX, postID string, timestamp int64, deleteByID string) error {
|
|
ret := _m.Called(rctx, postID, timestamp, deleteByID)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for Delete")
|
|
}
|
|
|
|
var r0 error
|
|
if rf, ok := ret.Get(0).(func(request.CTX, string, int64, string) error); ok {
|
|
r0 = rf(rctx, postID, timestamp, deleteByID)
|
|
} else {
|
|
r0 = ret.Error(0)
|
|
}
|
|
|
|
return r0
|
|
}
|
|
|
|
// DeleteAllPostRemindersForPost provides a mock function with given fields: postId
|
|
func (_m *PostStore) DeleteAllPostRemindersForPost(postId string) error {
|
|
ret := _m.Called(postId)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for DeleteAllPostRemindersForPost")
|
|
}
|
|
|
|
var r0 error
|
|
if rf, ok := ret.Get(0).(func(string) error); ok {
|
|
r0 = rf(postId)
|
|
} else {
|
|
r0 = ret.Error(0)
|
|
}
|
|
|
|
return r0
|
|
}
|
|
|
|
// Get provides a mock function with given fields: rctx, id, opts, userID, sanitizeOptions
|
|
func (_m *PostStore) Get(rctx request.CTX, id string, opts model.GetPostsOptions, userID string, sanitizeOptions map[string]bool) (*model.PostList, error) {
|
|
ret := _m.Called(rctx, id, opts, userID, sanitizeOptions)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for Get")
|
|
}
|
|
|
|
var r0 *model.PostList
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(request.CTX, string, model.GetPostsOptions, string, map[string]bool) (*model.PostList, error)); ok {
|
|
return rf(rctx, id, opts, userID, sanitizeOptions)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(request.CTX, string, model.GetPostsOptions, string, map[string]bool) *model.PostList); ok {
|
|
r0 = rf(rctx, id, opts, userID, sanitizeOptions)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).(*model.PostList)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(request.CTX, string, model.GetPostsOptions, string, map[string]bool) error); ok {
|
|
r1 = rf(rctx, id, opts, userID, sanitizeOptions)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetDirectPostParentsForExportAfter provides a mock function with given fields: limit, afterID, includeArchivedChannels
|
|
func (_m *PostStore) GetDirectPostParentsForExportAfter(limit int, afterID string, includeArchivedChannels bool) ([]*model.DirectPostForExport, error) {
|
|
ret := _m.Called(limit, afterID, includeArchivedChannels)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetDirectPostParentsForExportAfter")
|
|
}
|
|
|
|
var r0 []*model.DirectPostForExport
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(int, string, bool) ([]*model.DirectPostForExport, error)); ok {
|
|
return rf(limit, afterID, includeArchivedChannels)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(int, string, bool) []*model.DirectPostForExport); ok {
|
|
r0 = rf(limit, afterID, includeArchivedChannels)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).([]*model.DirectPostForExport)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(int, string, bool) error); ok {
|
|
r1 = rf(limit, afterID, includeArchivedChannels)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetEditHistoryForPost provides a mock function with given fields: postID
|
|
func (_m *PostStore) GetEditHistoryForPost(postID string) ([]*model.Post, error) {
|
|
ret := _m.Called(postID)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetEditHistoryForPost")
|
|
}
|
|
|
|
var r0 []*model.Post
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(string) ([]*model.Post, error)); ok {
|
|
return rf(postID)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(string) []*model.Post); ok {
|
|
r0 = rf(postID)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).([]*model.Post)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(string) error); ok {
|
|
r1 = rf(postID)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetEtag provides a mock function with given fields: channelID, allowFromCache, collapsedThreads, includeTranslations
|
|
func (_m *PostStore) GetEtag(channelID string, allowFromCache bool, collapsedThreads bool, includeTranslations bool) string {
|
|
ret := _m.Called(channelID, allowFromCache, collapsedThreads, includeTranslations)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetEtag")
|
|
}
|
|
|
|
var r0 string
|
|
if rf, ok := ret.Get(0).(func(string, bool, bool, bool) string); ok {
|
|
r0 = rf(channelID, allowFromCache, collapsedThreads, includeTranslations)
|
|
} else {
|
|
r0 = ret.Get(0).(string)
|
|
}
|
|
|
|
return r0
|
|
}
|
|
|
|
// GetFlaggedPosts provides a mock function with given fields: userID, offset, limit
|
|
func (_m *PostStore) GetFlaggedPosts(userID string, offset int, limit int) (*model.PostList, error) {
|
|
ret := _m.Called(userID, offset, limit)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetFlaggedPosts")
|
|
}
|
|
|
|
var r0 *model.PostList
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(string, int, int) (*model.PostList, error)); ok {
|
|
return rf(userID, offset, limit)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(string, int, int) *model.PostList); ok {
|
|
r0 = rf(userID, offset, limit)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).(*model.PostList)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(string, int, int) error); ok {
|
|
r1 = rf(userID, offset, limit)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetFlaggedPostsForChannel provides a mock function with given fields: userID, channelID, offset, limit
|
|
func (_m *PostStore) GetFlaggedPostsForChannel(userID string, channelID string, offset int, limit int) (*model.PostList, error) {
|
|
ret := _m.Called(userID, channelID, offset, limit)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetFlaggedPostsForChannel")
|
|
}
|
|
|
|
var r0 *model.PostList
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(string, string, int, int) (*model.PostList, error)); ok {
|
|
return rf(userID, channelID, offset, limit)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(string, string, int, int) *model.PostList); ok {
|
|
r0 = rf(userID, channelID, offset, limit)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).(*model.PostList)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(string, string, int, int) error); ok {
|
|
r1 = rf(userID, channelID, offset, limit)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetFlaggedPostsForTeam provides a mock function with given fields: userID, teamID, offset, limit
|
|
func (_m *PostStore) GetFlaggedPostsForTeam(userID string, teamID string, offset int, limit int) (*model.PostList, error) {
|
|
ret := _m.Called(userID, teamID, offset, limit)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetFlaggedPostsForTeam")
|
|
}
|
|
|
|
var r0 *model.PostList
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(string, string, int, int) (*model.PostList, error)); ok {
|
|
return rf(userID, teamID, offset, limit)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(string, string, int, int) *model.PostList); ok {
|
|
r0 = rf(userID, teamID, offset, limit)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).(*model.PostList)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(string, string, int, int) error); ok {
|
|
r1 = rf(userID, teamID, offset, limit)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetMaxPostSize provides a mock function with no fields
|
|
func (_m *PostStore) GetMaxPostSize() int {
|
|
ret := _m.Called()
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetMaxPostSize")
|
|
}
|
|
|
|
var r0 int
|
|
if rf, ok := ret.Get(0).(func() int); ok {
|
|
r0 = rf()
|
|
} else {
|
|
r0 = ret.Get(0).(int)
|
|
}
|
|
|
|
return r0
|
|
}
|
|
|
|
// GetNthRecentPostTime provides a mock function with given fields: n
|
|
func (_m *PostStore) GetNthRecentPostTime(n int64) (int64, error) {
|
|
ret := _m.Called(n)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetNthRecentPostTime")
|
|
}
|
|
|
|
var r0 int64
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(int64) (int64, error)); ok {
|
|
return rf(n)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(int64) int64); ok {
|
|
r0 = rf(n)
|
|
} else {
|
|
r0 = ret.Get(0).(int64)
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(int64) error); ok {
|
|
r1 = rf(n)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetOldest provides a mock function with no fields
|
|
func (_m *PostStore) GetOldest() (*model.Post, error) {
|
|
ret := _m.Called()
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetOldest")
|
|
}
|
|
|
|
var r0 *model.Post
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func() (*model.Post, error)); ok {
|
|
return rf()
|
|
}
|
|
if rf, ok := ret.Get(0).(func() *model.Post); ok {
|
|
r0 = rf()
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).(*model.Post)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func() error); ok {
|
|
r1 = rf()
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetOldestEntityCreationTime provides a mock function with no fields
|
|
func (_m *PostStore) GetOldestEntityCreationTime() (int64, error) {
|
|
ret := _m.Called()
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetOldestEntityCreationTime")
|
|
}
|
|
|
|
var r0 int64
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func() (int64, error)); ok {
|
|
return rf()
|
|
}
|
|
if rf, ok := ret.Get(0).(func() int64); ok {
|
|
r0 = rf()
|
|
} else {
|
|
r0 = ret.Get(0).(int64)
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func() error); ok {
|
|
r1 = rf()
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetParentsForExportAfter provides a mock function with given fields: limit, afterID, includeArchivedChannels
|
|
func (_m *PostStore) GetParentsForExportAfter(limit int, afterID string, includeArchivedChannels bool) ([]*model.PostForExport, error) {
|
|
ret := _m.Called(limit, afterID, includeArchivedChannels)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetParentsForExportAfter")
|
|
}
|
|
|
|
var r0 []*model.PostForExport
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(int, string, bool) ([]*model.PostForExport, error)); ok {
|
|
return rf(limit, afterID, includeArchivedChannels)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(int, string, bool) []*model.PostForExport); ok {
|
|
r0 = rf(limit, afterID, includeArchivedChannels)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).([]*model.PostForExport)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(int, string, bool) error); ok {
|
|
r1 = rf(limit, afterID, includeArchivedChannels)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetPostAfterTime provides a mock function with given fields: channelID, timestamp, collapsedThreads
|
|
func (_m *PostStore) GetPostAfterTime(channelID string, timestamp int64, collapsedThreads bool) (*model.Post, error) {
|
|
ret := _m.Called(channelID, timestamp, collapsedThreads)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetPostAfterTime")
|
|
}
|
|
|
|
var r0 *model.Post
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(string, int64, bool) (*model.Post, error)); ok {
|
|
return rf(channelID, timestamp, collapsedThreads)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(string, int64, bool) *model.Post); ok {
|
|
r0 = rf(channelID, timestamp, collapsedThreads)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).(*model.Post)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(string, int64, bool) error); ok {
|
|
r1 = rf(channelID, timestamp, collapsedThreads)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetPostIdAfterTime provides a mock function with given fields: channelID, timestamp, collapsedThreads
|
|
func (_m *PostStore) GetPostIdAfterTime(channelID string, timestamp int64, collapsedThreads bool) (string, error) {
|
|
ret := _m.Called(channelID, timestamp, collapsedThreads)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetPostIdAfterTime")
|
|
}
|
|
|
|
var r0 string
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(string, int64, bool) (string, error)); ok {
|
|
return rf(channelID, timestamp, collapsedThreads)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(string, int64, bool) string); ok {
|
|
r0 = rf(channelID, timestamp, collapsedThreads)
|
|
} else {
|
|
r0 = ret.Get(0).(string)
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(string, int64, bool) error); ok {
|
|
r1 = rf(channelID, timestamp, collapsedThreads)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetPostIdBeforeTime provides a mock function with given fields: channelID, timestamp, collapsedThreads
|
|
func (_m *PostStore) GetPostIdBeforeTime(channelID string, timestamp int64, collapsedThreads bool) (string, error) {
|
|
ret := _m.Called(channelID, timestamp, collapsedThreads)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetPostIdBeforeTime")
|
|
}
|
|
|
|
var r0 string
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(string, int64, bool) (string, error)); ok {
|
|
return rf(channelID, timestamp, collapsedThreads)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(string, int64, bool) string); ok {
|
|
r0 = rf(channelID, timestamp, collapsedThreads)
|
|
} else {
|
|
r0 = ret.Get(0).(string)
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(string, int64, bool) error); ok {
|
|
r1 = rf(channelID, timestamp, collapsedThreads)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetPostReminderMetadata provides a mock function with given fields: postID
|
|
func (_m *PostStore) GetPostReminderMetadata(postID string) (*store.PostReminderMetadata, error) {
|
|
ret := _m.Called(postID)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetPostReminderMetadata")
|
|
}
|
|
|
|
var r0 *store.PostReminderMetadata
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(string) (*store.PostReminderMetadata, error)); ok {
|
|
return rf(postID)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(string) *store.PostReminderMetadata); ok {
|
|
r0 = rf(postID)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).(*store.PostReminderMetadata)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(string) error); ok {
|
|
r1 = rf(postID)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetPostReminders provides a mock function with given fields: now
|
|
func (_m *PostStore) GetPostReminders(now int64) ([]*model.PostReminder, error) {
|
|
ret := _m.Called(now)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetPostReminders")
|
|
}
|
|
|
|
var r0 []*model.PostReminder
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(int64) ([]*model.PostReminder, error)); ok {
|
|
return rf(now)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(int64) []*model.PostReminder); ok {
|
|
r0 = rf(now)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).([]*model.PostReminder)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(int64) error); ok {
|
|
r1 = rf(now)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetPosts provides a mock function with given fields: rctx, options, allowFromCache, sanitizeOptions
|
|
func (_m *PostStore) GetPosts(rctx request.CTX, options model.GetPostsOptions, allowFromCache bool, sanitizeOptions map[string]bool) (*model.PostList, error) {
|
|
ret := _m.Called(rctx, options, allowFromCache, sanitizeOptions)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetPosts")
|
|
}
|
|
|
|
var r0 *model.PostList
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(request.CTX, model.GetPostsOptions, bool, map[string]bool) (*model.PostList, error)); ok {
|
|
return rf(rctx, options, allowFromCache, sanitizeOptions)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(request.CTX, model.GetPostsOptions, bool, map[string]bool) *model.PostList); ok {
|
|
r0 = rf(rctx, options, allowFromCache, sanitizeOptions)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).(*model.PostList)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(request.CTX, model.GetPostsOptions, bool, map[string]bool) error); ok {
|
|
r1 = rf(rctx, options, allowFromCache, sanitizeOptions)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetPostsAfter provides a mock function with given fields: rctx, options, sanitizeOptions
|
|
func (_m *PostStore) GetPostsAfter(rctx request.CTX, options model.GetPostsOptions, sanitizeOptions map[string]bool) (*model.PostList, error) {
|
|
ret := _m.Called(rctx, options, sanitizeOptions)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetPostsAfter")
|
|
}
|
|
|
|
var r0 *model.PostList
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(request.CTX, model.GetPostsOptions, map[string]bool) (*model.PostList, error)); ok {
|
|
return rf(rctx, options, sanitizeOptions)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(request.CTX, model.GetPostsOptions, map[string]bool) *model.PostList); ok {
|
|
r0 = rf(rctx, options, sanitizeOptions)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).(*model.PostList)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(request.CTX, model.GetPostsOptions, map[string]bool) error); ok {
|
|
r1 = rf(rctx, options, sanitizeOptions)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetPostsBatchForIndexing provides a mock function with given fields: startTime, startPostID, limit
|
|
func (_m *PostStore) GetPostsBatchForIndexing(startTime int64, startPostID string, limit int) ([]*model.PostForIndexing, error) {
|
|
ret := _m.Called(startTime, startPostID, limit)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetPostsBatchForIndexing")
|
|
}
|
|
|
|
var r0 []*model.PostForIndexing
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(int64, string, int) ([]*model.PostForIndexing, error)); ok {
|
|
return rf(startTime, startPostID, limit)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(int64, string, int) []*model.PostForIndexing); ok {
|
|
r0 = rf(startTime, startPostID, limit)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).([]*model.PostForIndexing)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(int64, string, int) error); ok {
|
|
r1 = rf(startTime, startPostID, limit)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetPostsBefore provides a mock function with given fields: rctx, options, sanitizeOptions
|
|
func (_m *PostStore) GetPostsBefore(rctx request.CTX, options model.GetPostsOptions, sanitizeOptions map[string]bool) (*model.PostList, error) {
|
|
ret := _m.Called(rctx, options, sanitizeOptions)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetPostsBefore")
|
|
}
|
|
|
|
var r0 *model.PostList
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(request.CTX, model.GetPostsOptions, map[string]bool) (*model.PostList, error)); ok {
|
|
return rf(rctx, options, sanitizeOptions)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(request.CTX, model.GetPostsOptions, map[string]bool) *model.PostList); ok {
|
|
r0 = rf(rctx, options, sanitizeOptions)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).(*model.PostList)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(request.CTX, model.GetPostsOptions, map[string]bool) error); ok {
|
|
r1 = rf(rctx, options, sanitizeOptions)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetPostsByIds provides a mock function with given fields: postIds
|
|
func (_m *PostStore) GetPostsByIds(postIds []string) ([]*model.Post, error) {
|
|
ret := _m.Called(postIds)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetPostsByIds")
|
|
}
|
|
|
|
var r0 []*model.Post
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func([]string) ([]*model.Post, error)); ok {
|
|
return rf(postIds)
|
|
}
|
|
if rf, ok := ret.Get(0).(func([]string) []*model.Post); ok {
|
|
r0 = rf(postIds)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).([]*model.Post)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func([]string) error); ok {
|
|
r1 = rf(postIds)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetPostsByThread provides a mock function with given fields: threadID, since
|
|
func (_m *PostStore) GetPostsByThread(threadID string, since int64) ([]*model.Post, error) {
|
|
ret := _m.Called(threadID, since)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetPostsByThread")
|
|
}
|
|
|
|
var r0 []*model.Post
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(string, int64) ([]*model.Post, error)); ok {
|
|
return rf(threadID, since)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(string, int64) []*model.Post); ok {
|
|
r0 = rf(threadID, since)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).([]*model.Post)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(string, int64) error); ok {
|
|
r1 = rf(threadID, since)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetPostsCreatedAt provides a mock function with given fields: channelID, timestamp
|
|
func (_m *PostStore) GetPostsCreatedAt(channelID string, timestamp int64) ([]*model.Post, error) {
|
|
ret := _m.Called(channelID, timestamp)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetPostsCreatedAt")
|
|
}
|
|
|
|
var r0 []*model.Post
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(string, int64) ([]*model.Post, error)); ok {
|
|
return rf(channelID, timestamp)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(string, int64) []*model.Post); ok {
|
|
r0 = rf(channelID, timestamp)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).([]*model.Post)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(string, int64) error); ok {
|
|
r1 = rf(channelID, timestamp)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetPostsForReporting provides a mock function with given fields: rctx, queryParams
|
|
func (_m *PostStore) GetPostsForReporting(rctx request.CTX, queryParams model.ReportPostQueryParams) (*model.ReportPostListResponse, error) {
|
|
ret := _m.Called(rctx, queryParams)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetPostsForReporting")
|
|
}
|
|
|
|
var r0 *model.ReportPostListResponse
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(request.CTX, model.ReportPostQueryParams) (*model.ReportPostListResponse, error)); ok {
|
|
return rf(rctx, queryParams)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(request.CTX, model.ReportPostQueryParams) *model.ReportPostListResponse); ok {
|
|
r0 = rf(rctx, queryParams)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).(*model.ReportPostListResponse)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(request.CTX, model.ReportPostQueryParams) error); ok {
|
|
r1 = rf(rctx, queryParams)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetPostsSince provides a mock function with given fields: rctx, options, allowFromCache, sanitizeOptions
|
|
func (_m *PostStore) GetPostsSince(rctx request.CTX, options model.GetPostsSinceOptions, allowFromCache bool, sanitizeOptions map[string]bool) (*model.PostList, error) {
|
|
ret := _m.Called(rctx, options, allowFromCache, sanitizeOptions)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetPostsSince")
|
|
}
|
|
|
|
var r0 *model.PostList
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(request.CTX, model.GetPostsSinceOptions, bool, map[string]bool) (*model.PostList, error)); ok {
|
|
return rf(rctx, options, allowFromCache, sanitizeOptions)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(request.CTX, model.GetPostsSinceOptions, bool, map[string]bool) *model.PostList); ok {
|
|
r0 = rf(rctx, options, allowFromCache, sanitizeOptions)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).(*model.PostList)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(request.CTX, model.GetPostsSinceOptions, bool, map[string]bool) error); ok {
|
|
r1 = rf(rctx, options, allowFromCache, sanitizeOptions)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetPostsSinceForSync provides a mock function with given fields: options, cursor, limit
|
|
func (_m *PostStore) GetPostsSinceForSync(options model.GetPostsSinceForSyncOptions, cursor model.GetPostsSinceForSyncCursor, limit int) ([]*model.Post, model.GetPostsSinceForSyncCursor, error) {
|
|
ret := _m.Called(options, cursor, limit)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetPostsSinceForSync")
|
|
}
|
|
|
|
var r0 []*model.Post
|
|
var r1 model.GetPostsSinceForSyncCursor
|
|
var r2 error
|
|
if rf, ok := ret.Get(0).(func(model.GetPostsSinceForSyncOptions, model.GetPostsSinceForSyncCursor, int) ([]*model.Post, model.GetPostsSinceForSyncCursor, error)); ok {
|
|
return rf(options, cursor, limit)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(model.GetPostsSinceForSyncOptions, model.GetPostsSinceForSyncCursor, int) []*model.Post); ok {
|
|
r0 = rf(options, cursor, limit)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).([]*model.Post)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(model.GetPostsSinceForSyncOptions, model.GetPostsSinceForSyncCursor, int) model.GetPostsSinceForSyncCursor); ok {
|
|
r1 = rf(options, cursor, limit)
|
|
} else {
|
|
r1 = ret.Get(1).(model.GetPostsSinceForSyncCursor)
|
|
}
|
|
|
|
if rf, ok := ret.Get(2).(func(model.GetPostsSinceForSyncOptions, model.GetPostsSinceForSyncCursor, int) error); ok {
|
|
r2 = rf(options, cursor, limit)
|
|
} else {
|
|
r2 = ret.Error(2)
|
|
}
|
|
|
|
return r0, r1, r2
|
|
}
|
|
|
|
// GetRepliesForExport provides a mock function with given fields: parentID
|
|
func (_m *PostStore) GetRepliesForExport(parentID string) ([]*model.ReplyForExport, error) {
|
|
ret := _m.Called(parentID)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetRepliesForExport")
|
|
}
|
|
|
|
var r0 []*model.ReplyForExport
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(string) ([]*model.ReplyForExport, error)); ok {
|
|
return rf(parentID)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(string) []*model.ReplyForExport); ok {
|
|
r0 = rf(parentID)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).([]*model.ReplyForExport)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(string) error); ok {
|
|
r1 = rf(parentID)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// GetSingle provides a mock function with given fields: rctx, id, inclDeleted
|
|
func (_m *PostStore) GetSingle(rctx request.CTX, id string, inclDeleted bool) (*model.Post, error) {
|
|
ret := _m.Called(rctx, id, inclDeleted)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for GetSingle")
|
|
}
|
|
|
|
var r0 *model.Post
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(request.CTX, string, bool) (*model.Post, error)); ok {
|
|
return rf(rctx, id, inclDeleted)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(request.CTX, string, bool) *model.Post); ok {
|
|
r0 = rf(rctx, id, inclDeleted)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).(*model.Post)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(request.CTX, string, bool) error); ok {
|
|
r1 = rf(rctx, id, inclDeleted)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// HasAutoResponsePostByUserSince provides a mock function with given fields: options, userID
|
|
func (_m *PostStore) HasAutoResponsePostByUserSince(options model.GetPostsSinceOptions, userID string) (bool, error) {
|
|
ret := _m.Called(options, userID)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for HasAutoResponsePostByUserSince")
|
|
}
|
|
|
|
var r0 bool
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(model.GetPostsSinceOptions, string) (bool, error)); ok {
|
|
return rf(options, userID)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(model.GetPostsSinceOptions, string) bool); ok {
|
|
r0 = rf(options, userID)
|
|
} else {
|
|
r0 = ret.Get(0).(bool)
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(model.GetPostsSinceOptions, string) error); ok {
|
|
r1 = rf(options, userID)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// InvalidateLastPostTimeCache provides a mock function with given fields: channelID
|
|
func (_m *PostStore) InvalidateLastPostTimeCache(channelID string) {
|
|
_m.Called(channelID)
|
|
}
|
|
|
|
// Overwrite provides a mock function with given fields: rctx, post
|
|
func (_m *PostStore) Overwrite(rctx request.CTX, post *model.Post) (*model.Post, error) {
|
|
ret := _m.Called(rctx, post)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for Overwrite")
|
|
}
|
|
|
|
var r0 *model.Post
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(request.CTX, *model.Post) (*model.Post, error)); ok {
|
|
return rf(rctx, post)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(request.CTX, *model.Post) *model.Post); ok {
|
|
r0 = rf(rctx, post)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).(*model.Post)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(request.CTX, *model.Post) error); ok {
|
|
r1 = rf(rctx, post)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// OverwriteMultiple provides a mock function with given fields: rctx, posts
|
|
func (_m *PostStore) OverwriteMultiple(rctx request.CTX, posts []*model.Post) ([]*model.Post, int, error) {
|
|
ret := _m.Called(rctx, posts)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for OverwriteMultiple")
|
|
}
|
|
|
|
var r0 []*model.Post
|
|
var r1 int
|
|
var r2 error
|
|
if rf, ok := ret.Get(0).(func(request.CTX, []*model.Post) ([]*model.Post, int, error)); ok {
|
|
return rf(rctx, posts)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(request.CTX, []*model.Post) []*model.Post); ok {
|
|
r0 = rf(rctx, posts)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).([]*model.Post)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(request.CTX, []*model.Post) int); ok {
|
|
r1 = rf(rctx, posts)
|
|
} else {
|
|
r1 = ret.Get(1).(int)
|
|
}
|
|
|
|
if rf, ok := ret.Get(2).(func(request.CTX, []*model.Post) error); ok {
|
|
r2 = rf(rctx, posts)
|
|
} else {
|
|
r2 = ret.Error(2)
|
|
}
|
|
|
|
return r0, r1, r2
|
|
}
|
|
|
|
// PermanentDelete provides a mock function with given fields: rctx, postID
|
|
func (_m *PostStore) PermanentDelete(rctx request.CTX, postID string) error {
|
|
ret := _m.Called(rctx, postID)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for PermanentDelete")
|
|
}
|
|
|
|
var r0 error
|
|
if rf, ok := ret.Get(0).(func(request.CTX, string) error); ok {
|
|
r0 = rf(rctx, postID)
|
|
} else {
|
|
r0 = ret.Error(0)
|
|
}
|
|
|
|
return r0
|
|
}
|
|
|
|
// PermanentDeleteAssociatedData provides a mock function with given fields: postIds
|
|
func (_m *PostStore) PermanentDeleteAssociatedData(postIds []string) error {
|
|
ret := _m.Called(postIds)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for PermanentDeleteAssociatedData")
|
|
}
|
|
|
|
var r0 error
|
|
if rf, ok := ret.Get(0).(func([]string) error); ok {
|
|
r0 = rf(postIds)
|
|
} else {
|
|
r0 = ret.Error(0)
|
|
}
|
|
|
|
return r0
|
|
}
|
|
|
|
// PermanentDeleteBatch provides a mock function with given fields: endTime, limit
|
|
func (_m *PostStore) PermanentDeleteBatch(endTime int64, limit int64) (int64, error) {
|
|
ret := _m.Called(endTime, limit)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for PermanentDeleteBatch")
|
|
}
|
|
|
|
var r0 int64
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(int64, int64) (int64, error)); ok {
|
|
return rf(endTime, limit)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(int64, int64) int64); ok {
|
|
r0 = rf(endTime, limit)
|
|
} else {
|
|
r0 = ret.Get(0).(int64)
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(int64, int64) error); ok {
|
|
r1 = rf(endTime, limit)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// PermanentDeleteBatchForRetentionPolicies provides a mock function with given fields: retentionPolicyBatchConfigs, cursor
|
|
func (_m *PostStore) PermanentDeleteBatchForRetentionPolicies(retentionPolicyBatchConfigs model.RetentionPolicyBatchConfigs, cursor model.RetentionPolicyCursor) (int64, model.RetentionPolicyCursor, error) {
|
|
ret := _m.Called(retentionPolicyBatchConfigs, cursor)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for PermanentDeleteBatchForRetentionPolicies")
|
|
}
|
|
|
|
var r0 int64
|
|
var r1 model.RetentionPolicyCursor
|
|
var r2 error
|
|
if rf, ok := ret.Get(0).(func(model.RetentionPolicyBatchConfigs, model.RetentionPolicyCursor) (int64, model.RetentionPolicyCursor, error)); ok {
|
|
return rf(retentionPolicyBatchConfigs, cursor)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(model.RetentionPolicyBatchConfigs, model.RetentionPolicyCursor) int64); ok {
|
|
r0 = rf(retentionPolicyBatchConfigs, cursor)
|
|
} else {
|
|
r0 = ret.Get(0).(int64)
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(model.RetentionPolicyBatchConfigs, model.RetentionPolicyCursor) model.RetentionPolicyCursor); ok {
|
|
r1 = rf(retentionPolicyBatchConfigs, cursor)
|
|
} else {
|
|
r1 = ret.Get(1).(model.RetentionPolicyCursor)
|
|
}
|
|
|
|
if rf, ok := ret.Get(2).(func(model.RetentionPolicyBatchConfigs, model.RetentionPolicyCursor) error); ok {
|
|
r2 = rf(retentionPolicyBatchConfigs, cursor)
|
|
} else {
|
|
r2 = ret.Error(2)
|
|
}
|
|
|
|
return r0, r1, r2
|
|
}
|
|
|
|
// PermanentDeleteByChannel provides a mock function with given fields: rctx, channelID
|
|
func (_m *PostStore) PermanentDeleteByChannel(rctx request.CTX, channelID string) error {
|
|
ret := _m.Called(rctx, channelID)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for PermanentDeleteByChannel")
|
|
}
|
|
|
|
var r0 error
|
|
if rf, ok := ret.Get(0).(func(request.CTX, string) error); ok {
|
|
r0 = rf(rctx, channelID)
|
|
} else {
|
|
r0 = ret.Error(0)
|
|
}
|
|
|
|
return r0
|
|
}
|
|
|
|
// PermanentDeleteByUser provides a mock function with given fields: rctx, userID
|
|
func (_m *PostStore) PermanentDeleteByUser(rctx request.CTX, userID string) error {
|
|
ret := _m.Called(rctx, userID)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for PermanentDeleteByUser")
|
|
}
|
|
|
|
var r0 error
|
|
if rf, ok := ret.Get(0).(func(request.CTX, string) error); ok {
|
|
r0 = rf(rctx, userID)
|
|
} else {
|
|
r0 = ret.Error(0)
|
|
}
|
|
|
|
return r0
|
|
}
|
|
|
|
// RefreshPostStats provides a mock function with no fields
|
|
func (_m *PostStore) RefreshPostStats() error {
|
|
ret := _m.Called()
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for RefreshPostStats")
|
|
}
|
|
|
|
var r0 error
|
|
if rf, ok := ret.Get(0).(func() error); ok {
|
|
r0 = rf()
|
|
} else {
|
|
r0 = ret.Error(0)
|
|
}
|
|
|
|
return r0
|
|
}
|
|
|
|
// RestoreContentFlaggedPost provides a mock function with given fields: post, statusFieldId, contentFlaggingManagedFieldId
|
|
func (_m *PostStore) RestoreContentFlaggedPost(post *model.Post, statusFieldId string, contentFlaggingManagedFieldId string) error {
|
|
ret := _m.Called(post, statusFieldId, contentFlaggingManagedFieldId)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for RestoreContentFlaggedPost")
|
|
}
|
|
|
|
var r0 error
|
|
if rf, ok := ret.Get(0).(func(*model.Post, string, string) error); ok {
|
|
r0 = rf(post, statusFieldId, contentFlaggingManagedFieldId)
|
|
} else {
|
|
r0 = ret.Error(0)
|
|
}
|
|
|
|
return r0
|
|
}
|
|
|
|
// Save provides a mock function with given fields: rctx, post
|
|
func (_m *PostStore) Save(rctx request.CTX, post *model.Post) (*model.Post, error) {
|
|
ret := _m.Called(rctx, post)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for Save")
|
|
}
|
|
|
|
var r0 *model.Post
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(request.CTX, *model.Post) (*model.Post, error)); ok {
|
|
return rf(rctx, post)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(request.CTX, *model.Post) *model.Post); ok {
|
|
r0 = rf(rctx, post)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).(*model.Post)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(request.CTX, *model.Post) error); ok {
|
|
r1 = rf(rctx, post)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// SaveMultiple provides a mock function with given fields: rctx, posts
|
|
func (_m *PostStore) SaveMultiple(rctx request.CTX, posts []*model.Post) ([]*model.Post, int, error) {
|
|
ret := _m.Called(rctx, posts)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for SaveMultiple")
|
|
}
|
|
|
|
var r0 []*model.Post
|
|
var r1 int
|
|
var r2 error
|
|
if rf, ok := ret.Get(0).(func(request.CTX, []*model.Post) ([]*model.Post, int, error)); ok {
|
|
return rf(rctx, posts)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(request.CTX, []*model.Post) []*model.Post); ok {
|
|
r0 = rf(rctx, posts)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).([]*model.Post)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(request.CTX, []*model.Post) int); ok {
|
|
r1 = rf(rctx, posts)
|
|
} else {
|
|
r1 = ret.Get(1).(int)
|
|
}
|
|
|
|
if rf, ok := ret.Get(2).(func(request.CTX, []*model.Post) error); ok {
|
|
r2 = rf(rctx, posts)
|
|
} else {
|
|
r2 = ret.Error(2)
|
|
}
|
|
|
|
return r0, r1, r2
|
|
}
|
|
|
|
// Search provides a mock function with given fields: teamID, userID, params
|
|
func (_m *PostStore) Search(teamID string, userID string, params *model.SearchParams) (*model.PostList, error) {
|
|
ret := _m.Called(teamID, userID, params)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for Search")
|
|
}
|
|
|
|
var r0 *model.PostList
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(string, string, *model.SearchParams) (*model.PostList, error)); ok {
|
|
return rf(teamID, userID, params)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(string, string, *model.SearchParams) *model.PostList); ok {
|
|
r0 = rf(teamID, userID, params)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).(*model.PostList)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(string, string, *model.SearchParams) error); ok {
|
|
r1 = rf(teamID, userID, params)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// SearchPostsForUser provides a mock function with given fields: rctx, paramsList, userID, teamID, page, perPage
|
|
func (_m *PostStore) SearchPostsForUser(rctx request.CTX, paramsList []*model.SearchParams, userID string, teamID string, page int, perPage int) (*model.PostSearchResults, error) {
|
|
ret := _m.Called(rctx, paramsList, userID, teamID, page, perPage)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for SearchPostsForUser")
|
|
}
|
|
|
|
var r0 *model.PostSearchResults
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(request.CTX, []*model.SearchParams, string, string, int, int) (*model.PostSearchResults, error)); ok {
|
|
return rf(rctx, paramsList, userID, teamID, page, perPage)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(request.CTX, []*model.SearchParams, string, string, int, int) *model.PostSearchResults); ok {
|
|
r0 = rf(rctx, paramsList, userID, teamID, page, perPage)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).(*model.PostSearchResults)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(request.CTX, []*model.SearchParams, string, string, int, int) error); ok {
|
|
r1 = rf(rctx, paramsList, userID, teamID, page, perPage)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// SetPostReminder provides a mock function with given fields: reminder
|
|
func (_m *PostStore) SetPostReminder(reminder *model.PostReminder) error {
|
|
ret := _m.Called(reminder)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for SetPostReminder")
|
|
}
|
|
|
|
var r0 error
|
|
if rf, ok := ret.Get(0).(func(*model.PostReminder) error); ok {
|
|
r0 = rf(reminder)
|
|
} else {
|
|
r0 = ret.Error(0)
|
|
}
|
|
|
|
return r0
|
|
}
|
|
|
|
// Update provides a mock function with given fields: rctx, newPost, oldPost
|
|
func (_m *PostStore) Update(rctx request.CTX, newPost *model.Post, oldPost *model.Post) (*model.Post, error) {
|
|
ret := _m.Called(rctx, newPost, oldPost)
|
|
|
|
if len(ret) == 0 {
|
|
panic("no return value specified for Update")
|
|
}
|
|
|
|
var r0 *model.Post
|
|
var r1 error
|
|
if rf, ok := ret.Get(0).(func(request.CTX, *model.Post, *model.Post) (*model.Post, error)); ok {
|
|
return rf(rctx, newPost, oldPost)
|
|
}
|
|
if rf, ok := ret.Get(0).(func(request.CTX, *model.Post, *model.Post) *model.Post); ok {
|
|
r0 = rf(rctx, newPost, oldPost)
|
|
} else {
|
|
if ret.Get(0) != nil {
|
|
r0 = ret.Get(0).(*model.Post)
|
|
}
|
|
}
|
|
|
|
if rf, ok := ret.Get(1).(func(request.CTX, *model.Post, *model.Post) error); ok {
|
|
r1 = rf(rctx, newPost, oldPost)
|
|
} else {
|
|
r1 = ret.Error(1)
|
|
}
|
|
|
|
return r0, r1
|
|
}
|
|
|
|
// NewPostStore creates a new instance of PostStore. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
|
|
// The first argument is typically a *testing.T value.
|
|
func NewPostStore(t interface {
|
|
mock.TestingT
|
|
Cleanup(func())
|
|
}) *PostStore {
|
|
mock := &PostStore{}
|
|
mock.Mock.Test(t)
|
|
|
|
t.Cleanup(func() { mock.AssertExpectations(t) })
|
|
|
|
return mock
|
|
}
|