(taskData adaptix.TaskData)
| 294 | } |
| 295 | |
| 296 | func (tm *TaskManager) Save(taskData adaptix.TaskData) error { |
| 297 | agent, err := tm.getAgent(taskData.AgentId) |
| 298 | if err != nil { |
| 299 | return err |
| 300 | } |
| 301 | |
| 302 | agentData := agent.GetData() |
| 303 | taskData.Type = adaptix.TASK_TYPE_TASK |
| 304 | taskData.TaskId, _ = krypt.GenerateUID(8) |
| 305 | taskData.Computer = agentData.Computer |
| 306 | taskData.User = agentData.Username |
| 307 | taskData.StartDate = time.Now().Unix() |
| 308 | taskData.FinishDate = taskData.StartDate |
| 309 | taskData.Sync = true |
| 310 | taskData.Completed = true |
| 311 | |
| 312 | packet_task := CreateSpAgentTaskSync(taskData) |
| 313 | tm.ts.TsSyncAllClients(packet_task) |
| 314 | |
| 315 | _ = tm.ts.DBMS.DbTaskInsert(taskData) |
| 316 | |
| 317 | return nil |
| 318 | } |
| 319 | |
| 320 | func (tm *TaskManager) ProcessDisconnectedClient(clientName string) { |
| 321 | tm.ts.Agents.ForEach(func(agentId string, agentValue interface{}) bool { |
no test coverage detected