mirror of
https://github.com/mattermost/mattermost.git
synced 2025-02-25 18:55:24 -06:00
375c0632fa
* Created message export scheduled task * Added CLI command to immediately kick off an export job * Added email addresses for users joining and leaving the channel to the export * Added support for both MySQL and PostgreSQL * Fixing gofmt error * Added a new ChannelMemberHistory store and associated tests * Updating the ChannelMemberHistory channel as users create/join/leave channels * Added user email to the message export object so it can be included in the actiance export xml * Don't fail to log a leave event if a corresponding join event wasn't logged * Adding copyright notices * Adding message export settings to daily diagnostics report * Added System Console integration for message export * Cleaned up TODOs * Made batch size configurable * Added export from timestamp to CLI command * Made ChannelMemberHistory table updates best effort * Added a context-based timeout option to the message export CLI * Minor PR updates/improvements * Removed unnecessary fields from MessageExport object to reduce query overhead * Removed JSON functions from the message export query in an effort to optimize performance * Changed the way that channel member history queries and purges work to better account for edge cases * Fixing a test I missed with the last refactor * Added file copy functionality to file backend, improved config validation, added default config values * Fixed file copy tests * More concise use of the testing libraries * Fixed context leak error * Changed default export path to correctly place an 'export' directory under the 'data' directory * Can't delete records from a read replica * Fixed copy file tests * Start job workers when license is applied, if configured to do so * Suggestions from the PR * Moar unit tests * Fixed test imports
46 lines
1.5 KiB
Go
46 lines
1.5 KiB
Go
// Copyright (c) 2017-present Mattermost, Inc. All Rights Reserved.
|
|
// See License.txt for license information.
|
|
|
|
package utils
|
|
|
|
import (
|
|
"net/http"
|
|
|
|
"github.com/mattermost/mattermost-server/model"
|
|
)
|
|
|
|
type FileBackend interface {
|
|
TestConnection() *model.AppError
|
|
|
|
ReadFile(path string) ([]byte, *model.AppError)
|
|
CopyFile(oldPath, newPath string) *model.AppError
|
|
MoveFile(oldPath, newPath string) *model.AppError
|
|
WriteFile(f []byte, path string) *model.AppError
|
|
RemoveFile(path string) *model.AppError
|
|
|
|
ListDirectory(path string) (*[]string, *model.AppError)
|
|
RemoveDirectory(path string) *model.AppError
|
|
}
|
|
|
|
func NewFileBackend(settings *model.FileSettings) (FileBackend, *model.AppError) {
|
|
switch *settings.DriverName {
|
|
case model.IMAGE_DRIVER_S3:
|
|
return &S3FileBackend{
|
|
endpoint: settings.AmazonS3Endpoint,
|
|
accessKey: settings.AmazonS3AccessKeyId,
|
|
secretKey: settings.AmazonS3SecretAccessKey,
|
|
secure: settings.AmazonS3SSL == nil || *settings.AmazonS3SSL,
|
|
signV2: settings.AmazonS3SignV2 != nil && *settings.AmazonS3SignV2,
|
|
region: settings.AmazonS3Region,
|
|
bucket: settings.AmazonS3Bucket,
|
|
encrypt: settings.AmazonS3SSE != nil && *settings.AmazonS3SSE && IsLicensed() && *License().Features.Compliance,
|
|
trace: settings.AmazonS3Trace != nil && *settings.AmazonS3Trace,
|
|
}, nil
|
|
case model.IMAGE_DRIVER_LOCAL:
|
|
return &LocalFileBackend{
|
|
directory: settings.Directory,
|
|
}, nil
|
|
}
|
|
return nil, model.NewAppError("NewFileBackend", "No file driver selected.", nil, "", http.StatusInternalServerError)
|
|
}
|