trigger_action_remove_workflow_schema.inc

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

class Trigger_Action_Remove_Workflow_Schema extends Trigger_Action
{


    public static function execute($settings, &$state)
    {
        $am =& $GLOBALS['SQ_SYSTEM']->am;
        $wfm = $GLOBALS['SQ_SYSTEM']->getWorkflowManager();

        // check required settings
        if (empty($settings['schemaid'])) return FALSE;

        if (empty($state['asset'])) {
            // grab the asset if assetid is given, but not the asset.
            if (empty($state['assetid'])) {
                return FALSE;
            } else {
                $state['asset'] = $am->getAsset($state['assetid']);
            }
        }

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

        $cascade_to_children = array_get_index($settings, 'cascade_to_children', FALSE);

        $schema = $am->getAsset($settings['schemaid']);
        if (is_null($schema)) return FALSE;
        if ($schema->type() != 'workflow_schema') return FALSE;
        
        $result = TRUE;
        $assets = Array ($state['assetid']);
        
        if (!$cascade_to_children) {
            //This part ensures schemas are removed from depedant children of a single targeted asset (cascade off).
            $dependants = $GLOBALS['SQ_SYSTEM']->am->getDependantChildren($state['assetid']);
            foreach (array_keys($dependants) as $child_id) {
                $assets[] = $child_id;
            }
        }
        
        foreach ($assets as $assetid) {
            $schema_info = $wfm->getAssetSchemaInfo($assetid, $schema->id);
            if (!empty($schema_info)) {
                $running_schemas = $wfm->getSchemas($assetid, NULL, TRUE);
                if (empty($running_schemas) || !array_key_exists($schema->id, $running_schemas)) {
                    $success = $wfm->deleteSchema($assetid, $schema->id, FALSE);
                    if (!$success) $result = FALSE;
                }
            }
        }
        
        if ($cascade_to_children) {
            $children = $am->getChildren($state['assetid']);
            foreach (array_keys($children) as $child_id) {
                $schema_info = $wfm->getAssetSchemaInfo($child_id, $schema->id);
                if (!empty($schema_info)) {
                    $running_schemas = $wfm->getSchemas($child_id, NULL, TRUE);
                    if (empty($running_schemas) || !array_key_exists($schema->id, $running_schemas)) {
                        $success = $wfm->deleteSchema($child_id, $schema->id, FALSE);
                        if (!$success) $result = FALSE;
                    }
                }
            }
        }

        if (!$result) {
            return FALSE;
        } else {
            return TRUE;
        }
        
    }//end execute()


    public static function getInterface($settings, $prefix, $write_access=FALSE)
    {
        $current_schemaid      = array_get_index($settings, 'schemaid', 0);
        $cascade_to_children = array_get_index($settings, 'cascade_to_children', FALSE);
        
        ob_start();
            if ($write_access) {
                echo translate('select_workflow_schema_to_remove').' ';
                asset_finder($prefix.'[schemaid]', $current_schemaid, Array('workflow_schema' => 'I'));

                echo '<br />';
                check_box($prefix.'[cascade_to_children]', '1', $cascade_to_children);
                label(translate('cascade_schema_removal_to_children'), $prefix.'[cascade_to_children]');

            } else {
                if (!empty($current_schemaid)) {
                    $schema_info = $GLOBALS['SQ_SYSTEM']->am->getAssetInfo(Array($current_schemaid));
                    echo translate('select_workflow_schema_to_remove').' ';
                    echo '<b>'.$schema_info[$current_schemaid]['name'].' (#'.$current_schemaid.')</b>';
                } else {
                    echo translate('select_workflow_schema_to_remove').' ';
                    echo '<b>'.translate('trigger_schema_no_schema_specified').'</b>';
                }

                echo '<br />';
                echo '<img src="'.sq_web_path('lib').'/web/images/'.($cascade_to_children ? 'tick' : 'cross').'.gif" alt="'.($cascade_to_children ? translate('yes') : translate('no')).'" /> ';
                echo translate('cascade_schema_removal_to_children');
            }

            $output = ob_get_contents();
        ob_end_clean();

        return $output;

    }//end getInterface()


    public static function processInterface(&$settings, $request_data)
    {
        $schema_info = array_get_index($request_data, 'schemaid', Array('assetid' => 0));
        $settings['schemaid'] = array_get_index($schema_info, 'assetid', 0);
        $settings['cascade_to_children']  = array_get_index($request_data, 'cascade_to_children', FALSE);

        return FALSE;

    }//end processInterface()


}//end class

?>