AOEpeople / crawler

domain/process/class.tx_crawler_domain_process_repository.php

Spacing +3 added lines, -3 removed lines

@@ -66,7 +66,7 @@ 
             $this->tableName,
             $where,
             '',
-            htmlspecialchars($orderField) . ' ' . htmlspecialchars($orderDirection),
+            htmlspecialchars($orderField).' '.htmlspecialchars($orderDirection),
             self::getLimitFromItemCountAndOffset($itemCount, $offset)
         );
 
@@ -111,7 +111,7 @@ 
      */
     public function countNotTimeouted($ttl)
     {
-        return $this->countByWhere('deleted = 0 AND ttl > ' . intval($ttl));
+        return $this->countByWhere('deleted = 0 AND ttl > '.intval($ttl));
     }
 
     /**
@@ -127,7 +127,7 @@ 
     {
         $itemCount = filter_var($itemCount, FILTER_VALIDATE_INT, ['options' => ['min_range' => 1, 'default' => 20]]);
         $offset = filter_var($offset, FILTER_VALIDATE_INT, ['options' => ['min_range' => 0, 'default' => 0]]);
-        $limit = $offset . ', ' . $itemCount;
+        $limit = $offset.', '.$itemCount;
 
         return $limit;
     }

domain/process/class.tx_crawler_domain_process_manager.php

Spacing +20 added lines, -20 removed lines

@@ -26,7 +26,7 @@ 
  * Manages cralwer processes and can be used to start a new process or multiple processes
  *
  */
-class tx_crawler_domain_process_manager  {
+class tx_crawler_domain_process_manager {
 
     /**
      * @var $timeToLive integer
@@ -83,21 +83,21 @@ 
      *
      * @throws RuntimeException
      */
-    public function multiProcess( $timeout ) {
+    public function multiProcess($timeout) {
 
         if ($this->processLimit <= 1) {
-            throw new RuntimeException('To run crawler in multi process mode you have to configure the processLimit > 1.' . PHP_EOL);
+            throw new RuntimeException('To run crawler in multi process mode you have to configure the processLimit > 1.'.PHP_EOL);
         }
 
         $pendingItemsStart = $this->queueRepository->countAllPendingItems();
         $itemReportLimit = 20;
-        $reportItemCount =     $pendingItemsStart -  $itemReportLimit;
+        $reportItemCount = $pendingItemsStart - $itemReportLimit;
         if ($this->verbose) {
             $this->reportItemStatus();
         }
         $this->startRequiredProcesses();
         $nextTimeOut = time() + $this->timeToLive;
-        for ($i=0; $i<$timeout; $i++) {
+        for ($i = 0; $i < $timeout; $i++) {
             $currentPendingItems = $this->queueRepository->countAllPendingItems();
             if ($this->startRequiredProcesses($this->verbose)) {
                 $nextTimeOut = time() + $this->timeToLive;
@@ -112,16 +112,16 @@ 
                 if ($this->verbose) {
                     $this->reportItemStatus();
                 }
-                $reportItemCount = $currentPendingItems -  $itemReportLimit;
+                $reportItemCount = $currentPendingItems - $itemReportLimit;
             }
             sleep(1);
             if ($nextTimeOut < time()) {
-                $timedOutProcesses = $this->processRepository->findAll('','DESC',NULL,0,'ttl >'.$nextTimeOut);
+                $timedOutProcesses = $this->processRepository->findAll('', 'DESC', NULL, 0, 'ttl >'.$nextTimeOut);
                 $nextTimeOut = time() + $this->timeToLive;
                 if ($this->verbose) {
-                    echo 'Cleanup'.implode(',',$timedOutProcesses->getProcessIds()).chr(10);
+                    echo 'Cleanup'.implode(',', $timedOutProcesses->getProcessIds()).chr(10);
                 }
-                $this->crawlerObj->CLI_releaseProcesses($timedOutProcesses->getProcessIds(),true);
+                $this->crawlerObj->CLI_releaseProcesses($timedOutProcesses->getProcessIds(), true);
             }
         }
         if ($currentPendingItems > 0 && $this->verbose) {
@@ -143,17 +143,17 @@ 
      */
     private function startRequiredProcesses() {
         $ret = FALSE;
-        $currentProcesses= $this->processRepository->countActive();
-        $availableProcessesCount = $this->processLimit-$currentProcesses;
+        $currentProcesses = $this->processRepository->countActive();
+        $availableProcessesCount = $this->processLimit - $currentProcesses;
         $requiredProcessesCount = ceil($this->queueRepository->countAllUnassignedPendingItems() / $this->countInARun);
-        $startProcessCount = min(array($availableProcessesCount,$requiredProcessesCount));
+        $startProcessCount = min(array($availableProcessesCount, $requiredProcessesCount));
         if ($startProcessCount <= 0) {
             return $ret;
         }
         if ($startProcessCount && $this->verbose) {
             echo 'Start '.$startProcessCount.' new processes (Running:'.$currentProcesses.')';
         }
-        for($i=0;$i<$startProcessCount;$i++) {
+        for ($i = 0; $i < $startProcessCount; $i++) {
             usleep(100);
             if ($this->startProcess()) {
                 if ($this->verbose) {
@@ -173,25 +173,25 @@ 
      * @throws Exception if no crawlerprocess was started
      */
     public function startProcess() {
-        $ttl = (time() + $this->timeToLive -1);
+        $ttl = (time() + $this->timeToLive - 1);
         $current = $this->processRepository->countNotTimeouted($ttl);
         // Check whether OS is Windows
         if (TYPO3_OS === 'WIN') {
-            $sCompletePath = escapeshellcmd('start ' . $this->getCrawlerCliPath());
+            $sCompletePath = escapeshellcmd('start '.$this->getCrawlerCliPath());
             $oFileHandler = popen($sCompletePath, 'r');
             if ($oFileHandler !== false) {
                 pclose($oFileHandler);
             }
         }
         else {
-            $sCompletePath = '(' .escapeshellcmd($this->getCrawlerCliPath()) . ' &) > /dev/null';
+            $sCompletePath = '('.escapeshellcmd($this->getCrawlerCliPath()).' &) > /dev/null';
             $oFileHandler = system($sCompletePath);
         }
         if ($oFileHandler === false) {
             throw new Exception('could not start process!');
         }
         else {
-            for ($i=0;$i<10;$i++) {
+            for ($i = 0; $i < 10; $i++) {
                 if ($this->processRepository->countNotTimeouted($ttl) > $current) {
                     return true;
                 }
@@ -206,10 +206,10 @@ 
      *
      * @return string
      */
-    public function getCrawlerCliPath(){
-        $phpPath         = $this->crawlerObj->extensionSettings['phpPath'] . ' ';
+    public function getCrawlerCliPath() {
+        $phpPath         = $this->crawlerObj->extensionSettings['phpPath'].' ';
         $pathToTypo3     = rtrim(\TYPO3\CMS\Core\Utility\GeneralUtility::getIndpEnv('TYPO3_DOCUMENT_ROOT'), '/');
-        $pathToTypo3     .= rtrim(\TYPO3\CMS\Core\Utility\GeneralUtility::getIndpEnv('TYPO3_SITE_PATH'), '/');
+        $pathToTypo3 .= rtrim(\TYPO3\CMS\Core\Utility\GeneralUtility::getIndpEnv('TYPO3_SITE_PATH'), '/');
         $cliPart         = '/typo3/cli_dispatch.phpsh crawler';
         
         $scriptPath = $phpPath.$pathToTypo3.$cliPart;

domain/process/class.tx_crawler_domain_process.php

Spacing +1 added lines, -1 removed lines

@@ -128,7 +128,7 @@
 	 */
 	public function getProgress() {
 		$all = $this->countItemsAssigned();
-		if ($all<=0) {
+		if ($all <= 0) {
 			return 0;
 		}
 

domain/process/class.tx_crawler_domain_process_collection.php

Spacing +6 added lines, -6 removed lines

@@ -48,8 +48,8 @@ 
 	 * @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');
+		if (!parent::offsetExists($index)) {
+			throw new Exception('Index "'.var_export($index, true).'" for tx_crawler_domain_process are not available');
 		}
 		return parent::offsetGet($index);
 	}
@@ -63,7 +63,7 @@ 
 	 * @return void
 	 */
 	public function offsetSet($index, $subject) {
-		if (! $subject instanceof tx_crawler_domain_process ) {
+		if (!$subject instanceof tx_crawler_domain_process) {
 			throw new InvalidArgumentException('Wrong parameter type given, "tx_crawler_domain_process" expected!');
 		}
 		parent::offsetSet($index, $subject);
@@ -76,7 +76,7 @@ 
 	 * @return void
 	 */
 	public function append($subject) {
-		if (! $subject instanceof tx_crawler_domain_process ) {
+		if (!$subject instanceof tx_crawler_domain_process) {
 			throw new InvalidArgumentException('Wrong parameter type given, "tx_crawler_domain_process" expected!');
 		}
 		parent::append($subject);
@@ -87,9 +87,9 @@ 
 	 * @return array
 	 */
 	public function getProcessIds() {
-		$result=array();
+		$result = array();
 		foreach ($this->getIterator() as $value) {
-			$result[]=$value->getProcess_id();
+			$result[] = $value->getProcess_id();
 		}
 		return $result;
 	}

domain/events/class.tx_crawler_domain_events_dispatcher.php

Spacing +5 added lines, -5 removed lines

@@ -70,7 +70,7 @@ 
 	 */
     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'])) {
+    	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')) {
@@ -122,9 +122,9 @@ 
 	 * @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);
+		if (is_array($this->observers[$event])) {
+			foreach ($this->observers[$event] as $eventObserver) {
+				call_user_func(array($eventObserver['object'], $eventObserver['method']), $event, $group, $attachedData);
 			}
 		}
 	}
@@ -137,7 +137,7 @@ 
 	 */
 	public static function getInstance() {
 
-		if(!self::$instance instanceof tx_crawler_domain_events_dispatcher) {
+		if (!self::$instance instanceof tx_crawler_domain_events_dispatcher) {
 			$dispatcher = new tx_crawler_domain_events_dispatcher();
 			self::$instance = $dispatcher;
 		}

view/process/class.tx_crawler_view_process_list.php

Spacing +9 added lines, -9 removed lines

@@ -282,7 +282,7 @@ 
 	 * @return string icon
 	 */
 	protected function getIconForState($state) {
-		switch($state) {
+		switch ($state) {
 			case 'running':
 				$icon = 'bullet_orange';
 				$title = $this->getLLLabel('LLL:EXT:crawler/modfunc1/locallang.xml:labels.process.running');
@@ -315,7 +315,7 @@ 
 	 * @return string
 	 */
 	protected function getRefreshLink() {
-		return '<input onclick="window.location=\'' . \TYPO3\CMS\Backend\Utility\BackendUtility::getModuleUrl('web_info') . '&SET[crawlaction]=multiprocess' . '\';" type="button" style="padding:4px 4px 4px 20px; background-position: 3px 3px; background-image: url(\'' . $this->getIconPath() . 'arrow_refresh.png' . '\'); background-repeat: no-repeat;" value="' . $this->getLLLabel('LLL:EXT:crawler/modfunc1/locallang.xml:labels.refresh') . '" />';
+		return '<input onclick="window.location=\''.\TYPO3\CMS\Backend\Utility\BackendUtility::getModuleUrl('web_info').'&SET[crawlaction]=multiprocess'.'\';" type="button" style="padding:4px 4px 4px 20px; background-position: 3px 3px; background-image: url(\''.$this->getIconPath().'arrow_refresh.png'.'\'); background-repeat: no-repeat;" value="'.$this->getLLLabel('LLL:EXT:crawler/modfunc1/locallang.xml:labels.refresh').'" />';
 	}
 
 	/**
@@ -334,9 +334,9 @@ 
 	 */
 	protected function getEnableDisableLink() {
 		if ($this->getIsCrawlerEnabled()) {
-			return '<input onclick="window.location+=\'&action=stopCrawling\';" type="button" style="padding:4px 4px 4px 20px; background-position: 3px 3px; background-image: url(\'' . $this->getIconPath() . 'control_stop_blue.png' . '\'); background-repeat: no-repeat;" value="' . $this->getLLLabel('LLL:EXT:crawler/modfunc1/locallang.xml:labels.disablecrawling') . '" />';
+			return '<input onclick="window.location+=\'&action=stopCrawling\';" type="button" style="padding:4px 4px 4px 20px; background-position: 3px 3px; background-image: url(\''.$this->getIconPath().'control_stop_blue.png'.'\'); background-repeat: no-repeat;" value="'.$this->getLLLabel('LLL:EXT:crawler/modfunc1/locallang.xml:labels.disablecrawling').'" />';
 		} else {
-			return '<input onclick="window.location+=\'&action=resumeCrawling\';" type="button" style="padding:4px 4px 4px 20px; background-position: 3px 3px; background-image: url(\'' . $this->getIconPath() . 'control_play.png' . '\'); background-repeat: no-repeat;" value="' . $this->getLLLabel('LLL:EXT:crawler/modfunc1/locallang.xml:labels.enablecrawling') . '" />';
+			return '<input onclick="window.location+=\'&action=resumeCrawling\';" type="button" style="padding:4px 4px 4px 20px; background-position: 3px 3px; background-image: url(\''.$this->getIconPath().'control_play.png'.'\'); background-repeat: no-repeat;" value="'.$this->getLLLabel('LLL:EXT:crawler/modfunc1/locallang.xml:labels.enablecrawling').'" />';
 		}
 	}
 
@@ -348,9 +348,9 @@ 
 	 */
 	protected function getModeLink() {
 		if ($this->getMode() == 'detail') {
-			return '<input onclick="window.location+=\'&SET[processListMode]=simple\';" type="button" style="padding:4px 4px 4px 20px; background-position: 3px 3px; background-image: url(\'' . $this->getIconPath() . 'arrow_in.png' . '\'); background-repeat: no-repeat;" value="' . $this->getLLLabel('LLL:EXT:crawler/modfunc1/locallang.xml:labels.show.running') . '" />';
+			return '<input onclick="window.location+=\'&SET[processListMode]=simple\';" type="button" style="padding:4px 4px 4px 20px; background-position: 3px 3px; background-image: url(\''.$this->getIconPath().'arrow_in.png'.'\'); background-repeat: no-repeat;" value="'.$this->getLLLabel('LLL:EXT:crawler/modfunc1/locallang.xml:labels.show.running').'" />';
 		} elseif ($this->getMode() == 'simple') {
-			return '<input onclick="window.location+=\'&SET[processListMode]=detail\';" type="button" style="padding:4px 4px 4px 20px; background-position: 3px 3px; background-image: url(\'' . $this->getIconPath() . 'arrow_out.png' . '\'); background-repeat: no-repeat;" value="' . $this->getLLLabel('LLL:EXT:crawler/modfunc1/locallang.xml:labels.show.all') . '" />';
+			return '<input onclick="window.location+=\'&SET[processListMode]=detail\';" type="button" style="padding:4px 4px 4px 20px; background-position: 3px 3px; background-image: url(\''.$this->getIconPath().'arrow_out.png'.'\'); background-repeat: no-repeat;" value="'.$this->getLLLabel('LLL:EXT:crawler/modfunc1/locallang.xml:labels.show.all').'" />';
 		}
 	}
 
@@ -362,7 +362,7 @@ 
 	 */
 	protected function getAddLink() {
 		if ($this->getActiveProcessCount() < $this->getMaxActiveProcessCount() && $this->getIsCrawlerEnabled()) {
-			return '<input onclick="window.location+=\'&action=addProcess\';" type="button" style="padding:4px 4px 4px 20px; background-position: 3px 3px; background-image: url(\'' . $this->getIconPath() . 'add.png' . '\'); background-repeat: no-repeat;" value="' . $this->getLLLabel('LLL:EXT:crawler/modfunc1/locallang.xml:labels.process.add') . '" />';
+			return '<input onclick="window.location+=\'&action=addProcess\';" type="button" style="padding:4px 4px 4px 20px; background-position: 3px 3px; background-image: url(\''.$this->getIconPath().'add.png'.'\'); background-repeat: no-repeat;" value="'.$this->getLLLabel('LLL:EXT:crawler/modfunc1/locallang.xml:labels.process.add').'" />';
 		} else {
 			return '';
 		}
@@ -383,11 +383,11 @@ 
 	 * @param string $icon
 	 * @return string html tag for icon
 	 */
-	protected function getIcon($icon, $title='') {
+	protected function getIcon($icon, $title = '') {
 		if (!empty($title)) {
 			$title = ' title="'.$title.'"';
 		}
-		return '<img src="'.$this->getIconPath().$icon.'.png" ' . $title . ' />';
+		return '<img src="'.$this->getIconPath().$icon.'.png" '.$title.' />';
 	}
 
 	/**

Classes/Utility/SchedulerUtility.php

Spacing +10 added lines, -10 removed lines

@@ -42,36 +42,36 @@
     {
         $GLOBALS['TYPO3_CONF_VARS']['SC_OPTIONS']['scheduler']['tasks']['AOE\\Crawler\\Task\\CrawlerQueueTask'] = array(
             'extension'        => $extKey,
-            'title'            => 'LLL:EXT:' . $extKey . '/Resources/Private/Language/Backend.xlf:crawler_im.name',
-            'description'      => 'LLL:EXT:' . $extKey . '/Resources/Private/Language/Backend.xlf:crawler_im.description',
+            'title'            => 'LLL:EXT:'.$extKey.'/Resources/Private/Language/Backend.xlf:crawler_im.name',
+            'description'      => 'LLL:EXT:'.$extKey.'/Resources/Private/Language/Backend.xlf:crawler_im.description',
             'additionalFields' => 'AOE\\Crawler\\Task\\CrawlerQueueTaskAdditionalFieldProvider'
         );
 
         $GLOBALS['TYPO3_CONF_VARS']['SC_OPTIONS']['scheduler']['tasks']['AOE\\Crawler\\Task\\CrawlerTask'] = array(
             'extension'        => $extKey,
-            'title'            => 'LLL:EXT:' . $extKey . '/Resources/Private/Language/Backend.xlf:crawler_crawl.name',
-            'description'      => 'LLL:EXT:' . $extKey . '/Resources/Private/Language/Backend.xlf:crawler_crawl.description',
+            'title'            => 'LLL:EXT:'.$extKey.'/Resources/Private/Language/Backend.xlf:crawler_crawl.name',
+            'description'      => 'LLL:EXT:'.$extKey.'/Resources/Private/Language/Backend.xlf:crawler_crawl.description',
             'additionalFields' => 'AOE\\Crawler\\Task\\CrawlerTaskAdditionalFieldProvider'
         );
 
         $GLOBALS['TYPO3_CONF_VARS']['SC_OPTIONS']['scheduler']['tasks']['AOE\\Crawler\\Task\\CrawlMultiProcessTask'] = array(
             'extension'        => $extKey,
-            'title'            => 'LLL:EXT:' . $extKey . '/Resources/Private/Language/Backend.xlf:crawler_crawlMultiProcess.name',
-            'description'      => 'LLL:EXT:' . $extKey . '/Resources/Private/Language/Backend.xlf:crawler_crawl.description',
+            'title'            => 'LLL:EXT:'.$extKey.'/Resources/Private/Language/Backend.xlf:crawler_crawlMultiProcess.name',
+            'description'      => 'LLL:EXT:'.$extKey.'/Resources/Private/Language/Backend.xlf:crawler_crawl.description',
             'additionalFields' => 'AOE\\Crawler\\Task\\CrawlMultiProcessTaskAdditionalFieldProvider'
         );
 
         $GLOBALS['TYPO3_CONF_VARS']['SC_OPTIONS']['scheduler']['tasks']['AOE\\Crawler\\Task\\FlushQueueTask'] = array(
             'extension'        => $extKey,
-            'title'            => 'LLL:EXT:' . $extKey . '/Resources/Private/Language/Backend.xlf:crawler_flush.name',
-            'description'      => 'LLL:EXT:' . $extKey . '/Resources/Private/Language/Backend.xlf:crawler_flush.description',
+            'title'            => 'LLL:EXT:'.$extKey.'/Resources/Private/Language/Backend.xlf:crawler_flush.name',
+            'description'      => 'LLL:EXT:'.$extKey.'/Resources/Private/Language/Backend.xlf:crawler_flush.description',
             'additionalFields' => 'AOE\\Crawler\\Task\\FlushQueueTaskAdditionalFieldProvider'
         );
 
         $GLOBALS['TYPO3_CONF_VARS']['SC_OPTIONS']['scheduler']['tasks']['AOE\\Crawler\\Task\\ProcessCleanupTask'] = array(
             'extension'        => $extKey,
-            'title'            => 'LLL:EXT:' . $extKey . '/Resources/Private/Language/Backend.xlf:crawler_processCleanup.name',
-            'description'      => 'LLL:EXT:' . $extKey . '/Resources/Private/Language/Backend.xlf:crawler_processCleanup.description',
+            'title'            => 'LLL:EXT:'.$extKey.'/Resources/Private/Language/Backend.xlf:crawler_processCleanup.name',
+            'description'      => 'LLL:EXT:'.$extKey.'/Resources/Private/Language/Backend.xlf:crawler_processCleanup.description',
         );
     }
 }

Classes/Utility/TcaUtility.php

Spacing +3 added lines, -3 removed lines

@@ -46,7 +46,7 @@ 
     {
         if (is_array($GLOBALS['TYPO3_CONF_VARS']['EXTCONF']['crawler']['procInstructions'])) {
             foreach ($GLOBALS['TYPO3_CONF_VARS']['EXTCONF']['crawler']['procInstructions'] as $key => $value) {
-                $configuration['items'][] = array($value . ' [' . $key . ']', $key, $this->getExtensionIcon($key));
+                $configuration['items'][] = array($value.' ['.$key.']', $key, $this->getExtensionIcon($key));
             }
         }
 
@@ -66,8 +66,8 @@ 
         if (method_exists('TYPO3\\CMS\\Core\\Utility\\ExtensionManagementUtility', 'getExtensionKeyByPrefix')) {
             $parts = explode('_', $key);
             if (is_array($parts) && count($parts) > 2) {
-                $extensionKey = ExtensionManagementUtility::getExtensionKeyByPrefix('tx_' . $parts[1]);
-                $extIcon = ExtensionManagementUtility::extRelPath($extensionKey) . 'ext_icon.gif';
+                $extensionKey = ExtensionManagementUtility::getExtensionKeyByPrefix('tx_'.$parts[1]);
+                $extIcon = ExtensionManagementUtility::extRelPath($extensionKey).'ext_icon.gif';
             }
         }
 

Classes/Utility/TypoScriptUtility.php

Spacing +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
             $templateUid = $GLOBALS['TYPO3_DB']->exec_SELECTgetSingleRow(
                 '*',
                 'sys_template',
-                'root=1 AND pid=' . (int)$page['uid'] .
+                'root=1 AND pid='.(int) $page['uid'].
                 \TYPO3\CMS\Backend\Utility\BackendUtility::BEenableFields('sys_template')
             );