mirror of
https://github.com/hanzoai/team.git
synced 2026-10-30 14:49: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.
81 lines
2.5 KiB
Go
81 lines
2.5 KiB
Go
// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
|
|
// See LICENSE.txt for license information.
|
|
|
|
package delete_expired_posts
|
|
|
|
import (
|
|
"encoding/json"
|
|
"time"
|
|
|
|
"github.com/hanzoteam/server/server/public/model"
|
|
"github.com/hanzoteam/server/server/public/shared/mlog"
|
|
"github.com/hanzoteam/server/server/public/shared/request"
|
|
"github.com/hanzoteam/server/server/v8/channels/jobs"
|
|
"github.com/hanzoteam/server/server/v8/channels/store"
|
|
)
|
|
|
|
const (
|
|
expiredPostsBatchSize = 100
|
|
expiredPostsJobBatchWaitTime = 100 * time.Millisecond
|
|
)
|
|
|
|
type AppIface interface {
|
|
DeletePost(rctx request.CTX, postID, deleteByID string) (*model.Post, *model.AppError)
|
|
PermanentDeletePostDataRetainStub(rctx request.CTX, post *model.Post, deleteByID string) (*model.PostDeletionReport, *model.AppError)
|
|
GetSinglePost(rctx request.CTX, postID string, includeDeleted bool) (*model.Post, *model.AppError)
|
|
GetPostsByIds(postIDs []string) ([]*model.Post, int64, *model.AppError)
|
|
}
|
|
|
|
func MakeWorker(jobServer *jobs.JobServer, store store.Store, app AppIface) *jobs.SimpleWorker {
|
|
const workerName = "DeleteExpiredPosts"
|
|
|
|
isEnabled := func(cfg *model.Config) bool {
|
|
return model.SafeDereference(cfg.ServiceSettings.EnableBurnOnRead)
|
|
}
|
|
execute := func(logger mlog.LoggerIFace, job *model.Job) error {
|
|
if job.Data == nil {
|
|
job.Data = make(model.StringMap)
|
|
}
|
|
|
|
deletedPostIDs := make([]string, 0)
|
|
lastPostId := ""
|
|
for {
|
|
time.Sleep(expiredPostsJobBatchWaitTime)
|
|
postIDs, err := store.TemporaryPost().GetExpiredPosts(request.EmptyContext(logger), lastPostId, expiredPostsBatchSize)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
if len(postIDs) == 0 {
|
|
break
|
|
}
|
|
|
|
lastPostId = postIDs[len(postIDs)-1]
|
|
|
|
expiredPosts, _, appErr := app.GetPostsByIds(postIDs)
|
|
if appErr != nil {
|
|
logger.Error("Failed to get expired posts by IDs", mlog.Err(appErr))
|
|
return appErr
|
|
}
|
|
|
|
for _, post := range expiredPosts {
|
|
_, appErr = app.PermanentDeletePostDataRetainStub(request.EmptyContext(logger), post, "")
|
|
if appErr != nil {
|
|
logger.Error("Failed to delete expired post", mlog.Err(appErr), mlog.String("post_id", post.Id))
|
|
continue
|
|
}
|
|
deletedPostIDs = append(deletedPostIDs, post.Id)
|
|
}
|
|
}
|
|
|
|
deletedPostIDsJSON, err := json.Marshal(deletedPostIDs)
|
|
if err != nil {
|
|
logger.Error("Failed to marshal deleted post IDs", mlog.Err(err))
|
|
return err
|
|
}
|
|
job.Data["deleted_post_ids"] = string(deletedPostIDsJSON)
|
|
return nil
|
|
}
|
|
return jobs.NewSimpleWorker(workerName, jobServer, execute, isEnabled)
|
|
}
|