AOEpeople / crawler

domain/process/class.tx_crawler_domain_process.php

Indentation +141 added lines, -141 removed lines

@@ -24,145 +24,145 @@
 
 class tx_crawler_domain_process extends tx_crawler_domain_lib_abstract_dbobject {
 
-	CONST STATE_RUNNING = 'running';
-	CONST STATE_CANCELLED = 'cancelled';
-	CONST STATE_COMPLETED = 'completed';
-
-	/**
-	 * @var string table name
-	 */
-	protected static $tableName = 'tx_crawler_process';
-
-	/**
-	 * Returns the activity state for this process
-	 *
-	 * @param void
-	 * @return boolean
-	 */
-	public function getActive() {
-		return $this->row['active'];
-	}
-
-	/**
-	 * Returns the identifier for the process
-	 *
-	 * @return string
-	 */
-	public function getProcess_id() {
-		return $this->row['process_id'];
-	}
-
-	/**
-	 * Returns the timestamp of the exectime for the first relevant queue item.
-	 * This can be used to determine the runtime
-	 *
-	 * @return int
-	 */
-	public function getTimeForFirstItem() {
-		$queueRepository = new tx_crawler_domain_queue_repository();
-		$entry = $queueRepository->findYoungestEntryForProcess($this);
-
-		return $entry->getExecutionTime();
-	}
-
-	/**
-	 * Returns the timestamp of the exectime for the last relevant queue item.
-	 * This can be used to determine the runtime
-	 *
-	 * @return int
-	 */
-	public function getTimeForLastItem() {
-		$queueRepository = new tx_crawler_domain_queue_repository();
-		$entry = $queueRepository->findOldestEntryForProcess($this);
-
-		return $entry->getExecutionTime();
-	}
-
-	/**
-	 * Returns the difference between first and last processed item
-	 *
-	 * @return int
-	 */
-	public function getRuntime() {
-		return $this->getTimeForLastItem() - $this->getTimeForFirstItem();
-	}
-
-	/**
-	 * Returns the ttl of the process
-	 *
-	 * @return int
-	 */
-	public function getTTL() {
-		return $this->row['ttl'];
-	}
-
-	/**
-	 * Counts the number of items which need to be processed
-	 *
-	 * @author Timo Schmidt <timo.schmidt@aoemedia.de>
-	 * @param void
-	 * @return int
-	 */
-	public function countItemsProcessed() {
-		$queueRepository = new tx_crawler_domain_queue_repository();
-		return $queueRepository->countExecutedItemsByProcess($this);
-	}
-
-	/**
-	 * Counts the number of items which still need to be processed
-	 *
-	 * @author Timo Schmidt <timo.schmidt@aoemedia.de>
-	 * @param void
-	 * @return int
-	 */
-	public function countItemsToProcess() {
-		$queueRepository = new tx_crawler_domain_queue_repository();
-		return $queueRepository->countNonExecutedItemsByProcess($this);
-	}
-
-	/**
-	 * Returns the Progress of a crawling process as a percentage value
-	 *
-	 * @param void
-	 * @return float
-	 */
-	public function getProgress() {
-		$all = $this->countItemsAssigned();
-		if ($all<=0) {
-			return 0;
-		}
-
-		$res = round((100 / $all) * $this->countItemsProcessed());
-
-		if ($res > 100.0) {
-			return 100.0;
-		}
-		return $res;
-	}
-
-	/**
-	 * Returns the number of assigned Entrys
-	 *
-	 * @return int
-	 */
-	public function countItemsAssigned() {
-		return $this->row['assigned_items_count'];
-	}
-
-	/**
-	 * Return the processes current state
-	 *
-	 * @param void
-	 * @return string 'running'|'cancelled'|'completed'
-	 */
-	public function getState() {
-		if ($this->getActive() && $this->getProgress() < 100) {
-			$stage = tx_crawler_domain_process::STATE_RUNNING;
-		} elseif (!$this->getActive() && $this->getProgress() < 100) {
-			$stage = tx_crawler_domain_process::STATE_CANCELLED;
-		} else {
-			$stage = tx_crawler_domain_process::STATE_COMPLETED;
-		}
-		return $stage;
-	}
+    CONST STATE_RUNNING = 'running';
+    CONST STATE_CANCELLED = 'cancelled';
+    CONST STATE_COMPLETED = 'completed';
+
+    /**
+     * @var string table name
+     */
+    protected static $tableName = 'tx_crawler_process';
+
+    /**
+     * Returns the activity state for this process
+     *
+     * @param void
+     * @return boolean
+     */
+    public function getActive() {
+        return $this->row['active'];
+    }
+
+    /**
+     * Returns the identifier for the process
+     *
+     * @return string
+     */
+    public function getProcess_id() {
+        return $this->row['process_id'];
+    }
+
+    /**
+     * Returns the timestamp of the exectime for the first relevant queue item.
+     * This can be used to determine the runtime
+     *
+     * @return int
+     */
+    public function getTimeForFirstItem() {
+        $queueRepository = new tx_crawler_domain_queue_repository();
+        $entry = $queueRepository->findYoungestEntryForProcess($this);
+
+        return $entry->getExecutionTime();
+    }
+
+    /**
+     * Returns the timestamp of the exectime for the last relevant queue item.
+     * This can be used to determine the runtime
+     *
+     * @return int
+     */
+    public function getTimeForLastItem() {
+        $queueRepository = new tx_crawler_domain_queue_repository();
+        $entry = $queueRepository->findOldestEntryForProcess($this);
+
+        return $entry->getExecutionTime();
+    }
+
+    /**
+     * Returns the difference between first and last processed item
+     *
+     * @return int
+     */
+    public function getRuntime() {
+        return $this->getTimeForLastItem() - $this->getTimeForFirstItem();
+    }
+
+    /**
+     * Returns the ttl of the process
+     *
+     * @return int
+     */
+    public function getTTL() {
+        return $this->row['ttl'];
+    }
+
+    /**
+     * Counts the number of items which need to be processed
+     *
+     * @author Timo Schmidt <timo.schmidt@aoemedia.de>
+     * @param void
+     * @return int
+     */
+    public function countItemsProcessed() {
+        $queueRepository = new tx_crawler_domain_queue_repository();
+        return $queueRepository->countExecutedItemsByProcess($this);
+    }
+
+    /**
+     * Counts the number of items which still need to be processed
+     *
+     * @author Timo Schmidt <timo.schmidt@aoemedia.de>
+     * @param void
+     * @return int
+     */
+    public function countItemsToProcess() {
+        $queueRepository = new tx_crawler_domain_queue_repository();
+        return $queueRepository->countNonExecutedItemsByProcess($this);
+    }
+
+    /**
+     * Returns the Progress of a crawling process as a percentage value
+     *
+     * @param void
+     * @return float
+     */
+    public function getProgress() {
+        $all = $this->countItemsAssigned();
+        if ($all<=0) {
+            return 0;
+        }
+
+        $res = round((100 / $all) * $this->countItemsProcessed());
+
+        if ($res > 100.0) {
+            return 100.0;
+        }
+        return $res;
+    }
+
+    /**
+     * Returns the number of assigned Entrys
+     *
+     * @return int
+     */
+    public function countItemsAssigned() {
+        return $this->row['assigned_items_count'];
+    }
+
+    /**
+     * Return the processes current state
+     *
+     * @param void
+     * @return string 'running'|'cancelled'|'completed'
+     */
+    public function getState() {
+        if ($this->getActive() && $this->getProgress() < 100) {
+            $stage = tx_crawler_domain_process::STATE_RUNNING;
+        } elseif (!$this->getActive() && $this->getProgress() < 100) {
+            $stage = tx_crawler_domain_process::STATE_CANCELLED;
+        } else {
+            $stage = tx_crawler_domain_process::STATE_COMPLETED;
+        }
+        return $stage;
+    }
 }
\ No newline at end of file

domain/process/class.tx_crawler_domain_process_collection.php

Indentation +50 added lines, -50 removed lines

@@ -41,62 +41,62 @@
  */
 class tx_crawler_domain_process_collection extends ArrayObject {
 
-	/**
-	 * Method to retrieve an element from the collection.
-	 * @access public
- 	 * @throws Exception
-	 * @return tx_crawler_domain_process
-	 */
-	public function offsetGet($index) {
-		if (! parent::offsetExists($index)) {
-			throw new Exception('Index "' . var_export($index, true) . '" for tx_crawler_domain_process are not available');
-		}
-		return parent::offsetGet($index);
-	}
+    /**
+     * Method to retrieve an element from the collection.
+     * @access public
+     * @throws Exception
+     * @return tx_crawler_domain_process
+     */
+    public function offsetGet($index) {
+        if (! parent::offsetExists($index)) {
+            throw new Exception('Index "' . var_export($index, true) . '" for tx_crawler_domain_process are not available');
+        }
+        return parent::offsetGet($index);
+    }
 
-	/**
-	 * Method to add an element to the collection-
-	 *
-	 * @param mixed $index
-	 * @param tx_crawler_domain_process $subject
-	 * @throws InvalidArgumentException
-	 * @return void
-	 */
-	public function offsetSet($index, $subject) {
-		if (! $subject instanceof tx_crawler_domain_process ) {
-			throw new InvalidArgumentException('Wrong parameter type given, "tx_crawler_domain_process" expected!');
-		}
-		parent::offsetSet($index, $subject);
-	}
+    /**
+     * Method to add an element to the collection-
+     *
+     * @param mixed $index
+     * @param tx_crawler_domain_process $subject
+     * @throws InvalidArgumentException
+     * @return void
+     */
+    public function offsetSet($index, $subject) {
+        if (! $subject instanceof tx_crawler_domain_process ) {
+            throw new InvalidArgumentException('Wrong parameter type given, "tx_crawler_domain_process" expected!');
+        }
+        parent::offsetSet($index, $subject);
+    }
 
-	/**
-	 * Method to append an element to the collection
-	 * @param tx_crawler_domain_process $subject
-	 * @throws InvalidArgumentException
-	 * @return void
-	 */
-	public function append($subject) {
-		if (! $subject instanceof tx_crawler_domain_process ) {
-			throw new InvalidArgumentException('Wrong parameter type given, "tx_crawler_domain_process" expected!');
-		}
-		parent::append($subject);
-	}
+    /**
+     * Method to append an element to the collection
+     * @param tx_crawler_domain_process $subject
+     * @throws InvalidArgumentException
+     * @return void
+     */
+    public function append($subject) {
+        if (! $subject instanceof tx_crawler_domain_process ) {
+            throw new InvalidArgumentException('Wrong parameter type given, "tx_crawler_domain_process" expected!');
+        }
+        parent::append($subject);
+    }
 	
-	/**
-	 * returns array of process ids of the current collection
-	 * @return array
-	 */
-	public function getProcessIds() {
-		$result=array();
-		foreach ($this->getIterator() as $value) {
-			$result[]=$value->getProcess_id();
-		}
-		return $result;
-	}
+    /**
+     * returns array of process ids of the current collection
+     * @return array
+     */
+    public function getProcessIds() {
+        $result=array();
+        foreach ($this->getIterator() as $value) {
+            $result[]=$value->getProcess_id();
+        }
+        return $result;
+    }
 }
 
 
 if (defined('TYPO3_MODE') && $TYPO3_CONF_VARS[TYPO3_MODE]['XCLASS']['ext/crawler/domain/process/class.tx_crawler_domain_process_collection.php']) {
-	include_once($TYPO3_CONF_VARS[TYPO3_MODE]['XCLASS']['ext/crawler/domain/process/class.tx_crawler_domain_process_collection.php']);
+    include_once($TYPO3_CONF_VARS[TYPO3_MODE]['XCLASS']['ext/crawler/domain/process/class.tx_crawler_domain_process_collection.php']);
 }
 ?>
\ No newline at end of file

domain/events/interface.tx_crawler_domain_events_observer.php

Indentation +8 added lines, -8 removed lines

@@ -24,14 +24,14 @@
 
 interface tx_crawler_domain_events_observer {
 
-	/**
-	 * This method should be implemented by the observer to register events
-	 * that should be forwarded to the observer
-	 *
-	 * @param tx_crawler_domain_events_dispatcher $dispatcher
-	 * @return boolean
-	 */
-	public function registerObservers(tx_crawler_domain_events_dispatcher $dispatcher);
+    /**
+     * This method should be implemented by the observer to register events
+     * that should be forwarded to the observer
+     *
+     * @param tx_crawler_domain_events_dispatcher $dispatcher
+     * @return boolean
+     */
+    public function registerObservers(tx_crawler_domain_events_dispatcher $dispatcher);
 }
 
 ?>
\ No newline at end of file

domain/events/class.tx_crawler_domain_events_dispatcher.php

Indentation +75 added lines, -75 removed lines

@@ -52,32 +52,32 @@ 
  */
 class tx_crawler_domain_events_dispatcher {
 
-	/**
-	 * @var array of tx_crawler_domain_events_observer objects;
-	 */
-	protected $observers;
+    /**
+     * @var array of tx_crawler_domain_events_observer objects;
+     */
+    protected $observers;
 
-	/**
-	 * @var tx_crawler_domain_events_dispatcher
-	 */
-	protected static $instance;
+    /**
+     * @var tx_crawler_domain_events_dispatcher
+     */
+    protected static $instance;
 
-	/**
-	 * The __constructor is private because the dispatcher is a singleton
-	 *
-	 * @param void
-	 * @return void
-	 */
+    /**
+     * The __constructor is private because the dispatcher is a singleton
+     *
+     * @param void
+     * @return void
+     */
     protected function __construct() {
-    	$this->observers = array();
-    	if (is_array ($GLOBALS['TYPO3_CONF_VARS']['SC_OPTIONS']['crawler/domain/events/class.tx_crawler_domain_events_dispatcher.php']['registerObservers'])) {
-			foreach ($GLOBALS['TYPO3_CONF_VARS']['SC_OPTIONS']['crawler/domain/events/class.tx_crawler_domain_events_dispatcher.php']['registerObservers'] as $classRef) {
-				$hookObj = &\TYPO3\CMS\Core\Utility\GeneralUtility::getUserObj($classRef);
-				if (method_exists($hookObj, 'registerObservers')) {
-					$hookObj->registerObservers($this);
-				}
-			}
-		}
+        $this->observers = array();
+        if (is_array ($GLOBALS['TYPO3_CONF_VARS']['SC_OPTIONS']['crawler/domain/events/class.tx_crawler_domain_events_dispatcher.php']['registerObservers'])) {
+            foreach ($GLOBALS['TYPO3_CONF_VARS']['SC_OPTIONS']['crawler/domain/events/class.tx_crawler_domain_events_dispatcher.php']['registerObservers'] as $classRef) {
+                $hookObj = &\TYPO3\CMS\Core\Utility\GeneralUtility::getUserObj($classRef);
+                if (method_exists($hookObj, 'registerObservers')) {
+                    $hookObj->registerObservers($this);
+                }
+            }
+        }
     }
 
     /**
@@ -86,62 +86,62 @@ 
      * @param void
      * @return array array with registered events.
      */
-	protected function getEvents() {
-		return array_keys($this->observers);
-	}
+    protected function getEvents() {
+        return array_keys($this->observers);
+    }
 
-	/**
-	 * This method can be used to add an observer for an event to the dispatcher
-	 *
-	 * @param tx_crawler_domain_events_observer $observer_object
-	 * @param string $observer_method
-	 * @param string $event
-	 * @return void
-	 */
-	public function addObserver(tx_crawler_domain_events_observer $observer_object, $observer_method, $event) {
-		$this->observers[$event][] = array('object' => $observer_object, 'method' => $observer_method);
-	}
+    /**
+     * This method can be used to add an observer for an event to the dispatcher
+     *
+     * @param tx_crawler_domain_events_observer $observer_object
+     * @param string $observer_method
+     * @param string $event
+     * @return void
+     */
+    public function addObserver(tx_crawler_domain_events_observer $observer_object, $observer_method, $event) {
+        $this->observers[$event][] = array('object' => $observer_object, 'method' => $observer_method);
+    }
 
-	/**
-	 * Enables checking whether a certain event is observed by anyone
-	 *
-	 * @param string $event
-	 * @return boolean
-	 */
-	public function hasObserver($event) {
-		return count($this->observers[$event]) > 0;
-	}
+    /**
+     * Enables checking whether a certain event is observed by anyone
+     *
+     * @param string $event
+     * @return boolean
+     */
+    public function hasObserver($event) {
+        return count($this->observers[$event]) > 0;
+    }
 
-	/**
-	 * This method should be used to post a event to the dispatcher. Each
-	 * registered observer will be notified about the event.
-	 *
-	 * @param string $event
-	 * @param string $group
-	 * @param mixed $attachedData
-	 * @return void
-	 */
-	public function post($event, $group, $attachedData) {
-		if(is_array($this->observers[$event])) {
-			foreach($this->observers[$event] as $eventObserver) {
-				call_user_func(array($eventObserver['object'],$eventObserver['method']),$event,$group,$attachedData);
-			}
-		}
-	}
+    /**
+     * This method should be used to post a event to the dispatcher. Each
+     * registered observer will be notified about the event.
+     *
+     * @param string $event
+     * @param string $group
+     * @param mixed $attachedData
+     * @return void
+     */
+    public function post($event, $group, $attachedData) {
+        if(is_array($this->observers[$event])) {
+            foreach($this->observers[$event] as $eventObserver) {
+                call_user_func(array($eventObserver['object'],$eventObserver['method']),$event,$group,$attachedData);
+            }
+        }
+    }
 
-	/**
-	 * Returns the instance of the dispatcher singleton
-	 *
-	 * @param void
-	 * @return tx_crawler_domain_events_dispatcher
-	 */
-	public static function getInstance() {
+    /**
+     * Returns the instance of the dispatcher singleton
+     *
+     * @param void
+     * @return tx_crawler_domain_events_dispatcher
+     */
+    public static function getInstance() {
 
-		if(!self::$instance instanceof tx_crawler_domain_events_dispatcher) {
-			$dispatcher = new tx_crawler_domain_events_dispatcher();
-			self::$instance = $dispatcher;
-		}
+        if(!self::$instance instanceof tx_crawler_domain_events_dispatcher) {
+            $dispatcher = new tx_crawler_domain_events_dispatcher();
+            self::$instance = $dispatcher;
+        }
 
-		return self::$instance;
-	}
+        return self::$instance;
+    }
 }

view/class.tx_crawler_view_pagination.php

Indentation +115 added lines, -115 removed lines

@@ -24,121 +24,121 @@
 
 class tx_crawler_view_pagination {
 
-	/**
-	 * @var string template path
-	 */
-	protected $template = 'EXT:crawler/template/pagination.php';
-
-	/**
-	 * @var int $perpage number of items perPage
-	 */
-	protected $perPage;
-
-	/**
-	 * @var int $currentOffset current offset
-	 */
-	protected $currentOffset;
-
-	/**
-	 * @var int $totalItemCount number of total item
-	 */
-	protected $totalItemCount;
-
-	/**
-	 * @var string $baseUrl
-	 */
-	protected $baseUrl;
-
-
-
-
-	/**
-	 * Method to render the view.
-	 *
-	 * @return string html content
-	 */
-	public function render() {
-		ob_start();
-		$this->template = \TYPO3\CMS\Core\Utility\GeneralUtility::getFileAbsFileName($this->template);
-		include($this->template);
-		$content = ob_get_contents();
-		ob_end_clean();
-
-		return $content;
-	}
-
-	/**
-	 * Returns the currently configured offset-
-	 * @return int
-	 */
-	public function getCurrentOffset() {
-		return $this->currentOffset;
-	}
-
-	/**
-	 * Method to read the number of items per page
-	 *
-	 * @return int
-	 */
-	public function getPerPage() {
-		return $this->perPage;
-	}
-
-	/**
-	 * Method to set the current offset from start
-	 *
-	 * @param int $currentOffset
-	 */
-	public function setCurrentOffset($currentOffset) {
-		$this->currentOffset = $currentOffset;
-	}
-
-	/**
-	 * Number of items per page.
-	 *
-	 * @param int $perPage
-	 */
-	public function setPerPage($perPage) {
-		$this->perPage = $perPage;
-	}
-
-	/**
-	 * returns the total number of items
-	 * @return int
-	 */
-	public function getTotalItemCount() {
-		return $this->totalItemCount;
-	}
-
-	/**
-	 * Method to set the total number of items in the pagination
-	 *
-	 * @param int $totalItemCount
-	 */
-	public function setTotalItemCount($totalItemCount) {
-		$this->totalItemCount = $totalItemCount;
-	}
-
-	/**
-	 * Returns the total number of pages needed to  display all content which
-	 * is paginatable
-	 *
-	 * @return double
-	 */
-	public function getTotalPagesCount() {
-	 	return ceil($this->getTotalItemCount() / $this->getPerPage());
-	}
-
-	/**
-	 * This method is used to caluclate the label for a pageoffset,
-	 * in normal cases its the internal offset + 1
-	 *
-	 * @param int $pageoffset
-	 * @return int
-	 */
-	protected function getLabelForPageOffset($pageoffset) {
-		return $pageoffset + 1;
-	}
+    /**
+     * @var string template path
+     */
+    protected $template = 'EXT:crawler/template/pagination.php';
+
+    /**
+     * @var int $perpage number of items perPage
+     */
+    protected $perPage;
+
+    /**
+     * @var int $currentOffset current offset
+     */
+    protected $currentOffset;
+
+    /**
+     * @var int $totalItemCount number of total item
+     */
+    protected $totalItemCount;
+
+    /**
+     * @var string $baseUrl
+     */
+    protected $baseUrl;
+
+
+
+
+    /**
+     * Method to render the view.
+     *
+     * @return string html content
+     */
+    public function render() {
+        ob_start();
+        $this->template = \TYPO3\CMS\Core\Utility\GeneralUtility::getFileAbsFileName($this->template);
+        include($this->template);
+        $content = ob_get_contents();
+        ob_end_clean();
+
+        return $content;
+    }
+
+    /**
+     * Returns the currently configured offset-
+     * @return int
+     */
+    public function getCurrentOffset() {
+        return $this->currentOffset;
+    }
+
+    /**
+     * Method to read the number of items per page
+     *
+     * @return int
+     */
+    public function getPerPage() {
+        return $this->perPage;
+    }
+
+    /**
+     * Method to set the current offset from start
+     *
+     * @param int $currentOffset
+     */
+    public function setCurrentOffset($currentOffset) {
+        $this->currentOffset = $currentOffset;
+    }
+
+    /**
+     * Number of items per page.
+     *
+     * @param int $perPage
+     */
+    public function setPerPage($perPage) {
+        $this->perPage = $perPage;
+    }
+
+    /**
+     * returns the total number of items
+     * @return int
+     */
+    public function getTotalItemCount() {
+        return $this->totalItemCount;
+    }
+
+    /**
+     * Method to set the total number of items in the pagination
+     *
+     * @param int $totalItemCount
+     */
+    public function setTotalItemCount($totalItemCount) {
+        $this->totalItemCount = $totalItemCount;
+    }
+
+    /**
+     * Returns the total number of pages needed to  display all content which
+     * is paginatable
+     *
+     * @return double
+     */
+    public function getTotalPagesCount() {
+            return ceil($this->getTotalItemCount() / $this->getPerPage());
+    }
+
+    /**
+     * This method is used to caluclate the label for a pageoffset,
+     * in normal cases its the internal offset + 1
+     *
+     * @param int $pageoffset
+     * @return int
+     */
+    protected function getLabelForPageOffset($pageoffset) {
+        return $pageoffset + 1;
+    }
 
 }
 

domain/lib/class.tx_crawler_domain_lib_abstract_repository.php

Indentation +28 added lines, -28 removed lines

@@ -24,36 +24,36 @@
 
 abstract class tx_crawler_domain_lib_abstract_repository {
 
-	/**
-	 * @var string object class name
-	 */
-	protected $objectClassname;
+    /**
+     * @var string object class name
+     */
+    protected $objectClassname;
 
-	/**
-	 * @var string table name
-	 */
-	protected $tableName;
+    /**
+     * @var string table name
+     */
+    protected $tableName;
 
-	/**
-	 * Returns an instance of the TYPO3 database class.
-	 *
-	 * @return \TYPO3\CMS\Core\Database\DatabaseConnection
-	 */
-	protected function getDB() {
-		return $GLOBALS['TYPO3_DB'];
-	}
+    /**
+     * Returns an instance of the TYPO3 database class.
+     *
+     * @return \TYPO3\CMS\Core\Database\DatabaseConnection
+     */
+    protected function getDB() {
+        return $GLOBALS['TYPO3_DB'];
+    }
 
-	/**
-	 * Counts items by a given where clause
-	 *
-	 * @param  string $where    Where clause
-	 * @return integer
-	 */
-	protected function countByWhere($where) {
-		$db  = $this->getDB();
-		$rs  = $db->exec_SELECTquery('count(*) as anz', $this->tableName, $where);
-		$res = $db->sql_fetch_assoc($rs);
+    /**
+     * Counts items by a given where clause
+     *
+     * @param  string $where    Where clause
+     * @return integer
+     */
+    protected function countByWhere($where) {
+        $db  = $this->getDB();
+        $rs  = $db->exec_SELECTquery('count(*) as anz', $this->tableName, $where);
+        $res = $db->sql_fetch_assoc($rs);
 
-		return $res['anz'];
-	}
+        return $res['anz'];
+    }
 }

domain/process/class.tx_crawler_domain_process_repository.php

Indentation +81 added lines, -81 removed lines

@@ -24,97 +24,97 @@
 
 class tx_crawler_domain_process_repository extends tx_crawler_domain_lib_abstract_repository {
 
-	/**
-	 * @var string object class name
-	 */
-	protected $objectClassname = 'tx_crawler_domain_process';
+    /**
+     * @var string object class name
+     */
+    protected $objectClassname = 'tx_crawler_domain_process';
 
-	/**
-	 * @var string
-	 */
-	protected $tableName = 'tx_crawler_process';
+    /**
+     * @var string
+     */
+    protected $tableName = 'tx_crawler_process';
 
-	/**
-	 * This method is used to find all cli processes within a limit.
-	 * 
-	 * @param  string  $orderField
-	 * @param  string  $orderDirection
-	 * @param  integer $itemCount
-	 * @param  integer $offset
-	 * @param  string  $where
-	 * @return tx_crawler_domain_process_collection
-	 */
-	public function findAll($orderField = '', $orderDirection = 'DESC', $itemCount = NULL, $offset = NULL, $where = '') {
-		/** @var tx_crawler_domain_process_collection $collection */
-		$collection = \TYPO3\CMS\Core\Utility\GeneralUtility::makeInstance('tx_crawler_domain_process_collection');
+    /**
+     * This method is used to find all cli processes within a limit.
+     * 
+     * @param  string  $orderField
+     * @param  string  $orderDirection
+     * @param  integer $itemCount
+     * @param  integer $offset
+     * @param  string  $where
+     * @return tx_crawler_domain_process_collection
+     */
+    public function findAll($orderField = '', $orderDirection = 'DESC', $itemCount = NULL, $offset = NULL, $where = '') {
+        /** @var tx_crawler_domain_process_collection $collection */
+        $collection = \TYPO3\CMS\Core\Utility\GeneralUtility::makeInstance('tx_crawler_domain_process_collection');
 
-		$orderField = trim($orderField);
-		$orderField = empty($orderField) ? 'process_id' : $orderField;
+        $orderField = trim($orderField);
+        $orderField = empty($orderField) ? 'process_id' : $orderField;
 
-		$orderDirection = strtoupper(trim($orderDirection));
-		$orderDirection = in_array($orderDirection, array('ASC', 'DESC')) ? $orderDirection : 'DESC';
+        $orderDirection = strtoupper(trim($orderDirection));
+        $orderDirection = in_array($orderDirection, array('ASC', 'DESC')) ? $orderDirection : 'DESC';
 
-		$rows = $this->getDB()->exec_SELECTgetRows(
-			'*',
-			$this->tableName,
-			$where,
-			'',
-			htmlspecialchars($orderField) . ' ' . htmlspecialchars($orderDirection),
-			self::getLimitFromItemCountAndOffset($itemCount, $offset)
-		);
+        $rows = $this->getDB()->exec_SELECTgetRows(
+            '*',
+            $this->tableName,
+            $where,
+            '',
+            htmlspecialchars($orderField) . ' ' . htmlspecialchars($orderDirection),
+            self::getLimitFromItemCountAndOffset($itemCount, $offset)
+        );
 
-		if (is_array($rows)) {
-			foreach($rows as $row) {
-				$collection->append(\TYPO3\CMS\Core\Utility\GeneralUtility::makeInstance($this->objectClassname, $row));
-			}
-		}
+        if (is_array($rows)) {
+            foreach($rows as $row) {
+                $collection->append(\TYPO3\CMS\Core\Utility\GeneralUtility::makeInstance($this->objectClassname, $row));
+            }
+        }
 
-		return $collection;
-	}
+        return $collection;
+    }
 
-	/**
-	 * This method is used to count all processes in the process table.
-	 *
-	 * @param  string $where    Where clause
-	 * @return integer
-	 * @author Timo Schmidt <timo.schmidt@aoe.com>
-	 */
-	public function countAll($where = '1 = 1') {
-		return $this->countByWhere($where);
-	}
+    /**
+     * This method is used to count all processes in the process table.
+     *
+     * @param  string $where    Where clause
+     * @return integer
+     * @author Timo Schmidt <timo.schmidt@aoe.com>
+     */
+    public function countAll($where = '1 = 1') {
+        return $this->countByWhere($where);
+    }
 
-	/**
-	 * Returns the number of active processes.
-	 *
-	 * @return integer
-	 */
-	public function countActive() {
-		return $this->countByWhere('active = 1 AND deleted = 0');
-	}
+    /**
+     * Returns the number of active processes.
+     *
+     * @return integer
+     */
+    public function countActive() {
+        return $this->countByWhere('active = 1 AND deleted = 0');
+    }
 
-	/**
-	 * Returns the number of processes that live longer than the given timestamp.
-	 *
-	 * @param  integer $ttl
-	 * @return integer
-	 */
-	public function countNotTimeouted($ttl) {
-		return $this->countByWhere('deleted = 0 AND ttl > ' . intval($ttl));
-	}
+    /**
+     * Returns the number of processes that live longer than the given timestamp.
+     *
+     * @param  integer $ttl
+     * @return integer
+     */
+    public function countNotTimeouted($ttl) {
+        return $this->countByWhere('deleted = 0 AND ttl > ' . intval($ttl));
+    }
 
-	/**
-	 * Get limit clause
-	 *
-	 * @param  integer $itemCount   Item count
-	 * @param  integer $offset      Offset
-	 * @return string               Limit clause
-	 * @author Fabrizio Branca <fabrizio.branca@aoem.com>
-	 */
-	public static function getLimitFromItemCountAndOffset($itemCount, $offset) {
-		$itemCount = filter_var($itemCount, FILTER_VALIDATE_INT, array('options' => array('min_range' => 1, 'default' => 20)));
-		$offset = filter_var($offset, FILTER_VALIDATE_INT, array('options' => array('min_range' => 0, 'default' => 0)));
-		$limit = $offset . ', ' . $itemCount;
+    /**
+     * Get limit clause
+     *
+     * @param  integer $itemCount   Item count
+     * @param  integer $offset      Offset
+     * @return string               Limit clause
+     * @author Fabrizio Branca <fabrizio.branca@aoem.com>
+     */
+    public static function getLimitFromItemCountAndOffset($itemCount, $offset) {
+        $itemCount = filter_var($itemCount, FILTER_VALIDATE_INT, array('options' => array('min_range' => 1, 'default' => 20)));
+        $offset = filter_var($offset, FILTER_VALIDATE_INT, array('options' => array('min_range' => 0, 'default' => 0)));
+        $limit = $offset . ', ' . $itemCount;
 
-		return $limit;
-	}
+        return $limit;
+    }
 }

modfunc1/class.tx_crawler_modfunc1.php

Indentation +23 added lines, -23 removed lines

@@ -203,23 +203,23 @@ 
             $setId = intval(\TYPO3\CMS\Core\Utility\GeneralUtility::_GP('setID'));
 
             $h_func .= '<hr/>' .
-                       $GLOBALS['LANG']->sL('LLL:EXT:crawler/modfunc1/locallang.xml:labels.display') . ': ' . \TYPO3\CMS\Backend\Utility\BackendUtility::getFuncMenu($this->pObj->id,
+                        $GLOBALS['LANG']->sL('LLL:EXT:crawler/modfunc1/locallang.xml:labels.display') . ': ' . \TYPO3\CMS\Backend\Utility\BackendUtility::getFuncMenu($this->pObj->id,
                     'SET[log_display]', $this->pObj->MOD_SETTINGS['log_display'], $this->pObj->MOD_MENU['log_display'],
                     'index.php', '&setID=' . $setId) . ' - ' .
-                       $GLOBALS['LANG']->sL('LLL:EXT:crawler/modfunc1/locallang.xml:labels.showresultlog') . ': ' . \TYPO3\CMS\Backend\Utility\BackendUtility::getFuncCheck($this->pObj->id,
+                        $GLOBALS['LANG']->sL('LLL:EXT:crawler/modfunc1/locallang.xml:labels.showresultlog') . ': ' . \TYPO3\CMS\Backend\Utility\BackendUtility::getFuncCheck($this->pObj->id,
                     'SET[log_resultLog]', $this->pObj->MOD_SETTINGS['log_resultLog'], 'index.php',
                     '&setID=' . $setId . $quiPart) . ' - ' .
-                       $GLOBALS['LANG']->sL('LLL:EXT:crawler/modfunc1/locallang.xml:labels.showfevars') . ': ' . \TYPO3\CMS\Backend\Utility\BackendUtility::getFuncCheck($this->pObj->id,
+                        $GLOBALS['LANG']->sL('LLL:EXT:crawler/modfunc1/locallang.xml:labels.showfevars') . ': ' . \TYPO3\CMS\Backend\Utility\BackendUtility::getFuncCheck($this->pObj->id,
                     'SET[log_feVars]', $this->pObj->MOD_SETTINGS['log_feVars'], 'index.php',
                     '&setID=' . $setId . $quiPart) . ' - ' .
-                       $GLOBALS['LANG']->sL('LLL:EXT:crawler/modfunc1/locallang.xml:labels.itemsPerPage') . ': ' .
-                       \TYPO3\CMS\Backend\Utility\BackendUtility::getFuncMenu(
-                           $this->pObj->id,
-                           'SET[itemsPerPage]',
-                           $this->pObj->MOD_SETTINGS['itemsPerPage'],
-                           $this->pObj->MOD_MENU['itemsPerPage'],
-                           'index.php'
-                       );
+                        $GLOBALS['LANG']->sL('LLL:EXT:crawler/modfunc1/locallang.xml:labels.itemsPerPage') . ': ' .
+                        \TYPO3\CMS\Backend\Utility\BackendUtility::getFuncMenu(
+                            $this->pObj->id,
+                            'SET[itemsPerPage]',
+                            $this->pObj->MOD_SETTINGS['itemsPerPage'],
+                            $this->pObj->MOD_MENU['itemsPerPage'],
+                            'index.php'
+                        );
         }
 
         $theOutput = $this->pObj->doc->spacer(5);
@@ -353,9 +353,9 @@ 
                         time()) . '<br />';
                 $output .= '<br />
 					<table class="lrPadding c-list url-table">' .
-                           $this->drawURLs_printTableHeader() .
-                           $code .
-                           '</table>';
+                            $this->drawURLs_printTableHeader() .
+                            $code .
+                            '</table>';
             } else {
                 $output .= count(array_keys($this->duplicateTrack)) . ' ' . $GLOBALS['LANG']->sL('LLL:EXT:crawler/modfunc1/locallang.xml:labels.submitted') . '. <br /><br />';
                 $output .= '<input type="submit" name="_" value="' . $GLOBALS['LANG']->sL('LLL:EXT:crawler/modfunc1/locallang.xml:labels.continue') . '" />';
@@ -546,8 +546,8 @@ 
 				<input type="hidden" value="' . $showSetId . '" name="setID" />
 				<br />
 				Current server time: ' . date('H:i:s', time()) . '<br />' .
-                       'Status: ' . $resStatus . '<br />' .
-                       \TYPO3\CMS\Core\Utility\DebugUtility::viewArray($q_entry);
+                        'Status: ' . $resStatus . '<br />' .
+                        \TYPO3\CMS\Core\Utility\DebugUtility::viewArray($q_entry);
         } else {    // Show list:
 
             // If either id or set id, show list:
@@ -609,9 +609,9 @@ 
 
 
 						<table class="lrPadding c-list crawlerlog">' .
-                               $this->drawLog_printTableHeader() .
-                               $code .
-                               '</table>';
+                                $this->drawLog_printTableHeader() .
+                                $code .
+                                '</table>';
                 }
             } else {    // Otherwise show available sets:
                 $setList = $GLOBALS['TYPO3_DB']->exec_SELECTgetRows(
@@ -646,8 +646,8 @@ 
                 $output .= '
 					<br /><br />
 					<table class="lrPadding c-list">' .
-                           $code .
-                           '</table>';
+                            $code .
+                            '</table>';
             }
         }
 
@@ -866,7 +866,7 @@ 
 				<td>' . $GLOBALS['LANG']->sL('LLL:EXT:crawler/modfunc1/locallang.xml:labels.pagetitle') . ':</td>
 				<td>' . $GLOBALS['LANG']->sL('LLL:EXT:crawler/modfunc1/locallang.xml:labels.qid') . ':</td>
 				<td>&nbsp;</td>' .
-                   ($this->pObj->MOD_SETTINGS['log_resultLog'] ? '
+                    ($this->pObj->MOD_SETTINGS['log_resultLog'] ? '
 				<td>' . $GLOBALS['LANG']->sL('LLL:EXT:crawler/modfunc1/locallang.xml:labels.resultlog') . ':</td>' : '
 				<td>' . $GLOBALS['LANG']->sL('LLL:EXT:crawler/modfunc1/locallang.xml:labels.scheduledtime') . ':</td>
 				<td>' . $GLOBALS['LANG']->sL('LLL:EXT:crawler/modfunc1/locallang.xml:labels.runtime') . ':</td>') . '
@@ -875,7 +875,7 @@ 
 				<td>' . $GLOBALS['LANG']->sL('LLL:EXT:crawler/modfunc1/locallang.xml:labels.groups') . ':</td>
 				<td>' . $GLOBALS['LANG']->sL('LLL:EXT:crawler/modfunc1/locallang.xml:labels.procinstr') . ':</td>
 				<td>' . $GLOBALS['LANG']->sL('LLL:EXT:crawler/modfunc1/locallang.xml:labels.setid') . ':</td>' .
-                   ($this->pObj->MOD_SETTINGS['log_feVars'] ? '
+                    ($this->pObj->MOD_SETTINGS['log_feVars'] ? '
 				<td>' . htmlspecialchars('TSFE->id') . '</td>
 				<td>' . htmlspecialchars('TSFE->gr_list') . '</td>
 				<td>' . htmlspecialchars('TSFE->no_cache') . '</td>' : '') . '