Method EnqueueAction

internal/sessions/manager.go:151–164

EnqueueAction adds a pending action to a session's queue. Poison actions are always inserted at the front (highest priority).

(sessionID string, action *PendingAction)

// EnqueueAction adds a pending action to a session's queue.
// Poison actions are always inserted at the front (highest priority).
func (m *Manager) EnqueueAction(sessionID string, action *PendingAction) bool {
	sess := m.Get(sessionID)
	if sess == nil {
		return false
	}
	sess.mu.Lock()
	defer sess.mu.Unlock()
	if action.Type == ActionPoison {
		sess.pendingActions = append([]*PendingAction{action}, sess.pendingActions...)
	} else {
		sess.pendingActions = append(sess.pendingActions, action)
	}
	return true
}

// DequeueAction removes and returns the next pending action.
// Poison actions have priority: if any exist, the first poison is returned.