// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved. // See LICENSE.txt for license information. package product_notices import ( "github.com/mattermost/mattermost/server/public/model" "github.com/mattermost/mattermost/server/public/shared/mlog" "github.com/mattermost/mattermost/server/v8/channels/jobs" ) type AppIface interface { UpdateProductNotices() *model.AppError } func MakeWorker(jobServer *jobs.JobServer, app AppIface) *jobs.SimpleWorker { const workerName = "ProductNotices" isEnabled := func(cfg *model.Config) bool { return *cfg.AnnouncementSettings.AdminNoticesEnabled || *cfg.AnnouncementSettings.UserNoticesEnabled } execute := func(logger mlog.LoggerIFace, job *model.Job) error { defer jobServer.HandleJobPanic(logger, job) if err := app.UpdateProductNotices(); err != nil { logger.Error("Worker: Failed to fetch product notices", mlog.Err(err)) return err } return nil } worker := jobs.NewSimpleWorker(workerName, jobServer, execute, isEnabled) return worker }