src/process/executors.go - master - atombpmn/atom-engine

src/process/executors.go
72 строки2 KB
sembaev-a-a
Initial commit
18 ноя 2025, 03:22
18 ноя 2025, 03:228f621c0
/*
This file is part of the AtomBPMN (R) project.
Copyright (c) 2025 Matreska Market LLC (ООО «Matreska Market»).
Authors: Matreska Team.

This project is dual-licensed under AGPL-3.0 and AtomBPMN Commercial License.
*/

package process

import (
	"atom-engine/src/core/logger"
	"atom-engine/src/core/models"
)

// TaskExecutor executes tasks
// Исполнитель задач
type TaskExecutor struct{}

// Execute executes task
// Выполняет задачу
func (te *TaskExecutor) Execute(token *models.Token, element map[string]interface{}) (*ExecutionResult, error) {
	// Use helper function for basic flow element execution
	return executeBasicFlowElement(token, element, "task")
}

// GetElementType returns element type
// Возвращает тип элемента
func (te *TaskExecutor) GetElementType() string {
	return "task"
}

// NOTE: ServiceTaskExecutor moved to src/process/flow/elements/task/service_task.go
// Old ServiceTaskExecutor removed - now using new version with Jobs integration

// UserTaskExecutor executes user tasks
// Исполнитель пользовательских задач
type UserTaskExecutor struct{}

// Execute executes user task
// Выполняет пользовательскую задачу
func (ute *UserTaskExecutor) Execute(token *models.Token, element map[string]interface{}) (*ExecutionResult, error) {
	logger.Info("Executing user task",
		logger.String("token_id", token.TokenID),
		logger.String("element_id", token.CurrentElementID))

	// Get task name for logging
	taskName, _ := element["name"].(string)
	if taskName == "" {
		taskName = token.CurrentElementID
	}

	// User tasks typically wait for external completion
	// For now, we'll put the token in waiting state
	logger.Info("User task waiting for completion",
		logger.String("token_id", token.TokenID),
		logger.String("task_name", taskName))

	return &ExecutionResult{
		Success:      true,
		TokenUpdated: true,
		NextElements: []string{},
		WaitingFor:   "user_task_completion",
		Completed:    false,
	}, nil
}

// GetElementType returns element type
// Возвращает тип элемента
func (ute *UserTaskExecutor) GetElementType() string {
	return "userTask"
}