path: root/php/lib/mirror.php

<?php
/**
 *  Application functions.  Dependent on lib/db.php!
 *  @package mirror
 *  @subpackage lib
 *  @todo add transactions once innodb table types are in place 
 */

class Mirror {

/**
 *  Get an alpha-list of regions for select list.
 *  @return array $regions
 */
public static function get_regions_select()
{
    $regions = DB::get("SELECT region_id,region_name FROM mirror_regions ORDER BY region_name ASC",PDO::FETCH_ASSOC);
    foreach ($regions as $region) {
        $retval[$region['region_id']]=$region['region_name'];
    }
    return $retval;
}

/**
 *  Get an priority-list of regions for select list.
 *  @return array $regions
 */
public static function get_regions_select_priority()
{
    $regions = DB::get("SELECT region_id,region_name FROM mirror_regions ORDER BY region_priority ASC",PDO::FETCH_ASSOC);
    foreach ($regions as $region) {
        $retval[$region['region_id']]=$region['region_name'];
    }
    return $retval;
}

/**
 *  Insert region.
 *  @param string $name
 *  @param int $priority
 *  @return bool
 */
public static function insert_region($name,$priority)
{
    return DB::query("INSERT INTO mirror_regions(region_name,region_priority) VALUES(?,?)", [$name, $priority]);
}

/**
 *  Update region.
 *  @param int $id
 *  @param string $name
 *  @param int $priority
 *  @return bool
 */
public static function update_region($id,$name,$priority)
{
    return DB::query("UPDATE mirror_regions SET region_name=?,region_priority=? WHERE region_id=?", [$name, $priority, $id]);
}

/**
 *  Get one region.
 *  @param int $id
 *  @return array
 */
public static function get_one_region($id)
{
    return DB::get_one("SELECT * FROM mirror_regions WHERE region_id = ?", PDO::FETCH_ASSOC, [$id]);
}

/**
 *  Delete a region.
 *  @param int $id
 *  @return bool
 */
public static function delete_region($id)
{
    return DB::query("DELETE FROM mirror_regions WHERE region_id=?", [$id]);
}

/**
 *  Get an alpha-list of mirrors for select list.
 *  @return array $mirrors
 */
public static function get_mirrors_select()
{
    $mirrors = DB::get("SELECT mirror_id,mirror_name FROM mirror_mirrors ORDER BY mirror_name ASC",PDO::FETCH_ASSOC);
    foreach ($mirrors as $mirror) {
        $retval[$mirror['mirror_id']]=$mirror['mirror_name'];
    }
    return $retval;
}

/**
 *  Get regions.
 *  @return array
 */
public static function get_regions()
{
    return DB::get("
        SELECT
            mirror_regions.*,
            COUNT(mirror_id) as mirrors
        FROM
            mirror_regions
        LEFT JOIN
            mirror_mirror_region_map
        ON
            mirror_regions.region_id = mirror_mirror_region_map.region_id
        GROUP BY
            mirror_regions.region_id
    ",PDO::FETCH_ASSOC);
}

/**
 *  Insert mirror.
 *  @param string $name
 *  @param int $region_id
 *  @param string $baseurl
 *  @param int $rating
 *  @return bool
 */
public static function insert_mirror($name,$region_id,$baseurl,$rating)
{
    return (DB::query("INSERT INTO mirror_mirrors(mirror_name,mirror_baseurl,mirror_rating) VALUES(?,?,?)", [$name, $baseurl, $rating]) &&
	DB::query("INSERT INTO mirror_mirror_region_map(mirror_id,region_id) VALUES(?,?)", [DB::insert_id(), $region_id]))?true:false;
}

/**
 *  Update mirror.
 *  @param string $name
 *  @param int $region_id
 *  @param string $baseurl
 *  @param int $rating
 *  @return bool
 */
public static function update_mirror($id,$name,$region_id,$baseurl,$rating)
{
    return (DB::query("UPDATE mirror_mirrors SET mirror_name=?,mirror_baseurl=?,mirror_rating=? WHERE mirror_id=?", [$name, $baseurl, $rating, $id])
	&& DB::query("UPDATE mirror_mirror_region_map SET region_id=? WHERE mirror_id=?", [$region_id, $id]))?true:false;
}

/**
 *  Delete mirror.
 *  @return bool
 */
public static function delete_mirror($mirror_id)
{
    return (DB::query("DELETE FROM mirror_mirrors WHERE mirror_id=?", [$mirror_id])
	&& DB::query("DELETE FROM mirror_mirror_region_map WHERE mirror_id=?", [$mirror_id]))?true:false;
}

/**
 *  Get one mirror record.
 *  @param int $mirror_id
 *  @return array mirror information
 */
public static function get_one_mirror($mirror_id)
{
    return DB::get_one("SELECT mirror_mirrors.*,region_id FROM mirror_mirrors JOIN mirror_mirror_region_map USING(mirror_id) WHERE mirror_mirrors.mirror_id=?", PDO::FETCH_ASSOC, [$mirror_id]);
}

/**
 *  Get list of mirrors.
 *  @return array
 */
public static function get_mirrors()
{
    return DB::get("
        SELECT 
            mirror_mirrors.*,
    		IF(mirror_mirrors.mirror_active='0','DISABLED','ok') as mirror_active,
            region_name
        FROM 
            mirror_mirrors,
            mirror_regions,
            mirror_mirror_region_map
        WHERE
            mirror_regions.region_id = mirror_mirror_region_map.region_id AND
            mirror_mirrors.mirror_id = mirror_mirror_region_map.mirror_id
    ",PDO::FETCH_ASSOC);
}

/**
 *  Insert product.
 *  @param string $name
 *  @param int $priority
 *  @return bool
 */ 
public static function insert_product($name,$priority)
{
    return DB::query("INSERT INTO mirror_products(product_name,product_priority) VALUES(?,?)", [$name, $priority]);
}

/**
 *  Update product.
 *  @param int $id
 *  @param string $name
 *  @param int $priority
 *  @return bool
 */ 
public static function update_product($id,$name,$priority)
{
    return DB::query("UPDATE mirror_products SET product_name=?,product_priority=? WHERE product_id=?", [$name, $priority, $id]);
}

/**
 *  Get one product.
 *  @param int $id
 *  @return array
 */
public static function get_one_product($id)
{
    return DB::get_one("SELECT * FROM mirror_products WHERE product_id = ?", PDO::FETCH_ASSOC ,[$id]);
}

/**
 *  Delete a product.
 *  @param int $id
 *  @return bool
 */
public static function delete_product($id)
{
    return DB::query("DELETE FROM mirror_products WHERE product_id=?", [$id]);
}

/**
 *  Get products.
 *  @return array
 */
public static function get_products()
{
    return DB::get("SELECT * FROM mirror_products",PDO::FETCH_ASSOC);
}

/**
 *  Insert os.
 *  @param string $name
 *  @param int $priority
 *  @return bool
 */
public static function insert_os($name,$priority)
{
    return DB::query("INSERT INTO mirror_os(os_name,os_priority) VALUES(?,?)", [$name, $priority]);
}

/**
 *  Update os.
 *  @param int $id
 *  @param string $name
 *  @param int $priority
 *  @return bool
 */
public static function update_os($id,$name,$priority)
{
    return DB::query("UPDATE mirror_os SET os_name=?,os_priority=? WHERE os_id=?", [$name, $priority, $id]);
}

/**
 *  Get one os.
 *  @param int $id
 *  @return array
 */
public static function get_one_os($id)
{
    return DB::get_one("SELECT * FROM mirror_os WHERE os_id = ?", PDO::FETCH_ASSOC, [$id]);
}

/**
 *  Delete a os.
 *  @param int $id
 *  @return bool
 */
public static function delete_os($id)
{
    return DB::query("DELETE FROM mirror_os WHERE os_id=?", [$id]);
}

/**
 *  Get operating systems.
 *  @return array
 */
public static function get_oss()
{
    return DB::get("SELECT * FROM mirror_os",PDO::FETCH_ASSOC);
}

/**
 *  Get an alpha-list of operating systems for select list.
 *  @return array $oss
 */
public static function get_oss_select()
{
    $oss = DB::get("SELECT os_id,os_name FROM mirror_os ORDER BY os_name ASC",PDO::FETCH_ASSOC);
    foreach ($oss as $os) {
        $retval[$os['os_id']]=$os['os_name'];
    }
    return $retval;
}

/**
 *  Get an priority-list of operating systems for select list.
 *  @return array $oss
 */
public static function get_oss_select_priority()
{
    $oss = DB::get("SELECT os_id,os_name FROM mirror_os ORDER BY os_priority ASC",PDO::FETCH_ASSOC);
    foreach ($oss as $os) {
        $retval[$os['os_id']]=$os['os_name'];
    }
    return $retval;
}

/**
 *  Get an alpha-list of products for select list.
 *  @return array $products
 */
public static function get_products_select()
{
    $products = DB::get("SELECT product_id,product_name FROM mirror_products ORDER BY product_name ASC",PDO::FETCH_ASSOC); 
    foreach ($products as $product) {
        $retval[$product['product_id']]=$product['product_name'];
    }
    return $retval;
}

/**
 *  Get an priority-list of operating systems for select list.
 *  @return array $oss
 */
public static function get_products_select_priority()
{
    $products = DB::get("SELECT product_id,product_name FROM mirror_products ORDER BY product_priority ASC",PDO::FETCH_ASSOC);
    foreach ($products as $product) {
        $retval[$product['product_id']]=$product['product_name'];
    }
    return $retval;
}

/**
 *  Insert a new location.
 *  @param int $product
 *  @param int $os
 *  @param string $path
 *  @return bool
 */
public static function insert_location($product,$os,$path)
{
    return DB::query("INSERT INTO mirror_locations(product_id,os_id,location_path) VALUES(?,?,?)", [$product, $os, $path]);
}

/**
 *  Update a location.
 *  @param int $location
 *  @param int $product
 *  @param int $os
 *  @param string $path
 *  @return bool
 */
public static function update_location($location,$product,$os,$path)
{
    return DB::query("UPDATE mirror_locations SET product_id=?,os_id=?,location_path=? WHERE location_id=?", [$product, $os, $path, $location]);
}

/**
 *  Delete a location.
 *  @param int $id
 *  @return bool
 */
public static function delete_location($id)
{
    return DB::query("DELETE FROM mirror_locations WHERE location_id=?", [$id]);
}

/**
 *  Get locations.
 *  @return array $locations array containing all location information.
 */
public static function get_locations()
{
    return DB::get("
        SELECT 
            location_id,
            product_name,
            os_name,
            location_path 
        FROM 
            mirror_locations,
            mirror_products,
            mirror_os
        WHERE
            mirror_locations.product_id = mirror_products.product_id AND
            mirror_locations.os_id = mirror_os.os_id
    ");
}

/**
 *  Get one location.
 *  @param int $id
 *  @return array
 */
public static function get_one_location($id)
{
    return DB::get_one("SELECT * FROM mirror_locations WHERE location_id = ?", PDO::FETCH_ASSOC, [$id]);
}

/**
 *  Insert a new user.
 *  @param string $username
 *  @param string $password
 *  @param string $rpassword (re-entered password)
 *  @param string $firstname
 *  @param string $lastname
 *  @param string $email
 *  @return bool
 */
public static function insert_user($username,$password,$rpassword,$firstname,$lastname,$email)
{
    if ($password==$rpassword) {
	$passwordHash = password_hash($password, PASSWORD_DEFAULT);
        return DB::query("INSERT INTO mirror_users(username,password,user_firstname,user_lastname,user_email) VALUES(?,?,?,?,?)",
		[$username, $passwordHash, $firstname, $lastname, $email]);
    } else {
        set_error('User could not be added because passwords did not match.');
    }
}

/**
 *  Update a user.
 *  @param int $user
 *  @param string $username
 *  @param string $password
 *  @param string $rpassword (re-entered password)
 *  @param string $firstname
 *  @param string $lastname
 *  @param string $email
 *  @return bool
 */
public static function update_user($user,$username,$password,$rpassword,$firstname,$lastname,$email)
{
    if($password==$rpassword&&!empty($password)) {
        $passwordHash = password_hash($password, PASSWORD_DEFAULT);
	return DB::query("UPDATE mirror_users SET username=?,password=?,user_firstname=?,user_lastname=?,user_email=? WHERE user_id=?",
           [$username, $passwordHash, $firstname, $lastname, $email, $user]);
    }
    return DB::query("UPDATE mirror_users SET username=?,user_firstname=?,user_lastname=?,user_email=? WHERE user_id=?",
        [$username, $firstname, $lastname, $email, $user]);
}

/**
 *  Delete a user.
 *  @param int $id
 *  @return bool
 */
public static function delete_user($id)
{
    return DB::query("DELETE FROM mirror_users WHERE user_id=?", [$id]);
}

/**
 *  Get users.
 *  @return array $users array containing all user information.
 */
public static function get_users()
{
    return DB::get("SELECT * FROM mirror_users");
}

/**
 *  Get one user.
 *  @param int $id
 *  @return array
 */
public static function get_one_user($id)
{
    return DB::get_one("SELECT * FROM mirror_users WHERE user_id = ?", PDO::FETCH_ASSOC, [$id]);
}

/**
 *  Enable or disable a mirror.
 *  @param int $mirror
 *  @return bool
 */
public static function toggle($mirror)
{
    return (DB::query("UPDATE mirror_mirrors SET mirror_active = IF(mirror_active = '1', '0', '1') WHERE mirror_id = ?", [$mirror]))?true:false;
}

/**
 *  Get mirror statistics.
 *  @return array $stats
 */
public static function get_mirror_stats()
{
    return DB::get("
        SELECT
            *,
            COUNT(mirror_log.mirror_id) as count
        FROM
            mirror_mirrors,
            mirror_log,
            mirror_regions,
            mirror_mirror_region_map
        WHERE
            mirror_log.mirror_id = mirror_mirrors.mirror_id AND
            mirror_mirrors.mirror_id = mirror_mirror_region_map.mirror_id AND
            mirror_regions.region_id = mirror_mirror_region_map.region_id
        GROUP BY
            mirror_log.mirror_id 
    ");
}

/**
 *  Get product statistics.
 *  @return array $stats
 */
public static function get_product_stats()
{
    return DB::get("
        SELECT
            *,
            COUNT(mirror_locations.product_id) as count
        FROM
            mirror_log,
            mirror_locations,
            mirror_products
        WHERE
            mirror_log.location_id = mirror_locations.location_id AND
            mirror_locations.product_id = mirror_products.product_id
        GROUP BY
            mirror_locations.product_id
    ");
}