trigger_action_add_assetid_remap.inc

<?php
require_once SQ_INCLUDE_PATH.'/general_occasional.inc';
require_once SQ_CORE_PACKAGE_PATH.'/system/triggers/trigger_action/trigger_action.inc';

class Trigger_Action_Add_Assetid_Remap 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;

        $am = $GLOBALS['SQ_SYSTEM']->am;

        $result = Array(
                    'assetid'       => $state['asset']->id,
                    'remap_urls'    => '',
                  );

        // No URL is assigned, nothing we can do here.
        $urls = $state['asset']->getURLs();
        if (empty($urls)) return $result;

        // No site, no URL, I know, it's the same as the above.
        // Anyway I need the sites later
        $sites = $am->getParents($state['asset']->id, 'site');
        if (empty($sites)) return $result;

        // Get the list of tiny URLs we need to add
        $tiny_urls = Array();
        foreach (array_keys($sites) as $site_id) {

            $site = $am->getAsset($site_id);
            $site_urls = $site->getSiteURLs();

            if (empty($site_urls)) {
                // The site does not have URL yet
                continue;
            } else {
                $tiny_urls = array_merge($tiny_urls, $site_urls);
            }

        }

        // Map tiny URL
        $mapped_tiny_urls = Array();
        if (!empty($tiny_urls)) {
            foreach ($tiny_urls as $tiny_url) {

                foreach ($urls as $url_info) {
                    if ( ($pos = strpos($url_info['url'], $tiny_url['url'].'/')) === 0 ) {
                        // a URL can have both HTTP and HTTPS options ticked
                        $protocols = Array();
                        if ($url_info['http'] == 1) {
                            $protocols[] = 'http://';
                        }

                        if ($url_info['https'] == 1) {
                            $protocols[] = 'https://';
                        }

                        for ($i=0; $i<count($protocols); $i++) {
                            $old_url = $protocols[$i].$tiny_url['url'].'/'.$state['asset']->id;
                            $mapped_tiny_urls[$old_url] = $protocols[$i].$url_info['url'];
                        }

                        // If the asset has multiple webpaths, we just have to choose the first URL.
                        break;
                    }
                }

            }
        } else {
            return $result;
        }

        // Finally, insert Remap URLs
        if (!empty($mapped_tiny_urls)) {

            // Remove the previous remapped URLs already exist
            $GLOBALS['SQ_SYSTEM']->changeDatabaseConnection('db2');
            $GLOBALS['SQ_SYSTEM']->doTransaction('BEGIN');

            $old_urls = array_keys($mapped_tiny_urls);

            try {
                $bind_vars  = Array (
                                'urls'  => $old_urls,
                              );
                MatrixDAL::executeQuery('core', 'deleteRemapUrls', $bind_vars);
            } catch (Exception $e) {
                throw new Exception('Unable to delete remap urls due to the following database error:'.$e->getMessage());
            }//end try catch

            $GLOBALS['SQ_SYSTEM']->doTransaction('COMMIT');
            $GLOBALS['SQ_SYSTEM']->restoreDatabaseConnection();

            $rm = $GLOBALS['SQ_SYSTEM']->am->getSystemAsset('remap_manager');
            foreach ($mapped_tiny_urls as $old_url => $new_url) {
                $remap_result = $rm->addRemapURL($old_url, $new_url);
                switch ($remap_result) {
                    case 0:
                        trigger_error('CORE0271', E_USER_WARNING);
                    break;
                    case -1:
                        trigger_error('CORE0272', E_USER_WARNING, $old_url);
                    break;
                }
            }
        }//end if

        $result['remap_urls'] = $mapped_tiny_urls;
        return $result;

    }//end execute()


    public static function getInterface($settings, $prefix, $write_access=FALSE)
    {
        ob_start();
            echo translate('trigger_action_add_remap_message');
        return ob_get_clean();

    }//end getInterface()


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

    }//end getLocks()


}//end class

?>