mirror of
https://github.com/mattermost/mattermost.git
synced 2025-02-25 18:55:24 -06:00
50fc6e1e9e
* Prepare file upload infrastructure for Data Retention. This commit prepares the file upload infrastructure for the data retention feature that is under construction. Changes are: * Move file management code to utils to allow access to it from jobs. * From now on, store all file uploads in a top level folder which is the date of the day on which they were uploaded. This commit is based on Harrison Healey's branch, but updated to work with the latest master. * Use NewAppError
420 lines
17 KiB
Go
420 lines
17 KiB
Go
// Copyright (c) 2016-present Mattermost, Inc. All Rights Reserved.
|
|
// See License.txt for license information.
|
|
|
|
package store
|
|
|
|
import (
|
|
"time"
|
|
|
|
l4g "github.com/alecthomas/log4go"
|
|
"github.com/mattermost/platform/model"
|
|
)
|
|
|
|
type StoreResult struct {
|
|
Data interface{}
|
|
Err *model.AppError
|
|
}
|
|
|
|
type StoreChannel chan StoreResult
|
|
|
|
func Must(sc StoreChannel) interface{} {
|
|
r := <-sc
|
|
if r.Err != nil {
|
|
l4g.Close()
|
|
time.Sleep(time.Second)
|
|
panic(r.Err)
|
|
}
|
|
|
|
return r.Data
|
|
}
|
|
|
|
type Store interface {
|
|
Team() TeamStore
|
|
Channel() ChannelStore
|
|
Post() PostStore
|
|
User() UserStore
|
|
Audit() AuditStore
|
|
ClusterDiscovery() ClusterDiscoveryStore
|
|
Compliance() ComplianceStore
|
|
Session() SessionStore
|
|
OAuth() OAuthStore
|
|
System() SystemStore
|
|
Webhook() WebhookStore
|
|
Command() CommandStore
|
|
CommandWebhook() CommandWebhookStore
|
|
Preference() PreferenceStore
|
|
License() LicenseStore
|
|
Token() TokenStore
|
|
Emoji() EmojiStore
|
|
Status() StatusStore
|
|
FileInfo() FileInfoStore
|
|
Reaction() ReactionStore
|
|
Job() JobStore
|
|
UserAccessToken() UserAccessTokenStore
|
|
MarkSystemRanUnitTests()
|
|
Close()
|
|
DropAllTables()
|
|
TotalMasterDbConnections() int
|
|
TotalReadDbConnections() int
|
|
TotalSearchDbConnections() int
|
|
}
|
|
|
|
type TeamStore interface {
|
|
Save(team *model.Team) StoreChannel
|
|
Update(team *model.Team) StoreChannel
|
|
UpdateDisplayName(name string, teamId string) StoreChannel
|
|
Get(id string) StoreChannel
|
|
GetByName(name string) StoreChannel
|
|
SearchByName(name string) StoreChannel
|
|
SearchAll(term string) StoreChannel
|
|
SearchOpen(term string) StoreChannel
|
|
GetAll() StoreChannel
|
|
GetAllPage(offset int, limit int) StoreChannel
|
|
GetAllTeamListing() StoreChannel
|
|
GetAllTeamPageListing(offset int, limit int) StoreChannel
|
|
GetTeamsByUserId(userId string) StoreChannel
|
|
GetByInviteId(inviteId string) StoreChannel
|
|
PermanentDelete(teamId string) StoreChannel
|
|
AnalyticsTeamCount() StoreChannel
|
|
SaveMember(member *model.TeamMember) StoreChannel
|
|
UpdateMember(member *model.TeamMember) StoreChannel
|
|
GetMember(teamId string, userId string) StoreChannel
|
|
GetMembers(teamId string, offset int, limit int) StoreChannel
|
|
GetMembersByIds(teamId string, userIds []string) StoreChannel
|
|
GetTotalMemberCount(teamId string) StoreChannel
|
|
GetActiveMemberCount(teamId string) StoreChannel
|
|
GetTeamsForUser(userId string) StoreChannel
|
|
GetChannelUnreadsForAllTeams(excludeTeamId, userId string) StoreChannel
|
|
GetChannelUnreadsForTeam(teamId, userId string) StoreChannel
|
|
RemoveMember(teamId string, userId string) StoreChannel
|
|
RemoveAllMembersByTeam(teamId string) StoreChannel
|
|
RemoveAllMembersByUser(userId string) StoreChannel
|
|
}
|
|
|
|
type ChannelStore interface {
|
|
Save(channel *model.Channel) StoreChannel
|
|
CreateDirectChannel(userId string, otherUserId string) StoreChannel
|
|
SaveDirectChannel(channel *model.Channel, member1 *model.ChannelMember, member2 *model.ChannelMember) StoreChannel
|
|
Update(channel *model.Channel) StoreChannel
|
|
Get(id string, allowFromCache bool) StoreChannel
|
|
InvalidateChannel(id string)
|
|
InvalidateChannelByName(teamId, name string)
|
|
GetFromMaster(id string) StoreChannel
|
|
Delete(channelId string, time int64) StoreChannel
|
|
Restore(channelId string, time int64) StoreChannel
|
|
SetDeleteAt(channelId string, deleteAt int64, updateAt int64) StoreChannel
|
|
PermanentDeleteByTeam(teamId string) StoreChannel
|
|
PermanentDelete(channelId string) StoreChannel
|
|
GetByName(team_id string, name string, allowFromCache bool) StoreChannel
|
|
GetByNameIncludeDeleted(team_id string, name string, allowFromCache bool) StoreChannel
|
|
GetDeletedByName(team_id string, name string) StoreChannel
|
|
GetDeleted(team_id string, offset int, limit int) StoreChannel
|
|
GetChannels(teamId string, userId string) StoreChannel
|
|
GetMoreChannels(teamId string, userId string, offset int, limit int) StoreChannel
|
|
GetPublicChannelsForTeam(teamId string, offset int, limit int) StoreChannel
|
|
GetPublicChannelsByIdsForTeam(teamId string, channelIds []string) StoreChannel
|
|
GetChannelCounts(teamId string, userId string) StoreChannel
|
|
GetTeamChannels(teamId string) StoreChannel
|
|
GetAll(teamId string) StoreChannel
|
|
GetForPost(postId string) StoreChannel
|
|
SaveMember(member *model.ChannelMember) StoreChannel
|
|
UpdateMember(member *model.ChannelMember) StoreChannel
|
|
GetMembers(channelId string, offset, limit int) StoreChannel
|
|
GetMember(channelId string, userId string) StoreChannel
|
|
GetAllChannelMembersForUser(userId string, allowFromCache bool) StoreChannel
|
|
InvalidateAllChannelMembersForUser(userId string)
|
|
IsUserInChannelUseCache(userId string, channelId string) bool
|
|
GetAllChannelMembersNotifyPropsForChannel(channelId string, allowFromCache bool) StoreChannel
|
|
InvalidateCacheForChannelMembersNotifyProps(channelId string)
|
|
GetMemberForPost(postId string, userId string) StoreChannel
|
|
InvalidateMemberCount(channelId string)
|
|
GetMemberCountFromCache(channelId string) int64
|
|
GetMemberCount(channelId string, allowFromCache bool) StoreChannel
|
|
GetPinnedPosts(channelId string) StoreChannel
|
|
RemoveMember(channelId string, userId string) StoreChannel
|
|
PermanentDeleteMembersByUser(userId string) StoreChannel
|
|
PermanentDeleteMembersByChannel(channelId string) StoreChannel
|
|
UpdateLastViewedAt(channelIds []string, userId string) StoreChannel
|
|
IncrementMentionCount(channelId string, userId string) StoreChannel
|
|
AnalyticsTypeCount(teamId string, channelType string) StoreChannel
|
|
ExtraUpdateByUser(userId string, time int64) StoreChannel
|
|
GetMembersForUser(teamId string, userId string) StoreChannel
|
|
SearchInTeam(teamId string, term string) StoreChannel
|
|
SearchMore(userId string, teamId string, term string) StoreChannel
|
|
GetMembersByIds(channelId string, userIds []string) StoreChannel
|
|
AnalyticsDeletedTypeCount(teamId string, channelType string) StoreChannel
|
|
GetChannelUnread(channelId, userId string) StoreChannel
|
|
}
|
|
|
|
type PostStore interface {
|
|
Save(post *model.Post) StoreChannel
|
|
Update(newPost *model.Post, oldPost *model.Post) StoreChannel
|
|
Get(id string) StoreChannel
|
|
GetSingle(id string) StoreChannel
|
|
Delete(postId string, time int64) StoreChannel
|
|
PermanentDeleteByUser(userId string) StoreChannel
|
|
PermanentDeleteByChannel(channelId string) StoreChannel
|
|
GetPosts(channelId string, offset int, limit int, allowFromCache bool) StoreChannel
|
|
GetFlaggedPosts(userId string, offset int, limit int) StoreChannel
|
|
GetFlaggedPostsForTeam(userId, teamId string, offset int, limit int) StoreChannel
|
|
GetFlaggedPostsForChannel(userId, channelId string, offset int, limit int) StoreChannel
|
|
GetPostsBefore(channelId string, postId string, numPosts int, offset int) StoreChannel
|
|
GetPostsAfter(channelId string, postId string, numPosts int, offset int) StoreChannel
|
|
GetPostsSince(channelId string, time int64, allowFromCache bool) StoreChannel
|
|
GetEtag(channelId string, allowFromCache bool) StoreChannel
|
|
Search(teamId string, userId string, params *model.SearchParams) StoreChannel
|
|
AnalyticsUserCountsWithPostsByDay(teamId string) StoreChannel
|
|
AnalyticsPostCountsByDay(teamId string) StoreChannel
|
|
AnalyticsPostCount(teamId string, mustHaveFile bool, mustHaveHashtag bool) StoreChannel
|
|
InvalidateLastPostTimeCache(channelId string)
|
|
GetPostsCreatedAt(channelId string, time int64) StoreChannel
|
|
Overwrite(post *model.Post) StoreChannel
|
|
GetPostsByIds(postIds []string) StoreChannel
|
|
GetPostsBatchForIndexing(startTime int64, limit int) StoreChannel
|
|
}
|
|
|
|
type UserStore interface {
|
|
Save(user *model.User) StoreChannel
|
|
Update(user *model.User, allowRoleUpdate bool) StoreChannel
|
|
UpdateLastPictureUpdate(userId string) StoreChannel
|
|
UpdateUpdateAt(userId string) StoreChannel
|
|
UpdatePassword(userId, newPassword string) StoreChannel
|
|
UpdateAuthData(userId string, service string, authData *string, email string, resetMfa bool) StoreChannel
|
|
UpdateMfaSecret(userId, secret string) StoreChannel
|
|
UpdateMfaActive(userId string, active bool) StoreChannel
|
|
Get(id string) StoreChannel
|
|
GetAll() StoreChannel
|
|
InvalidateProfilesInChannelCacheByUser(userId string)
|
|
InvalidateProfilesInChannelCache(channelId string)
|
|
GetProfilesInChannel(channelId string, offset int, limit int) StoreChannel
|
|
GetAllProfilesInChannel(channelId string, allowFromCache bool) StoreChannel
|
|
GetProfilesNotInChannel(teamId string, channelId string, offset int, limit int) StoreChannel
|
|
GetProfilesWithoutTeam(offset int, limit int) StoreChannel
|
|
GetProfilesByUsernames(usernames []string, teamId string) StoreChannel
|
|
GetAllProfiles(offset int, limit int) StoreChannel
|
|
GetProfiles(teamId string, offset int, limit int) StoreChannel
|
|
GetProfileByIds(userId []string, allowFromCache bool) StoreChannel
|
|
InvalidatProfileCacheForUser(userId string)
|
|
GetByEmail(email string) StoreChannel
|
|
GetByAuth(authData *string, authService string) StoreChannel
|
|
GetAllUsingAuthService(authService string) StoreChannel
|
|
GetByUsername(username string) StoreChannel
|
|
GetForLogin(loginId string, allowSignInWithUsername, allowSignInWithEmail, ldapEnabled bool) StoreChannel
|
|
VerifyEmail(userId string) StoreChannel
|
|
GetEtagForAllProfiles() StoreChannel
|
|
GetEtagForProfiles(teamId string) StoreChannel
|
|
UpdateFailedPasswordAttempts(userId string, attempts int) StoreChannel
|
|
GetTotalUsersCount() StoreChannel
|
|
GetSystemAdminProfiles() StoreChannel
|
|
PermanentDelete(userId string) StoreChannel
|
|
AnalyticsUniqueUserCount(teamId string) StoreChannel
|
|
AnalyticsActiveCount(time int64) StoreChannel
|
|
GetUnreadCount(userId string) StoreChannel
|
|
GetUnreadCountForChannel(userId string, channelId string) StoreChannel
|
|
GetRecentlyActiveUsersForTeam(teamId string, offset, limit int) StoreChannel
|
|
GetNewUsersForTeam(teamId string, offset, limit int) StoreChannel
|
|
Search(teamId string, term string, options map[string]bool) StoreChannel
|
|
SearchNotInTeam(notInTeamId string, term string, options map[string]bool) StoreChannel
|
|
SearchInChannel(channelId string, term string, options map[string]bool) StoreChannel
|
|
SearchNotInChannel(teamId string, channelId string, term string, options map[string]bool) StoreChannel
|
|
SearchWithoutTeam(term string, options map[string]bool) StoreChannel
|
|
AnalyticsGetInactiveUsersCount() StoreChannel
|
|
AnalyticsGetSystemAdminCount() StoreChannel
|
|
GetProfilesNotInTeam(teamId string, offset int, limit int) StoreChannel
|
|
GetEtagForProfilesNotInTeam(teamId string) StoreChannel
|
|
}
|
|
|
|
type SessionStore interface {
|
|
Save(session *model.Session) StoreChannel
|
|
Get(sessionIdOrToken string) StoreChannel
|
|
GetSessions(userId string) StoreChannel
|
|
GetSessionsWithActiveDeviceIds(userId string) StoreChannel
|
|
Remove(sessionIdOrToken string) StoreChannel
|
|
RemoveAllSessions() StoreChannel
|
|
PermanentDeleteSessionsByUser(teamId string) StoreChannel
|
|
UpdateLastActivityAt(sessionId string, time int64) StoreChannel
|
|
UpdateRoles(userId string, roles string) StoreChannel
|
|
UpdateDeviceId(id string, deviceId string, expiresAt int64) StoreChannel
|
|
AnalyticsSessionCount() StoreChannel
|
|
}
|
|
|
|
type AuditStore interface {
|
|
Save(audit *model.Audit) StoreChannel
|
|
Get(user_id string, offset int, limit int) StoreChannel
|
|
PermanentDeleteByUser(userId string) StoreChannel
|
|
}
|
|
|
|
type ClusterDiscoveryStore interface {
|
|
Save(discovery *model.ClusterDiscovery) StoreChannel
|
|
Delete(discovery *model.ClusterDiscovery) StoreChannel
|
|
Exists(discovery *model.ClusterDiscovery) StoreChannel
|
|
GetAll(discoveryType, clusterName string) StoreChannel
|
|
SetLastPingAt(discovery *model.ClusterDiscovery) StoreChannel
|
|
Cleanup() StoreChannel
|
|
}
|
|
|
|
type ComplianceStore interface {
|
|
Save(compliance *model.Compliance) StoreChannel
|
|
Update(compliance *model.Compliance) StoreChannel
|
|
Get(id string) StoreChannel
|
|
GetAll(offset, limit int) StoreChannel
|
|
ComplianceExport(compliance *model.Compliance) StoreChannel
|
|
}
|
|
|
|
type OAuthStore interface {
|
|
SaveApp(app *model.OAuthApp) StoreChannel
|
|
UpdateApp(app *model.OAuthApp) StoreChannel
|
|
GetApp(id string) StoreChannel
|
|
GetAppByUser(userId string, offset, limit int) StoreChannel
|
|
GetApps(offset, limit int) StoreChannel
|
|
GetAuthorizedApps(userId string, offset, limit int) StoreChannel
|
|
DeleteApp(id string) StoreChannel
|
|
SaveAuthData(authData *model.AuthData) StoreChannel
|
|
GetAuthData(code string) StoreChannel
|
|
RemoveAuthData(code string) StoreChannel
|
|
PermanentDeleteAuthDataByUser(userId string) StoreChannel
|
|
SaveAccessData(accessData *model.AccessData) StoreChannel
|
|
UpdateAccessData(accessData *model.AccessData) StoreChannel
|
|
GetAccessData(token string) StoreChannel
|
|
GetAccessDataByUserForApp(userId, clientId string) StoreChannel
|
|
GetAccessDataByRefreshToken(token string) StoreChannel
|
|
GetPreviousAccessData(userId, clientId string) StoreChannel
|
|
RemoveAccessData(token string) StoreChannel
|
|
}
|
|
|
|
type SystemStore interface {
|
|
Save(system *model.System) StoreChannel
|
|
SaveOrUpdate(system *model.System) StoreChannel
|
|
Update(system *model.System) StoreChannel
|
|
Get() StoreChannel
|
|
GetByName(name string) StoreChannel
|
|
}
|
|
|
|
type WebhookStore interface {
|
|
SaveIncoming(webhook *model.IncomingWebhook) StoreChannel
|
|
GetIncoming(id string, allowFromCache bool) StoreChannel
|
|
GetIncomingList(offset, limit int) StoreChannel
|
|
GetIncomingByTeam(teamId string, offset, limit int) StoreChannel
|
|
UpdateIncoming(webhook *model.IncomingWebhook) StoreChannel
|
|
GetIncomingByChannel(channelId string) StoreChannel
|
|
DeleteIncoming(webhookId string, time int64) StoreChannel
|
|
PermanentDeleteIncomingByChannel(channelId string) StoreChannel
|
|
PermanentDeleteIncomingByUser(userId string) StoreChannel
|
|
|
|
SaveOutgoing(webhook *model.OutgoingWebhook) StoreChannel
|
|
GetOutgoing(id string) StoreChannel
|
|
GetOutgoingList(offset, limit int) StoreChannel
|
|
GetOutgoingByChannel(channelId string, offset, limit int) StoreChannel
|
|
GetOutgoingByTeam(teamId string, offset, limit int) StoreChannel
|
|
DeleteOutgoing(webhookId string, time int64) StoreChannel
|
|
PermanentDeleteOutgoingByChannel(channelId string) StoreChannel
|
|
PermanentDeleteOutgoingByUser(userId string) StoreChannel
|
|
UpdateOutgoing(hook *model.OutgoingWebhook) StoreChannel
|
|
|
|
AnalyticsIncomingCount(teamId string) StoreChannel
|
|
AnalyticsOutgoingCount(teamId string) StoreChannel
|
|
InvalidateWebhookCache(webhook string)
|
|
}
|
|
|
|
type CommandStore interface {
|
|
Save(webhook *model.Command) StoreChannel
|
|
Get(id string) StoreChannel
|
|
GetByTeam(teamId string) StoreChannel
|
|
Delete(commandId string, time int64) StoreChannel
|
|
PermanentDeleteByTeam(teamId string) StoreChannel
|
|
PermanentDeleteByUser(userId string) StoreChannel
|
|
Update(hook *model.Command) StoreChannel
|
|
AnalyticsCommandCount(teamId string) StoreChannel
|
|
}
|
|
|
|
type CommandWebhookStore interface {
|
|
Save(webhook *model.CommandWebhook) StoreChannel
|
|
Get(id string) StoreChannel
|
|
TryUse(id string, limit int) StoreChannel
|
|
Cleanup()
|
|
}
|
|
|
|
type PreferenceStore interface {
|
|
Save(preferences *model.Preferences) StoreChannel
|
|
Get(userId string, category string, name string) StoreChannel
|
|
GetCategory(userId string, category string) StoreChannel
|
|
GetAll(userId string) StoreChannel
|
|
Delete(userId, category, name string) StoreChannel
|
|
DeleteCategory(userId string, category string) StoreChannel
|
|
DeleteCategoryAndName(category string, name string) StoreChannel
|
|
PermanentDeleteByUser(userId string) StoreChannel
|
|
IsFeatureEnabled(feature, userId string) StoreChannel
|
|
}
|
|
|
|
type LicenseStore interface {
|
|
Save(license *model.LicenseRecord) StoreChannel
|
|
Get(id string) StoreChannel
|
|
}
|
|
|
|
type TokenStore interface {
|
|
Save(recovery *model.Token) StoreChannel
|
|
Delete(token string) StoreChannel
|
|
GetByToken(token string) StoreChannel
|
|
Cleanup()
|
|
}
|
|
|
|
type EmojiStore interface {
|
|
Save(emoji *model.Emoji) StoreChannel
|
|
Get(id string, allowFromCache bool) StoreChannel
|
|
GetByName(name string) StoreChannel
|
|
GetList(offset, limit int) StoreChannel
|
|
Delete(id string, time int64) StoreChannel
|
|
}
|
|
|
|
type StatusStore interface {
|
|
SaveOrUpdate(status *model.Status) StoreChannel
|
|
Get(userId string) StoreChannel
|
|
GetByIds(userIds []string) StoreChannel
|
|
GetOnlineAway() StoreChannel
|
|
GetOnline() StoreChannel
|
|
GetAllFromTeam(teamId string) StoreChannel
|
|
ResetAll() StoreChannel
|
|
GetTotalActiveUsersCount() StoreChannel
|
|
UpdateLastActivityAt(userId string, lastActivityAt int64) StoreChannel
|
|
}
|
|
|
|
type FileInfoStore interface {
|
|
Save(info *model.FileInfo) StoreChannel
|
|
Get(id string) StoreChannel
|
|
GetByPath(path string) StoreChannel
|
|
GetForPost(postId string, readFromMaster bool, allowFromCache bool) StoreChannel
|
|
InvalidateFileInfosForPostCache(postId string)
|
|
AttachToPost(fileId string, postId string) StoreChannel
|
|
DeleteForPost(postId string) StoreChannel
|
|
PermanentDelete(fileId string) StoreChannel
|
|
}
|
|
|
|
type ReactionStore interface {
|
|
Save(reaction *model.Reaction) StoreChannel
|
|
Delete(reaction *model.Reaction) StoreChannel
|
|
GetForPost(postId string, allowFromCache bool) StoreChannel
|
|
DeleteAllWithEmojiName(emojiName string) StoreChannel
|
|
}
|
|
|
|
type JobStore interface {
|
|
Save(job *model.Job) StoreChannel
|
|
UpdateOptimistically(job *model.Job, currentStatus string) StoreChannel
|
|
UpdateStatus(id string, status string) StoreChannel
|
|
UpdateStatusOptimistically(id string, currentStatus string, newStatus string) StoreChannel
|
|
Get(id string) StoreChannel
|
|
GetAllPage(offset int, limit int) StoreChannel
|
|
GetAllByType(jobType string) StoreChannel
|
|
GetAllByTypePage(jobType string, offset int, limit int) StoreChannel
|
|
GetAllByStatus(status string) StoreChannel
|
|
Delete(id string) StoreChannel
|
|
}
|
|
|
|
type UserAccessTokenStore interface {
|
|
Save(token *model.UserAccessToken) StoreChannel
|
|
Delete(tokenId string) StoreChannel
|
|
DeleteAllForUser(userId string) StoreChannel
|
|
Get(tokenId string) StoreChannel
|
|
GetByToken(tokenString string) StoreChannel
|
|
GetByUser(userId string, page, perPage int) StoreChannel
|
|
}
|