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.
92 lines
2.2 KiB
Go
92 lines
2.2 KiB
Go
// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
|
|
// See LICENSE.txt for license information.
|
|
|
|
package jobs
|
|
|
|
import (
|
|
"errors"
|
|
|
|
"github.com/hanzoteam/server/server/public/model"
|
|
"github.com/hanzoteam/server/server/public/shared/configservice"
|
|
"github.com/hanzoteam/server/server/public/shared/mlog"
|
|
)
|
|
|
|
type Workers struct {
|
|
ConfigService configservice.ConfigService
|
|
Watcher *Watcher
|
|
|
|
workers map[string]model.Worker
|
|
|
|
listenerId string
|
|
running bool
|
|
}
|
|
|
|
var (
|
|
ErrWorkersNotRunning = errors.New("job workers are not running")
|
|
ErrWorkersRunning = errors.New("job workers are running")
|
|
ErrWorkersUninitialized = errors.New("job workers are not initialized")
|
|
)
|
|
|
|
func NewWorkers(configService configservice.ConfigService) *Workers {
|
|
return &Workers{
|
|
ConfigService: configService,
|
|
workers: make(map[string]model.Worker),
|
|
}
|
|
}
|
|
|
|
func (workers *Workers) AddWorker(name string, worker model.Worker) {
|
|
workers.workers[name] = worker
|
|
}
|
|
|
|
func (workers *Workers) Get(name string) model.Worker {
|
|
return workers.workers[name]
|
|
}
|
|
|
|
// Start starts the workers. This call is not safe for concurrent use.
|
|
// Synchronization should be implemented by the caller.
|
|
func (workers *Workers) Start() {
|
|
mlog.Info("Starting workers")
|
|
|
|
for _, w := range workers.workers {
|
|
if w.IsEnabled(workers.ConfigService.Config()) {
|
|
go w.Run()
|
|
}
|
|
}
|
|
|
|
go workers.Watcher.Start()
|
|
|
|
workers.listenerId = workers.ConfigService.AddConfigListener(workers.handleConfigChange)
|
|
workers.running = true
|
|
}
|
|
|
|
func (workers *Workers) handleConfigChange(oldConfig *model.Config, newConfig *model.Config) {
|
|
mlog.Debug("Workers received config change.")
|
|
|
|
for _, w := range workers.workers {
|
|
if w.IsEnabled(oldConfig) && !w.IsEnabled(newConfig) {
|
|
w.Stop()
|
|
}
|
|
if !w.IsEnabled(oldConfig) && w.IsEnabled(newConfig) {
|
|
go w.Run()
|
|
}
|
|
}
|
|
}
|
|
|
|
// Stop stops the workers. This call is not safe for concurrent use.
|
|
// Synchronization should be implemented by the caller.
|
|
func (workers *Workers) Stop() {
|
|
workers.ConfigService.RemoveConfigListener(workers.listenerId)
|
|
|
|
workers.Watcher.Stop()
|
|
|
|
for _, w := range workers.workers {
|
|
if w.IsEnabled(workers.ConfigService.Config()) {
|
|
w.Stop()
|
|
}
|
|
}
|
|
|
|
workers.running = false
|
|
|
|
mlog.Info("Stopped workers")
|
|
}
|