Method executeAction

injection/engine.go:228–285

executeAction executes the action specified by a rule.

(ctx *InjectionContext, rule *Rule)

// executeAction executes the action specified by a rule.
func (e *Engine) executeAction(ctx *InjectionContext, rule *Rule) (*ActionResult, error) {
	// Update action stats (atomic for counter, mutex for map)
	e.stats.ActionsExecuted.Add(1)
	e.stats.mu.Lock()
	e.stats.ActionCounts[rule.Action]++
	e.stats.mu.Unlock()

	// Handle simple verdict actions
	switch rule.Action {
	case ActionAccept:
		return &ActionResult{
			Action:    ActionAccept,
			Success:   true,
			Timestamp: time.Now(),
		}, nil

	case ActionDrop:
		e.stats.PacketsDropped.Add(1)

		return &ActionResult{
			Action:    ActionDrop,
			Success:   true,
			Drop:      true,
			Timestamp: time.Now(),
		}, nil
	}

	// Get action handler for complex actions
	handler, err := GetActionHandler(rule.Action)
	if err != nil {
		return nil, err
	}

	if handler == nil {
		return nil, fmt.Errorf("no handler for action: %s", rule.Action)
	}

	// Execute the action
	result, err := handler.Execute(ctx, rule.ActionConfig)
	if err != nil {
		return nil, err
	}

	// Update statistics based on result (all atomic)
	if result != nil {
		if result.Drop {
			e.stats.PacketsDropped.Add(1)
		}
		if result.ModifiedPacket != nil {
			e.stats.PacketsModified.Add(1)
		}
		if len(result.InjectPackets) > 0 {
			e.stats.PacketsInjected.Add(uint64(len(result.InjectPackets)))
		}
	}

	return result, nil
}