Websites/perf.webkit.org/public/include/build-requests-fetcher.php

<?php

require_once('test-path-resolver.php');
require_once('uploaded-file-helpers.php');

class BuildRequestsFetcher {
    function __construct($db) {
        $this->db = $db;
        $this->rows = null;
        $this->commit_sets = array();
        $this->commits_by_id = array();
        $this->commits = array();
        $this->commit_sets_by_id = array();
        $this->uploaded_files = array();
        $this->uploaded_files_by_id = array();
    }

    function fetch_for_task($task_id) {
        $this->rows = $this->db->query_and_fetch_all('SELECT *, testgroup_task as task_id
            FROM build_requests LEFT OUTER JOIN builds ON request_build = build_id, analysis_test_groups
            WHERE request_group = testgroup_id AND testgroup_task = $1
            ORDER BY request_group, request_order', array($task_id));
    }

    function fetch_for_group($task_id, $test_group_id) {
        $this->rows = $this->db->query_and_fetch_all('SELECT *
            FROM build_requests LEFT OUTER JOIN builds ON request_build = build_id
            WHERE request_group = $1 ORDER BY request_order', array($test_group_id));
        foreach ($this->rows as &$row)
            $row['task_id'] = $task_id;
    }

    function fetch_incomplete_requests_for_triggerable($triggerable_id) {
        $this->rows = $this->db->query_and_fetch_all('SELECT *, test_groups.testgroup_task as task_id FROM build_requests,
            (SELECT testgroup_id, testgroup_task, (case when testgroup_author is not null then 0 else 1 end) as author_order, testgroup_created_at
                FROM analysis_test_groups WHERE EXISTS
                    (SELECT 1 FROM build_requests WHERE testgroup_id = request_group AND request_status
                        IN (\'pending\', \'scheduled\', \'running\'))) AS test_groups
            WHERE request_triggerable = $1 AND request_group = test_groups.testgroup_id
            ORDER BY author_order, testgroup_created_at, request_order', array($triggerable_id));
    }

    function fetch_request($request_id) {
        $this->rows = $this->db->select_rows('build_requests', 'request', array('id' => $request_id));
    }

    function has_results() { return is_array($this->rows); }
    function results() { return $this->results_internal(false); }
    function results_with_resolved_ids() { return $this->results_internal(true); }

    private function results_internal($resolve_ids) {
        if (!$this->rows)
            return array();

        $id_to_platform_name = array();
        if ($resolve_ids) {
            foreach ($this->db->select_rows('platforms', 'platform', array()) as $platform)
                $id_to_platform_name[$platform['platform_id']] = $platform['platform_name'];
        }
        $test_path_resolver = new TestPathResolver($this->db);

        $requests = array();
        foreach ($this->rows as $row) {
            $test_id = $row['request_test'];
            $platform_id = $row['request_platform'];
            $commit_set_id = $row['request_commit_set'];

            $this->fetch_commits_for_set_if_needed($commit_set_id, $resolve_ids);

            array_push($requests, array(
                'id' => $row['request_id'],
                'task' => $row['task_id'],
                'triggerable' => $row['request_triggerable'],
                'repositoryGroup' => $row['request_repository_group'],
                'test' => $resolve_ids ? $test_path_resolver->path_for_test($test_id) : $test_id,
                'platform' => $resolve_ids ? $id_to_platform_name[$platform_id] : $platform_id,
                'testGroup' => $row['request_group'],
                'order' => $row['request_order'],
                'commitSet' => $commit_set_id,
                'status' => $row['request_status'],
                'url' => $row['request_url'],
                'build' => $row['request_build'],
                'createdAt' => $row['request_created_at'] ? strtotime($row['request_created_at']) * 1000 : NULL,
            ));
        }
        return $requests;
    }

    function commit_sets() { return $this->commit_sets; }
    function commits() { return $this->commits; }
    function uploaded_files() { return $this->uploaded_files; }

    private function fetch_commits_for_set_if_needed($commit_set_id, $resolve_ids) {
        if (array_key_exists($commit_set_id, $this->commit_sets_by_id))
            return;

        $commit_set_items = $this->db->query_and_fetch_all('SELECT *
            FROM commit_set_items LEFT OUTER JOIN  commits ON commitset_commit = commit_id
                LEFT OUTER JOIN repositories ON repository_id = commit_repository
                WHERE commitset_set = $1', array($commit_set_id));

        $custom_roots = array();
        $revision_items = array();
        foreach ($commit_set_items as $row) {
            $repository_id = $resolve_ids ? $row['repository_name'] : $row['repository_id'];
            $revision = $row['commit_revision'];
            $commit_time = $row['commit_time'];

            $root_file_id = $row['commitset_root_file'];
            $commit_id = $row['commitset_commit'];
            if ($root_file_id && !$commit_id) {
                $this->add_uploaded_file($root_file_id);
                array_push($custom_roots, $root_file_id);
                continue;
            }

            $patch_file_id = $row['commitset_patch_file'];
            if ($patch_file_id)
                $this->add_uploaded_file($patch_file_id);

            $root_file_id = $row['commitset_root_file'];
            if ($root_file_id)
                $this->add_uploaded_file($root_file_id);

            array_push($revision_items, array(
                'commit' => $row['commit_id'],
                'patch' => $patch_file_id,
                'rootFile' => $root_file_id,
                'commitOwner' => $row['commitset_commit_owner'],
                'requiresBuild' => Database::is_true($row['commitset_requires_build'])));

            if (array_key_exists($commit_id, $this->commits_by_id))
                continue;

            array_push($this->commits, array(
                'id' => $commit_id,
                'repository' => $repository_id,
                'commitOwner' => $row['commitset_commit_owner'],
                'revision' => $revision,
                'time' => Database::to_js_time($commit_time)));

            $this->commits_by_id[$commit_id] = TRUE;
        }

        $this->commit_sets_by_id[$commit_set_id] = TRUE;

        $owner_commits_rows = $this->db->query_and_fetch_all('SELECT * FROM commits, repositories
            WHERE commit_repository = repository_id AND  commit_id
            IN (SELECT DISTINCT(commitset_commit_owner) FROM commit_set_items
              WHERE commitset_set = $1 AND commitset_commit_owner IS NOT NULL)', array($commit_set_id));

        foreach ($owner_commits_rows as $row) {
            $commit_id = $row['commit_id'];
            if (array_key_exists($commit_id, $this->commits_by_id))
                continue;

            array_push($this->commits, array(
                'id' => $commit_id,
                'repository' => $resolve_ids ? $row['repository_name'] : $row['repository_id'],
                'commitOwner' => NULL,
                'revision' => $row['commit_revision'],
                'time' => Database::to_js_time($row['commit_time'])));
            $this->commits_by_id[$commit_id] = TRUE;
        }

        array_push($this->commit_sets, array('id' => $commit_set_id, 'revisionItems' => $revision_items, 'customRoots' => $custom_roots));
    }

    private function add_uploaded_file($root_file_id)
    {
        if (!array_key_exists($root_file_id, $this->uploaded_files_by_id)) {
            $uploaded_file_row = $this->db->select_first_row('uploaded_files', 'file', array('id' => $root_file_id));
            array_push($this->uploaded_files, format_uploaded_file($uploaded_file_row));
        }
    }
}

?>