Edit File by line

<?php namespace la\core\cache;

[0] Fix | Delete

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

[1] Fix | Delete

[2] Fix | Delete

use Exception;

[3] Fix | Delete

[4] Fix | Delete

/**

[5] Fix | Delete

* FlowFlow.

[6] Fix | Delete

[7] Fix | Delete

* @package FlowFlow

[8] Fix | Delete

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

[9] Fix | Delete

[10] Fix | Delete

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

[11] Fix | Delete

* @copyright Looks Awesome

[12] Fix | Delete

[13] Fix | Delete

class LAAdminModerationCacheManager extends LACacheManager {

[14] Fix | Delete

function __construct( $context = null, $force = false ) {

[15] Fix | Delete

parent::__construct( $context, $force );

[16] Fix | Delete

}

[17] Fix | Delete

[18] Fix | Delete

public function moderate() {

[19] Fix | Delete

$conn = $this->db->conn();

[20] Fix | Delete

try {

[21] Fix | Delete

if ($conn->beginTransaction()){

[22] Fix | Delete

$hash = $_POST['hash'];

[23] Fix | Delete

$action = $_POST['moderation_action'];

[24] Fix | Delete

$stream_id = $_POST['stream'];

[25] Fix | Delete

$feeds = [];

[26] Fix | Delete

$stream = $this->db->getStream($stream_id);

[27] Fix | Delete

foreach ( $stream['feeds'] as $feed ) {

[28] Fix | Delete

$feeds[] = $feed['id'];

[29] Fix | Delete

}

[30] Fix | Delete

[31] Fix | Delete

$commonPartOfSql = $conn->parse("`feed_id` in (?a) AND `creation_index` <= ?i", $feeds, $this->decodeHash($hash));

[32] Fix | Delete

$additionalPartOfSql = $conn->parse("`post_status` = 'new'");

[33] Fix | Delete

$status = $action == 'new_posts_approve' ? 'approved' : 'disapproved';

[34] Fix | Delete

$this->db->setPostStatus($status, $conn->parse('WHERE ?p AND ?p', $commonPartOfSql, $additionalPartOfSql));

[35] Fix | Delete

if (isset($_POST['changed'])){

[36] Fix | Delete

$creation_index = time();

[37] Fix | Delete

$commonPartOfSql = $conn->parse("`feed_id` in (?a)", $feeds);

[38] Fix | Delete

foreach ( $_POST['changed'] as $id => $item ) {

[39] Fix | Delete

$status = ($item['approved'] === "true") ? 'approved' : 'disapproved';

[40] Fix | Delete

$this->db->setPostStatus($status, $conn->parse('WHERE ?p AND `post_id` = ?s', $commonPartOfSql, $id), $creation_index);

[41] Fix | Delete

}

[42] Fix | Delete

}

[43] Fix | Delete

$conn->commit();

[44] Fix | Delete

}

[45] Fix | Delete

$conn->rollbackAndClose();

[46] Fix | Delete

die();

[47] Fix | Delete

} catch ( Exception $e ){

[48] Fix | Delete

$conn->rollbackAndClose();

[49] Fix | Delete

die($e->getMessage());

[50] Fix | Delete

}

[51] Fix | Delete

}

[52] Fix | Delete

[53] Fix | Delete

protected function getGetFields() {

[54] Fix | Delete

$select = parent::getGetFields();

[55] Fix | Delete

$select .= ', post.post_status';

[56] Fix | Delete

return $select;

[57] Fix | Delete

}

[58] Fix | Delete

[59] Fix | Delete

protected function getGetFilters() {

[60] Fix | Delete

$args = parent::getGetFilters();

[61] Fix | Delete

$args[] = $this->db->conn()->parse('post.post_status != ?s', 'new');

[62] Fix | Delete

return $args;

[63] Fix | Delete

}

[64] Fix | Delete

[65] Fix | Delete

protected function buildPost( $row, $moderation = false ) {

[66] Fix | Delete

$post = parent::buildPost( $row, $moderation );

[67] Fix | Delete

$post->status = $row['post_status'];

[68] Fix | Delete

return $post;

[69] Fix | Delete

}

[70] Fix | Delete

[71] Fix | Delete

protected function getOnlyNew($moderation) {

[72] Fix | Delete

$result = parent::getOnlyNew($moderation);

[73] Fix | Delete

$filters = parent::getGetFilters();

[74] Fix | Delete

$filters[] = $this->db->conn()->parse('post.post_status = ?s', 'new');

[75] Fix | Delete

$resultFromDB = $this->db->getPostsIf2($this->getGetFields(), implode(' AND ', $filters));

[76] Fix | Delete

if (false === $resultFromDB) $resultFromDB = [];

[77] Fix | Delete

foreach ( $resultFromDB as $row ) {

[78] Fix | Delete

$result[] = $this->buildPost($row, $moderation[$row['feed_id']]);

[79] Fix | Delete

}

[80] Fix | Delete

return $result;

[81] Fix | Delete

}

[82] Fix | Delete

}

[83] Fix | Delete