class RulesAction

class RulesAction extends RulesAbstractPlugin implements RulesActionInterface {
    
    /**
     * @var string
     */
    protected $itemName = 'action';
    
    /**
     * Execute the callback and update/save data as specified by the action.
     */
    protected function executeCallback(array $args, RulesState $state = NULL) {
        rules_log('Evaluating the action %name.', array(
            '%name' => $this->label($this->elementName),
        ), RulesLog::INFO, $this);
        $return = $this->__call('execute', empty($this->info['named parameter']) ? $args : array(
            $args,
        ));
        // Get the (partially) wrapped arguments.
        $args = $state->currentArguments;
        if (is_array($return)) {
            foreach ($return as $name => $data) {
                // Add provided variables.
                if (isset($this->info['provides'][$name])) {
                    $var_name = isset($this->settings[$name . ':var']) ? $this->settings[$name . ':var'] : $name;
                    if (!$state->varInfo($var_name)) {
                        $state->addVariable($var_name, $data, $this->info['provides'][$name]);
                        rules_log('Added the provided variable %name of type %type', array(
                            '%name' => $var_name,
                            '%type' => $this->info['provides'][$name]['type'],
                        ), RulesLog::INFO, $this);
                        if (!empty($this->info['provides'][$name]['save']) && $state->variables[$var_name] instanceof EntityMetadataWrapper) {
                            $state->saveChanges($var_name, $state->variables[$var_name]);
                        }
                    }
                }
                elseif (!isset($this->info['provides'][$name])) {
                    // Update the data value using the wrapper.
                    if (isset($args[$name]) && $args[$name] instanceof EntityMetadataWrapper) {
                        try {
                            $args[$name]->set($data);
                        } catch (EntityMetadataWrapperException $e) {
                            throw new RulesEvaluationException('Unable to update the argument for parameter %name: %error', array(
                                '%name' => $name,
                                '%error' => $e->getMessage(),
                            ), $this);
                        }
                    }
                    elseif (array_key_exists($name, $args)) {
                        // Map back to the source variable name and update it.
                        $var_name = !empty($this->settings[$name . ':select']) ? str_replace('-', '_', $this->settings[$name . ':select']) : $name;
                        $state->variables[$var_name] = $data;
                    }
                }
            }
        }
        // Save parameters as defined in the parameter info.
        if ($return !== FALSE) {
            foreach ($this->info['parameter'] as $name => $info) {
                if (!empty($info['save']) && $args[$name] instanceof EntityMetadataWrapper) {
                    if (isset($this->settings[$name . ':select'])) {
                        $state->saveChanges($this->settings[$name . ':select'], $args[$name]);
                    }
                    else {
                        // Wrapper has been configured via direct input, so just save.
                        rules_log('Saved argument of type %type for parameter %name.', array(
                            '%name' => $name,
                            '%type' => $args[$name]->type(),
                        ));
                        $args[$name]->save();
                    }
                }
            }
        }
    }

}