trigger_action_call_rest_resource.inc

<?php
require_once SQ_CORE_PACKAGE_PATH.'/system/triggers/trigger_action/trigger_action.inc';
require_once SQ_ATTRIBUTES_PATH.'/http_request/http_request.inc';

class Trigger_Action_Call_Rest_Resource extends Trigger_Action
{
    public static function execute($settings, &$state)
    {
        if (empty($state['asset'])) {
            // grab the asset if assetid is given, but not the asset.
            if (empty($state['assetid'])) {
                return FALSE;
            } else {
                $state['asset'] = $GLOBALS['SQ_SYSTEM']->am->getAsset($state['assetid']);
            }
        }

        if (is_null($state['asset'])) return FALSE;

        $assetid = $state['asset']->id;

        $http_request_value = $settings['http_request'];

        // create a new http request object
        $http_request_attr = new Asset_Attribute_HTTP_Request(0, $http_request_value);
        if (is_null($http_request_attr)) return FALSE;

        $current_value = unserialize($http_request_attr->value);

        // return false if there is no method or url specified
        if (empty($current_value['method']) && empty($current_value['urls'])) {
            return FALSE;
        }

        // Get list of replacements
        $keywords_list = Array();
        if (isset($current_value['urls'])) {
            $keywords_list = array_merge(
                                        $keywords_list,
                                        retrieve_keywords_replacements(implode(', ', $current_value['urls']))
                                    );
        }
        
        if (isset($current_value['request_headers'])) {
            $keywords_list = array_merge(
                                        $keywords_list,
                                        retrieve_keywords_replacements(implode(', ', $current_value['request_headers']))
                                    );
        }

        if (isset($current_value['request_body'])) {
            $keywords_list = array_merge(
                                        $keywords_list,
                                        retrieve_keywords_replacements($current_value['request_body'])
                                    );
        }
        
        if (isset($current_value['http_auth_options'])) {
            $keywords_list = array_merge(
                                        $keywords_list,
                                        retrieve_keywords_replacements(implode(', ', $current_value['http_auth_options']))
                                    );
        }

        $keywords_list = array_unique($keywords_list);

        // ...and find their replacements and set them to the http request object
        $replacements = Array();
        foreach ($keywords_list as $keyword) {
            $replacements[$keyword] = $state['asset']->getKeywordReplacement($keyword);
        }

        $http_request_attr->setKeywordReplacements($replacements);

        // send the request
        $res =& $http_request_attr->run();

        // pass the triggering asset and REST responses received
        $GLOBALS['SQ_SYSTEM']->broadcastTriggerEvent('trigger_event_rest_response_received', $state['asset'], $res);
        $GLOBALS['SQ_SYSTEM']->am->forgetAsset($state['asset']);

        return Array(
                'assetid'   => $assetid,
               );

    }//end execute()


    public static function getInterface($settings, $prefix, $write_access=FALSE)
    {
        ob_start();
        
        $new_prefix = str_replace(array('[',']'), '_', $prefix);

        $http_request_value = array_get_index($settings, 'http_request', Array());
        $http_request_attr = new Asset_Attribute_HTTP_Request(0, $http_request_value);

        $http_request_attr->paint($new_prefix.'_http_request', !$write_access);

        hidden_field($prefix.'[new_prefix]', $new_prefix);

        return ob_get_clean();

    }//end getInterface()


    public static function processInterface(&$settings, $request_data)
    {
        if (!isset($settings['http_request'])) {
            $http_request_value = serialize(Array());
        } else {
            $http_request_value = $settings['http_request'];
        }

        $http_request_attr = new Asset_Attribute_HTTP_Request(0, $http_request_value);
        $new_prefix = str_replace(array('[',']'), '_', array_get_index($request_data, 'new_prefix', ''));

        $http_request_attr->process($new_prefix.'_http_request');
        $settings['http_request'] = $http_request_attr->value;

        return FALSE;

    }//end processInterface()


    public static function getLocks($settings, &$state)
    {
        return Array($state['assetid'] => Array('lookups'));

    }//end getLocks()


}//end class

?>