Method Create

internal/bridge/taskmanager.go:95–117

Create registers a new task in Pending state. If a task with the same sessionID+taskID already exists, it is returned as-is.

(sessionID string, taskID uint32, module string)

// Create registers a new task in Pending state.
// If a task with the same sessionID+taskID already exists, it is returned as-is.
func (tm *TaskManager) Create(sessionID string, taskID uint32, module string) *Task {
	key := taskKey{sessionID, taskID}
	now := time.Now()

	tm.mu.Lock()
	defer tm.mu.Unlock()

	if existing, ok := tm.tasks[key]; ok {
		return existing
	}

	task := &Task{
		ID:        taskID,
		SessionID: sessionID,
		Module:    module,
		State:     TaskPending,
		CreatedAt: now,
		UpdatedAt: now,
		resultCh:  make(chan *sessions.CommandResult, taskResultBufferSize),
	}
	tm.tasks[key] = task
	return task
}

// Get returns the task for the given sessionID+taskID, or nil.
func (tm *TaskManager) Get(sessionID string, taskID uint32) *Task {