Function enqueueAndAwait

internal/bridge/commands.go:111–139

enqueueAndAwait builds a PendingAction, enqueues it, binds it to the task, and waits for the result. Returns nil if any step fails.

(ctx ModuleContext, sessionID string, taskID uint32, sess *sessions.Session, toolName, command string)

// enqueueAndAwait builds a PendingAction, enqueues it, binds it to the task,
// and waits for the result. Returns nil if any step fails.
func enqueueAndAwait(ctx ModuleContext, sessionID string, taskID uint32, sess *sessions.Session, toolName, command string) *sessions.CommandResult {
	args := sessions.BuildCommandArguments(sess, toolName, command)
	cmdID := sessions.GenerateCommandID()
	action := &sessions.PendingAction{
		ID:        cmdID,
		TaskID:    taskID,
		Type:      sessions.ActionToolCall,
		ToolName:  toolName,
		Arguments: args,
		CreatedAt: time.Now(),
	}
	if !sessions.Global().EnqueueAction(sessionID, action) {
		ctx.Tasks.Fail(sessionID, taskID, "enqueue failed")
		return nil
	}
	ctx.Tasks.BindCommand(sessionID, taskID, cmdID)

	ch := ctx.Tasks.AwaitResult(sessionID, taskID)
	if ch == nil {
		ctx.Tasks.Fail(sessionID, taskID, "await failed")
		return nil
	}
	result, ok := awaitTaskResult(ch, taskID)
	if !ok {
		ctx.Tasks.Fail(sessionID, taskID, "channel closed")
		return nil
	}
	return result
}

// enqueueToolAction builds a PendingAction, enqueues it, and binds to the task.
// Returns the command ID and true on success, or ("", false) on failure.