insideout10 / wordlift-plugin

src/includes/class-wordlift-listable.php

Indentation +39 added lines, -39 removed lines

@@ -4,44 +4,44 @@
  */
 abstract class Wordlift_Listable {
 
-	/**
-	 * List the items starting at the specified offset and up to the specified limit.
-	 *
-	 * @param int $offset The start offset.
-	 * @param int $limit The maximum number of items to return.
-	 * @param array $args Additional arguments.
-	 *
-	 * @return array A array of items (or an empty array if no items are found).
-	 */
-	abstract function find( $offset = 0, $limit = 10, $args = array() );
-
-	/**
-	 * @param callable $callback
-	 * @param array $args
-	 * @param int $offset
-	 * @param int $max
-	 */
-	public function process( $callback, $args = array(), $offset = 0, $max = PHP_INT_MAX ) {
-
-		// We process users in chunks in order to avoid using too much memory,
-		// starting at offset 0, 10 users at a time.
-		$limit = 10;
-
-		while ( 0 < sizeof( $items = $this->find( $offset, $limit, $args ) ) && $offset < $max ) {
-
-			// Cycle through items and call the callback function.
-			foreach ( $items as $item ) {
-				call_user_func_array( $callback, array( $item ) );
-			}
-
-			// Clean the cache to avoid memory errors.
-			wp_cache_flush();
-
-			// Move to the next offset.
-			$offset += $limit;
-
-		}
-
-	}
+    /**
+     * List the items starting at the specified offset and up to the specified limit.
+     *
+     * @param int $offset The start offset.
+     * @param int $limit The maximum number of items to return.
+     * @param array $args Additional arguments.
+     *
+     * @return array A array of items (or an empty array if no items are found).
+     */
+    abstract function find( $offset = 0, $limit = 10, $args = array() );
+
+    /**
+     * @param callable $callback
+     * @param array $args
+     * @param int $offset
+     * @param int $max
+     */
+    public function process( $callback, $args = array(), $offset = 0, $max = PHP_INT_MAX ) {
+
+        // We process users in chunks in order to avoid using too much memory,
+        // starting at offset 0, 10 users at a time.
+        $limit = 10;
+
+        while ( 0 < sizeof( $items = $this->find( $offset, $limit, $args ) ) && $offset < $max ) {
+
+            // Cycle through items and call the callback function.
+            foreach ( $items as $item ) {
+                call_user_func_array( $callback, array( $item ) );
+            }
+
+            // Clean the cache to avoid memory errors.
+            wp_cache_flush();
+
+            // Move to the next offset.
+            $offset += $limit;
+
+        }
+
+    }
 
 }

Spacing +5 added lines, -5 removed lines

@@ -13,7 +13,7 @@ 
 	 *
 	 * @return array A array of items (or an empty array if no items are found).
 	 */
-	abstract function find( $offset = 0, $limit = 10, $args = array() );
+	abstract function find($offset = 0, $limit = 10, $args = array());
 
 	/**
 	 * @param callable $callback
@@ -21,17 +21,17 @@ 
 	 * @param int $offset
 	 * @param int $max
 	 */
-	public function process( $callback, $args = array(), $offset = 0, $max = PHP_INT_MAX ) {
+	public function process($callback, $args = array(), $offset = 0, $max = PHP_INT_MAX) {
 
 		// We process users in chunks in order to avoid using too much memory,
 		// starting at offset 0, 10 users at a time.
 		$limit = 10;
 
-		while ( 0 < sizeof( $items = $this->find( $offset, $limit, $args ) ) && $offset < $max ) {
+		while (0 < sizeof($items = $this->find($offset, $limit, $args)) && $offset < $max) {
 
 			// Cycle through items and call the callback function.
-			foreach ( $items as $item ) {
-				call_user_func_array( $callback, array( $item ) );
+			foreach ($items as $item) {
+				call_user_func_array($callback, array($item));
 			}
 
 			// Clean the cache to avoid memory errors.

src/includes/class-wordlift-rebuild-service.php

Indentation +122 added lines, -122 removed lines

@@ -13,127 +13,127 @@
  */
 class Wordlift_Rebuild_Service extends Wordlift_Listable {
 
-	/**
-	 * A {@link Wordlift_Log_Service} instance.
-	 *
-	 * @since 3.6.0
-	 * @access private
-	 * @var \Wordlift_Log_Service $log A {@link Wordlift_Log_Service} instance.
-	 */
-	private $log;
-
-	/**
-	 * A {@link Wordlift_Sparql_Service} instance.
-	 * @since 3.6.0
-	 * @access private
-	 * @var \Wordlift_Sparql_Service $sparql_service A {@link Wordlift_Sparql_Service} instance.
-	 */
-	private $sparql_service;
-
-	/**
-	 * @var \Wordlift_Uri_Service
-	 */
-	private $uri_service;
-
-	/**
-	 * Create an instance of Wordlift_Rebuild_Service.
-	 *
-	 * @since 3.6.0
-	 *
-	 * @param \Wordlift_Sparql_Service $sparql_service A {@link Wordlift_Sparql_Service} instance used to query the remote dataset.
-	 * @param \Wordlift_Uri_Service $uri_service
-	 */
-	public function __construct( $sparql_service, $uri_service ) {
-
-		$this->log = Wordlift_Log_Service::get_logger( 'Wordlift_Rebuild_Service' );
-
-		$this->sparql_service = $sparql_service;
-		$this->uri_service    = $uri_service;
-	}
-
-	/**
-	 * Rebuild the Linked Data remote dataset by clearing it out and repopulating
-	 * it with local data.
-	 *
-	 * @since 3.6.0
-	 */
-	public function rebuild() {
-
-		// Give ourselves some time to process the data.
-		set_time_limit( 21600 ); // 6 hours
-
-		// Send textual output.
-		header( 'Content-type: text/plain; charset=utf-8' );
-
-		// We start at 0 by default and get to max.
-		$offset = $_GET['offset'] ?: 0;
-		$limit  = $_GET['limit'] ?: PHP_INT_MAX;
-		$max    = $offset + $limit;
-
-		// If we're starting at offset 0, then delete existing URIs and data from
-		// the remote dataset.
-		if ( 0 === $offset ) {
-
-			// Clear out all generated URIs, since the dataset URI might have changed
-			// in the process.
-			$this->uri_service->delete_all();
-
-			// Delete all the triples in the remote dataset.
-			$this->sparql_service->queue( 'DELETE { ?s ?p ?o } WHERE { ?s ?p ?o };' );
-
-		}
-
-		// Go through the list of published entities and posts and call the (legacy)
-		// `wl_linked_data_save_post` function for each one. We're using the `process`
-		// function which is provided by the parent `Wordlift_Listable` abstract class
-		// and will cycle through all the posts w/ a very small memory footprint
-		// in order to avoid memory errors.
-
-		$count = 0;
-		$this->process( function ( $post ) use ( &$count ) {
-			$count ++;
-			wl_linked_data_save_post( $post->ID );
-		}, array(
-			'post_status' => 'publish',
-			'post_type'   => array( 'entity', 'post' )
-		), $offset, $max );
-
-		// Redirect to the next chunk.
-		if ( $count == $limit ) {
-			wp_redirect( admin_url( 'admin-ajax.php?action=wl_rebuild&offset=' . ( $offset + $limit ) . '&limit=' . $limit ) );
-		} else {
-			echo( "done [ count :: $count ][ limit :: $limit ]" );
-		}
-
-		// If we're being called as AJAX, die here.
-		if ( DOING_AJAX ) {
-			wp_die();
-		}
-
-	}
-
-	/**
-	 * List the items starting at the specified offset and up to the specified limit.
-	 *
-	 * @since 3.6.0
-	 *
-	 * @param int $offset The start offset.
-	 * @param int $limit The maximum number of items to return.
-	 * @param array $args Additional arguments.
-	 *
-	 * @return array A array of items (or an empty array if no items are found).
-	 */
-	function find( $offset = 0, $limit = 10, $args = array() ) {
-
-		return get_posts( wp_parse_args( $args, array(
-			'offset'      => $offset,
-			'numberposts' => $limit,
-			'fields'      => 'all',
-			'orderby'     => 'ID',
-			'order'       => 'ASC',
-			'post_status' => 'any',
-			'post_type'   => 'post'
-		) ) );
-	}
+    /**
+     * A {@link Wordlift_Log_Service} instance.
+     *
+     * @since 3.6.0
+     * @access private
+     * @var \Wordlift_Log_Service $log A {@link Wordlift_Log_Service} instance.
+     */
+    private $log;
+
+    /**
+     * A {@link Wordlift_Sparql_Service} instance.
+     * @since 3.6.0
+     * @access private
+     * @var \Wordlift_Sparql_Service $sparql_service A {@link Wordlift_Sparql_Service} instance.
+     */
+    private $sparql_service;
+
+    /**
+     * @var \Wordlift_Uri_Service
+     */
+    private $uri_service;
+
+    /**
+     * Create an instance of Wordlift_Rebuild_Service.
+     *
+     * @since 3.6.0
+     *
+     * @param \Wordlift_Sparql_Service $sparql_service A {@link Wordlift_Sparql_Service} instance used to query the remote dataset.
+     * @param \Wordlift_Uri_Service $uri_service
+     */
+    public function __construct( $sparql_service, $uri_service ) {
+
+        $this->log = Wordlift_Log_Service::get_logger( 'Wordlift_Rebuild_Service' );
+
+        $this->sparql_service = $sparql_service;
+        $this->uri_service    = $uri_service;
+    }
+
+    /**
+     * Rebuild the Linked Data remote dataset by clearing it out and repopulating
+     * it with local data.
+     *
+     * @since 3.6.0
+     */
+    public function rebuild() {
+
+        // Give ourselves some time to process the data.
+        set_time_limit( 21600 ); // 6 hours
+
+        // Send textual output.
+        header( 'Content-type: text/plain; charset=utf-8' );
+
+        // We start at 0 by default and get to max.
+        $offset = $_GET['offset'] ?: 0;
+        $limit  = $_GET['limit'] ?: PHP_INT_MAX;
+        $max    = $offset + $limit;
+
+        // If we're starting at offset 0, then delete existing URIs and data from
+        // the remote dataset.
+        if ( 0 === $offset ) {
+
+            // Clear out all generated URIs, since the dataset URI might have changed
+            // in the process.
+            $this->uri_service->delete_all();
+
+            // Delete all the triples in the remote dataset.
+            $this->sparql_service->queue( 'DELETE { ?s ?p ?o } WHERE { ?s ?p ?o };' );
+
+        }
+
+        // Go through the list of published entities and posts and call the (legacy)
+        // `wl_linked_data_save_post` function for each one. We're using the `process`
+        // function which is provided by the parent `Wordlift_Listable` abstract class
+        // and will cycle through all the posts w/ a very small memory footprint
+        // in order to avoid memory errors.
+
+        $count = 0;
+        $this->process( function ( $post ) use ( &$count ) {
+            $count ++;
+            wl_linked_data_save_post( $post->ID );
+        }, array(
+            'post_status' => 'publish',
+            'post_type'   => array( 'entity', 'post' )
+        ), $offset, $max );
+
+        // Redirect to the next chunk.
+        if ( $count == $limit ) {
+            wp_redirect( admin_url( 'admin-ajax.php?action=wl_rebuild&offset=' . ( $offset + $limit ) . '&limit=' . $limit ) );
+        } else {
+            echo( "done [ count :: $count ][ limit :: $limit ]" );
+        }
+
+        // If we're being called as AJAX, die here.
+        if ( DOING_AJAX ) {
+            wp_die();
+        }
+
+    }
+
+    /**
+     * List the items starting at the specified offset and up to the specified limit.
+     *
+     * @since 3.6.0
+     *
+     * @param int $offset The start offset.
+     * @param int $limit The maximum number of items to return.
+     * @param array $args Additional arguments.
+     *
+     * @return array A array of items (or an empty array if no items are found).
+     */
+    function find( $offset = 0, $limit = 10, $args = array() ) {
+
+        return get_posts( wp_parse_args( $args, array(
+            'offset'      => $offset,
+            'numberposts' => $limit,
+            'fields'      => 'all',
+            'orderby'     => 'ID',
+            'order'       => 'ASC',
+            'post_status' => 'any',
+            'post_type'   => 'post'
+        ) ) );
+    }
 
 }

Spacing +18 added lines, -18 removed lines

@@ -43,9 +43,9 @@ 
 	 * @param \Wordlift_Sparql_Service $sparql_service A {@link Wordlift_Sparql_Service} instance used to query the remote dataset.
 	 * @param \Wordlift_Uri_Service $uri_service
 	 */
-	public function __construct( $sparql_service, $uri_service ) {
+	public function __construct($sparql_service, $uri_service) {
 
-		$this->log = Wordlift_Log_Service::get_logger( 'Wordlift_Rebuild_Service' );
+		$this->log = Wordlift_Log_Service::get_logger('Wordlift_Rebuild_Service');
 
 		$this->sparql_service = $sparql_service;
 		$this->uri_service    = $uri_service;
@@ -60,10 +60,10 @@ 
 	public function rebuild() {
 
 		// Give ourselves some time to process the data.
-		set_time_limit( 21600 ); // 6 hours
+		set_time_limit(21600); // 6 hours
 
 		// Send textual output.
-		header( 'Content-type: text/plain; charset=utf-8' );
+		header('Content-type: text/plain; charset=utf-8');
 
 		// We start at 0 by default and get to max.
 		$offset = $_GET['offset'] ?: 0;
@@ -72,14 +72,14 @@ 
 
 		// If we're starting at offset 0, then delete existing URIs and data from
 		// the remote dataset.
-		if ( 0 === $offset ) {
+		if (0 === $offset) {
 
 			// Clear out all generated URIs, since the dataset URI might have changed
 			// in the process.
 			$this->uri_service->delete_all();
 
 			// Delete all the triples in the remote dataset.
-			$this->sparql_service->queue( 'DELETE { ?s ?p ?o } WHERE { ?s ?p ?o };' );
+			$this->sparql_service->queue('DELETE { ?s ?p ?o } WHERE { ?s ?p ?o };');
 
 		}
 
@@ -90,23 +90,23 @@ 
 		// in order to avoid memory errors.
 
 		$count = 0;
-		$this->process( function ( $post ) use ( &$count ) {
-			$count ++;
-			wl_linked_data_save_post( $post->ID );
+		$this->process(function($post) use (&$count) {
+			$count++;
+			wl_linked_data_save_post($post->ID);
 		}, array(
 			'post_status' => 'publish',
-			'post_type'   => array( 'entity', 'post' )
-		), $offset, $max );
+			'post_type'   => array('entity', 'post')
+		), $offset, $max);
 
 		// Redirect to the next chunk.
-		if ( $count == $limit ) {
-			wp_redirect( admin_url( 'admin-ajax.php?action=wl_rebuild&offset=' . ( $offset + $limit ) . '&limit=' . $limit ) );
+		if ($count == $limit) {
+			wp_redirect(admin_url('admin-ajax.php?action=wl_rebuild&offset='.($offset + $limit).'&limit='.$limit));
 		} else {
-			echo( "done [ count :: $count ][ limit :: $limit ]" );
+			echo("done [ count :: $count ][ limit :: $limit ]");
 		}
 
 		// If we're being called as AJAX, die here.
-		if ( DOING_AJAX ) {
+		if (DOING_AJAX) {
 			wp_die();
 		}
 
@@ -123,9 +123,9 @@ 
 	 *
 	 * @return array A array of items (or an empty array if no items are found).
 	 */
-	function find( $offset = 0, $limit = 10, $args = array() ) {
+	function find($offset = 0, $limit = 10, $args = array()) {
 
-		return get_posts( wp_parse_args( $args, array(
+		return get_posts(wp_parse_args($args, array(
 			'offset'      => $offset,
 			'numberposts' => $limit,
 			'fields'      => 'all',
@@ -133,7 +133,7 @@ 
 			'order'       => 'ASC',
 			'post_status' => 'any',
 			'post_type'   => 'post'
-		) ) );
+		)));
 	}
 
 }