<?php
/**
 * Update manager client library.
 *
 * @category   Functions Update Manager
 * @package    Pandora FMS
 * @subpackage Community
 * @version    1.0.0
 * @license    See below
 *
 *    ______                 ___                    _______ _______ ________
 *   |   __ \.-----.--.--.--|  |.-----.----.-----. |    ___|   |   |     __|
 *  |    __/|  _  |     |  _  ||  _  |   _|  _  | |    ___|       |__     |
 * |___|   |___._|__|__|_____||_____|__| |___._| |___|   |__|_|__|_______|
 *
 * ============================================================================
 * Copyright (c) 2005-2021 Artica Soluciones Tecnologicas
 * Please see http://pandorafms.org for full contribution list
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License
 * as published by the Free Software Foundation for version 2.
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 * ============================================================================
 */

/*
 *
 * Registration functions - Start.
 *
 */


/**
 * Verifies registration state.
 *
 * @return boolean Status.
 */
function update_manager_verify_registration()
{
    global $config;

    if (isset($config['pandora_uid']) === true
        && $config['pandora_uid'] != ''
        && $config['pandora_uid'] != 'OFFLINE'
    ) {
        // Verify with UpdateManager.
        return true;
    }

    return false;
}


/**
 * Check if a trial license is in use.
 *
 * @return boolean true if a trial license is in use, false otherwise.
 */
function update_manager_verify_trial()
{
    global $config;

    if (isset($config['license_licensed_to'])
        && strstr($config['license_licensed_to'], 'info@pandorafms.com') !== false
    ) {
        return true;
    }

    return false;
}


/**
 * Check if the trial license is not expired.
 *
 * @return boolean true if the trial license is expired, false otherwise.
 */
function update_manager_verify_license_expired()
{
    global $config;

    $current_date = date('Ymd');
    if (isset($config['license_expiry_date']) && $current_date >= $config['license_expiry_date']) {
        return true;
    }

    return false;
}


/**
 * Parses responses from configuration wizard.
 *
 * @return void
 */
function config_wiz_process()
{
    global $config;
    $email = get_parameter('email', false);
    $timezone = get_parameter('timezone', false);
    $language = get_parameter('language', false);

    if ($email !== false) {
        config_update_value('language', $language);
    }

    if ($timezone !== false) {
        config_update_value('timezone', $timezone);
    }

    if ($email !== false) {
        db_process_sql_update(
            'tusuario',
            ['email' => $email],
            ['id_user' => $config['id_user']]
        );
    }

    // Update the alert action Mail to XXX/Administrator
    // if it is set to default.
    $mail_check = 'yourmail@domain.es';
    $mail_alert = alerts_get_alert_action_field1(1);
    if ($mail_check === $mail_alert && $email !== false) {
        alerts_update_alert_action(
            1,
            [
                'field1'          => $email,
                'field1_recovery' => $email,
            ]
        );
    }

    config_update_value('initial_wizard', 1);
}


/**
 * Generates base code to print main configuration modal.
 *
 * Asks for timezone, mail.
 *
 * @param boolean $return   Print output or not.
 * @param boolean $launch   Process JS modal.
 * @param string  $callback Call to JS function at end.
 *
 * @return string HTML.
 */
function config_wiz_modal(
    $return=false,
    $launch=true,
    $callback=false
) {
    global $config;

    $email = db_get_value('email', 'tusuario', 'id_user', $config['id_user']);
    // Avoid to show default email.
    if ($email == 'admin@example.com') {
        $email = '';
    }

    $output = '';

    // Prints first step pandora registration.
    $output .= '<div id="configuration_wizard" title="'.__('%s configuration wizard', get_product_name()).'" class="invisible">';

    $output .= '<div id="help_dialog">';
    $output .= __('Please fill the following information in order to configure your %s instance successfully', get_product_name()).'.';
    $output .= '</div>';

    $output .= '<div  >';
    $table = new StdClass();
    $table->class = 'databox filters';
    $table->width = '100%';
    $table->data = [];
    $table->size = [];
    $table->size[0] = '40%';
    $table->style[0] = 'font-weight:bold';
    $table->size[1] = '60%';
    $table->border = '5px solid';

    $table->data[0][0] = __('Language code');
    $table->data[0][1] = html_print_select_from_sql(
        'SELECT id_language, name FROM tlanguage',
        'language',
        $config['language'],
        '',
        '',
        '',
        true
    );

    $zone_name = [
        'Africa'     => __('Africa'),
        'America'    => __('America'),
        'Antarctica' => __('Antarctica'),
        'Arctic'     => __('Arctic'),
        'Asia'       => __('Asia'),
        'Atlantic'   => __('Atlantic'),
        'Australia'  => __('Australia'),
        'Europe'     => __('Europe'),
        'Indian'     => __('Indian'),
        'Pacific'    => __('Pacific'),
        'UTC'        => __('UTC'),
    ];

    if ($zone_selected == '') {
        if ($config['timezone'] != '') {
            $zone_array = explode('/', $config['timezone']);
            $zone_selected = $zone_array[0];
        } else {
            $zone_selected = 'Europe';
        }
    }

    $timezones = timezone_identifiers_list();
    foreach ($timezones as $timezone) {
        if (strpos($timezone, $zone_selected) !== false) {
            $timezone_country = preg_replace('/^.*\//', '', $timezone);
            $timezone_n[$timezone] = $timezone_country;
        }
    }

    $table->data[2][0] = __('Timezone setup').' '.ui_print_help_tip(
        __('Must have the same time zone as the system or database to avoid mismatches of time.'),
        true
    );
    $table->data[2][1] = html_print_select($zone_name, 'zone', $zone_selected, 'show_timezone()', '', '', true);
    $table->data[2][1] .= '&nbsp;&nbsp;'.html_print_select($timezone_n, 'timezone', $config['timezone'], '', '', '', true);

    $table->data[4][0] = __('E-mail for receiving alerts');
    $table->data[4][1] = html_print_input_text('email', $email, '', 50, 255, true);

    $output .= html_print_table($table, true);
    $output .= '</div>';

    $output .= '<div class="left">';
    $output .= html_print_submit_button(
        __('Cancel'),
        'cancel',
        false,
        'class="ui-widget ui-state-default ui-corner-all ui-button-text-only sub cancel submit-cancel w100px"',
        true
    );
    $output .= '</div>';
    $output .= '<div class="right">';
    $output .= html_print_submit_button(
        __('Continue'),
        'register-next',
        false,
        'class="ui-widget ui-state-default ui-corner-all ui-button-text-only sub ok submit-next w100px"',
        true
    );
    $output .= '</div>';
    $output .= '<div id="all-required" class="all_required">';
    $output .= __('All fields required');
    $output .= '</div>';
    $output .= '</div>';

    $output .= '</div>';

    // Verification modal.
    $output .= '<div id="wiz_ensure_cancel" title="Confirmation Required" class="invisible">';
    $output .= '<div class="font_12_20">';
    $output .= __('Are you sure you don\'t want to configure a base email?');
    $output .= '<p>';
    $output .= __('You could change this options later in "alert actions" and setting your account.');
    $output .= '</p>';
    $output .= '</div>';
    $output .= '</div>';

    ob_start();
    ?>

<script type="text/javascript">
function show_timezone () {
    zone = $("#zone").val();

    $.ajax({
        type: "POST",
        url: "ajax.php",
        data: "page=godmode/setup/setup&select_timezone=1&zone=" + zone,
        dataType: "json",
        success: function(data) {
            $("#timezone").empty();
            jQuery.each (data, function (id, value) {
                timezone = value;
                var timezone_country = timezone.replace (/^.*\//g, "");
                $("select[name='timezone']")
                .append(
                    $("<option>")
                    .val(timezone)
                    .html(timezone_country)
                );
            });
        }
    });
}

$("#language").click(function () {
    var change_language = $("#language").val();

    if (change_language === default_language_displayed) return;
    jQuery.post (
        "ajax.php",
        {
            "page": "general/register",
            "change_language": change_language
        },
        function (data) {}
    ).done(function () {
        location.reload();
    });
});

function show_configuration_wizard() {
    $("#configuration_wizard").dialog({
        resizable: true,
        draggable: true,
        modal: true,
        width: 630,
        overlay: {
                opacity: 0.5,
                background: "black"
            },
        closeOnEscape: false,
        open: function(event, ui) { $(".ui-dialog-titlebar-close").hide(); }
    });

    default_language_displayed = $("#language").val();

    $(".ui-widget-overlay").css("background", "#000");
    $(".ui-widget-overlay").css("opacity", 0.6);
    $(".ui-draggable").css("cursor", "inherit");


    // CLICK EVENTS: Cancel and Registration
    $("#submit-cancel").click (function (e) {
        e.preventDefault();
        $("#wiz_ensure_cancel").dialog({
            buttons: [
                {
                    "text": "No",
                    "class": 'submit-cancel',
                    "click" : function() {
                        $(this).dialog("close");
                    }
                },
                {
                    "text": "Yes",
                    "class": 'submit-next',
                    "click" : function() {
                        jQuery.post (
                            "ajax.php",
                            {
                                "page": "general/register",
                                "cancel_wizard": 1
                            },
                            function (data) {}
                        );
                        $(this).dialog("close");
                        $("#configuration_wizard" ).dialog('close');
                    }
                }
            ]
        });

        $("#wiz_ensure_cancel").dialog('open');
    });

    $("#submit-register-next").click (function () {
        // All fields are required.
        if ($("#text-email").val() == '') {
            $("#all-required").show();
        } else {
            var timezone = $("#timezone").val();
            var language = $("#language").val();
            var email_identification = $("#text-email").val();

            jQuery.post (
                "ajax.php",
                {
                    "page": "general/register",
                    "save_required_wizard": 1,
                    "email": email_identification,
                    "language": language,
                    "timezone": timezone
                },
                function (data) {
                    <?php
                    if (isset($callback) && $callback != '') {
                        echo $callback;
                    }
                    ?>
                }
            );

            $("#configuration_wizard").dialog('close');
        }
    });
}

    <?php
    if ($launch === true) {
        ?>
        $(document).ready (function () {
            show_configuration_wizard();
        });
        <?php
    }
    ?>

</script>

    <?php
    // Add js.
    $output .= ob_get_clean();

    if ($return === false) {
        echo $output;
    }

    return $output;

}


/**
 * Parse registration wiz.
 *
 * @return array Status feedback.
 */
function registration_wiz_process()
{
    global $config;

    $register_pandora = get_parameter('register_pandora', 0);
    $next_check = (time() + 1 * SECONDS_1DAY);
    $ui_feedback = [
        'status'  => true,
        'message' => '',
    ];

    // Pandora register update.
    $um_message = update_manager_register_instance();
    $ui_feedback['message'] .= $um_message['message'].'<br><br>';
    $ui_feedback['status'] = $um_message['success'] && $ui_feedback['status'];

    if ($ui_feedback['status']) {
        // Store next identification reminder.
        config_update_value(
            'identification_reminder_timestamp',
            $next_check
        );
    }

    return $ui_feedback;
}


/**
 * Shows a modal to register current console in UpdateManager.
 *
 * @param boolean $return   Return or show html.
 * @param boolean $launch   Execute wizard.
 * @param string  $callback Call function when done.
 *
 * @return string HTML code.
 */
function registration_wiz_modal(
    $return=false,
    $launch=true,
    $callback=false,
    $return_message=false
) {
    global $config;
    $output = '';

    // Do not show the wizard for trial licenses.
    if (update_manager_verify_trial()) {
        ui_print_info_message('Your license is trial. Please contact Artica at info@artica.es for a valid license', '', $return_message);
        return '';
    }

    if (update_manager_verify_license_expired()) {
        ui_print_error_message('The license has expired. Please contact Artica at info@artica.es', '', $return_message);
        return '';
    }

    $product_name = get_product_name();

    $output .= '<div id="registration_wizard" title="';
    $output .= __('Register to Update Manager');
    $output .= '" class="invisible">';
    $output .= '<div class="register_update_manager">';
    $output .= html_print_image('images/pandora_circle_big.png', true);
    $output .= '</div>';

    $output .= '<div class="newsletter_div">';
    $output .= __(
        'Keep this %s console up to date with latest updates.',
        $product_name
    );
    $output .= '</div>';

    $output .= '<div class="license_text both">';
    $output .= '<p>';
    $output .= __('When you subscribe to the %s Update Manager service, you accept that we register your %s instance as an identifier on a database owned by %s. This data will solely be used to provide you with information about %s and will not be conceded to third parties. You can unregister from said database at any time from the Update Manager options.', $product_name, $product_name, $product_name, $product_name);
    $output .= '</p>';
    $output .= '</div>';

    $output .= '<div class="submit_buttons_container">';
    $output .= '<div class="left">';
    $output .= html_print_submit_button(
        __('Cancel'),
        'cancel_registration',
        false,
        'class="ui-widget ui-state-default ui-corner-all ui-button-text-only sub upd submit-cancel"',
        true
    );
    $output .= '</div>';
    $output .= '<div class="right">';
    $output .= html_print_submit_button(
        __('OK!'),
        'register',
        false,
        'class="ui-widget ui-state-default ui-corner-all ui-button-text-only sub ok submit-next w100px"',
        true
    );
    $output .= '</div>';
    $output .= '</div>';

    $output .= '<div id="both"></div>';
    $output .= '<br/>';
    $output .= '</div>';

    // Verification modal.
    $output .= '<div id="reg_ensure_cancel" title="Confirmation Required" class="invisible">';
    $output .= '<div class="font_12_20">';
    $output .= __('Are you sure you don\'t want to use update manager?');
    $output .= '<p>';
    $output .= __('You will need to update your system manually, through source code or RPM packages to be up to date with latest updates.');
    $output .= '</p>';
    $output .= '</div>';
    $output .= '</div>';

    // Results modal.
    $output .= '<div id="reg_result" title="Registration process result" class="invisible">';
    $output .= '<div id="reg_result_content" class="font_12_20">';
    $output .= '</div>';
    $output .= '</div>';

    ob_start();
    ?>
<script type="text/javascript">

function show_registration_wizard() {
    $("#registration_wizard").dialog({
        resizable: true,
        draggable: true,
        modal: true,
        width: 630,
        overlay: {
                opacity: 0.5,
                background: "black"
            },
        closeOnEscape: false,
        open: function(event, ui) { $(".ui-dialog-titlebar-close").hide(); }
    });

    default_language_displayed = $("#language").val();

    $(".ui-widget-overlay").css("background", "#000");
    $(".ui-widget-overlay").css("opacity", 0.6);
    $(".ui-draggable").css("cursor", "inherit");


    // CLICK EVENTS: Cancel and Registration
    $("#submit-cancel_registration").click (function (e) {
        e.preventDefault();
        $("#reg_ensure_cancel").dialog({
            buttons: [
                {
                    "text": "No",
                    "class": 'submit-cancel',
                    "click" : function() {
                        $(this).dialog("close");
                    }
                },
                {
                    "text": "Yes",
                    "class": 'submit-next',
                    "click" : function() {
                        jQuery.post (
                            "ajax.php",
                            {
                                "page": "general/register",
                                "cancel_registration": 1
                            },
                            function (data) {}
                        );
                        $(this).dialog("close");
                        $("#registration_wizard" ).dialog('close');
                    }
                }
            ]
        });

        $("#reg_ensure_cancel").dialog('open');
    });

    $("#submit-register").click (function () {
        // All fields are required.
        if ($("#text-email").val() == '') {
            $("#all-required").show();
        } else {
            var timezone = $("#timezone").val();
            var language = $("#language").val();
            var email_identification = $("#text-email").val();

            jQuery.post (
                "ajax.php",
                {
                    "page": "general/register",
                    "register_console": 1
                },
                function (data) {
                    cl = '';
                    msg = 'no response';

                    try {
                        json = JSON.parse(data);
                        cl = json.status
                        msg = json.message;

                    } catch (error) {
                        msg = 'Failed: ' + error;
                        cl = 'error';
                    }

                    if (!cl || cl == 'error') {
                        cl = 'error';
                    } else {
                        // Success.
                    }

                    $('#reg_result_content').html(msg);
                    $('#reg_result').addClass(cl);
                    $('#reg_result').dialog({
                        buttons: [
                            {
                                "text": "OK",
                                "class": "submit-next",
                                "click": function() {
                                    $(this).dialog('close');
                                    $("#registration_wizard").dialog('close');
                                    <?php
                                    if (isset($callback) && $callback != '') {
                                        echo $callback;
                                    }
                                    ?>
                                }
                            }
                        ]
                    });
                }
            );
        }
    });
}

    <?php
    if ($launch === true) {
        ?>
        $(document).ready (function () {
            show_registration_wizard();
        });
        <?php
    }
    ?>


</script>

    <?php
    // Add js.
    $output .= ob_get_clean();

    if ($return === false) {
        echo $output;
    }

    return $output;
}


/**
 * Parse newsletter wiz.
 *
 * @return array Status feedback.
 */
function newsletter_wiz_process()
{
    global $config;

    $email = get_parameter('email', '');

    // Pandora newsletter update.
    $um_message = update_manager_insert_newsletter($email);

    $ui_feedback['message'] = $um_message['message'];

    if ($um_message['success']) {
        // Success or already registered.
        db_process_sql_update(
            'tusuario',
            ['middlename' => 1],
            ['id_user' => $config['id_user']]
        );
        $ui_feedback['status'] = $um_message['success'];
    } else {
        $ui_feedback['status'] = false;
    }

    return $ui_feedback;
}


/**
 * Show a modal allowing the user register into newsletter.
 *
 * @param boolean $return   Print content o return it.
 * @param boolean $launch   Launch directly on load or not.
 * @param string  $callback Call function when done.
 *
 * @return string HTML code.
 */
function newsletter_wiz_modal(
    $return=false,
    $launch=true,
    $callback=false
) {
    global $config;

    $output = '';

    $product_name = get_product_name();
    $email = db_get_value(
        'email',
        'tusuario',
        'id_user',
        $config['id_user']
    );

    // Avoid to show default email.
    if ($email === 'admin@example.com') {
        $email = '';
    }

    $modalContent = html_print_div(
        [
            'class'   => 'register_update_manager',
            'content' => html_print_image(
                'images/pandora_circle_big.png',
                true
            ),
        ],
        true
    );

    $modalContent .= html_print_div(
        [
            'class'   => 'newsletter_div',
            'content' => __('Subscribe to our newsletter'),
        ],
        true
    );

    $modalContent .= html_print_div(
        [
            'class'   => 'license_text both',
            'content' => sprintf(
                '<p>%s</p><p>%s</p>',
                __('Stay up to date with updates, upgrades and promotions by subscribing to our newsletter.'),
                __(
                    'By subscribing to the newsletter, you accept that your email will be transferred to a database owned by %s. These data will be used only to provide you with information about %s and will not be given to third parties. You can unsubscribe from this database at any time from the newsletter subscription options.',
                    $product_name,
                    $product_name
                )
            ),
        ],
        true
    );

    // Email Input case.
    $emailInputCase = '<span id="label-email-newsletter">'.__('Email').' </span>'.html_print_input_text_extended(
        'email-newsletter',
        $email,
        'text-email-newsletter',
        '',
        30,
        255,
        false,
        '',
        ['style' => 'display: inline-block; width: 200px;'],
        true
    );

    // Generate the submit buttons.
    // Cancel Button.
    $submitButtons = html_print_div(
        [
            'class'   => 'left',
            'content' => html_print_submit_button(
                __('Cancel'),
                'cancel_newsletter',
                false,
                'class="ui-widget ui-state-default ui-corner-all ui-button-text-only sub upd submit-cancel w100px"',
                true
            ),
        ],
        true
    );

    // OK Button.
    $submitButtons .= html_print_div(
        [
            'class'   => 'right',
            'content' => html_print_submit_button(
                __('OK!'),
                'newsletter',
                false,
                'class="ui-widget ui-state-default ui-corner-all ui-button-text-only sub ok submit-next w100px"',
                true
            ),
        ],
        true
    );

    $submitButtonsCase = html_print_div(
        [
            'class'   => 'submit_buttons_container',
            'content' => $submitButtons,
        ],
        true
    );

    $modalContent .= html_print_div(
        [
            'class'   => 'mrgn_lft_4em',
            'content' => html_print_div(
                [
                    'id'      => 'box_newsletter',
                    'content' => $emailInputCase.$submitButtonsCase.'<div id="both"></div><br />',
                ],
                true
            ),
        ],
        true
    );

    $output .= html_print_div(
        [
            'id'      => 'newsletter_wizard',
            'style'   => 'display: none;',
            'title'   => __('Do you want to be up to date?'),
            'content' => $modalContent,
        ],
        true
    );

    // Verification modal.
    $verificationContent = html_print_div(
        [
            'class'   => 'font_12_20',
            'content' => __('Are you sure you don\'t want to subscribe?').'<p>'.__('You will miss all news about amazing features and fixes!').'</p>',
        ],
        true
    );

    $output .= html_print_div(
        [
            'id'      => 'news_ensure_cancel',
            'style'   => 'display: none;',
            'title'   => 'Confirmation Required',
            'content' => $verificationContent,
        ],
        true
    );

    // Results modal.
    $resultsContent = html_print_div(
        [
            'id'    => 'news_result_content',
            'class' => 'font_12_20',
        ],
        true
    );

    $output .= html_print_div(
        [
            'id'      => 'news_result',
            'style'   => 'display: none;',
            'title'   => 'Subscription process result',
            'content' => $resultsContent,
        ],
        true
    );

    ob_start();
    ?>
<script type="text/javascript">

function show_newsletter_wizard() {
    $("#newsletter_wizard").dialog({
        resizable: true,
        draggable: true,
        modal: true,
        width: 630,
        overlay: {
                opacity: 0.5,
                background: "black"
            },
        closeOnEscape: false,
        open: function(event, ui) { $(".ui-dialog-titlebar-close").hide(); }
    });

    default_language_displayed = $("#language").val();

    $(".ui-widget-overlay").css("background", "#000");
    $(".ui-widget-overlay").css("opacity", 0.6);
    $(".ui-draggable").css("cursor", "inherit");


    // CLICK EVENTS: Cancel and Registration
    $("#submit-cancel_newsletter").click (function (e) {
        e.preventDefault();
        $("#news_ensure_cancel").dialog({
            buttons: [
                {
                    text: "No",
                    "class": 'submit-cancel',
                    click : function() {
                        $(this).dialog('close');
                    }
                },
                {
                    text: "Yes",
                    "class": 'submit-next',
                    click : function() {
                        jQuery.post ("ajax.php",
                            {
                                "page": "general/register",
                                "cancel_newsletter": 1
                            },
                            function (data) {}
                        );
                        $(this).dialog("close");
                        $("#newsletter_wizard" ).dialog('close');
                    }
                }
            ]
        });

        $("#news_ensure_cancel").dialog('open');
    });

    $("#submit-newsletter").click (function () {
        // All fields are required.
        if ($("#text-email").val() == '') {
            $("#all-required").show();
        } else {
            var timezone = $("#timezone").val();
            var language = $("#language").val();
            var email_identification = $("#text-email-newsletter").val();

            if (email_identification == '') {
                msg = '<?php echo __('You must specify an email'); ?>';
                $('#news_result_content').html(msg);
                $('#news_result').dialog({
                    buttons: {
                        'Ok': function() {
                            $(this).dialog('close');
                        }
                    }
                });
            } else {

                jQuery.post (
                    "ajax.php",
                    {
                        "page": "general/register",
                        "register_newsletter": 1,
                        "email": email_identification
                    },
                    function (data) {
                        cl = '';
                        msg = 'no response';

                        try {
                            json = JSON.parse(data);
                            cl = json.status
                            msg = json.message;

                        } catch (error) {
                            msg = 'Failed: ' + error;
                            cl = 'error';
                        }

                        if (!cl || cl == 'error') {
                            cl = 'error';
                        } else {
                            // Success.
                        }

                        $('#news_result_content').html(msg);
                        $('#news_result').addClass(cl);
                        $('#news_result').dialog({
                            buttons: {
                                'Ok': function() {
                                    $(this).dialog('close');
                                    $("#newsletter_wizard").dialog('close');
                                    <?php
                                    if (isset($callback) && $callback != '') {
                                        echo $callback;
                                    }
                                    ?>
                                }
                            }
                        });
                    }
                );
            }
        }
    });
}

    <?php
    if ($launch === true) {
        ?>
        $(document).ready (function () {
            show_newsletter_wizard();
        });
        <?php
    }
    ?>


</script>

    <?php
    $output .= ob_get_clean();

    if (!$return) {
        echo $output;
    }

    return $output;
}


/*
 *
 * Registration functions - End.
 *
 */


/**
 * Prepare configuration values.
 *
 * @return array UM Configuration tokens.
 */
function update_manager_get_config_values()
{
    global $config;
    global $build_version;
    global $pandora_version;

    enterprise_include_once('include/functions_license.php');

    $license = db_get_value(
        db_escape_key_identifier('value'),
        'tupdate_settings',
        db_escape_key_identifier('key'),
        'customer_key'
    );

    $data = enterprise_hook('license_get_info');

    if ($data === ENTERPRISE_NOT_HOOK) {
        $limit_count = db_get_value_sql('SELECT count(*) FROM tagente');
    } else {
        $limit_count = $data['count_enabled'];
    }

    return [
        'license'        => $license,
        'current_update' => update_manager_get_current_package(),
        'limit_count'    => $limit_count,
        'build'          => $build_version,
        'version'        => $pandora_version,
        'puid'           => $config['pandora_uid'],
    ];
}


/**
 * Function to remove dir and files inside.
 *
 * @param string $dir Path to dir.
 *
 * @return void
 */
function rrmdir($dir)
{
    if (is_dir($dir)) {
        $objects = scandir($dir);

        foreach ($objects as $object) {
            if ($object != '.' && $object != '..') {
                if (filetype($dir.'/'.$object) == 'dir') {
                    rrmdir($dir.'/'.$object);
                } else {
                    unlink($dir.'/'.$object);
                }
            }
        }

        reset($objects);
        rmdir($dir);
    } else {
        unlink($dir);
    }
}


/**
 * Install updates step2.
 *
 * @return void
 */
function update_manager_install_package_step2()
{
    global $config;

    ob_clean();

    $package = (string) get_parameter('package');
    $package = trim($package);

    $version = (string) get_parameter('version', 0);

    $path = sys_get_temp_dir().'/pandora_oum/'.$package;

    // All files extracted.
    $files_total = $path.'/files.txt';
    // Files copied.
    $files_copied = $path.'/files.copied.txt';
    $return = [];

    if (file_exists($files_copied)) {
        unlink($files_copied);
    }

    if (file_exists($path)) {
        $files_h = fopen($files_total, 'r');
        if ($files_h === false) {
            $return['status'] = 'error';
            $return['message'] = __('An error ocurred while reading a file.');
            echo json_encode($return);
            return;
        }

        while ($line = stream_get_line($files_h, 65535, "\n")) {
            $line = trim($line);

            // Tries to move the old file to the directory backup
            // inside the extracted package.
            if (file_exists($config['homedir'].'/'.$line)) {
                rename($config['homedir'].'/'.$line, $path.'/backup/'.$line);
            }

            // Tries to move the new file to the Integria directory.
            $dirname = dirname($line);
            if (!file_exists($config['homedir'].'/'.$dirname)) {
                $dir_array = explode('/', $dirname);
                $temp_dir = '';
                foreach ($dir_array as $dir) {
                    $temp_dir .= '/'.$dir;
                    if (!file_exists($config['homedir'].$temp_dir)) {
                        mkdir($config['homedir'].$temp_dir);
                    }
                }
            }

            if (is_dir($path.'/'.$line)) {
                if (!file_exists($config['homedir'].'/'.$line)) {
                    mkdir($config['homedir'].'/'.$line);
                    file_put_contents($files_copied, $line."\n", (FILE_APPEND | LOCK_EX));
                }
            } else {
                // Copy the new file.
                if (rename($path.'/'.$line, $config['homedir'].'/'.$line)) {
                    // Append the moved file to the copied files txt.
                    if (!file_put_contents($files_copied, $line."\n", (FILE_APPEND | LOCK_EX))) {
                        // If the copy process fail, this code tries to
                        // restore the files backed up before.
                        $files_copied_h = fopen($files_copied, 'r');
                        if ($files_copied_h === false) {
                            $backup_status = __('Some of your old files might not be recovered.');
                        } else {
                            while ($line_c = stream_get_line($files_copied_h, 65535, "\n")) {
                                $line_c = trim($line_c);
                                if (!rename($path.'/backup/'.$line, $config['homedir'].'/'.$line_c)) {
                                    $backup_status = __('Some of your files might not be recovered.');
                                }
                            }

                            if (!rename($path.'/backup/'.$line, $config['homedir'].'/'.$line)) {
                                $backup_status = __('Some of your files might not be recovered.');
                            }

                            fclose($files_copied_h);
                        }

                        fclose($files_h);
                        $return['status'] = 'error';
                        $return['message'] = __(
                            'Line "%s" not copied to the progress file.',
                            $line
                        ).'&nbsp;'.$backup_status;
                        echo json_encode($return);
                        return;
                    }
                } else {
                    // If the copy process fail, this code tries to restore
                    // the files backed up before.
                    $files_copied_h = fopen($files_copied, 'r');
                    if ($files_copied_h === false) {
                        $backup_status = __('Some of your files might not be recovered.');
                    } else {
                        while ($line_c = stream_get_line($files_copied_h, 65535, "\n")) {
                            $line_c = trim($line_c);
                            if (!rename(
                                $path.'/backup/'.$line,
                                $config['homedir'].'/'.$line
                            )
                            ) {
                                $backup_status = __('Some of your old files might not be recovered.');
                            }
                        }

                        fclose($files_copied_h);
                    }

                    fclose($files_h);
                    $return['status'] = 'error';
                    $return['message'] = __(
                        'Line "%s" not copied to the progress file.',
                        $line
                    ).'&nbsp;'.$backup_status;
                    echo json_encode($return);
                    return;
                }
            }
        }

        fclose($files_h);
    } else {
        $return['status'] = 'error';
        $return['message'] = __('The package does not exist');
        echo json_encode($return);
        return;
    }

    update_manager_enterprise_set_version($version);
    $product_name = io_safe_output(get_product_name());

    // Generate audit entry.
    db_pandora_audit(
        'Update '.$product_name,
        'Update version: '.$version.' of '.$product_name.' by '.$config['id_user']
    );

    $return['status'] = 'success';
    $return['message'] = __('The package is installed.');
    echo json_encode($return);

}


/**
 * Launch update manager client.
 *
 * @return void
 */
function update_manager_main()
{
    global $config;
    ?>
    <script type="text/javascript">
        <?php
        echo 'var unknown_error_update_manager = "'.__('There is a unknown error.').'";';
        ?>
    </script>
    <script src="include/javascript/update_manager.js"></script>
    <script type="text/javascript">
        var version_update = "";
        var stop_check_progress = 0;

        $(document).ready(function() {
            check_online_free_packages();
        });
    </script>
    <?php
}


/**
 * Check updates available (opensource).
 *
 * @return boolean Packages available or not.
 */
function update_manager_check_online_free_packages_available()
{
    global $config;

    $update_message = '';

    $um_config_values = update_manager_get_config_values();

    $params = [
        'action'          => 'newest_package',
        'license'         => $um_config_values['license'],
        'limit_count'     => $um_config_values['limit_count'],
        'current_package' => $um_config_values['current_update'],
        'version'         => $um_config_values['version'],
        'build'           => $um_config_values['build'],
        'puid'            => $um_config_values['puid'],
    ];

    $curlObj = curl_init();
    curl_setopt($curlObj, CURLOPT_URL, get_um_url().'server.php');
    curl_setopt($curlObj, CURLOPT_RETURNTRANSFER, 1);
    curl_setopt($curlObj, CURLOPT_POST, true);
    curl_setopt($curlObj, CURLOPT_POSTFIELDS, $params);
    curl_setopt($curlObj, CURLOPT_SSL_VERIFYPEER, false);
    curl_setopt($curlObj, CURLOPT_CONNECTTIMEOUT, 4);

    if (isset($config['update_manager_proxy_server'])) {
        curl_setopt($curlObj, CURLOPT_PROXY, $config['update_manager_proxy_server']);
    }

    if (isset($config['update_manager_proxy_port'])) {
        curl_setopt($curlObj, CURLOPT_PROXYPORT, $config['update_manager_proxy_port']);
    }

    if (isset($config['update_manager_proxy_user'])) {
        curl_setopt($curlObj, CURLOPT_PROXYUSERPWD, $config['update_manager_proxy_user'].':'.$config['update_manager_proxy_password']);
    }

    $result = curl_exec($curlObj);
    $http_status = curl_getinfo($curlObj, CURLINFO_HTTP_CODE);
    curl_close($curlObj);

    if ($result === false) {
        return false;
    } else if ($http_status >= 400 && $http_status < 500) {
        return false;
    } else if ($http_status >= 500) {
        return false;
    } else {
        $result = json_decode($result, true);

        if (empty($result)) {
            return false;
        } else {
            return true;
        }
    }
}


/**
 * Update process, online packages.
 *
 * @param boolean $is_ajax Is ajax call o direct call.
 *
 * @return string HTML update message.
 */
function update_manager_check_online_free_packages($is_ajax=true)
{
    global $config;

    $update_message = '';

    $um_config_values = update_manager_get_config_values();

    $params = [
        'action'          => 'newest_package',
        'license'         => $um_config_values['license'],
        'limit_count'     => $um_config_values['limit_count'],
        'current_package' => $um_config_values['current_update'],
        'version'         => $um_config_values['version'],
        'build'           => $um_config_values['build'],
        'puid'            => $um_config_values['puid'],
    ];

    /*
     * To test using shell execute:
     * wget https://artica.es/pandoraupdate7/server.php -O- \
     * --no-check-certificate --post-data \
     * "action=newest_package&license=PANDORA_FREE&limit_count=1&current_package=1&version=v5.1RC1&build=PC140625"
     */

    $curlObj = curl_init();
    curl_setopt($curlObj, CURLOPT_URL, get_um_url().'server.php');
    curl_setopt($curlObj, CURLOPT_RETURNTRANSFER, 1);
    curl_setopt($curlObj, CURLOPT_POST, true);
    curl_setopt($curlObj, CURLOPT_POSTFIELDS, $params);
    curl_setopt($curlObj, CURLOPT_SSL_VERIFYPEER, false);
    if (isset($config['update_manager_proxy_server'])) {
        curl_setopt(
            $curlObj,
            CURLOPT_PROXY,
            $config['update_manager_proxy_server']
        );
    }

    if (isset($config['update_manager_proxy_port'])) {
        curl_setopt(
            $curlObj,
            CURLOPT_PROXYPORT,
            $config['update_manager_proxy_port']
        );
    }

    if (isset($config['update_manager_proxy_user'])) {
        curl_setopt(
            $curlObj,
            CURLOPT_PROXYUSERPWD,
            $config['update_manager_proxy_user'].':'.$config['update_manager_proxy_password']
        );
    }

    $result = curl_exec($curlObj);
    $http_status = curl_getinfo($curlObj, CURLINFO_HTTP_CODE);
    curl_close($curlObj);

    if ($result === false) {
        if ($is_ajax) {
            echo __('Could not connect to internet');
        } else {
            $update_message = __('Could not connect to internet');
        }
    } else if ($http_status >= 400 && $http_status < 500) {
        if ($is_ajax) {
            echo __('Server not found.');
        } else {
            $update_message = __('Server not found.');
        }
    } else if ($http_status >= 500) {
        if ($is_ajax) {
            echo $result;
        } else {
            $update_message = $result;
        }
    } else {
        if ($is_ajax) {
            $result = json_decode($result, true);

            if (!empty($result)) {
                ?>
                <script type="text/javascript">
                    var mr_available = "<?php echo __('Minor release available'); ?>\n";
                    var package_available = "<?php echo __('New package available'); ?>\n";
                    var mr_not_accepted = "<?php echo __('Minor release rejected. Changes will not apply.'); ?>\n";
                    var mr_not_accepted_code_yes = "<?php echo __('Minor release rejected. The database will not be updated and the package will apply.'); ?>\n";
                    var mr_cancel = "<?php echo __('Minor release rejected. Changes will not apply.'); ?>\n";
                    var package_cancel = "<?php echo __('These package changes will not apply.'); ?>\n";
                    var package_not_accepted = "<?php echo __('Package rejected. These package changes will not apply.'); ?>\n";
                    var mr_success = "<?php echo __('Database successfully updated'); ?>\n";
                    var mr_error = "<?php echo __('Error in MR file'); ?>\n";
                    var package_success = "<?php echo __('Package updated successfully'); ?>\n";
                    var package_error = "<?php echo __('Error in package updated'); ?>\n";
                    var bad_mr_file = "<?php echo __('Database MR version is inconsistent, do you want to apply the package?'); ?>\n";
                    var mr_available_header = "<?php echo __('There are db changes'); ?>\n";
                    var text1_mr_file = "<?php echo __('There are new database changes available to apply. Do you want to start the DB update process?'); ?>\n";
                    var text2_mr_file = "<?php echo __('We recommend launching '); ?>\n";
                    var text3_mr_file = "<?php echo __('Scheduled downtime'); ?>\n";

                    var language = "<?php echo $config['language']; ?>";
                    var docsUrl = (language === "es")
                        ? "http://wiki.pandorafms.com/index.php?title=Pandora:Documentation_es:Actualizacion#Versi.C3.B3n_7.0NG_.28_Rolling_Release_.29"
                        : "http://wiki.pandorafms.com/index.php?title=Pandora:Documentation_en:Anexo_Upgrade#Version_7.0NG_.28_Rolling_Release_.29";

                    var text4_mr_file = "<?php echo __(' to this process'); ?>";
                    text4_mr_file += "<br><br>";
                    text4_mr_file += "<a class=\"font_10pt italic\" target=\"blank\" href=\"" + docsUrl + "\">";
                    text4_mr_file += "<?php echo __('About minor release update'); ?>";
                    text4_mr_file += "</a>";

                    var text1_package_file = "<?php echo __('There is a new update available'); ?>\n";
                    var text2_package_file = "<?php echo __('There is a new update available to apply. Do you want to start the update process?'); ?>\n";
                    var applying_mr = "<?php echo __('Applying DB MR'); ?>\n";
                    var cancel_button = "<?php echo __('Cancel'); ?>\n";
                    var ok_button = "<?php echo __('Ok'); ?>\n";
                    var apply_mr_button = "<?php echo __('Apply MR'); ?>\n";
                    var apply_button = "<?php echo __('Apply'); ?>\n";
                </script>
                <?php
                $baseurl = ui_get_full_url(false, false, false, false);
                echo '<p><b>There is a new version:</b> '.$result[0]['version'].'</p>';
                echo "<a class='update_manager_button' href='javascript: update_last_package(\"".base64_encode($result[0]['file_name']).'", "'.$result[0]['version'].'", "'.$baseurl."\");'>".__('Update').'</a>';
            } else {
                echo __('There is no update available.');
            }

            return $update_message;
        } else {
            if (!empty($result)) {
                $result = json_decode($result, true);
                $update_message = 'There is a new version: '.$result[0]['version'];
            }

            return $update_message;
        }
    }

}


/**
 * Executes an action against UpdateManager.
 *
 * @param string  $action            Action to perform.
 * @param boolean $additional_params Extra parameters (optional).
 *
 * @return array With UM response.
 */
function update_manager_curl_request($action, $additional_params=false)
{
    global $config;

    $error_array = [
        'success'        => true,
        'update_message' => '',
    ];
    $update_message = '';

    $um_config_values = update_manager_get_config_values();

    $params = [
        'license'         => $um_config_values['license'],
        'limit_count'     => $um_config_values['limit_count'],
        'current_package' => $um_config_values['current_update'],
        'version'         => $um_config_values['version'],
        'build'           => $um_config_values['build'],
        'puid'            => $um_config_values['puid'],
    ];
    if ($additional_params !== false) {
        $params = array_merge($params, $additional_params);
    }

    $params['action'] = $action;

    $curlObj = curl_init();
    curl_setopt($curlObj, CURLOPT_URL, get_um_url().'server.php');
    curl_setopt($curlObj, CURLOPT_RETURNTRANSFER, 1);
    curl_setopt($curlObj, CURLOPT_POST, true);
    curl_setopt($curlObj, CURLOPT_POSTFIELDS, $params);
    curl_setopt($curlObj, CURLOPT_SSL_VERIFYPEER, false);
    if (isset($config['update_manager_proxy_server'])) {
        curl_setopt($curlObj, CURLOPT_PROXY, $config['update_manager_proxy_server']);
    }

    if (isset($config['update_manager_proxy_port'])) {
        curl_setopt($curlObj, CURLOPT_PROXYPORT, $config['update_manager_proxy_port']);
    }

    if (isset($config['update_manager_proxy_user'])) {
        curl_setopt($curlObj, CURLOPT_PROXYUSERPWD, $config['update_manager_proxy_user'].':'.$config['update_manager_proxy_password']);
    }

    $result = curl_exec($curlObj);
    $http_status = curl_getinfo($curlObj, CURLINFO_HTTP_CODE);
    curl_close($curlObj);

    $error_array['http_status'] = $http_status;

    if ($result === false) {
        $error_array['success'] = false;
        if ($is_ajax) {
            echo __('Could not connect to internet');
            return $error_array;
        } else {
            $error_array['update_message'] = __('Could not connect to internet');
            return $error_array;
        }
    } else if ($http_status >= 400 && $http_status < 500) {
        $error_array['success'] = false;
        if ($is_ajax) {
            echo __('Server not found.');
            return $error_array;
        } else {
            $error_array['update_message'] = __('Server not found.');
            return $error_array;
        }
    } else if ($http_status >= 500) {
        $error_array['success'] = false;
        if ($is_ajax) {
            echo $result;
            return $error_array;
        } else {
            $error_array['update_message'] = $result;
            return $error_array;
        }
    }

    $error_array['update_message'] = $result;
    return $error_array;

}


/**
 * Subscribes an email account into newsletter.
 *
 * @param string $email E-mail.
 *
 * @return array With success [true/false], message [string].
 */
function update_manager_insert_newsletter($email)
{
    global $config;

    if ($email === '') {
        return false;
    }

    $params = [
        'email'    => $email,
        'language' => $config['language'],
        'license'  => db_get_value_filter(
            'value',
            'tupdate_settings',
            ['key' => 'customer_key']
        ),
    ];

    $result = update_manager_curl_request('new_newsletter', $params);

    if (!$result['success']) {
        return [
            'success' => false,
            'message' => __('Remote server error on newsletter request'),
        ];
    }

    switch ($result['http_status']) {
        case 200:
            $message = json_decode($result['update_message'], true);
            if ($message['success'] == 1) {
                return [
                    'success' => true,
                    'message' => __('E-mail successfully subscribed to newsletter.'),
                ];
            } else {
                return [
                    'success' => true,
                    'message' => __('E-mail has already subscribed to newsletter.'),
                ];
            }

        default:
        return [
            'success' => false,
            'message' => __('Update manager returns error code: ').$result['http_status'].'.',
        ];
    }
}


/**
 * Registers this console into UpdateManager.
 *
 * @return array With success [true/false], message [string].
 */
function update_manager_register_instance()
{
    global $config;

    $email = db_get_value('email', 'tusuario', 'id_user', $config['id_user']);

    $um_config_values = update_manager_get_config_values();

    $params = [
        'action'          => 'newest_package',
        'license'         => $um_config_values['license'],
        'limit_count'     => $um_config_values['limit_count'],
        'current_package' => $um_config_values['current_update'],
        'version'         => $um_config_values['version'],
        'build'           => $um_config_values['build'],
        'puid'            => $um_config_values['puid'],
        'email'           => $email,
        'language'        => $config['language'],
        'timezone'        => $config['timezone'],
    ];

    $result = update_manager_curl_request('new_register', $params);

    if (!$result['success']) {
        return [
            'success' => false,
            'message' => __('Error while registering console.').'<br/>'.$result['update_message'],
        ];
    }

    switch ($result['http_status']) {
        case 200:
            // Retrieve the PUID.
            $message = json_decode($result['update_message'], true);

            if ($message['success'] == 1) {
                $puid = $message['pandora_uid'];
                config_update_value('pandora_uid', $puid);

                // The tupdate table is reused to display messages.
                // A specific entry to tupdate_package is required.
                // Then, this tupdate_package id is saved in tconfig.
                db_process_sql_insert(
                    'tupdate_package',
                    ['description' => '__UMMESSAGES__']
                );
                $id_um_package_messages = db_get_value(
                    'id',
                    'tupdate_package',
                    'description',
                    '__UMMESSAGES__'
                );
                config_update_value(
                    'id_um_package_messages',
                    $id_um_package_messages
                );
                return [
                    'success' => true,
                    'message' => __('Pandora successfully subscribed with UID: ').$puid.'.',
                ];
            } else {
                return [
                    'success' => false,
                    'message' => __('Unsuccessful subscription.'),
                ];
            }

        default:
        return [
            'success' => false,
            'message' => __('Update manager returns error code: ').$result['http_status'].'.',
        ];
    }
}


/**
 * Extracts OUM package.
 *
 * @return boolean Success or not.
 */
function update_manager_extract_package()
{
    global $config;

    $path_package = $config['attachment_store'].'/downloads/last_package.tgz';

    ob_start();

    if (!defined('PHP_VERSION_ID')) {
        $version = explode('.', PHP_VERSION);
        define(
            'PHP_VERSION_ID',
            ($version[0] * 10000 + $version[1] * 100 + $version[2])
        );
    }

    $extracted = false;

    // Phar and exception working fine in 5.5.0 or higher.
    if (PHP_VERSION_ID >= 50505) {
        $phar = new PharData($path_package);
        try {
            $result = $phar->extractTo(
                $config['attachment_store'].'/downloads/',
                null,
                true
            );
            $extracted = true;
        } catch (Exception $e) {
            echo ' There\'s a problem ... -> '.$e->getMessage();
            $extracted = false;
        }
    }

    $return = true;

    if ($extracted === false) {
        // Phar extraction failed. Fallback to OS extraction.
        $return = false;

        if (strtoupper(substr(PHP_OS, 0, 3)) == 'WIN') {
            // Unsupported OS.
            echo 'This OS ['.PHP_OS.'] does not support direct extraction of tgz files. Upgrade PHP version to be > 5.5.0';
        } else {
            $return = true;
            system('tar xzf "'.$path_package.'" -C '.$config['attachment_store'].'/downloads/');
        }
    }

    ob_end_clean();

    rrmdir($path_package);

    if ($result == 0) {
        db_process_sql_update(
            'tconfig',
            [
                'value' => json_encode(
                    [
                        'status'  => 'fail',
                        'message' => __('Failed extracting the package to temp directory.'),
                    ]
                ),
            ],
            ['token' => 'progress_update_status']
        );

        return false;
    }

    // An update have been applied, clean phantomjs cache.
    config_update_value(
        'clean_phantomjs_cache',
        1
    );

    db_process_sql_update(
        'tconfig',
        ['value' => 50],
        ['token' => 'progress_update']
    );

    return $return;
}


/**
 * The update copy entire tgz or fail (leaving some parts copied
 * and others not).
 * This does not make changes on DB.
 *
 * @return boolean Success or not.
 */
function update_manager_starting_update()
{
    global $config;

    $full_path = $config['attachment_store'].'/downloads';

    $homedir = $config['homedir'];

    $result = update_manager_recurse_copy(
        $full_path,
        $homedir,
        ['install.php']
    );

    rrmdir($full_path.'/pandora_console');

    if (!$result) {
        db_process_sql_update(
            'tconfig',
            [
                'value' => json_encode(
                    [
                        'status'  => 'fail',
                        'message' => __('Failed the copying of the files.'),
                    ]
                ),
            ],
            ['token' => 'progress_update_status']
        );

        return false;
    } else {
        db_process_sql_update(
            'tconfig',
            ['value' => 100],
            ['token' => 'progress_update']
        );
        db_process_sql_update(
            'tconfig',
            [
                'value' => json_encode(
                    [
                        'status'  => 'end',
                        'message' => __('Package extracted successfully.'),
                    ]
                ),
            ],
            ['token' => 'progress_update_status']
        );

        return true;
    }
}


/**
 * Copies recursively extracted package updates to target path.
 *
 * @param string $src        Path.
 * @param string $dst        Path.
 * @param string $black_list Path.
 *
 * @return boolean Success or not.
 */
function update_manager_recurse_copy($src, $dst, $black_list)
{
    $dir = opendir($src);
    @mkdir($dst);
    @trigger_error('NONE');

    while (false !== ( $file = readdir($dir))) {
        if (( $file != '.' ) && ( $file != '..' ) && (!in_array($file, $black_list))) {
            if (is_dir($src.'/'.$file)) {
                $dir_dst = $dst;

                if ($file != 'pandora_console') {
                    $dir_dst .= '/'.$file;
                }

                if (!update_manager_recurse_copy(
                    $src.'/'.$file,
                    $dir_dst,
                    $black_list
                )
                ) {
                    return false;
                }
            } else {
                $result = copy($src.'/'.$file, $dst.'/'.$file);
                $error = error_get_last();

                if (strstr($error['message'], 'copy(')) {
                    return false;
                }
            }
        }
    }

    closedir($dir);

    return true;
}


/**
 * Updates current update (DB).
 *
 * @param string $current_package Current package.
 *
 * @return void
 */
function update_manager_set_current_package($current_package)
{
    if (enterprise_installed()) {
        $token = 'current_package_enterprise';
    } else {
        $token = 'current_package';
    }

    $col_value = db_escape_key_identifier('value');
    $col_key = db_escape_key_identifier('key');

    $value = db_get_value(
        $col_value,
        'tupdate_settings',
        $col_key,
        $token
    );

    if ($value === false) {
        db_process_sql_insert(
            'tupdate_settings',
            [
                $col_value => $current_package,
                $col_key   => $token,
            ]
        );
    } else {
        db_process_sql_update(
            'tupdate_settings',
            [$col_value => $current_package],
            [$col_key => $token]
        );
    }
}


/**
 * Retrieves current update from DB.
 *
 * @return string Current update.
 */
function update_manager_get_current_package()
{
    global $config;

    if (enterprise_installed()) {
        $token = 'current_package_enterprise';
    } else {
        $token = 'current_package';
    }

    $current_update = db_get_value(
        db_escape_key_identifier('value'),
        'tupdate_settings',
        db_escape_key_identifier('key'),
        $token
    );

    if ($current_update === false) {
        $current_update = 0;
        if (isset($config[$token])) {
            $current_update = $config[$token];
        }
    }

    return $current_update;
}


/**
 * Function recursive delete directory.
 *
 * @param string $dir    Directory to delete.
 * @param array  $result Array result state and message.
 *
 * @return array Return result array with status 0 valid or 1 false and
 * type 'f' file and 'd' dir and route path file or directory.
 */
function rmdir_recursive(string $dir, array &$result)
{
    foreach (scandir($dir) as $file) {
        if ('.' === $file || '..' === $file) {
            continue;
        }

        if (is_dir($dir.'/'.$file) === true) {
            rmdir_recursive($dir.'/'.$file, $result);
        } else {
            $unlink = unlink($dir.'/'.$file);
            $res = [];
            $res['status'] = ($unlink === true) ? 0 : 1;
            $res['type'] = 'f';
            $res['path'] = $dir.'/'.$file;
            array_push($result, $res);
        }
    }

    $rmdir = rmdir($dir);
    $res = [];
    $res['status'] = ($rmdir === true) ? 0 : 1;
    $res['type'] = 'd';
    $res['path'] = $dir;
    array_push($result, $res);

    return $result;
}