snap2/util/SnapBulkAction.php5

<?php

abstract class SnapBulkAction extends SObject {
    const DEPTH_IMMEDIATE = 0;
    const DEPTH_ALL = 1;

    private static $VERSION_ACTIONS = array(
        SnapVersion::STATUS_PRIVATE => array(
            SnapVersion::STATUS_PENDING => 'submit',
            SnapVersion::STATUS_DEFUNCT => 'defunct'
        ),
        SnapVersion::STATUS_PENDING => array(
            SnapVersion::STATUS_DEV => 'approveForDev',
            SnapVersion::STATUS_LIVE => 'approveForLive',
            SnapVersion::STATUS_PRIVATE => 'deny',
            SnapVersion::STATUS_DEFUNCT => 'defunct'
        ),
        SnapVersion::STATUS_DEV => array(
            SnapVersion::STATUS_LIVE => 'approveForLive',
            SnapVersion::STATUS_DEFUNCT => 'defunct'
        ),
        SnapVersion::STATUS_LIVE => array(
            SnapVersion::STATUS_DEFUNCT => 'defunct'
        ),
        SnapVersion::STATUS_DEFUNCT => array(
            -1 => 'destroy'
        )
    );

    public static function listVersionsRecursive($base = '//', $depth = self::DEPTH_ALL,
                                $constraint = array(), $limit = array(), $order = array())
    {
        $baseObj = SnapFile::lookup($base);
        if(!$baseObj) {
            self::setStaticError('Invalid base path: \'' . $base . '\'');
            return null;
        }

        if($depth == self::DEPTH_IMMEDIATE) {
            $baseId = $baseObj->getId();
            if($baseObj->getType() == 'Directory') {
                $query = <<<END_QUERY
SELECT versionId, path FROM PathCache
    LEFT JOIN Version ON PathCache.versionId = Version.id
    WHERE PathCache.path LIKE BINARY '$base%'
        AND PathCache.versionId IS NOT NULL
        AND Version.resourceId IN
            (SELECT id FROM Resource
                LEFT JOIN ResourceLink ON Resource.id = ResourceLink.childId
                WHERE ResourceLink.parentId = $baseId)
END_QUERY;
            }
            else {
                $query = <<<END_QUERY
SELECT versionId, path FROM PathCache
    LEFT JOIN Version ON PathCache.versionId = Version.id
    WHERE PathCache.path LIKE BINARY '$base%'
        AND PathCache.versionId IS NOT NULL
        AND Version.resourceId = $baseId
END_QUERY;
            }
        }
        else {
            $query = 'SELECT versionId, path FROM PathCache WHERE versionId IS NOT NULL AND path LIKE BINARY \''
                    . $base . '%\'';
        }

        if(!SnapDBI::query($query)) {
            self::setStaticError('Error doing query');
            return null;
        }

        $ret = array();
        while(($row = SnapDBI::getRow()) !== false) {
            $ret[$row['versionId']] = $row['path'];
        }

        SnapDBI::freeResult();

        return $ret;
    }

    public static function listResourcesRecursive($base = '//', $depth = self::DEPTH_ALL,
                                $constraint = array(), $limit = array(), $order = array())
    {
    }

    public static function listDirectoriesRecursive($base = '//', $depth = self::DEPTH_ALL,
                                $constraint = array(), $limit = array(), $order = array())
    {
    }

    public static function bulkApprove($base, $from, $to, $options = array()) {
        $recursive = isset($options['recursive']) ? $options['recursive'] : true;
        $single = isset($options['single']) ? $options['single'] : true;
        $fullStats = isset($options['fullStats']) ? $options['fullStats'] : false;
        $dryRun = isset($options['dryRun']) ? $options['dryRun'] : false;

        $success = 0;
        $fail = 0;

        $versions = self::listVersionsRecursive($base, $recursive ? self::DEPTH_ALL : self::DEPTH_IMMEDIATE);

        if($single) {
            $resources = array();
            $curResource = -1;
            $skipped = 0;
        }

        if($fullStats)
            $stats = array();

        foreach($versions as $id => $path) {
            $v = SnapVersion::retrieve($id);
            if($single && $v->getResourceId() != $curResource) {
                $resources[$v->getResourceId()] = array(
                    SnapVersion::STATUS_PRIVATE => false,
                    SnapVersion::STATUS_PENDING => false,
                    SnapVersion::STATUS_DEV => false,
                    SnapVersion::STATUS_LIVE => false,
                    SnapVersion::STATUS_DEFUNCT => false
                );
                $curResource = $v->getResourceId();
            }

            if($v->getStatus() == $from) {
                if($single) {
                    if($resources[$curResource][$from] == true) {
                        if($fullStats)
                            $stats[$path] = 'skipped';
                        $skipped++;
                        continue;
                    }
                    else
                        $resources[$curResource][$from] = true;
                }

                $func = self::$VERSION_ACTIONS[$from][$to];
                if($dryRun)
                    $func = 'can' . ucfirst($func);

                if($v->$func()) {
                    if($fullStats)
                        $stats[$path] = 'success';
                    $success++;
                }
                else {
                    if($fullStats) {
                        if($dryRun)
                            $stats[$path] = 'failure: ' . $v->getReason();
                        else
                            $stats[$path] = 'failure: ' . $v->getLastError();
                    }
                    $fail++;
                }
            }
            unset($v);
        }

        if($fullStats && $single)
            return array($success, $fail, $skipped, $stats);
        else if($fullStats)
            return array($success, $fail, $stats);
        else if($single)
            return array($success, $fail, $skipped);
        else
            return array($success, $fail);
    }
}

?>

---