<?php

function ends_with($str, $key) {
    return strrpos($str, $key) == strlen($str) - strlen($key);
}

function ctype_alnum_underscore($str) {
    return ctype_alnum(str_replace('_', '', $str));
}

function &array_ensure_item_has_array(&$array, $key) {
    if (!array_key_exists($key, $array))
        $array[$key] = array();
    return $array[$key];
}

function array_get($array, $key, $default = NULL) {
    if (!array_key_exists($key, $array))
        return $default;
    return $array[$key];
}

function array_set_default(&$array, $key, $default) {
    if (!array_key_exists($key, $array))
        $array[$key] = $default;
}

$_config = NULL;

define('CONFIG_DIR', realpath(dirname(__FILE__) . '/../../'));

function config($key, $default = NULL) {
    global $_config;
    if (!$_config) {
        $file_path = getenv('ORG_WEBKIT_PERF_CONFIG_PATH');
        if (!$file_path)
            $file_path = CONFIG_DIR . '/config.json';
        $_config = json_decode(file_get_contents($file_path), true);
    }
    return array_get($_config, $key, $default);
}

function config_path($key, $path) {
    return CONFIG_DIR . '/' . config($key) . '/' . $path;
}

function same_till_last_occurrence_of_string($main_string, $comparing_string, $compare_to_last_position_string) {
    if (!$compare_to_last_position_string)
        return !strcmp($main_string, $comparing_string);

    $position_in_main_string = strrpos($main_string, $compare_to_last_position_string);
    $position_in_comparing_string = strrpos($comparing_string, $compare_to_last_position_string);
    if ($position_in_main_string !== $position_in_comparing_string)
        return FALSE;
    if ($position_in_main_string === FALSE)
        return !strcmp($main_string, $comparing_string);
    return !substr_compare($main_string, $comparing_string, 0, $position_in_main_string);
}

function generate_json_data_with_elapsed_time_if_needed($filename, $object, $elapsed_time) {
    if (!assert(ctype_alnum(str_replace(array('-', '_', '.'), '', $filename))))
        return NULL;

    $target_file_path = config_path('dataDirectory', $filename);
    $object['elapsedTime'] = $elapsed_time;
    $content = json_encode($object);

    if (file_exists($target_file_path) && same_till_last_occurrence_of_string(file_get_contents($target_file_path), $content, 'elapsedTime'))
        return $content;

    $temp_file_path = tempnam(config_path('dataDirectory', ''), $filename . '-temp-');
    file_put_contents($temp_file_path, $content, LOCK_EX);
    return rename($temp_file_path, $target_file_path) ?  $content : NULL;
}

if (config('debug')) {
    error_reporting(E_ALL | E_STRICT);
    ini_set('display_errors', 'On');
} else
    error_reporting(E_ERROR);

date_default_timezone_set('UTC');

class Database
{
    private $connection = false;

    function __destruct() {
        if ($this->connection)
            pg_close($this->connection);
        $this->connection = false;
    }

    static function is_true($value) {
        return $value == 't';
    }

    static function to_database_boolean($value) {
        return $value ? 't' : 'f';
    }

    static function to_js_time($time_str) {
        $timestamp_in_ms = strtotime($time_str) * 1000;
        $dot_index = strrpos($time_str, '.');
        if ($dot_index !== FALSE) {
            // Keep 5 decimal digits as postgres timestamp may only have 5 decimal digits.
            // Multiply by 1000 ahead to avoid losing precision. 1538041792.670479 will become 1538041792.6705 on php.
            $timestamp_in_ms += round(floatval(substr($time_str, $dot_index)), 5) * 1000;
        }
        return intval($timestamp_in_ms);
    }

    static function escape_for_like($string) {
        return str_replace(array('\\', '_', '%'), array('\\\\', '\\_', '\\%'), $string);
    }

    function connect() {
        $databaseConfig = config('database');

        $host = $databaseConfig['host'];
        $port = $databaseConfig['port'];
        $dbname = $databaseConfig['name'];
        $user = $databaseConfig['username'];
        $password = $databaseConfig['password'];
        $connectionString = "host=$host port=$port dbname=$dbname user=$user password=$password";

        $sslConfigString = '';

        if (array_get($databaseConfig, 'ssl')) {
            $sslConfig = $databaseConfig['ssl'];
            $sslConfigString .= ' sslmode=' . array_get($sslConfig, 'mode', 'require');
            foreach (array('rootcert', 'cert', 'key') as $key) {
                if (!array_get($sslConfig, $key))
                    continue;

                $path = $sslConfig[$key];
                if (strlen($path) && $path[0] !== '/')
                    $path = CONFIG_DIR . '/' . $path;

                $sslConfigString .= " ssl$key=$path";
            }
        }

        $connectionString .= $sslConfigString;
        $this->connection = @pg_connect($connectionString);
        return $this->connection ? true : false;
    }

    private function prefixed_column_names($columns, $prefix = NULL) {
        if (!$prefix || !$columns)
            return join(', ', $columns);
        return $prefix . '_' . join(', ' . $prefix . '_', $columns);
    }

    private function prefixed_name($column, $prefix = NULL) {
        return $prefix ? $prefix . '_' . $column : $column;
    }

    private function prepare_params($params, &$placeholders, &$values, &$null_columns = NULL) {
        $column_names = array();

        $i = count($values) + 1;
        foreach (array_keys($params) as $name) {
            $current_value = $params[$name];
            if ($current_value === NULL && $null_columns !== NULL) {
                array_push($null_columns, $name);
                continue;
            }
            assert(ctype_alnum_underscore($name));
            array_push($column_names, $name);
            array_push($placeholders, '$' . $i);
            if (is_bool($current_value))
                $current_value = $this->to_database_boolean($current_value);
            array_push($values, $current_value);
            $i++;
        }

        return $column_names;
    }

    private function select_conditions_with_null_columns($prefix, $column_names, $placeholders, $null_columns) {
        $column_names = $this->prefixed_column_names($column_names, $prefix);
        $placeholders = join(', ', $placeholders);

        if (!$column_names && !$placeholders)
            $column_names = $placeholders = '1';
        $query = "($column_names) = ($placeholders)";
        foreach ($null_columns as $column_name)
            $query .= ' AND ' . $this->prefixed_name($column_name, $prefix) . ' IS NULL';
        return $query;
    }

    function insert_row($table, $prefix, $params, $returning = 'id') {
        $placeholders = array();
        $values = array();
        $column_names = $this->prepare_params($params, $placeholders, $values);

        assert(!$prefix || ctype_alnum_underscore($prefix));
        $column_names = $this->prefixed_column_names($column_names, $prefix);
        $placeholders = join(', ', $placeholders);

        $value_query = $column_names ? "($column_names) VALUES ($placeholders)" : ' VALUES (default)';
        if ($returning) {
            $returning_column_name = $this->prefixed_name($returning, $prefix);
            $rows = $this->query_and_fetch_all("INSERT INTO $table $value_query RETURNING $returning_column_name", $values);
            return $rows ? $rows[0][$returning_column_name] : NULL;
        }

        return $this->query_and_get_affected_rows("INSERT INTO $table $value_query", $values) == 1;
    }

    function select_or_insert_row($table, $prefix, $select_params, $insert_params = NULL, $returning = 'id') {
        return $this->_select_update_or_insert_row($table, $prefix, $select_params, $insert_params, $returning, FALSE, TRUE);
    }

    function update_or_insert_row($table, $prefix, $select_params, $insert_params = NULL, $returning = 'id') {
        return $this->_select_update_or_insert_row($table, $prefix, $select_params, $insert_params, $returning, TRUE, TRUE);
    }

    function update_row($table, $prefix, $select_params, $update_params, $returning = 'id') {
        return $this->_select_update_or_insert_row($table, $prefix, $select_params, $update_params, $returning, TRUE, FALSE);
    }

    private function _select_update_or_insert_row($table, $prefix, $select_params, $insert_params, $returning, $should_update, $should_insert) {
        $values = array();

        $select_placeholders = array();
        $select_null_columns = array();
        $select_column_names = $this->prepare_params($select_params, $select_placeholders, $values, $select_null_columns);
        $select_values = array_slice($values, 0);

        if ($insert_params === NULL)
            $insert_params = $select_params;
        $insert_placeholder_list = array();
        $insert_column_name_list = $this->prepare_params($insert_params, $insert_placeholder_list, $values);

        assert(!!$returning);
        assert(!$prefix || ctype_alnum_underscore($prefix));
        $returning_column_name = $returning == '*' ? '*' : $this->prefixed_name($returning, $prefix);

        $condition = $this->select_conditions_with_null_columns($prefix, $select_column_names, $select_placeholders, $select_null_columns);
        $query = "SELECT $returning_column_name FROM $table WHERE $condition";

        $insert_column_names = $this->prefixed_column_names($insert_column_name_list, $prefix);
        $insert_placeholders = join(', ', $insert_placeholder_list);

        // http://stackoverflow.com/questions/1109061/insert-on-duplicate-update-in-postgresql
        $rows = NULL;
        if ($should_update) {
            // FIXME: Remove this special case and use ROW expression when no instance uses Postgres < 10.
            if (count($insert_placeholder_list) == 1 && count($insert_column_name_list) == 1)
                $rows = $this->query_and_fetch_all("UPDATE $table SET $insert_column_names = $insert_placeholders
                    WHERE $condition RETURNING $returning_column_name", $values);
            else
                $rows = $this->query_and_fetch_all("UPDATE $table SET ($insert_column_names) = ($insert_placeholders)
                    WHERE $condition RETURNING $returning_column_name", $values);
        }
        if (!$rows && $should_insert) {
            $rows = $this->query_and_fetch_all("INSERT INTO $table ($insert_column_names) SELECT $insert_placeholders
                WHERE NOT EXISTS ($query) RETURNING $returning_column_name", $values);
        }
        if (!$should_update && !$rows)
            $rows = $this->query_and_fetch_all($query, $select_values);

        return $rows ? ($returning == '*' ? $rows[0] : $rows[0][$returning_column_name]) : NULL;
    }

    function select_first_row($table, $prefix, $params, $order_by = NULL) {
        return $this->select_first_or_last_row($table, $prefix, $params, $order_by, FALSE);
    }

    function select_last_row($table, $prefix, $params, $order_by = NULL) {
        return $this->select_first_or_last_row($table, $prefix, $params, $order_by, TRUE);
    }

    private function select_first_or_last_row($table, $prefix, $params, $order_by, $descending_order) {
        $rows = $this->select_rows($table, $prefix, $params, $order_by, $descending_order, 0, 1);
        return $rows ? $rows[0] : NULL;
    }

    function select_rows($table, $prefix, $params,
        $order_by = NULL, $descending_order = FALSE, $offset = NULL, $limit = NULL) {

        $placeholders = array();
        $values = array();
        $null_columns = array();
        $column_names = $this->prepare_params($params, $placeholders, $values, $null_columns);
        $condition = $this->select_conditions_with_null_columns($prefix, $column_names, $placeholders, $null_columns);

        $query = "SELECT * FROM $table WHERE $condition";

        if ($order_by) {
            if (!is_array($order_by))
                $order_by = array($order_by);

            $order_columns = array();
            foreach ($order_by as $order_key) {
                assert(ctype_alnum_underscore($order_key));
                $order_column = $this->prefixed_name($order_key, $prefix) . ' ' . ($descending_order? 'DESC' : 'ASC');
                array_push($order_columns, $order_column);
            }
            $query .= ' ORDER BY ' . join(', ', $order_columns);
        }
        if ($offset !== NULL)
            $query .= ' OFFSET ' . intval($offset);
        if ($limit !== NULL)
            $query .= ' LIMIT ' . intval($limit);

        return $this->query_and_fetch_all($query, $values);
    }

    function query_and_get_affected_rows($query, $params = array()) {
        if (!$this->connection)
            return FALSE;
        $result = pg_query_params($this->connection, $query, $params);
        if (!$result)
            return FALSE;
        return pg_affected_rows($result);
    }

    function query_and_fetch_all($query, $params = array()) {
        if (!$this->connection)
            return NULL;
        $result = pg_query_params($this->connection, $query, $params);
        if (!$result)
            return NULL;
        if (pg_num_rows($result) == 0)
            return array();
        return pg_fetch_all($result);
    }

    function query($query, $params = array()) {
        if (!$this->connection)
            return FALSE;
        return pg_query_params($this->connection, $query, $params);
    }

    function fetch_next_row($result) {
        return pg_fetch_assoc($result);
    }

    function fetch_table($table_name, $column_to_be_ordered_by = null) {
        if (!$this->connection || !ctype_alnum_underscore($table_name) || ($column_to_be_ordered_by && !ctype_alnum_underscore($column_to_be_ordered_by)))
            return false;
        $clauses = '';
        if ($column_to_be_ordered_by)
            $clauses .= 'ORDER BY ' . $column_to_be_ordered_by;
        return $this->query_and_fetch_all("SELECT * FROM $table_name $clauses");
    }

    function begin_transaction() {
        return $this->connection and pg_query($this->connection, "BEGIN");
    }

    function commit_transaction() {
        return $this->connection and pg_query($this->connection, 'COMMIT');
    }

    function rollback_transaction() {
        return $this->connection and pg_query($this->connection, 'ROLLBACK');
    }

}

?>