insideout10 / wordlift-plugin

src/modules/dashboard/includes/Common/Cursor.php

Indentation +127 added lines, -127 removed lines

@@ -6,132 +6,132 @@
 
 class Cursor implements \Serializable, \JsonSerializable {
 
-	private $position;
-	private $element;
-	private $direction;
-
-	/**
-	 * @throws Exception when one of the parameters has an invalid value.
-	 */
-	public function __construct( $position, $element, $direction ) {
-		$this->set_position( $position );
-		$this->set_element( $element );
-		$this->set_direction( $direction );
-	}
-
-	public function get_position() {
-		return $this->position;
-	}
-
-	public function set_position( $value ) {
-		$this->position = $value;
-	}
-
-	public function get_element() {
-		return $this->element;
-	}
-
-	/**
-	 * @throws Exception when one of the parameters has an invalid value.
-	 */
-	public function set_element( $value ) {
-		if ( ! in_array( $value, array( 'INCLUDED', 'EXCLUDED' ), true ) ) {
-			throw new Exception( "Invalid value, only 'INCLUDED' or 'EXCLUDED' accepted." );
-		}
-
-		$this->element = $value;
-	}
-
-	public function get_direction() {
-		return $this->direction;
-	}
-
-	/**
-	 * @throws Exception when one of the parameters has an invalid value.
-	 */
-	public function set_direction( $value ) {
-		if ( ! in_array( $value, array( 'ASCENDING', 'DESCENDING' ), true ) ) {
-			throw new Exception( "Invalid value, only 'ASCENDING' or 'DESCENDING' accepted." );
-		}
-
-		$this->direction = $value;
-	}
-
-	public function to_base64_string() {
-		// The requirement for cursors is to be obfuscated.
-		// phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.obfuscation_base64_encode
-		return base64_encode( wp_json_encode( $this ) );
-	}
-
-	public static function from_base64_string( $value ) {
-		if ( ! is_string( $value ) ) {
-			return self::empty_cursor();
-		}
-
-		try {
-			// The requirement for cursors is to be obfuscated.
-			// phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.obfuscation_base64_decode
-			$json_string = base64_decode( $value, true );
-			$json_array  = json_decode( $json_string, true );
-
-			return self::from_array( $json_array );
-		} catch ( Exception $e ) {
-			return self::empty_cursor();
-		}
-	}
-
-	/**
-	 * @throws Exception when one of the parameters is not accepted.
-	 */
-	public static function from_array( $data ) {
-		return new Cursor( $data['position'], $data['element'], $data['direction'] );
-	}
-
-	public static function empty_cursor() {
-		return new self( null, 'INCLUDED', 'ASCENDING' );
-	}
-
-	public function __serialize() {
-		return array(
-			'position'  => $this->position,
-			'element'   => $this->element,
-			'direction' => $this->direction,
-		);
-	}
-
-	/**
-	 * Controls how the object is represented during PHP serialization.
-	 *
-	 * @return string The PHP serialized representation of the object.
-	 */
-	public function serialize() {
-		// phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.serialize_serialize
-		return serialize( $this->__serialize() );
-	}
-
-	/**
-	 * @throws Exception when unserialization fails.
-	 */
-	public function unserialize( $data ) {
-		// phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.serialize_unserialize
-		$this->__unserialize( unserialize( $data ) );
-	}
-
-	/**
-	 * @throws Exception when unserialization fails.
-	 */
-	public function __unserialize( array $data ) {
-		$this->set_position( $data['position'] );
-		$this->set_element( $data['element'] );
-		$this->set_direction( $data['direction'] );
-	}
-
-	public function jsonSerialize() {
-		return array(
-			'position'  => $this->position,
-			'element'   => $this->element,
-			'direction' => $this->direction,
-		);
-	}
+    private $position;
+    private $element;
+    private $direction;
+
+    /**
+     * @throws Exception when one of the parameters has an invalid value.
+     */
+    public function __construct( $position, $element, $direction ) {
+        $this->set_position( $position );
+        $this->set_element( $element );
+        $this->set_direction( $direction );
+    }
+
+    public function get_position() {
+        return $this->position;
+    }
+
+    public function set_position( $value ) {
+        $this->position = $value;
+    }
+
+    public function get_element() {
+        return $this->element;
+    }
+
+    /**
+     * @throws Exception when one of the parameters has an invalid value.
+     */
+    public function set_element( $value ) {
+        if ( ! in_array( $value, array( 'INCLUDED', 'EXCLUDED' ), true ) ) {
+            throw new Exception( "Invalid value, only 'INCLUDED' or 'EXCLUDED' accepted." );
+        }
+
+        $this->element = $value;
+    }
+
+    public function get_direction() {
+        return $this->direction;
+    }
+
+    /**
+     * @throws Exception when one of the parameters has an invalid value.
+     */
+    public function set_direction( $value ) {
+        if ( ! in_array( $value, array( 'ASCENDING', 'DESCENDING' ), true ) ) {
+            throw new Exception( "Invalid value, only 'ASCENDING' or 'DESCENDING' accepted." );
+        }
+
+        $this->direction = $value;
+    }
+
+    public function to_base64_string() {
+        // The requirement for cursors is to be obfuscated.
+        // phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.obfuscation_base64_encode
+        return base64_encode( wp_json_encode( $this ) );
+    }
+
+    public static function from_base64_string( $value ) {
+        if ( ! is_string( $value ) ) {
+            return self::empty_cursor();
+        }
+
+        try {
+            // The requirement for cursors is to be obfuscated.
+            // phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.obfuscation_base64_decode
+            $json_string = base64_decode( $value, true );
+            $json_array  = json_decode( $json_string, true );
+
+            return self::from_array( $json_array );
+        } catch ( Exception $e ) {
+            return self::empty_cursor();
+        }
+    }
+
+    /**
+     * @throws Exception when one of the parameters is not accepted.
+     */
+    public static function from_array( $data ) {
+        return new Cursor( $data['position'], $data['element'], $data['direction'] );
+    }
+
+    public static function empty_cursor() {
+        return new self( null, 'INCLUDED', 'ASCENDING' );
+    }
+
+    public function __serialize() {
+        return array(
+            'position'  => $this->position,
+            'element'   => $this->element,
+            'direction' => $this->direction,
+        );
+    }
+
+    /**
+     * Controls how the object is represented during PHP serialization.
+     *
+     * @return string The PHP serialized representation of the object.
+     */
+    public function serialize() {
+        // phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.serialize_serialize
+        return serialize( $this->__serialize() );
+    }
+
+    /**
+     * @throws Exception when unserialization fails.
+     */
+    public function unserialize( $data ) {
+        // phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.serialize_unserialize
+        $this->__unserialize( unserialize( $data ) );
+    }
+
+    /**
+     * @throws Exception when unserialization fails.
+     */
+    public function __unserialize( array $data ) {
+        $this->set_position( $data['position'] );
+        $this->set_element( $data['element'] );
+        $this->set_direction( $data['direction'] );
+    }
+
+    public function jsonSerialize() {
+        return array(
+            'position'  => $this->position,
+            'element'   => $this->element,
+            'direction' => $this->direction,
+        );
+    }
 
 }

Spacing +28 added lines, -28 removed lines

@@ -13,17 +13,17 @@ 
 	/**
 	 * @throws Exception when one of the parameters has an invalid value.
 	 */
-	public function __construct( $position, $element, $direction ) {
-		$this->set_position( $position );
-		$this->set_element( $element );
-		$this->set_direction( $direction );
+	public function __construct($position, $element, $direction) {
+		$this->set_position($position);
+		$this->set_element($element);
+		$this->set_direction($direction);
 	}
 
 	public function get_position() {
 		return $this->position;
 	}
 
-	public function set_position( $value ) {
+	public function set_position($value) {
 		$this->position = $value;
 	}
 
@@ -34,9 +34,9 @@ 
 	/**
 	 * @throws Exception when one of the parameters has an invalid value.
 	 */
-	public function set_element( $value ) {
-		if ( ! in_array( $value, array( 'INCLUDED', 'EXCLUDED' ), true ) ) {
-			throw new Exception( "Invalid value, only 'INCLUDED' or 'EXCLUDED' accepted." );
+	public function set_element($value) {
+		if ( ! in_array($value, array('INCLUDED', 'EXCLUDED'), true)) {
+			throw new Exception("Invalid value, only 'INCLUDED' or 'EXCLUDED' accepted.");
 		}
 
 		$this->element = $value;
@@ -49,9 +49,9 @@ 
 	/**
 	 * @throws Exception when one of the parameters has an invalid value.
 	 */
-	public function set_direction( $value ) {
-		if ( ! in_array( $value, array( 'ASCENDING', 'DESCENDING' ), true ) ) {
-			throw new Exception( "Invalid value, only 'ASCENDING' or 'DESCENDING' accepted." );
+	public function set_direction($value) {
+		if ( ! in_array($value, array('ASCENDING', 'DESCENDING'), true)) {
+			throw new Exception("Invalid value, only 'ASCENDING' or 'DESCENDING' accepted.");
 		}
 
 		$this->direction = $value;
@@ -60,22 +60,22 @@ 
 	public function to_base64_string() {
 		// The requirement for cursors is to be obfuscated.
 		// phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.obfuscation_base64_encode
-		return base64_encode( wp_json_encode( $this ) );
+		return base64_encode(wp_json_encode($this));
 	}
 
-	public static function from_base64_string( $value ) {
-		if ( ! is_string( $value ) ) {
+	public static function from_base64_string($value) {
+		if ( ! is_string($value)) {
 			return self::empty_cursor();
 		}
 
 		try {
 			// The requirement for cursors is to be obfuscated.
 			// phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.obfuscation_base64_decode
-			$json_string = base64_decode( $value, true );
-			$json_array  = json_decode( $json_string, true );
+			$json_string = base64_decode($value, true);
+			$json_array  = json_decode($json_string, true);
 
-			return self::from_array( $json_array );
-		} catch ( Exception $e ) {
+			return self::from_array($json_array);
+		} catch (Exception $e) {
 			return self::empty_cursor();
 		}
 	}
@@ -83,12 +83,12 @@ 
 	/**
 	 * @throws Exception when one of the parameters is not accepted.
 	 */
-	public static function from_array( $data ) {
-		return new Cursor( $data['position'], $data['element'], $data['direction'] );
+	public static function from_array($data) {
+		return new Cursor($data['position'], $data['element'], $data['direction']);
 	}
 
 	public static function empty_cursor() {
-		return new self( null, 'INCLUDED', 'ASCENDING' );
+		return new self(null, 'INCLUDED', 'ASCENDING');
 	}
 
 	public function __serialize() {
@@ -106,24 +106,24 @@ 
 	 */
 	public function serialize() {
 		// phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.serialize_serialize
-		return serialize( $this->__serialize() );
+		return serialize($this->__serialize());
 	}
 
 	/**
 	 * @throws Exception when unserialization fails.
 	 */
-	public function unserialize( $data ) {
+	public function unserialize($data) {
 		// phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.serialize_unserialize
-		$this->__unserialize( unserialize( $data ) );
+		$this->__unserialize(unserialize($data));
 	}
 
 	/**
 	 * @throws Exception when unserialization fails.
 	 */
-	public function __unserialize( array $data ) {
-		$this->set_position( $data['position'] );
-		$this->set_element( $data['element'] );
-		$this->set_direction( $data['direction'] );
+	public function __unserialize(array $data) {
+		$this->set_position($data['position']);
+		$this->set_element($data['element']);
+		$this->set_direction($data['direction']);
 	}
 
 	public function jsonSerialize() {

src/modules/dashboard/includes/Common/Cursor_Sort.php

Indentation +43 added lines, -43 removed lines

@@ -4,48 +4,48 @@
 
 class Cursor_Sort {
 
-	private static $sort_property_to_colname = array(
-		'date_modified_gmt' => 'post_modified_gmt',
-		'term_name'         => 'name',
-	);
-	/**
-	 * @var false|string
-	 */
-	private $sort_property;
-	/**
-	 * @var mixed
-	 */
-	private $sort_colname;
-	/**
-	 * @var string
-	 */
-	private $sort_direction;
-
-	public function __construct( $sort ) {
-		$this->sort_property  = substr( $sort, 1 );
-		$this->sort_colname   = isset( self::$sort_property_to_colname[ $this->sort_property ] ) ? self::$sort_property_to_colname[ $this->sort_property ] : $this->sort_property;
-		$this->sort_direction = substr( $sort, 0, 1 ) === '+' ? 'ASC' : 'DESC';
-	}
-
-	/**
-	 * @return false|string
-	 */
-	public function get_sort_property() {
-		return $this->sort_property;
-	}
-
-	/**
-	 * @return false|mixed|string
-	 */
-	public function get_sort_colname() {
-		return $this->sort_colname;
-	}
-
-	/**
-	 * @return string
-	 */
-	public function get_sort_direction() {
-		return $this->sort_direction;
-	}
+    private static $sort_property_to_colname = array(
+        'date_modified_gmt' => 'post_modified_gmt',
+        'term_name'         => 'name',
+    );
+    /**
+     * @var false|string
+     */
+    private $sort_property;
+    /**
+     * @var mixed
+     */
+    private $sort_colname;
+    /**
+     * @var string
+     */
+    private $sort_direction;
+
+    public function __construct( $sort ) {
+        $this->sort_property  = substr( $sort, 1 );
+        $this->sort_colname   = isset( self::$sort_property_to_colname[ $this->sort_property ] ) ? self::$sort_property_to_colname[ $this->sort_property ] : $this->sort_property;
+        $this->sort_direction = substr( $sort, 0, 1 ) === '+' ? 'ASC' : 'DESC';
+    }
+
+    /**
+     * @return false|string
+     */
+    public function get_sort_property() {
+        return $this->sort_property;
+    }
+
+    /**
+     * @return false|mixed|string
+     */
+    public function get_sort_colname() {
+        return $this->sort_colname;
+    }
+
+    /**
+     * @return string
+     */
+    public function get_sort_direction() {
+        return $this->sort_direction;
+    }
 
 }

Spacing +4 added lines, -4 removed lines

@@ -20,10 +20,10 @@
 	 */
 	private $sort_direction;
 
-	public function __construct( $sort ) {
-		$this->sort_property  = substr( $sort, 1 );
-		$this->sort_colname   = isset( self::$sort_property_to_colname[ $this->sort_property ] ) ? self::$sort_property_to_colname[ $this->sort_property ] : $this->sort_property;
-		$this->sort_direction = substr( $sort, 0, 1 ) === '+' ? 'ASC' : 'DESC';
+	public function __construct($sort) {
+		$this->sort_property  = substr($sort, 1);
+		$this->sort_colname   = isset(self::$sort_property_to_colname[$this->sort_property]) ? self::$sort_property_to_colname[$this->sort_property] : $this->sort_property;
+		$this->sort_direction = substr($sort, 0, 1) === '+' ? 'ASC' : 'DESC';
 	}
 
 	/**

src/modules/dashboard/includes/Common/Page.php

Indentation +58 added lines, -58 removed lines

@@ -4,70 +4,70 @@
 
 class Page implements \Serializable, \JsonSerializable {
 
-	/**
-	 * @var mixed
-	 */
-	private $items;
+    /**
+     * @var mixed
+     */
+    private $items;
 
-	private $self;
-	private $first;
-	private $prev;
-	private $next;
-	private $last;
+    private $self;
+    private $first;
+    private $prev;
+    private $next;
+    private $last;
 
-	public function __construct( $items, $self, $first, $prev, $next, $last ) {
-		$this->items = $items;
-		$this->self  = $self;
-		$this->first = $first;
-		$this->prev  = $prev;
-		$this->next  = $next;
-		$this->last  = $last;
-	}
+    public function __construct( $items, $self, $first, $prev, $next, $last ) {
+        $this->items = $items;
+        $this->self  = $self;
+        $this->first = $first;
+        $this->prev  = $prev;
+        $this->next  = $next;
+        $this->last  = $last;
+    }
 
-	public function __serialize() {
-		return array(
-			'self'  => $this->self,
-			'first' => $this->first,
-			'prev'  => $this->prev,
-			'next'  => $this->next,
-			'last'  => $this->last,
-			'items' => $this->items,
-		);
-	}
+    public function __serialize() {
+        return array(
+            'self'  => $this->self,
+            'first' => $this->first,
+            'prev'  => $this->prev,
+            'next'  => $this->next,
+            'last'  => $this->last,
+            'items' => $this->items,
+        );
+    }
 
-	/**
-	 * Controls how the object is represented during PHP serialization.
-	 *
-	 * @return string The PHP serialized representation of the object.
-	 */
-	public function serialize() {
-		// phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.serialize_serialize
-		return serialize( $this->__serialize() );
-	}
+    /**
+     * Controls how the object is represented during PHP serialization.
+     *
+     * @return string The PHP serialized representation of the object.
+     */
+    public function serialize() {
+        // phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.serialize_serialize
+        return serialize( $this->__serialize() );
+    }
 
-	public function unserialize( $data ) {
-		// phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.serialize_unserialize
-		$this->__unserialize( unserialize( $data ) );
-	}
+    public function unserialize( $data ) {
+        // phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.serialize_unserialize
+        $this->__unserialize( unserialize( $data ) );
+    }
 
-	public function __unserialize( array $data ) {
-		$this->self  = $data['self'];
-		$this->first = $data['first'];
-		$this->prev  = $data['prev'];
-		$this->next  = $data['next'];
-		$this->last  = $data['last'];
-		$this->items = $data['items'];
-	}
+    public function __unserialize( array $data ) {
+        $this->self  = $data['self'];
+        $this->first = $data['first'];
+        $this->prev  = $data['prev'];
+        $this->next  = $data['next'];
+        $this->last  = $data['last'];
+        $this->items = $data['items'];
+    }
 
-	public function jsonSerialize() {
-		return array(
-			'self'  => $this->self,
-			'first' => $this->first,
-			'prev'  => $this->prev,
-			'next'  => $this->next,
-			'last'  => $this->last,
-			'items' => $this->items,
-		);
-	}
+    public function jsonSerialize() {
+        return array(
+            'self'  => $this->self,
+            'first' => $this->first,
+            'prev'  => $this->prev,
+            'next'  => $this->next,
+            'last'  => $this->last,
+            'items' => $this->items,
+        );
+    }
 
 }

Spacing +5 added lines, -5 removed lines

@@ -15,7 +15,7 @@ 
 	private $next;
 	private $last;
 
-	public function __construct( $items, $self, $first, $prev, $next, $last ) {
+	public function __construct($items, $self, $first, $prev, $next, $last) {
 		$this->items = $items;
 		$this->self  = $self;
 		$this->first = $first;
@@ -42,15 +42,15 @@ 
 	 */
 	public function serialize() {
 		// phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.serialize_serialize
-		return serialize( $this->__serialize() );
+		return serialize($this->__serialize());
 	}
 
-	public function unserialize( $data ) {
+	public function unserialize($data) {
 		// phpcs:ignore WordPress.PHP.DiscouragedPHPFunctions.serialize_unserialize
-		$this->__unserialize( unserialize( $data ) );
+		$this->__unserialize(unserialize($data));
 	}
 
-	public function __unserialize( array $data ) {
+	public function __unserialize(array $data) {
 		$this->self  = $data['self'];
 		$this->first = $data['first'];
 		$this->prev  = $data['prev'];

src/modules/dashboard/includes/Term_Entity_Match/Term_Query.php

Indentation +181 added lines, -181 removed lines

@@ -7,52 +7,52 @@ 
 use WP_REST_Request;
 
 class Term_Query {
-	/**
-	 * @var WP_REST_Request
-	 */
-	private $request;
-	/**
-	 * @var mixed
-	 */
-	private $position;
-	/**
-	 * @var mixed
-	 */
-	private $element;
-	/**
-	 * @var mixed
-	 */
-	private $direction;
-
-	private $sort;
-
-	private $sortby;
-	/**
-	 * @var mixed
-	 */
-	private $limit;
-
-	/** @var Cursor_Sort $cursor_sort */
-	private $cursor_sort;
-
-	/**
-	 * @param WP_REST_Request $request
-	 * @param Cursor          $cursor
-	 */
-	public function __construct( $request, $cursor, $cursor_sort, $limit ) {
-		global $wpdb;
-
-		$this->request     = $request;
-		$this->position    = $cursor->get_position();
-		$this->element     = $cursor->get_element();
-		$this->direction   = $cursor->get_direction();
-		$this->limit       = $limit;
-		$this->cursor_sort = $cursor_sort;
-
-		$this->set_sort();
-
-		// the `term_name` is required for sort.
-		$this->sql = "
+    /**
+     * @var WP_REST_Request
+     */
+    private $request;
+    /**
+     * @var mixed
+     */
+    private $position;
+    /**
+     * @var mixed
+     */
+    private $element;
+    /**
+     * @var mixed
+     */
+    private $direction;
+
+    private $sort;
+
+    private $sortby;
+    /**
+     * @var mixed
+     */
+    private $limit;
+
+    /** @var Cursor_Sort $cursor_sort */
+    private $cursor_sort;
+
+    /**
+     * @param WP_REST_Request $request
+     * @param Cursor          $cursor
+     */
+    public function __construct( $request, $cursor, $cursor_sort, $limit ) {
+        global $wpdb;
+
+        $this->request     = $request;
+        $this->position    = $cursor->get_position();
+        $this->element     = $cursor->get_element();
+        $this->direction   = $cursor->get_direction();
+        $this->limit       = $limit;
+        $this->cursor_sort = $cursor_sort;
+
+        $this->set_sort();
+
+        // the `term_name` is required for sort.
+        $this->sql = "
 			SELECT t.term_id as id,
 				e.about_jsonld as match_jsonld,
 				t.name,
@@ -66,140 +66,140 @@ 
 			WHERE 1=1
 		";
 
-		$this->cursor();
-		$this->has_match();
-		$this->term_contains();
-		$this->taxonomies();
-		$this->sort();
-		$this->limit();
-
-	}
-
-	public function get_results() {
-		global $wpdb;
-
-		// The `sql` is prepared in each delegated function in this class.
-		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
-		$items = $wpdb->get_results( $this->sql );
-
-		$sort = ( $this->sort === 'ASC' ? SORT_ASC : SORT_DESC );
-		array_multisort( array_column( $items, $this->cursor_sort->get_sort_property() ), $sort, $items );
-		$items = array_map( array( $this, 'map_item' ), $items );
-
-		return $items;
-	}
-
-	public function map_item( $item ) {
-		$item->match_name = $this->get_match_name( $item->match_jsonld );
-
-		return $item;
-	}
-
-	private function get_match_name( $jsonld ) {
-		$data = json_decode( $jsonld, true );
-		if ( ! $data || ! array_key_exists( 'name', $data ) ) {
-			return null;
-		}
-
-		return $data['name'];
-	}
-
-	private function post_types() {
-		$post_types = $this->request->has_param( 'post_types' )
-			? (array) $this->request->get_param( 'post_types' )
-			: array( 'post', 'page' );
-		$value      = array_map( 'esc_sql', $post_types );
-		$this->sql .= " AND p.post_type IN ( '" . implode( "', '", $value ) . "' )";
-	}
-
-	private function limit() {
-		$value      = is_numeric( $this->limit ) ? $this->limit : 10;
-		$this->sql .= ' LIMIT ' . esc_sql( $value );
-	}
-
-	private function has_match() {
-		if ( ! $this->request->has_param( 'has_match' ) ) {
-			return;
-		}
-
-		$value = (bool) $this->request->get_param( 'has_match' );
-
-		if ( $value ) {
-			$this->sql .= ' AND e.about_jsonld IS NOT NULL';
-		} else {
-			$this->sql .= ' AND e.about_jsonld IS NULL';
-		}
-	}
-
-	private function sort() {
-		switch ( $this->direction . '$' . $this->sort ) {
-			case 'ASCENDING$ASC':
-			case 'DESCENDING$DESC':
-				$sort = 'ASC';
-				break;
-			case 'ASCENDING$DESC':
-			case 'DESCENDING$ASC':
-				$sort = 'DESC';
-				break;
-		}
-
-		$this->sql .= ' ORDER BY t.' . $this->sortby . ' ' . $sort;
-	}
-
-	private function cursor() {
-		if ( ! isset( $this->position ) ) {
-			return;
-		}
-
-		switch ( $this->direction . '$' . $this->sort ) {
-			case 'ASCENDING$ASC':
-			case 'DESCENDING$DESC':
-				$condition = '>';
-				break;
-			case 'ASCENDING$DESC':
-			case 'DESCENDING$ASC':
-				$condition = '<';
-				break;
-		}
-
-		$condition .= ( $this->element === 'INCLUDED' ? '=' : '' );
-		global $wpdb;
-		// We control the vars in this method.
-		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
-		$this->sql .= $wpdb->prepare( ' AND t.' . esc_sql( $this->sortby ) . ' ' . $condition . ' %s', $this->position );
-	}
-
-	private function set_sort() {
-		$sortby_to_col = array(
-			// sort param  col
-			'term_name' => 'name',
-		);
-
-		$value = $this->request->has_param( 'sort' )
-			? $this->request->get_param( 'sort' )
-			: '+term_name';
-
-		$sortby       = substr( $value, 1 );
-		$this->sortby = isset( $sortby_to_col[ $sortby ] ) ? $sortby_to_col[ $sortby ] : $sortby;
-		$this->sort   = substr( $value, 0, 1 ) === '+' ? 'ASC' : 'DESC';
-	}
-
-	private function term_contains() {
-		if ( ! $this->request->has_param( 'term_contains' ) ) {
-			return;
-		}
-
-		global $wpdb;
-		$value      = $this->request->get_param( 'term_contains' );
-		$this->sql .= $wpdb->prepare( ' and t . name LIKE %s', '%' . esc_sql( $value ) . '%' );
-	}
-
-	private function taxonomies() {
-		$taxonomies = $this->request->has_param( 'taxonomies' )
-			? (array) $this->request->get_param( 'taxonomies' )
-			: array( 'post_tag', 'category' );
-		$value      = array_map( 'esc_sql', $taxonomies );
-		$this->sql .= " AND tt.taxonomy IN ( '" . implode( "', '", $value ) . "' )";
-	}
+        $this->cursor();
+        $this->has_match();
+        $this->term_contains();
+        $this->taxonomies();
+        $this->sort();
+        $this->limit();
+
+    }
+
+    public function get_results() {
+        global $wpdb;
+
+        // The `sql` is prepared in each delegated function in this class.
+        // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+        $items = $wpdb->get_results( $this->sql );
+
+        $sort = ( $this->sort === 'ASC' ? SORT_ASC : SORT_DESC );
+        array_multisort( array_column( $items, $this->cursor_sort->get_sort_property() ), $sort, $items );
+        $items = array_map( array( $this, 'map_item' ), $items );
+
+        return $items;
+    }
+
+    public function map_item( $item ) {
+        $item->match_name = $this->get_match_name( $item->match_jsonld );
+
+        return $item;
+    }
+
+    private function get_match_name( $jsonld ) {
+        $data = json_decode( $jsonld, true );
+        if ( ! $data || ! array_key_exists( 'name', $data ) ) {
+            return null;
+        }
+
+        return $data['name'];
+    }
+
+    private function post_types() {
+        $post_types = $this->request->has_param( 'post_types' )
+            ? (array) $this->request->get_param( 'post_types' )
+            : array( 'post', 'page' );
+        $value      = array_map( 'esc_sql', $post_types );
+        $this->sql .= " AND p.post_type IN ( '" . implode( "', '", $value ) . "' )";
+    }
+
+    private function limit() {
+        $value      = is_numeric( $this->limit ) ? $this->limit : 10;
+        $this->sql .= ' LIMIT ' . esc_sql( $value );
+    }
+
+    private function has_match() {
+        if ( ! $this->request->has_param( 'has_match' ) ) {
+            return;
+        }
+
+        $value = (bool) $this->request->get_param( 'has_match' );
+
+        if ( $value ) {
+            $this->sql .= ' AND e.about_jsonld IS NOT NULL';
+        } else {
+            $this->sql .= ' AND e.about_jsonld IS NULL';
+        }
+    }
+
+    private function sort() {
+        switch ( $this->direction . '$' . $this->sort ) {
+            case 'ASCENDING$ASC':
+            case 'DESCENDING$DESC':
+                $sort = 'ASC';
+                break;
+            case 'ASCENDING$DESC':
+            case 'DESCENDING$ASC':
+                $sort = 'DESC';
+                break;
+        }
+
+        $this->sql .= ' ORDER BY t.' . $this->sortby . ' ' . $sort;
+    }
+
+    private function cursor() {
+        if ( ! isset( $this->position ) ) {
+            return;
+        }
+
+        switch ( $this->direction . '$' . $this->sort ) {
+            case 'ASCENDING$ASC':
+            case 'DESCENDING$DESC':
+                $condition = '>';
+                break;
+            case 'ASCENDING$DESC':
+            case 'DESCENDING$ASC':
+                $condition = '<';
+                break;
+        }
+
+        $condition .= ( $this->element === 'INCLUDED' ? '=' : '' );
+        global $wpdb;
+        // We control the vars in this method.
+        // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
+        $this->sql .= $wpdb->prepare( ' AND t.' . esc_sql( $this->sortby ) . ' ' . $condition . ' %s', $this->position );
+    }
+
+    private function set_sort() {
+        $sortby_to_col = array(
+            // sort param  col
+            'term_name' => 'name',
+        );
+
+        $value = $this->request->has_param( 'sort' )
+            ? $this->request->get_param( 'sort' )
+            : '+term_name';
+
+        $sortby       = substr( $value, 1 );
+        $this->sortby = isset( $sortby_to_col[ $sortby ] ) ? $sortby_to_col[ $sortby ] : $sortby;
+        $this->sort   = substr( $value, 0, 1 ) === '+' ? 'ASC' : 'DESC';
+    }
+
+    private function term_contains() {
+        if ( ! $this->request->has_param( 'term_contains' ) ) {
+            return;
+        }
+
+        global $wpdb;
+        $value      = $this->request->get_param( 'term_contains' );
+        $this->sql .= $wpdb->prepare( ' and t . name LIKE %s', '%' . esc_sql( $value ) . '%' );
+    }
+
+    private function taxonomies() {
+        $taxonomies = $this->request->has_param( 'taxonomies' )
+            ? (array) $this->request->get_param( 'taxonomies' )
+            : array( 'post_tag', 'category' );
+        $value      = array_map( 'esc_sql', $taxonomies );
+        $this->sql .= " AND tt.taxonomy IN ( '" . implode( "', '", $value ) . "' )";
+    }
 
 }

Spacing +39 added lines, -39 removed lines

@@ -39,7 +39,7 @@ 
 	 * @param WP_REST_Request $request
 	 * @param Cursor          $cursor
 	 */
-	public function __construct( $request, $cursor, $cursor_sort, $limit ) {
+	public function __construct($request, $cursor, $cursor_sort, $limit) {
 		global $wpdb;
 
 		$this->request     = $request;
@@ -80,24 +80,24 @@ 
 
 		// The `sql` is prepared in each delegated function in this class.
 		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
-		$items = $wpdb->get_results( $this->sql );
+		$items = $wpdb->get_results($this->sql);
 
-		$sort = ( $this->sort === 'ASC' ? SORT_ASC : SORT_DESC );
-		array_multisort( array_column( $items, $this->cursor_sort->get_sort_property() ), $sort, $items );
-		$items = array_map( array( $this, 'map_item' ), $items );
+		$sort = ($this->sort === 'ASC' ? SORT_ASC : SORT_DESC);
+		array_multisort(array_column($items, $this->cursor_sort->get_sort_property()), $sort, $items);
+		$items = array_map(array($this, 'map_item'), $items);
 
 		return $items;
 	}
 
-	public function map_item( $item ) {
-		$item->match_name = $this->get_match_name( $item->match_jsonld );
+	public function map_item($item) {
+		$item->match_name = $this->get_match_name($item->match_jsonld);
 
 		return $item;
 	}
 
-	private function get_match_name( $jsonld ) {
-		$data = json_decode( $jsonld, true );
-		if ( ! $data || ! array_key_exists( 'name', $data ) ) {
+	private function get_match_name($jsonld) {
+		$data = json_decode($jsonld, true);
+		if ( ! $data || ! array_key_exists('name', $data)) {
 			return null;
 		}
 
@@ -105,26 +105,26 @@ 
 	}
 
 	private function post_types() {
-		$post_types = $this->request->has_param( 'post_types' )
-			? (array) $this->request->get_param( 'post_types' )
-			: array( 'post', 'page' );
-		$value      = array_map( 'esc_sql', $post_types );
-		$this->sql .= " AND p.post_type IN ( '" . implode( "', '", $value ) . "' )";
+		$post_types = $this->request->has_param('post_types')
+			? (array) $this->request->get_param('post_types')
+			: array('post', 'page');
+		$value      = array_map('esc_sql', $post_types);
+		$this->sql .= " AND p.post_type IN ( '".implode("', '", $value)."' )";
 	}
 
 	private function limit() {
-		$value      = is_numeric( $this->limit ) ? $this->limit : 10;
-		$this->sql .= ' LIMIT ' . esc_sql( $value );
+		$value      = is_numeric($this->limit) ? $this->limit : 10;
+		$this->sql .= ' LIMIT '.esc_sql($value);
 	}
 
 	private function has_match() {
-		if ( ! $this->request->has_param( 'has_match' ) ) {
+		if ( ! $this->request->has_param('has_match')) {
 			return;
 		}
 
-		$value = (bool) $this->request->get_param( 'has_match' );
+		$value = (bool) $this->request->get_param('has_match');
 
-		if ( $value ) {
+		if ($value) {
 			$this->sql .= ' AND e.about_jsonld IS NOT NULL';
 		} else {
 			$this->sql .= ' AND e.about_jsonld IS NULL';
@@ -132,7 +132,7 @@ 
 	}
 
 	private function sort() {
-		switch ( $this->direction . '$' . $this->sort ) {
+		switch ($this->direction.'$'.$this->sort) {
 			case 'ASCENDING$ASC':
 			case 'DESCENDING$DESC':
 				$sort = 'ASC';
@@ -143,15 +143,15 @@ 
 				break;
 		}
 
-		$this->sql .= ' ORDER BY t.' . $this->sortby . ' ' . $sort;
+		$this->sql .= ' ORDER BY t.'.$this->sortby.' '.$sort;
 	}
 
 	private function cursor() {
-		if ( ! isset( $this->position ) ) {
+		if ( ! isset($this->position)) {
 			return;
 		}
 
-		switch ( $this->direction . '$' . $this->sort ) {
+		switch ($this->direction.'$'.$this->sort) {
 			case 'ASCENDING$ASC':
 			case 'DESCENDING$DESC':
 				$condition = '>';
@@ -162,11 +162,11 @@ 
 				break;
 		}
 
-		$condition .= ( $this->element === 'INCLUDED' ? '=' : '' );
+		$condition .= ($this->element === 'INCLUDED' ? '=' : '');
 		global $wpdb;
 		// We control the vars in this method.
 		// phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
-		$this->sql .= $wpdb->prepare( ' AND t.' . esc_sql( $this->sortby ) . ' ' . $condition . ' %s', $this->position );
+		$this->sql .= $wpdb->prepare(' AND t.'.esc_sql($this->sortby).' '.$condition.' %s', $this->position);
 	}
 
 	private function set_sort() {
@@ -175,31 +175,31 @@ 
 			'term_name' => 'name',
 		);
 
-		$value = $this->request->has_param( 'sort' )
-			? $this->request->get_param( 'sort' )
+		$value = $this->request->has_param('sort')
+			? $this->request->get_param('sort')
 			: '+term_name';
 
-		$sortby       = substr( $value, 1 );
-		$this->sortby = isset( $sortby_to_col[ $sortby ] ) ? $sortby_to_col[ $sortby ] : $sortby;
-		$this->sort   = substr( $value, 0, 1 ) === '+' ? 'ASC' : 'DESC';
+		$sortby       = substr($value, 1);
+		$this->sortby = isset($sortby_to_col[$sortby]) ? $sortby_to_col[$sortby] : $sortby;
+		$this->sort   = substr($value, 0, 1) === '+' ? 'ASC' : 'DESC';
 	}
 
 	private function term_contains() {
-		if ( ! $this->request->has_param( 'term_contains' ) ) {
+		if ( ! $this->request->has_param('term_contains')) {
 			return;
 		}
 
 		global $wpdb;
-		$value      = $this->request->get_param( 'term_contains' );
-		$this->sql .= $wpdb->prepare( ' and t . name LIKE %s', '%' . esc_sql( $value ) . '%' );
+		$value      = $this->request->get_param('term_contains');
+		$this->sql .= $wpdb->prepare(' and t . name LIKE %s', '%'.esc_sql($value).'%');
 	}
 
 	private function taxonomies() {
-		$taxonomies = $this->request->has_param( 'taxonomies' )
-			? (array) $this->request->get_param( 'taxonomies' )
-			: array( 'post_tag', 'category' );
-		$value      = array_map( 'esc_sql', $taxonomies );
-		$this->sql .= " AND tt.taxonomy IN ( '" . implode( "', '", $value ) . "' )";
+		$taxonomies = $this->request->has_param('taxonomies')
+			? (array) $this->request->get_param('taxonomies')
+			: array('post_tag', 'category');
+		$value      = array_map('esc_sql', $taxonomies);
+		$this->sql .= " AND tt.taxonomy IN ( '".implode("', '", $value)."' )";
 	}
 
 }

src/modules/dashboard/includes/Term_Entity_Match/Term_Entity_Match_Rest_Controller.php

Indentation +298 added lines, -298 removed lines

@@ -21,303 +21,303 @@
  */
 class Term_Entity_Match_Rest_Controller extends \WP_REST_Controller {
 
-	/**
-	 * @var Post_Entity_Match_Service
-	 */
-	private $match_service;
-
-	/**
-	 * Construct
-	 *
-	 * @param $match_service
-	 */
-	public function __construct( $match_service ) {
-		$this->match_service = $match_service;
-	}
-
-	public function register_hooks() {
-		add_action( 'rest_api_init', array( $this, 'register_routes' ) );
-	}
-
-	/**
-	 * Register the routes for the objects of the controller.
-	 */
-	public function register_routes() {
-		// Get term matches by taxonomy name
-		register_rest_route(
-			WL_REST_ROUTE_DEFAULT_NAMESPACE,
-			'/term-matches',
-			array(
-				'methods'             => 'GET',
-				'callback'            => array( $this, 'get_term_matches' ),
-				'args'                => array(
-					'cursor'        => array(
-						'type'              => 'string',
-						// 'default'           => Cursor::EMPTY_CURSOR_AS_BASE64_STRING,
-						'validate_callback' => 'rest_validate_request_arg',
-						// 'sanitize_callback' => array( Cursor::class, 'rest_sanitize_request_arg' ),
-					),
-					'limit'         => array(
-						'type'              => 'integer',
-						'validate_callback' => 'rest_validate_request_arg',
-						'default'           => 10,
-						'minimum'           => 1,
-						'maximum'           => 100,
-						'sanitize_callback' => 'absint',
-					),
-					'taxonomies'    => array(
-						'type'              => 'array',
-						'validate_callback' => 'rest_validate_request_arg',
-					),
-					'has_match'     => array(
-						'type'              => 'boolean',
-						'required'          => false,
-						'validate_callback' => 'rest_validate_request_arg',
-					),
-					'term_contains' => array(
-						'type'              => 'string',
-						'required'          => false,
-						'validate_callback' => 'rest_validate_request_arg',
-					),
-					'sort'          => array(
-						'type'              => 'string',
-						'required'          => 'false',
-						'enum'              => array(
-							'+term_name',
-							'-term_name',
-							'+entity_name',
-							'-entity_name',
-							'+occurrences',
-							'-occurrences',
-						),
-						'validate_callback' => 'rest_validate_request_arg',
-					),
-				),
-				'permission_callback' => function () {
-					return current_user_can( 'manage_options' );
-				},
-			)
-		);
-
-		// Create a new match for a term
-		register_rest_route(
-			WL_REST_ROUTE_DEFAULT_NAMESPACE,
-			'/term-matches/(?P<term_id>\d+)/matches',
-			array(
-				'methods'             => 'POST',
-				'callback'            => array( $this, 'create_term_match' ),
-				'args'                => array(
-					'term_id' => array(
-						'required'          => true,
-						'validate_callback' => 'rest_validate_request_arg',
-					),
-				),
-				'permission_callback' => function () {
-					return current_user_can( 'manage_options' );
-				},
-			)
-		);
-
-		// Update an existing term match
-		register_rest_route(
-			WL_REST_ROUTE_DEFAULT_NAMESPACE,
-			'/term-matches/(?P<term_id>\d+)/matches/(?P<match_id>\d+)',
-			array(
-				'methods'             => 'PUT',
-				'callback'            => array( $this, 'update_term_match' ),
-				'args'                => array(
-					'term_id'  => array(
-						'required'          => true,
-						'validate_callback' => 'rest_validate_request_arg',
-					),
-					'match_id' => array(
-						'required'          => true,
-						'validate_callback' => 'rest_validate_request_arg',
-					),
-				),
-				'permission_callback' => function () {
-					return current_user_can( 'manage_options' );
-				},
-			)
-		);
-	}
-
-	public function get_term_matches( $request ) {
-		$limit       = $request->has_param( 'limit' ) ? $request->get_param( 'limit' ) : 10;
-		$cursor      = $request->has_param( 'cursor' )
-			? Cursor::from_base64_string( $request->get_param( 'cursor' ) )
-			: Cursor::empty_cursor();
-		$cursor_sort = new Cursor_Sort(
-			$request->has_param( 'sort' ) ? $request->get_param( 'sort' ) : '+term_name'
-		);
-
-		$query = new Term_Query( $request, $cursor, $cursor_sort, $limit + 1 );
-
-		$results       = $query->get_results();
-		$items         = $cursor->get_direction() === 'ASCENDING'
-			? array_slice( $results, 0, min( count( $results ), $limit ) )
-			: array_slice( $results, count( $results ) > $limit ? 1 : 0 );
-		$position      = current( $items )->{$cursor_sort->get_sort_property()};
-		$next_position = end( $items )->{$cursor_sort->get_sort_property()};
-
-		$self  = $cursor;
-		$first = new Cursor( null, 'INCLUDED', 'ASCENDING' );
-		$last  = new Cursor( null, 'INCLUDED', 'DESCENDING' );
-
-		return new Page(
-			$items,
-			$self->to_base64_string(),
-			$first->to_base64_string(),
-			$this->get_prev_cursor_as_base64_string( $cursor, $results, $limit, $position ),
-			$this->get_next_cursor_as_base64_string( $cursor, $results, $limit, $next_position ),
-			$last->to_base64_string()
-		);
-	}
-
-	/**
-	 * @param Cursor $cursor
-	 *
-	 * @return string|null
-	 * @throws Exception when one of the called functions throws an exception.
-	 */
-	private function get_prev_cursor_as_base64_string( $cursor, $results, $limit, $position ) {
-		if ( ( $cursor->get_direction() === 'ASCENDING' && $cursor->get_position() !== null ) || ( $cursor->get_direction() === 'DESCENDING' && count( $results ) > $limit ) ) {
-			$cursor = new Cursor( $position, 'EXCLUDED', 'DESCENDING' );
-
-			return $cursor->to_base64_string();
-		}
-
-		return null;
-	}
-
-	/**
-	 * @param Cursor $cursor
-	 *
-	 * @return string|null
-	 * @throws Exception when one of the called functions throws an exception.
-	 */
-	private function get_next_cursor_as_base64_string( $cursor, $results, $limit, $position ) {
-		if ( ( $cursor->get_direction() === 'DESCENDING' && $cursor->get_position() !== null ) || ( $cursor->get_direction() === 'ASCENDING' && count( $results ) > $limit ) ) {
-			$cursor = new Cursor( $position, 'EXCLUDED', 'ASCENDING' );
-
-			return $cursor->to_base64_string();
-		}
-
-		return null;
-	}
-
-	/**
-	 * Get the term matches by taxonomy name.
-	 *
-	 * @param  $request \WP_REST_Request
-	 *
-	 * @throws \Exception If there was a problem getting the match.
-	 */
-	public function get_term_matches_legacy( $request ) {
-
-		$cursor = $request->get_param( 'cursor' );
-		if ( $request->has_param( 'limit' ) ) {
-			$cursor['limit'] = $request->get_param( 'limit' );
-		}
-		if ( $request->has_param( 'sort' ) ) {
-			$cursor['sort'] = $request->get_param( 'sort' );
-		}
-		if ( $request->has_param( 'taxonomies' ) ) {
-			$cursor['query']['taxonomies'] = $request->get_param( 'taxonomies' );
-		}
-		if ( $request->has_param( 'has_match' ) ) {
-			$cursor['query']['has_match'] = $request->get_param( 'has_match' );
-		}
-		if ( $request->has_param( 'term_contains' ) ) {
-			$cursor['query']['term_contains'] = $request->get_param( 'term_contains' );
-		}
-
-		// Query.
-		$taxonomies = isset( $cursor['query']['taxonomies'] ) ? $cursor['query']['taxonomies'] : apply_filters(
-			'wl_dashboard__post_entity_match__taxonomies',
-			array(
-				'post_tag',
-				'category',
-			)
-		);
-
-		$has_match     = isset( $cursor['query']['has_match'] ) ? $cursor['query']['has_match'] : null;
-		$term_contains = isset( $cursor['query']['term_contains'] ) ? $cursor['query']['term_contains'] : null;
-
-		$items = $this->match_service->list_items(
-			array(
-				// Query
-				'taxonomies'    => $taxonomies,
-				'has_match'     => $has_match,
-				'term_contains' => $term_contains,
-				// Cursor-Pagination
-				'position'      => $cursor['position'],
-				'element'       => $cursor['element'],
-				'direction'     => $cursor['direction'],
-				// `+1` to check if we have other results.
-				'limit'         => $cursor['limit'] + 1,
-				'sort'          => $cursor['sort'],
-			)
-		);
-
-		return new Cursor_Page(
-			$items,
-			$cursor['position'],
-			$cursor['element'],
-			$cursor['direction'],
-			$cursor['sort'],
-			$cursor['limit'],
-			$cursor['query']
-		);
-	}
-
-	/**
-	 * Create a new match for a term.
-	 *
-	 * @param  $request \WP_REST_Request
-	 *
-	 * @throws \Exception If there was a problem creating the match.
-	 */
-	public function create_term_match( $request ) {
-
-		$term_id = $request->get_param( 'term_id' );
-
-		// If we dont have a entry on the match table, then add one.
-		$content_id = Wordpress_Content_Id::create_term( $term_id );
-		if ( ! Wordpress_Content_Service::get_instance()->get_entity_id( $content_id ) ) {
-			$uri = Entity_Uri_Generator::create_uri( $content_id->get_type(), $content_id->get_id() );
-			Wordpress_Content_Service::get_instance()->set_entity_id( $content_id, $uri );
-		}
-
-		$match_id = Wordpress_Dataset_Content_Service_Hooks::get_id_or_create(
-			$term_id,
-			Object_Type_Enum::TERM
-		);
-
-		return $this->match_service->set_jsonld(
-			$term_id,
-			Object_Type_Enum::TERM,
-			$match_id,
-			$request->get_json_params()
-		);
-	}
-
-	/**
-	 * Update term match.
-	 *
-	 * @param \WP_REST_Request $request
-	 *
-	 * @return Match_Entry
-	 *
-	 * @throws \Exception If there was a problem updating the match.
-	 */
-	public function update_term_match( $request ) {
-		return $this->match_service->set_jsonld(
-			$request->get_param( 'term_id' ),
-			Object_Type_Enum::TERM,
-			$request->get_param( 'match_id' ),
-			$request->get_json_params()
-		);
-	}
+    /**
+     * @var Post_Entity_Match_Service
+     */
+    private $match_service;
+
+    /**
+     * Construct
+     *
+     * @param $match_service
+     */
+    public function __construct( $match_service ) {
+        $this->match_service = $match_service;
+    }
+
+    public function register_hooks() {
+        add_action( 'rest_api_init', array( $this, 'register_routes' ) );
+    }
+
+    /**
+     * Register the routes for the objects of the controller.
+     */
+    public function register_routes() {
+        // Get term matches by taxonomy name
+        register_rest_route(
+            WL_REST_ROUTE_DEFAULT_NAMESPACE,
+            '/term-matches',
+            array(
+                'methods'             => 'GET',
+                'callback'            => array( $this, 'get_term_matches' ),
+                'args'                => array(
+                    'cursor'        => array(
+                        'type'              => 'string',
+                        // 'default'           => Cursor::EMPTY_CURSOR_AS_BASE64_STRING,
+                        'validate_callback' => 'rest_validate_request_arg',
+                        // 'sanitize_callback' => array( Cursor::class, 'rest_sanitize_request_arg' ),
+                    ),
+                    'limit'         => array(
+                        'type'              => 'integer',
+                        'validate_callback' => 'rest_validate_request_arg',
+                        'default'           => 10,
+                        'minimum'           => 1,
+                        'maximum'           => 100,
+                        'sanitize_callback' => 'absint',
+                    ),
+                    'taxonomies'    => array(
+                        'type'              => 'array',
+                        'validate_callback' => 'rest_validate_request_arg',
+                    ),
+                    'has_match'     => array(
+                        'type'              => 'boolean',
+                        'required'          => false,
+                        'validate_callback' => 'rest_validate_request_arg',
+                    ),
+                    'term_contains' => array(
+                        'type'              => 'string',
+                        'required'          => false,
+                        'validate_callback' => 'rest_validate_request_arg',
+                    ),
+                    'sort'          => array(
+                        'type'              => 'string',
+                        'required'          => 'false',
+                        'enum'              => array(
+                            '+term_name',
+                            '-term_name',
+                            '+entity_name',
+                            '-entity_name',
+                            '+occurrences',
+                            '-occurrences',
+                        ),
+                        'validate_callback' => 'rest_validate_request_arg',
+                    ),
+                ),
+                'permission_callback' => function () {
+                    return current_user_can( 'manage_options' );
+                },
+            )
+        );
+
+        // Create a new match for a term
+        register_rest_route(
+            WL_REST_ROUTE_DEFAULT_NAMESPACE,
+            '/term-matches/(?P<term_id>\d+)/matches',
+            array(
+                'methods'             => 'POST',
+                'callback'            => array( $this, 'create_term_match' ),
+                'args'                => array(
+                    'term_id' => array(
+                        'required'          => true,
+                        'validate_callback' => 'rest_validate_request_arg',
+                    ),
+                ),
+                'permission_callback' => function () {
+                    return current_user_can( 'manage_options' );
+                },
+            )
+        );
+
+        // Update an existing term match
+        register_rest_route(
+            WL_REST_ROUTE_DEFAULT_NAMESPACE,
+            '/term-matches/(?P<term_id>\d+)/matches/(?P<match_id>\d+)',
+            array(
+                'methods'             => 'PUT',
+                'callback'            => array( $this, 'update_term_match' ),
+                'args'                => array(
+                    'term_id'  => array(
+                        'required'          => true,
+                        'validate_callback' => 'rest_validate_request_arg',
+                    ),
+                    'match_id' => array(
+                        'required'          => true,
+                        'validate_callback' => 'rest_validate_request_arg',
+                    ),
+                ),
+                'permission_callback' => function () {
+                    return current_user_can( 'manage_options' );
+                },
+            )
+        );
+    }
+
+    public function get_term_matches( $request ) {
+        $limit       = $request->has_param( 'limit' ) ? $request->get_param( 'limit' ) : 10;
+        $cursor      = $request->has_param( 'cursor' )
+            ? Cursor::from_base64_string( $request->get_param( 'cursor' ) )
+            : Cursor::empty_cursor();
+        $cursor_sort = new Cursor_Sort(
+            $request->has_param( 'sort' ) ? $request->get_param( 'sort' ) : '+term_name'
+        );
+
+        $query = new Term_Query( $request, $cursor, $cursor_sort, $limit + 1 );
+
+        $results       = $query->get_results();
+        $items         = $cursor->get_direction() === 'ASCENDING'
+            ? array_slice( $results, 0, min( count( $results ), $limit ) )
+            : array_slice( $results, count( $results ) > $limit ? 1 : 0 );
+        $position      = current( $items )->{$cursor_sort->get_sort_property()};
+        $next_position = end( $items )->{$cursor_sort->get_sort_property()};
+
+        $self  = $cursor;
+        $first = new Cursor( null, 'INCLUDED', 'ASCENDING' );
+        $last  = new Cursor( null, 'INCLUDED', 'DESCENDING' );
+
+        return new Page(
+            $items,
+            $self->to_base64_string(),
+            $first->to_base64_string(),
+            $this->get_prev_cursor_as_base64_string( $cursor, $results, $limit, $position ),
+            $this->get_next_cursor_as_base64_string( $cursor, $results, $limit, $next_position ),
+            $last->to_base64_string()
+        );
+    }
+
+    /**
+     * @param Cursor $cursor
+     *
+     * @return string|null
+     * @throws Exception when one of the called functions throws an exception.
+     */
+    private function get_prev_cursor_as_base64_string( $cursor, $results, $limit, $position ) {
+        if ( ( $cursor->get_direction() === 'ASCENDING' && $cursor->get_position() !== null ) || ( $cursor->get_direction() === 'DESCENDING' && count( $results ) > $limit ) ) {
+            $cursor = new Cursor( $position, 'EXCLUDED', 'DESCENDING' );
+
+            return $cursor->to_base64_string();
+        }
+
+        return null;
+    }
+
+    /**
+     * @param Cursor $cursor
+     *
+     * @return string|null
+     * @throws Exception when one of the called functions throws an exception.
+     */
+    private function get_next_cursor_as_base64_string( $cursor, $results, $limit, $position ) {
+        if ( ( $cursor->get_direction() === 'DESCENDING' && $cursor->get_position() !== null ) || ( $cursor->get_direction() === 'ASCENDING' && count( $results ) > $limit ) ) {
+            $cursor = new Cursor( $position, 'EXCLUDED', 'ASCENDING' );
+
+            return $cursor->to_base64_string();
+        }
+
+        return null;
+    }
+
+    /**
+     * Get the term matches by taxonomy name.
+     *
+     * @param  $request \WP_REST_Request
+     *
+     * @throws \Exception If there was a problem getting the match.
+     */
+    public function get_term_matches_legacy( $request ) {
+
+        $cursor = $request->get_param( 'cursor' );
+        if ( $request->has_param( 'limit' ) ) {
+            $cursor['limit'] = $request->get_param( 'limit' );
+        }
+        if ( $request->has_param( 'sort' ) ) {
+            $cursor['sort'] = $request->get_param( 'sort' );
+        }
+        if ( $request->has_param( 'taxonomies' ) ) {
+            $cursor['query']['taxonomies'] = $request->get_param( 'taxonomies' );
+        }
+        if ( $request->has_param( 'has_match' ) ) {
+            $cursor['query']['has_match'] = $request->get_param( 'has_match' );
+        }
+        if ( $request->has_param( 'term_contains' ) ) {
+            $cursor['query']['term_contains'] = $request->get_param( 'term_contains' );
+        }
+
+        // Query.
+        $taxonomies = isset( $cursor['query']['taxonomies'] ) ? $cursor['query']['taxonomies'] : apply_filters(
+            'wl_dashboard__post_entity_match__taxonomies',
+            array(
+                'post_tag',
+                'category',
+            )
+        );
+
+        $has_match     = isset( $cursor['query']['has_match'] ) ? $cursor['query']['has_match'] : null;
+        $term_contains = isset( $cursor['query']['term_contains'] ) ? $cursor['query']['term_contains'] : null;
+
+        $items = $this->match_service->list_items(
+            array(
+                // Query
+                'taxonomies'    => $taxonomies,
+                'has_match'     => $has_match,
+                'term_contains' => $term_contains,
+                // Cursor-Pagination
+                'position'      => $cursor['position'],
+                'element'       => $cursor['element'],
+                'direction'     => $cursor['direction'],
+                // `+1` to check if we have other results.
+                'limit'         => $cursor['limit'] + 1,
+                'sort'          => $cursor['sort'],
+            )
+        );
+
+        return new Cursor_Page(
+            $items,
+            $cursor['position'],
+            $cursor['element'],
+            $cursor['direction'],
+            $cursor['sort'],
+            $cursor['limit'],
+            $cursor['query']
+        );
+    }
+
+    /**
+     * Create a new match for a term.
+     *
+     * @param  $request \WP_REST_Request
+     *
+     * @throws \Exception If there was a problem creating the match.
+     */
+    public function create_term_match( $request ) {
+
+        $term_id = $request->get_param( 'term_id' );
+
+        // If we dont have a entry on the match table, then add one.
+        $content_id = Wordpress_Content_Id::create_term( $term_id );
+        if ( ! Wordpress_Content_Service::get_instance()->get_entity_id( $content_id ) ) {
+            $uri = Entity_Uri_Generator::create_uri( $content_id->get_type(), $content_id->get_id() );
+            Wordpress_Content_Service::get_instance()->set_entity_id( $content_id, $uri );
+        }
+
+        $match_id = Wordpress_Dataset_Content_Service_Hooks::get_id_or_create(
+            $term_id,
+            Object_Type_Enum::TERM
+        );
+
+        return $this->match_service->set_jsonld(
+            $term_id,
+            Object_Type_Enum::TERM,
+            $match_id,
+            $request->get_json_params()
+        );
+    }
+
+    /**
+     * Update term match.
+     *
+     * @param \WP_REST_Request $request
+     *
+     * @return Match_Entry
+     *
+     * @throws \Exception If there was a problem updating the match.
+     */
+    public function update_term_match( $request ) {
+        return $this->match_service->set_jsonld(
+            $request->get_param( 'term_id' ),
+            Object_Type_Enum::TERM,
+            $request->get_param( 'match_id' ),
+            $request->get_json_params()
+        );
+    }
 
 }

Spacing +55 added lines, -55 removed lines

@@ -31,12 +31,12 @@ 
 	 *
 	 * @param $match_service
 	 */
-	public function __construct( $match_service ) {
+	public function __construct($match_service) {
 		$this->match_service = $match_service;
 	}
 
 	public function register_hooks() {
-		add_action( 'rest_api_init', array( $this, 'register_routes' ) );
+		add_action('rest_api_init', array($this, 'register_routes'));
 	}
 
 	/**
@@ -49,7 +49,7 @@ 
 			'/term-matches',
 			array(
 				'methods'             => 'GET',
-				'callback'            => array( $this, 'get_term_matches' ),
+				'callback'            => array($this, 'get_term_matches'),
 				'args'                => array(
 					'cursor'        => array(
 						'type'              => 'string',
@@ -93,8 +93,8 @@ 
 						'validate_callback' => 'rest_validate_request_arg',
 					),
 				),
-				'permission_callback' => function () {
-					return current_user_can( 'manage_options' );
+				'permission_callback' => function() {
+					return current_user_can('manage_options');
 				},
 			)
 		);
@@ -105,15 +105,15 @@ 
 			'/term-matches/(?P<term_id>\d+)/matches',
 			array(
 				'methods'             => 'POST',
-				'callback'            => array( $this, 'create_term_match' ),
+				'callback'            => array($this, 'create_term_match'),
 				'args'                => array(
 					'term_id' => array(
 						'required'          => true,
 						'validate_callback' => 'rest_validate_request_arg',
 					),
 				),
-				'permission_callback' => function () {
-					return current_user_can( 'manage_options' );
+				'permission_callback' => function() {
+					return current_user_can('manage_options');
 				},
 			)
 		);
@@ -124,7 +124,7 @@ 
 			'/term-matches/(?P<term_id>\d+)/matches/(?P<match_id>\d+)',
 			array(
 				'methods'             => 'PUT',
-				'callback'            => array( $this, 'update_term_match' ),
+				'callback'            => array($this, 'update_term_match'),
 				'args'                => array(
 					'term_id'  => array(
 						'required'          => true,
@@ -135,41 +135,41 @@ 
 						'validate_callback' => 'rest_validate_request_arg',
 					),
 				),
-				'permission_callback' => function () {
-					return current_user_can( 'manage_options' );
+				'permission_callback' => function() {
+					return current_user_can('manage_options');
 				},
 			)
 		);
 	}
 
-	public function get_term_matches( $request ) {
-		$limit       = $request->has_param( 'limit' ) ? $request->get_param( 'limit' ) : 10;
-		$cursor      = $request->has_param( 'cursor' )
-			? Cursor::from_base64_string( $request->get_param( 'cursor' ) )
+	public function get_term_matches($request) {
+		$limit       = $request->has_param('limit') ? $request->get_param('limit') : 10;
+		$cursor      = $request->has_param('cursor')
+			? Cursor::from_base64_string($request->get_param('cursor'))
 			: Cursor::empty_cursor();
 		$cursor_sort = new Cursor_Sort(
-			$request->has_param( 'sort' ) ? $request->get_param( 'sort' ) : '+term_name'
+			$request->has_param('sort') ? $request->get_param('sort') : '+term_name'
 		);
 
-		$query = new Term_Query( $request, $cursor, $cursor_sort, $limit + 1 );
+		$query = new Term_Query($request, $cursor, $cursor_sort, $limit + 1);
 
 		$results       = $query->get_results();
 		$items         = $cursor->get_direction() === 'ASCENDING'
-			? array_slice( $results, 0, min( count( $results ), $limit ) )
-			: array_slice( $results, count( $results ) > $limit ? 1 : 0 );
-		$position      = current( $items )->{$cursor_sort->get_sort_property()};
-		$next_position = end( $items )->{$cursor_sort->get_sort_property()};
+			? array_slice($results, 0, min(count($results), $limit))
+			: array_slice($results, count($results) > $limit ? 1 : 0);
+		$position      = current($items)->{$cursor_sort->get_sort_property()};
+		$next_position = end($items)->{$cursor_sort->get_sort_property()};
 
 		$self  = $cursor;
-		$first = new Cursor( null, 'INCLUDED', 'ASCENDING' );
-		$last  = new Cursor( null, 'INCLUDED', 'DESCENDING' );
+		$first = new Cursor(null, 'INCLUDED', 'ASCENDING');
+		$last  = new Cursor(null, 'INCLUDED', 'DESCENDING');
 
 		return new Page(
 			$items,
 			$self->to_base64_string(),
 			$first->to_base64_string(),
-			$this->get_prev_cursor_as_base64_string( $cursor, $results, $limit, $position ),
-			$this->get_next_cursor_as_base64_string( $cursor, $results, $limit, $next_position ),
+			$this->get_prev_cursor_as_base64_string($cursor, $results, $limit, $position),
+			$this->get_next_cursor_as_base64_string($cursor, $results, $limit, $next_position),
 			$last->to_base64_string()
 		);
 	}
@@ -180,9 +180,9 @@ 
 	 * @return string|null
 	 * @throws Exception when one of the called functions throws an exception.
 	 */
-	private function get_prev_cursor_as_base64_string( $cursor, $results, $limit, $position ) {
-		if ( ( $cursor->get_direction() === 'ASCENDING' && $cursor->get_position() !== null ) || ( $cursor->get_direction() === 'DESCENDING' && count( $results ) > $limit ) ) {
-			$cursor = new Cursor( $position, 'EXCLUDED', 'DESCENDING' );
+	private function get_prev_cursor_as_base64_string($cursor, $results, $limit, $position) {
+		if (($cursor->get_direction() === 'ASCENDING' && $cursor->get_position() !== null) || ($cursor->get_direction() === 'DESCENDING' && count($results) > $limit)) {
+			$cursor = new Cursor($position, 'EXCLUDED', 'DESCENDING');
 
 			return $cursor->to_base64_string();
 		}
@@ -196,9 +196,9 @@ 
 	 * @return string|null
 	 * @throws Exception when one of the called functions throws an exception.
 	 */
-	private function get_next_cursor_as_base64_string( $cursor, $results, $limit, $position ) {
-		if ( ( $cursor->get_direction() === 'DESCENDING' && $cursor->get_position() !== null ) || ( $cursor->get_direction() === 'ASCENDING' && count( $results ) > $limit ) ) {
-			$cursor = new Cursor( $position, 'EXCLUDED', 'ASCENDING' );
+	private function get_next_cursor_as_base64_string($cursor, $results, $limit, $position) {
+		if (($cursor->get_direction() === 'DESCENDING' && $cursor->get_position() !== null) || ($cursor->get_direction() === 'ASCENDING' && count($results) > $limit)) {
+			$cursor = new Cursor($position, 'EXCLUDED', 'ASCENDING');
 
 			return $cursor->to_base64_string();
 		}
@@ -213,27 +213,27 @@ 
 	 *
 	 * @throws \Exception If there was a problem getting the match.
 	 */
-	public function get_term_matches_legacy( $request ) {
+	public function get_term_matches_legacy($request) {
 
-		$cursor = $request->get_param( 'cursor' );
-		if ( $request->has_param( 'limit' ) ) {
-			$cursor['limit'] = $request->get_param( 'limit' );
+		$cursor = $request->get_param('cursor');
+		if ($request->has_param('limit')) {
+			$cursor['limit'] = $request->get_param('limit');
 		}
-		if ( $request->has_param( 'sort' ) ) {
-			$cursor['sort'] = $request->get_param( 'sort' );
+		if ($request->has_param('sort')) {
+			$cursor['sort'] = $request->get_param('sort');
 		}
-		if ( $request->has_param( 'taxonomies' ) ) {
-			$cursor['query']['taxonomies'] = $request->get_param( 'taxonomies' );
+		if ($request->has_param('taxonomies')) {
+			$cursor['query']['taxonomies'] = $request->get_param('taxonomies');
 		}
-		if ( $request->has_param( 'has_match' ) ) {
-			$cursor['query']['has_match'] = $request->get_param( 'has_match' );
+		if ($request->has_param('has_match')) {
+			$cursor['query']['has_match'] = $request->get_param('has_match');
 		}
-		if ( $request->has_param( 'term_contains' ) ) {
-			$cursor['query']['term_contains'] = $request->get_param( 'term_contains' );
+		if ($request->has_param('term_contains')) {
+			$cursor['query']['term_contains'] = $request->get_param('term_contains');
 		}
 
 		// Query.
-		$taxonomies = isset( $cursor['query']['taxonomies'] ) ? $cursor['query']['taxonomies'] : apply_filters(
+		$taxonomies = isset($cursor['query']['taxonomies']) ? $cursor['query']['taxonomies'] : apply_filters(
 			'wl_dashboard__post_entity_match__taxonomies',
 			array(
 				'post_tag',
@@ -241,8 +241,8 @@ 
 			)
 		);
 
-		$has_match     = isset( $cursor['query']['has_match'] ) ? $cursor['query']['has_match'] : null;
-		$term_contains = isset( $cursor['query']['term_contains'] ) ? $cursor['query']['term_contains'] : null;
+		$has_match     = isset($cursor['query']['has_match']) ? $cursor['query']['has_match'] : null;
+		$term_contains = isset($cursor['query']['term_contains']) ? $cursor['query']['term_contains'] : null;
 
 		$items = $this->match_service->list_items(
 			array(
@@ -278,15 +278,15 @@ 
 	 *
 	 * @throws \Exception If there was a problem creating the match.
 	 */
-	public function create_term_match( $request ) {
+	public function create_term_match($request) {
 
-		$term_id = $request->get_param( 'term_id' );
+		$term_id = $request->get_param('term_id');
 
 		// If we dont have a entry on the match table, then add one.
-		$content_id = Wordpress_Content_Id::create_term( $term_id );
-		if ( ! Wordpress_Content_Service::get_instance()->get_entity_id( $content_id ) ) {
-			$uri = Entity_Uri_Generator::create_uri( $content_id->get_type(), $content_id->get_id() );
-			Wordpress_Content_Service::get_instance()->set_entity_id( $content_id, $uri );
+		$content_id = Wordpress_Content_Id::create_term($term_id);
+		if ( ! Wordpress_Content_Service::get_instance()->get_entity_id($content_id)) {
+			$uri = Entity_Uri_Generator::create_uri($content_id->get_type(), $content_id->get_id());
+			Wordpress_Content_Service::get_instance()->set_entity_id($content_id, $uri);
 		}
 
 		$match_id = Wordpress_Dataset_Content_Service_Hooks::get_id_or_create(
@@ -311,11 +311,11 @@ 
 	 *
 	 * @throws \Exception If there was a problem updating the match.
 	 */
-	public function update_term_match( $request ) {
+	public function update_term_match($request) {
 		return $this->match_service->set_jsonld(
-			$request->get_param( 'term_id' ),
+			$request->get_param('term_id'),
 			Object_Type_Enum::TERM,
-			$request->get_param( 'match_id' ),
+			$request->get_param('match_id'),
 			$request->get_json_params()
 		);
 	}