mirror of
https://github.com/hanzoai/team.git
synced 2026-09-30 01:57:35 +00:00
zeekay
8feb24ea1f
The server module named github.com/hanzoai/team/server/v8 — a path that resolves to the retired workspace's repository, not this one — while server/public still published github.com/mattermost/mattermost/server/public. Both are github.com/hanzoteam/server/... now, which is where this code actually lives. That second half is what made the binary unbootable. Upstream's public path stayed claimed by upstream, mattermost-plugin-ai imported it, and the build linked public/model twice; public/plugin's gob.Register then ran twice under one name and panicked at init, before main. Reverting the rename traded the brand for a working binary. Rebranding the plugin alongside it needs no such trade: the agents fork is github.com/hanzoteam/agents/v2 against our public module, so no module named mattermost/mattermost is in the graph at all. Measured: `go list -deps ./cmd/mattermost` names exactly one public/model, and it is ours.
78 lines
2.3 KiB
Go
78 lines
2.3 KiB
Go
// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
|
|
// See LICENSE.txt for license information.
|
|
|
|
package export_delete
|
|
|
|
import (
|
|
"path/filepath"
|
|
"strings"
|
|
"time"
|
|
|
|
"github.com/wiggin77/merror"
|
|
|
|
"github.com/hanzoteam/server/server/public/model"
|
|
"github.com/hanzoteam/server/server/public/shared/configservice"
|
|
"github.com/hanzoteam/server/server/public/shared/mlog"
|
|
"github.com/hanzoteam/server/server/v8/channels/jobs"
|
|
)
|
|
|
|
type AppIface interface {
|
|
configservice.ConfigService
|
|
ListExportDirectory(path string) ([]string, *model.AppError)
|
|
ExportFileModTime(path string) (time.Time, *model.AppError)
|
|
RemoveExportFile(path string) *model.AppError
|
|
}
|
|
|
|
func MakeWorker(jobServer *jobs.JobServer, app AppIface) *jobs.SimpleWorker {
|
|
const workerName = "ExportDelete"
|
|
|
|
isEnabled := func(cfg *model.Config) bool {
|
|
return *cfg.ExportSettings.Directory != "" && *cfg.ExportSettings.RetentionDays > 0
|
|
}
|
|
execute := func(logger mlog.LoggerIFace, job *model.Job) error {
|
|
defer jobServer.HandleJobPanic(logger, job)
|
|
|
|
exportPath := *app.Config().ExportSettings.Directory
|
|
retentionTime := time.Duration(*app.Config().ExportSettings.RetentionDays) * 24 * time.Hour
|
|
exports, appErr := app.ListExportDirectory(exportPath)
|
|
if appErr != nil {
|
|
return appErr
|
|
}
|
|
|
|
errors := merror.New()
|
|
for i := range exports {
|
|
filename := filepath.Base(exports[i])
|
|
|
|
// Ignore files that were not created by the bulk export command
|
|
if !strings.HasSuffix(filename, "_export.zip") {
|
|
continue
|
|
}
|
|
|
|
modTime, appErr := app.ExportFileModTime(filepath.Join(exportPath, filename))
|
|
if appErr != nil {
|
|
logger.Debug("Worker: Failed to get file modification time",
|
|
mlog.Err(appErr), mlog.String("export", exports[i]))
|
|
errors.Append(appErr)
|
|
continue
|
|
}
|
|
|
|
if time.Now().After(modTime.Add(retentionTime)) {
|
|
// remove file data from storage.
|
|
if appErr := app.RemoveExportFile(exports[i]); appErr != nil {
|
|
logger.Debug("Worker: Failed to remove file",
|
|
mlog.Err(appErr), mlog.String("export", exports[i]))
|
|
errors.Append(appErr)
|
|
continue
|
|
}
|
|
}
|
|
}
|
|
|
|
if err := errors.ErrorOrNil(); err != nil {
|
|
logger.Warn("Worker: errors occurred", mlog.Err(err))
|
|
}
|
|
return nil
|
|
}
|
|
worker := jobs.NewSimpleWorker(workerName, jobServer, execute, isEnabled)
|
|
return worker
|
|
}
|