#!/usr/bin/php
<?php

/* mini-configs */
define("dbhost", "127.0.0.1");
define("dbuser", "");
define("dbpass", "");
define("dbname", "msvn");

/* определение цветов текста и фона для терминала )*/
define("CL_RESET", 0);
define("CL_BLACK", 30);
define("CL_RED", 31);
define("CL_GREEN", 32);
define("CL_YELLOW", 33);
define("CL_BLUE", 34);
define("CL_MAGENTA", 35);
define("CL_CIAN", 36);
define("CL_WHITE", 37);
/*BG_COLORS*/
define("BG_HIGHT_LIGHT", 1); // высокая контрастность
define("BG_LOW_LIGHT", 2);   // низкая контрастность
define("BG_RESET", 0);       // сброс...
define("BG_BLACK", 40);
define("BG_RED", 41);
define("BG_GREEN", 42);
define("BG_YELLOW", 43);
define("BG_BLUE", 44);
define("BG_MAGENTA", 45);
define("BG_CIAN", 46);
define("BG_WHITE", 47);

/*********************************************************/

function error($err_text) {
    cwrite("[Error]: ", mc(CL_RED));
    cwriteln($err_text, mc(CL_YELLOW));
}

function info($info_text) {
    cwrite("[Info]: ", mc(CL_CIAN));
    cwriteln($info_text, mc(CL_YELLOW));
}

function test_db() {
    if (mysql_connect(dbhost, dbuser, dbpass)) {
        if (mysql_select_db(dbname)) {
            info("База существует! Всё ок! Можно работать ;)");
        } else {
            error("Базы не существует, необходимо создать её.");
        }
    } else error("Ошибка подключения к серверу mysql.");
}


function make_color($text_color = CL_RESET, $bg_color = BG_HIGHT_LIGHT) {
    return "\033[".$bg_color.";".$text_color."m";
}

function reset_color() {
    return "\033[0m"; 
}

function mc($text_color = CL_RESET, $bg_color = BG_HIGHT_LIGHT) {
    return make_color($text_color, $bg_color);
}

function write($text = "") {
    fputs(STDOUT, $text);
}

function writeln($text = "") {
    write($text . "\n");
}

function cwrite($text, $colors) {
    write($colors . $text . reset_color());
}

function cwriteln($text, $colors) {
    $text .= "\n";
    cwrite($text, $colors);
}

function readln() {
    return trim(fgets(STDIN));
}

function creadln($color = "") {
    if ($color == "")
        $color = reset_color();
    write($color);
    $res = readln();
    write(reset_color());
    return $res;
}

function execr($command) {
    ob_start();
    system($command);
    $result = ob_get_contents();
    ob_get_clean();
    return trim($result);
}

function get_user_name() {
    return execr("whoami");
}

function connect_to_db() {
    if (mysql_connect(dbhost, dbuser, dbpass)) {
        if (!mysql_select_db(dbname)) {
            error("Невозможно выбрать базу данных. Она наверное не создана...");
            return false;
        }
    } else {
        error("Ошибка подключения к MySQL серверу.");
        return false;
    }
    return true;
}

function add_note($note, $from_user, $is_bug = false) {
    if ($note == "") {
        error("Заметка не может быть пустой...");
        return false;
    }
    if (!connect_to_db())
        return false;
    $sql = "INSERT INTO `notes` (`text`, `creator`, `cr_time`, `is_bug`) VALUES ('$note', '$from_user', UNIX_TIMESTAMP(), ".(int)$is_bug.");";
    if (mysql_query($sql)) {
        info("Запись успешно вставлена. Её индекс: " . mysql_insert_id());
        return true;
    } else {
        errro("Ошибка при добавлении записи. Error: " . mysql_error());
        return false;
    }
}

function get_time_date($from_unixstamp) {
    return date("d.m.Y/H:i:s", $from_unixstamp);
}

function list_notes() {
    if (!connect_to_db())
        return false;
    $sql = "SELECT * FROM `notes` ORDER BY `cr_time` DESC";
    if ($r = mysql_query($sql)) {
        if (mysql_num_rows($r)) {
            while ($note = mysql_fetch_array($r)) {
                cwrite($note['id'] . ". ", mc(CL_CIAN));
                cwrite($note['creator'] . ": ", mc(CL_BLUE));
                cwriteln($note['text'] . " (".get_time_date($note['cr_time']).")", mc(CL_GREEN));
            }
        } else info("Пока нет ни одной заметки.");
    } else {
        error("Ошибка при получении списка заметок. Error: " . mysql_error());
        return false;
    }
}

function user_exists($user_name = "") {
    connect_to_db();
    $r = mysql_query("SELECT * FROM `users` WHERE `uname` = '$user_name'");
    if ($r) {
        return (mysql_num_rows($r));
    } else return false;
}

function add_user($user_name = "") {
    connect_to_db();
    if ($user_name == "")
        $user_name = get_user_name();
    return (mysql_query("INSERT INTO `users`(`uname`, `last_login`) VALUES('$user_name', UNIX_TIMESTAMP())"));
}

function update_user_time($user_name = "") {
    connect_to_db();
    if ($user_name == "")
        $user_name = get_user_name();
    if (!user_exists($user_name)) 
        add_user($user_name);
    return (mysql_query("UPDATE `users` SET `last_login` = UNIX_TIMESTAMP() WHERE `uname` = '$user_name'"));
}

function get_user_last_time($user_name = "") {
    connect_to_db();
    if ($user_name == "")
        $user_name = get_user_name();
    $r = mysql_query("SELECT * FROM `users` WHERE `uname` = '$user_name'");
    if ($r) {
        if (!mysql_num_rows($r)) return false;
        $a = mysql_fetch_array($r);
        return $a['last_login']; 
    } else return false;
}

function check_new_notes() {
    connect_to_db();
    $utime = (int)get_user_last_time();
    $uname = get_user_name();
    $sql = "SELECT * FROM `notes` WHERE `cr_time` > $utime and `creator` != '$uname'";
    $r = mysql_query($sql);
    if ($r) {
        if (!mysql_num_rows($r)) {
            info("Новых заметок пока нет. Ждёмс!");
            return true;   
        }
        info("Есть новые заметки!!! Вот они: ");
        while ($note = mysql_fetch_array($r)) {
            cwrite($note['id'] . ". ", mc(CL_CIAN));
            cwrite($note['creator'] . ": ", mc(CL_BLUE));
            cwriteln($note['text'] . " (".get_time_date($note['cr_time']).")", mc(CL_GREEN));
        }
    } else return false;
}

function make_readed($note_id = "*") {
    if ($note_id == "*" || $note_id == "") {
        info("Все новые заметки помечены, как прочитанные. Ждём новых прикольных штук )");
        update_user_time();
        return true; 
    }
}

function get_note_creator($note_id) {
    $note_id = (int)$note_id;
    connect_to_db();
    $n = mysql_fetch_array(mysql_query("SELECT * FROM `notes` WHERE `id` = $note_id"));
    return $n['creator'];
}

function note_exists($note_id) {
    connect_to_db();
    $note_id = (int)$note_id;
    $r = mysql_query("SELECT * FROM `notes` WHERE `id` = $note_id");
    if ($r) {
        return mysql_num_rows($r);
    } else return false;
}

function rm_note($note_id) {
    $note_id = (int)$note_id;
    if ($note_id == 0) {
        error("Не указан индекс заметки, которую нужно удалить.");
        return false;
    }
    
    if (!note_exists($note_id)) {
        error("Заметки с индексом $note_id не существует, поэтому она не может быть удалена.");
        return false;
    }
    
    if (get_note_creator($note_id) == get_user_name()) {
        if (mysql_query("DELETE FROM `notes` WHERE `id` = $note_id")) {
            info("Заметка с индексом $note_id успешно удалена!");
            return true;
        } else {
            error("Ошибка при удалении заметки: " . mysql_error());
            return false;
        }
        
    } else {
        error("Вы не являетесь создателем этой заметки, поэтому не можете её удалить...");
        return false;
    }
}

function view_user_info($user_name = "") {
	if ($user_name == "") 
		$user_name = get_user_name();
	info("Пользователь $user_name в последний разпроверял заметки вот когда: " . get_time_date(get_user_last_login($user_name)));
}

function parse_command($command_line) {
    $p = explode(" ", $command_line);
    $p_count = count($p) - 1; //количество параметров
    $p_all = ""; //все параметры
    for ($i=1; $i<=$p_count; $i++) {
        $p_all .= $p[$i] . " ";
    }
    $p_all = trim($p_all);
    $cmd = $p[0]; //первой идёт команда. ок.
    //
    switch (strtolower($cmd)) {
        case "echo": writeln($p_all); break;
        case "exit": case ".": {
            cwriteln("Bye-bye! ;)", mc(CL_RED));
            writeln();
            exit; break;
        }
        case "get_user_name": writeln("You user-name is: " . get_user_name()); break;
    	case "get_user_time": @view_user_info($p[1]); break;
        case "whoami": writeln(get_user_name()); break;
        case "help": case "?": print_help(); break;
        case "test_db": test_db(); break;
        case "add": {
            @add_note($p_all, get_user_name(), false); 
            break;   
        }
        case "list": {
            list_notes();
            break;
        }
        case "check": case "check_new": case "check_new_notes": {
            check_new_notes();
            break;
        }
        case "mc": case "done": case "uncheck": case "readed": { //mc = make readed
            @make_readed($p[1]);
            break;
        }
        case "del": case "remove": case "rm": {
            @rm_note($p[1]);
            break;
        }
        
        default: error("Неизвестная команда..."); break;
    }
}

function print_help() {
    cwriteln("Mini-manual for mini-svn :)", mc(CL_WHITE));
    //
    cwrite("    get_user_name", mc(CL_YELLOW));
    cwriteln(" -- получить имя текущего пользователя.", mc(CL_GREEN));
    //
    cwrite("    test_db", mc(CL_YELLOW));
    cwriteln(" -- проверить коннект с MySQL сервером и базой.", mc(CL_GREEN));
    //
    cwrite("    add <текст заметки>", mc(CL_YELLOW));
    cwriteln(" -- добавить новую заметку. Текст заметки можно писать без кавычек. Но спец. символы оболочки нужно экранировать, если передаётся в качестве параметра.", mc(CL_GREEN));
    //
    cwrite("    list", mc(CL_YELLOW));
    cwriteln(" -- просмотр ВСЕХ заметок.", mc(CL_GREEN));
    //
    cwrite("    check", mc(CL_YELLOW));
    cwriteln(" -- проверить наличие новых заметок, которые ЭТОТ пользователь ещё не прочёл.", mc(CL_GREEN));
    //
    cwrite("    del, rm <note_id>", mc(CL_YELLOW));
    cwriteln(" -- удалить заметку по её индексу. Удалится, если пользователь является её создателем.", mc(CL_GREEN));
    //
    cwrite("    done, mc, uncheck, readed", mc(CL_YELLOW));
    cwriteln(" -- любая из этих команд помечает заметки для текущего пользователя, как прочитанные.", mc(CL_GREEN));
}

function enter_in_interactive_mode() {
    while (true) {
        cwrite("Input command: ", mc(CL_YELLOW));
        $input_str = creadln(mc(CL_GREEN));
        parse_command($input_str);
    }
}

function parse_args() {
    global $argc, $argv;
    if ($argc == 1) 
        enter_in_interactive_mode();
    if ($argc > 1) {
        $command_line = "";
        for ($i = 2; $i<=$argc; $i++) {
            $command_line .= $argv[$i-1] . " ";
        }
        parse_command(trim($command_line));
    }
}

/* begin :) */
parse_args();

?>