Function newTaskSyncService

core/services/agentpool/task_sync_test.go:28–44

newTaskSyncService builds an AgentJobService wired to the given bus and a throwaway data dir (so the file persister has somewhere to write). Model/config loaders are nil because the task sync paths under test never touch them.

(bus messaging.MessagingClient)

// throwaway data dir (so the file persister has somewhere to write). Model/config
// loaders are nil because the task sync paths under test never touch them.
func newTaskSyncService(bus messaging.MessagingClient) *AgentJobService {
	tmpDir := GinkgoT().TempDir()
	sysState := &system.SystemState{}
	sysState.Model.ModelsPath = tmpDir
	appConfig := config.NewApplicationConfig(
		config.WithDynamicConfigDir(tmpDir),
		config.WithContext(context.Background()),
	)
	appConfig.SystemState = sysState

	svc := NewAgentJobServiceWithPaths(appConfig, nil, nil, nil,
		// Distinct per-replica files so the file persister write-through never
		// crosses replicas: convergence here must be proven via the bus alone.
		tmpDir+"/tasks.json", tmpDir+"/jobs.json")
	svc.SetTaskSyncNATS(bus)
	return svc
}

var _ = Describe("AgentJobService task cross-replica sync", func() {
	Describe("two replicas sharing one bus", func() {