mirror of
https://github.com/hanzoai/team.git
synced 2026-11-01 07:55:31 +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.
84 lines
2.4 KiB
Go
84 lines
2.4 KiB
Go
// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
|
|
// See LICENSE.txt for license information.
|
|
|
|
package scheduled_recap
|
|
|
|
import (
|
|
"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"
|
|
)
|
|
|
|
// SchedulerPollingInterval defines how often the scheduler polls for due scheduled recaps.
|
|
const SchedulerPollingInterval = 1 * time.Minute
|
|
|
|
// Scheduler polls for due scheduled recaps and creates jobs for them.
|
|
type Scheduler struct {
|
|
*jobs.PeriodicScheduler
|
|
store store.Store
|
|
jobServer *jobs.JobServer
|
|
}
|
|
|
|
// MakeScheduler creates a new scheduler for scheduled recaps.
|
|
func MakeScheduler(jobServer *jobs.JobServer, storeInstance store.Store) *Scheduler {
|
|
isEnabled := func(cfg *model.Config) bool {
|
|
return cfg.AIRecapsEnabled()
|
|
}
|
|
return &Scheduler{
|
|
PeriodicScheduler: jobs.NewPeriodicScheduler(
|
|
jobServer,
|
|
model.JobTypeScheduledRecap,
|
|
SchedulerPollingInterval,
|
|
isEnabled,
|
|
),
|
|
store: storeInstance,
|
|
jobServer: jobServer,
|
|
}
|
|
}
|
|
|
|
// NextScheduleTime overrides to use tight polling interval.
|
|
func (s *Scheduler) NextScheduleTime(cfg *model.Config, now time.Time, pendingJobs bool, lastJob *model.Job) *time.Time {
|
|
next := now.Add(SchedulerPollingInterval)
|
|
return &next
|
|
}
|
|
|
|
// ScheduleJob polls for due scheduled recaps and creates jobs for each.
|
|
func (s *Scheduler) ScheduleJob(rctx request.CTX, cfg *model.Config, pendingJobs bool, lastJob *model.Job) (*model.Job, *model.AppError) {
|
|
now := model.GetMillis()
|
|
dueRecaps, err := s.store.ScheduledRecap().GetDueBefore(now, 100)
|
|
if err != nil {
|
|
mlog.Error("Failed to get due scheduled recaps", mlog.Err(err))
|
|
return nil, nil
|
|
}
|
|
|
|
for _, sr := range dueRecaps {
|
|
// The worker re-fetches the full row by ID, so the job only needs the ID.
|
|
jobData := model.StringMap{
|
|
"scheduled_recap_id": sr.Id,
|
|
}
|
|
|
|
job, jobErr := s.jobServer.CreateJobOnceByTypeAndData(
|
|
rctx,
|
|
model.JobTypeScheduledRecap,
|
|
jobData,
|
|
map[string]string{"scheduled_recap_id": sr.Id},
|
|
)
|
|
if jobErr != nil {
|
|
mlog.Warn("Scheduled recap job creation failed",
|
|
mlog.String("scheduled_recap_id", sr.Id),
|
|
mlog.Err(jobErr))
|
|
continue
|
|
}
|
|
if job == nil {
|
|
mlog.Debug("Scheduled recap job already queued",
|
|
mlog.String("scheduled_recap_id", sr.Id))
|
|
}
|
|
}
|
|
|
|
return nil, nil
|
|
}
|