local_webhooks/lib.php

<?php
// This file is part of Moodle - http://moodle.org/
//
// Moodle 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, either version 3 of the License, or
// (at your option) any later version.
//
// Moodle 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.
//
// You should have received a copy of the GNU General Public License
// along with Moodle.  If not, see <http://www.gnu.org/licenses/>.

/**
 * Library code used by the service control interfaces.
 *
 * @package   local_webhooks
 * @copyright 2017 "Valentin Popov" <info@valentineus.link>
 * @license   http://www.gnu.org/copyleft/gpl.html GNU GPL v3 or later
 */

defined("MOODLE_INTERNAL") || die();

require_once(__DIR__ . "/locallib.php");

/**
 * Change the status of the service.
 *
 * @param  number  $serviceid
 * @return boolean
 */
function local_webhooks_change_status($serviceid) {
    global $DB;

    $result = false;
    $conditions = array("id" => $serviceid);
    if ($DB->record_exists("local_webhooks_service", $conditions)) {
        $enabled = $DB->get_field("local_webhooks_service", "enable", $conditions, IGNORE_MISSING);
        $result = $DB->set_field("local_webhooks_service", "enable", !boolval($enabled), $conditions);
    }

    return boolval($result);
}

/**
 * Getting a list of all services.
 *
 * @param  number $limitfrom
 * @param  number $limitnum
 * @return array
 */
function local_webhooks_get_list_records($limitfrom = 0, $limitnum = 0) {
    global $DB;

    $listservices = $DB->get_records("local_webhooks_service", null, "id", "*", $limitfrom, $limitnum);

    foreach ($listservices as $servicerecord) {
        if (!empty($servicerecord->events)) {
            $servicerecord->events = local_webhooks_unarchive_data($servicerecord->events);
        }
    }

    return $listservices;
}

/**
 * Getting information about the service.
 *
 * @param  number $serviceid
 * @return object
 */
function local_webhooks_get_record($serviceid = 0) {
    global $DB;

    $servicerecord = $DB->get_record("local_webhooks_service", array("id" => $serviceid), "*", MUST_EXIST);

    if (!empty($servicerecord->events)) {
        $servicerecord->events = local_webhooks_unarchive_data($servicerecord->events);
    }

    return $servicerecord;
}

/**
 * Clear the database table.
 */
function local_webhooks_remove_list_records() {
    global $DB;

    $DB->delete_records("local_webhooks_service", null);
}

/**
 * Delete the record.
 *
 * @param number $serviceid
 */
function local_webhooks_remove_record($serviceid = 0) {
    global $DB;

    $DB->delete_records("local_webhooks_service", array("id" => $serviceid));
    local_webhooks_events::service_deleted($serviceid);
}

/**
 * Update the record in the database.
 *
 * @param  object  $data
 * @param  boolean $insert
 * @return boolean
 */
function local_webhooks_update_record($data, $insert = true) {
    global $DB;

    if (empty($data->events)) {
        $data->events = array();
    }

    $data->events = local_webhooks_archiving_data($data->events);

    if (boolval($insert)) {
        $result = $DB->insert_record("local_webhooks_service", $data, true, false);
        local_webhooks_events::service_added($result);
    } else {
        $result = $DB->update_record("local_webhooks_service", $data, false);
        local_webhooks_events::service_updated($data->id);
    }

    return boolval($result);
}

/**
 * Make a backup copy of all the services.
 *
 * @return string
 */
function local_webhooks_create_backup() {
    $listservices = local_webhooks_get_list_records();
    $listservices = local_webhooks_archiving_data($listservices);
    local_webhooks_events::backup_performed();
    return $listservices;
}

/**
 * Restore the data from the backup.
 *
 * @param string $data
 */
function local_webhooks_restore_backup($listservices = "") {
    $listservices = local_webhooks_unarchive_data($listservices);

    local_webhooks_remove_list_records();

    foreach ($listservices as $servicerecord) {
        local_webhooks_update_record($servicerecord, true);
    }

    local_webhooks_events::backup_restored();
}

/**
 * Compress an array into a string.
 *
 * @param  array  $data
 * @return string
 */
function local_webhooks_archiving_data($data = array()) {
    $result = base64_encode(gzcompress(serialize($data), 3));
    return $result;
}

/**
 * Gets an array from a compressed string.
 *
 * @param  string $data
 * @return array
 */
function local_webhooks_unarchive_data($data = "") {
    $result = unserialize(gzuncompress(base64_decode($data)));
    return $result;
}