Helper2013022000.php

Go to the documentation of this file.

<?php

class Elgg_Upgrades_Helper2013022000 {
    const RELATIONSHIP_SUCCESS = '2013022000';
    const RELATIONSHIP_FAILURE = '2013022000_fail';

    protected $siteGuid;

    protected $dbPrefix;

    public function __construct($siteGuid, $dbPrefix) {
        $this->siteGuid = $siteGuid;
        $this->dbPrefix = $dbPrefix;
    }

    public function getBatchOptions() {
        $relationship1 = sanitise_string(self::RELATIONSHIP_SUCCESS);
        $relationship2 = sanitise_string(self::RELATIONSHIP_FAILURE);
        // find users without either relationship
        return array(
            'type' => 'user',
            'callback' => '',
            'order_by' => 'e.guid',
            'joins' => array(
                "LEFT JOIN {$this->dbPrefix}entity_relationships er1
                ON (e.guid = er1.guid_one
                    AND er1.guid_two = {$this->siteGuid}
                    AND er1.relationship = '$relationship1')
                ",
                "LEFT JOIN {$this->dbPrefix}entity_relationships er2
                ON (e.guid = er2.guid_one
                    AND er2.guid_two = {$this->siteGuid}
                    AND er2.relationship = '$relationship2')
                ",
            ),
            'wheres' => array("er1.guid_one IS NULL AND er2.guid_one IS NULL"),
            'limit' => false,
        );
    }

    public function countUnmigratedUsers() {
        $opts = $this->getBatchOptions();
        $opts['count'] = true;
        return elgg_get_entities($opts);
    }

    public function makeMatrix($user_row) {
        $time_created = date('Y/m/d', $user_row->time_created);
        return "$time_created/$user_row->guid/";
    }

    public function removeDirIfEmpty($dir) {
        $files = scandir($dir);

        foreach ($files as $file) {
            if ($file == '..' || $file == '.') {
                continue;
            }

            // not empty.
            if (is_file("$dir/$file")) {
                return false;
            }

            // subdir not empty
            if (is_dir("$dir/$file") && !$this->removeDirIfEmpty("$dir/$file")) {
                return false;
            }
        }

        // only contains empty subdirs
        return rmdir($dir);
    }

    public function getLowerBucketBound($guid) {
        $bucket_size = Elgg_EntityDirLocator::BUCKET_SIZE;
        if ($guid < 1) {
            return false;
        }
        return (int) max(floor($guid / $bucket_size) * $bucket_size, 1);
    }

    public function markSuccess($guid) {
        add_entity_relationship($guid, self::RELATIONSHIP_SUCCESS, $this->siteGuid);
    }

    public function markFailure($guid) {
        add_entity_relationship($guid, self::RELATIONSHIP_FAILURE, $this->siteGuid);
    }

    public function forgetFailures() {
        $relationship = sanitise_string(self::RELATIONSHIP_FAILURE);
        update_data("
            DELETE FROM {$this->dbPrefix}entity_relationships
            WHERE relationship = '$relationship'
              AND guid_two = {$this->siteGuid}
        ");
    }

    public function forgetSuccesses() {
        $relationship = sanitise_string(self::RELATIONSHIP_SUCCESS);
        update_data("
            DELETE FROM {$this->dbPrefix}entity_relationships
            WHERE relationship = '$relationship'
              AND guid_two = {$this->siteGuid}
        ");
    }

    public function hasFailures() {
        $relationship = sanitise_string(self::RELATIONSHIP_FAILURE);
        $sql = "
            SELECT COUNT(*) AS cnt FROM {$this->dbPrefix}entity_relationships
            WHERE relationship = '$relationship'
              AND guid_two = {$this->siteGuid}
        ";
        $row = get_data_row($sql);
        return ($row->cnt > 0);
    }
}