<?php namespace la\core\snapshots;

[0] Fix | Delete

if ( ! defined( 'WPINC' ) ) die;

[1] Fix | Delete

[2] Fix | Delete

use Exception;

[3] Fix | Delete

use la\core\db\LADB;

[4] Fix | Delete

use la\core\db\LADBManager;

[5] Fix | Delete

use la\core\LAUtils;

[6] Fix | Delete

use stdClass;

[7] Fix | Delete

[8] Fix | Delete

/**

[9] Fix | Delete

* Flow-Flow

[10] Fix | Delete

*

[11] Fix | Delete

* Plugin class. This class should ideally be used to work with the

[12] Fix | Delete

* public-facing side of the WordPress site.

[13] Fix | Delete

*

[14] Fix | Delete

* If you're interested in introducing administrative or dashboard

[15] Fix | Delete

* functionality, then refer to `FlowFlowAdmin.php`

[16] Fix | Delete

*

[17] Fix | Delete

* @package FlowFlow

[18] Fix | Delete

* @author Looks Awesome <email@looks-awesome.com>

[19] Fix | Delete

[20] Fix | Delete

* @link http://looks-awesome.com

[21] Fix | Delete

* @copyright Looks Awesome

[22] Fix | Delete

*/

[23] Fix | Delete

class LASnapshotManager {

[24] Fix | Delete

const VERSION = '2.10';

[25] Fix | Delete

[26] Fix | Delete

private $context;

[27] Fix | Delete

[28] Fix | Delete

public function __construct($context) {

[29] Fix | Delete

$this->context = $context;

[30] Fix | Delete

[31] Fix | Delete

// secured endpoints

[32] Fix | Delete

add_action('wp_ajax_create_backup', [ $this, 'processAjaxRequest' ] );

[33] Fix | Delete

add_action('wp_ajax_restore_backup', [ $this, 'processAjaxRequest' ] );

[34] Fix | Delete

add_action('wp_ajax_delete_backup', [ $this, 'processAjaxRequest' ] );

[35] Fix | Delete

}

[36] Fix | Delete

[37] Fix | Delete

public function getSnapshots(){

[38] Fix | Delete

$result = [];

[39] Fix | Delete

$dbm = LAUtils::dbm($this->context);

[40] Fix | Delete

$rows = $dbm->conn()->getAll('SELECT * FROM ?n ORDER BY `creation_time` DESC', $dbm->snapshot_table_name);

[41] Fix | Delete

[42] Fix | Delete

foreach ( $rows as $row ) {

[43] Fix | Delete

$sn = new stdClass();

[44] Fix | Delete

$sn->id = $row['id'];

[45] Fix | Delete

$sn->description = $row['description'];

[46] Fix | Delete

$sn->creation_time = $row['creation_time'];

[47] Fix | Delete

$sn->settings = $row['settings'];

[48] Fix | Delete

$sn->version = $row['version'];

[49] Fix | Delete

$sn->outdated = version_compare(self::VERSION, $row['version'], '>=');

[50] Fix | Delete

$result[] = $sn;

[51] Fix | Delete

}

[52] Fix | Delete

return $result;

[53] Fix | Delete

}

[54] Fix | Delete

[55] Fix | Delete

/**

[56] Fix | Delete

* @throws Exception

[57] Fix | Delete

*/

[58] Fix | Delete

public function processAjaxRequest() {

[59] Fix | Delete

$result = [];

[60] Fix | Delete

[61] Fix | Delete

if (FF_USE_WP) {

[62] Fix | Delete

if (!current_user_can('manage_options') && !check_ajax_referer( 'flow_flow_nonce', 'security', false ) ) {

[63] Fix | Delete

die( json_encode( [ 'error' => 'not_allowed' ] ) );

[64] Fix | Delete

}

[65] Fix | Delete

}

[66] Fix | Delete

[67] Fix | Delete

if (isset($_REQUEST['action'])){

[68] Fix | Delete

$dbm = LAUtils::dbm($this->context);

[69] Fix | Delete

$dbm->dataInit();

[70] Fix | Delete

$conn = $dbm->conn();

[71] Fix | Delete

[72] Fix | Delete

try{

[73] Fix | Delete

if (false === $conn->beginTransaction()) throw new Exception('Don`t started transaction');

[74] Fix | Delete

[75] Fix | Delete

switch ($_REQUEST['action']){

[76] Fix | Delete

case 'create_backup':

[77] Fix | Delete

$result = $this->createBackup($dbm);

[78] Fix | Delete

break;

[79] Fix | Delete

case 'restore_backup':

[80] Fix | Delete

$result = $this->restoreBackup($dbm);

[81] Fix | Delete

break;

[82] Fix | Delete

case 'delete_backup':

[83] Fix | Delete

$result = $this->deleteBackup($dbm);

[84] Fix | Delete

break;

[85] Fix | Delete

}

[86] Fix | Delete

$conn->commit();

[87] Fix | Delete

}

[88] Fix | Delete

catch ( Exception $e){

[89] Fix | Delete

$conn->rollbackAndClose();

[90] Fix | Delete

error_log($e->getMessage());

[91] Fix | Delete

error_log($e->getTraceAsString());

[92] Fix | Delete

[93] Fix | Delete

switch ($_REQUEST['action']){

[94] Fix | Delete

case 'create_backup':

[95] Fix | Delete

$result = [ 'backed_up' => false ];

[96] Fix | Delete

break;

[97] Fix | Delete

case 'restore_backup':

[98] Fix | Delete

$result = [ 'restore' => false ];

[99] Fix | Delete

break;

[100] Fix | Delete

case 'delete_backup':

[101] Fix | Delete

$result = [ 'deleted' => false ];

[102] Fix | Delete

break;

[103] Fix | Delete

}

[104] Fix | Delete

}

[105] Fix | Delete

[106] Fix | Delete

}

[107] Fix | Delete

echo json_encode($result);

[108] Fix | Delete

die();

[109] Fix | Delete

}

[110] Fix | Delete

[111] Fix | Delete

/**

[112] Fix | Delete

* @param LADBManager $dbm

[113] Fix | Delete

*

[114] Fix | Delete

* @return array

[115] Fix | Delete

* @throws Exception

[116] Fix | Delete

*/

[117] Fix | Delete

public function createBackup ($dbm) {

[118] Fix | Delete

$all = [];

[119] Fix | Delete

$description = '';//TODO add description for snapshot

[120] Fix | Delete

[121] Fix | Delete

$conn = $dbm->conn();

[122] Fix | Delete

$options = $conn->getAll('SELECT `id`, `value` FROM ?n', $dbm->option_table_name);

[123] Fix | Delete

foreach ( $options as $option ) {

[124] Fix | Delete

$all[$option['id']] = $option['value'];

[125] Fix | Delete

}

[126] Fix | Delete

$all['streams'] = $dbm->streams();

[127] Fix | Delete

$all['sources'] = $dbm->sources();

[128] Fix | Delete

$result = gzcompress(serialize($all), 6);

[129] Fix | Delete

[130] Fix | Delete

$conn->query("INSERT INTO ?n (`description`, `settings`, `dump`, `version`) VALUES(?s, ?s, ?s, ?s)", $dbm->snapshot_table_name, $description, '', $result, $this->context['version']);

[131] Fix | Delete

[132] Fix | Delete

return [ 'backed_up' => true, 'result' => $conn->affectedRows() ];

[133] Fix | Delete

}

[134] Fix | Delete

[135] Fix | Delete

/**

[136] Fix | Delete

* @param LADBManager $dbm

[137] Fix | Delete

*

[138] Fix | Delete

* @return array

[139] Fix | Delete

* @throws Exception

[140] Fix | Delete

*/

[141] Fix | Delete

public function restoreBackup ($dbm) {

[142] Fix | Delete

$conn = $dbm->conn();

[143] Fix | Delete

if (false !== ($dump = $conn->getOne('SELECT `dump` FROM ?n WHERE id=?s', $dbm->snapshot_table_name, $_REQUEST['id']))){

[144] Fix | Delete

$all = gzuncompress($dump);

[145] Fix | Delete

$all = unserialize($all);

[146] Fix | Delete

unset($dump);

[147] Fix | Delete

[148] Fix | Delete

foreach ( $dbm->sources() as $id => $source ) {

[149] Fix | Delete

$dbm->deleteFeed($id);

[150] Fix | Delete

}

[151] Fix | Delete

[152] Fix | Delete

foreach ( $all['sources'] as $source ) {

[153] Fix | Delete

$dbm->modifySource($source);

[154] Fix | Delete

}

[155] Fix | Delete

unset($all['sources']);

[156] Fix | Delete

[157] Fix | Delete

$dbm->dataInit();

[158] Fix | Delete

[159] Fix | Delete

foreach ( $dbm->streams() as $stream ) {

[160] Fix | Delete

LADB::deleteStream($conn, $dbm->streams_table_name, $dbm->streams_sources_table_name, $stream['id']);

[161] Fix | Delete

}

[162] Fix | Delete

[163] Fix | Delete

foreach ( $all['streams'] as $stream ) {

[164] Fix | Delete

$obj = (object)$stream;

[165] Fix | Delete

LADB::setStream($conn, $dbm->streams_table_name, $dbm->streams_sources_table_name, $obj->id, $obj);

[166] Fix | Delete

$dbm->generateCss($obj);

[167] Fix | Delete

}

[168] Fix | Delete

unset($all['streams']);

[169] Fix | Delete

[170] Fix | Delete

foreach ( $all as $key => $value ) {

[171] Fix | Delete

$key = strpos($key, 'flow_flow_') === 0 ? str_replace('flow_flow_', '', $key) : $key;

[172] Fix | Delete

$dbm->setOption($key, $value);

[173] Fix | Delete

}

[174] Fix | Delete

$dbm->clean();

[175] Fix | Delete

return [ 'restore' => true ];

[176] Fix | Delete

}

[177] Fix | Delete

else {

[178] Fix | Delete

return [ 'found' => false ];

[179] Fix | Delete

}

[180] Fix | Delete

}

[181] Fix | Delete

[182] Fix | Delete

/**

[183] Fix | Delete

* @param LADBManager $dbm

[184] Fix | Delete

* @return array

[185] Fix | Delete

*/

[186] Fix | Delete

public function deleteBackup ($dbm) {

[187] Fix | Delete

$op = $dbm->conn()->query ('DELETE FROM ?n WHERE `id`=?s', $dbm->snapshot_table_name, $_REQUEST['id']);

[188] Fix | Delete

return [ 'deleted' => ( false !== $op) ];

[189] Fix | Delete

}

[190] Fix | Delete

}

[191] Fix | Delete