AOEpeople / crawler

Classes/Hooks/ProcessCleanUpHook.php

Spacing +10 added lines, -10 removed lines

@@ -70,14 +70,14 @@ 
         $results = $this->getDatabaseConnection()->exec_SELECTgetRows(
             'process_id, system_process_id',
             'tx_crawler_process',
-            'ttl <= ' . intval(time() - $this->extensionSettings['processMaxRunTime'] - 3600) . ' AND active = 1'
+            'ttl <= '.intval(time() - $this->extensionSettings['processMaxRunTime'] - 3600).' AND active = 1'
         );
 
         if (!is_array($results)) {
             return;
         }
         foreach ($results as $result) {
-            $systemProcessId = (int)$result['system_process_id'];
+            $systemProcessId = (int) $result['system_process_id'];
             $processId = $result['process_id'];
             if ($systemProcessId > 1) {
                 if ($this->doProcessStillExists($systemProcessId)) {
@@ -98,7 +98,7 @@ 
         $results = $this->getDatabaseConnection()->exec_SELECTgetRows(
             'process_id, system_process_id',
             'tx_crawler_process',
-            'ttl <= ' . intval(time() - $this->extensionSettings['processMaxRunTime']) . ' AND active = 1'
+            'ttl <= '.intval(time() - $this->extensionSettings['processMaxRunTime']).' AND active = 1'
         );
 
         if (!is_array($results)) {
@@ -106,7 +106,7 @@ 
         }
         foreach ($results as $result) {
             $processExists = false;
-            $systemProcessId = (int)$result['system_process_id'];
+            $systemProcessId = (int) $result['system_process_id'];
             $processId = $result['process_id'];
             if ($systemProcessId > 1) {
                 $dispatcherProcesses = $this->findDispatcherProcesses();
@@ -116,7 +116,7 @@ 
                 }
                 foreach ($dispatcherProcesses as $process) {
                     $responseArray = $this->createResponseArray($process);
-                    if ($systemProcessId === (int)$responseArray[1]) {
+                    if ($systemProcessId === (int) $responseArray[1]) {
                         $processExists = true;
                     };
                 }
@@ -138,12 +138,12 @@ 
     {
         $this->getDatabaseConnection()->exec_DELETEquery(
             'tx_crawler_process',
-            'process_id = ' . $this->getDatabaseConnection()->fullQuoteStr($processId, 'tx_crawler_process')
+            'process_id = '.$this->getDatabaseConnection()->fullQuoteStr($processId, 'tx_crawler_process')
         );
 
         $this->getDatabaseConnection()->exec_UPDATEquery(
             'tx_crawler_queue',
-            'process_id = ' . $this->getDatabaseConnection()->fullQuoteStr($processId, 'tx_crawler_queue'),
+            'process_id = '.$this->getDatabaseConnection()->fullQuoteStr($processId, 'tx_crawler_queue'),
             array('process_id' => '')
         );
     }
@@ -177,12 +177,12 @@ 
         $doProcessStillExists = false;
         if (!$this->isOsWindows()) {
             // Not windows
-            if (file_exists('/proc/' . $pid)) {
+            if (file_exists('/proc/'.$pid)) {
                 $doProcessStillExists = true;
             }
         } else {
             // Windows
-            exec('tasklist | find "' . $pid . '"', $returnArray, $returnValue);
+            exec('tasklist | find "'.$pid.'"', $returnArray, $returnValue);
             if (count($returnArray) > 0 && preg_match('/php/i', $returnValue[0])) {
                 $doProcessStillExists = true;
             }
@@ -204,7 +204,7 @@ 
             posix_kill($pid, 9);
         } else {
             // Windows
-            exec('taskkill /PID ' . $pid);
+            exec('taskkill /PID '.$pid);
         }
     }
 

Classes/Hooks/StaticFileCacheCreateUriHook.php

Spacing +3 added lines, -3 removed lines

@@ -66,10 +66,10 @@
         if ($this->isCrawlerExtensionRunning($frontend) && preg_match('#^/index.php\?&?id=(\d+)(&.*)?$#', $uri, $matches)) {
             $speakingUri = $frontend->cObj->typoLink_URL(array('parameter' => $matches[1], 'additionalParams' => $matches[2]));
             $speakingUriParts = parse_url($speakingUri);
-            if(false === $speakingUriParts){
-                throw new \Exception('Could not parse URI: ' . $speakingUri, 1289915976);
+            if (false === $speakingUriParts) {
+                throw new \Exception('Could not parse URI: '.$speakingUri, 1289915976);
             }
-            $speakingUrlPath = '/' . ltrim($speakingUriParts['path'], '/');
+            $speakingUrlPath = '/'.ltrim($speakingUriParts['path'], '/');
             // Don't change anything if speaking URL is part of old URI:
             // (it might be the case the using the speaking URL failed)
             if (strpos($uri, $speakingUrlPath) !== 0 || $speakingUrlPath === '/') {

Classes/ClickMenu/CrawlerClickMenu.php

Spacing +3 added lines, -3 removed lines

@@ -67,7 +67,7 @@ 
         $additionalParameters = array();
         $additionalParameters[] = 'SET[function]=tx_crawler_modfunc1';
         $additionalParameters[] = 'SET[crawlaction]=start';
-        $additionalParameters[] = 'configurationSelection[]=' . $crawlerConfiguration['name'];
+        $additionalParameters[] = 'configurationSelection[]='.$crawlerConfiguration['name'];
 
         $additionalMenuItems = array();
         $additionalMenuItems[] = $backRef->linkItem(
@@ -76,7 +76,7 @@ 
                 'crawler'
             ),
             $this->getContextMenuIcon(),
-            'top.goToModule(\'web_info\', 1, \'&' . implode('&', $additionalParameters) . '\'); return hideCM();'
+            'top.goToModule(\'web_info\', 1, \'&'.implode('&', $additionalParameters).'\'); return hideCM();'
         );
 
         return array_merge($menuItems, $additionalMenuItems);
@@ -91,7 +91,7 @@ 
     {
         $icon = sprintf(
             '<img src="%s" border="0" align="top" alt="" />',
-            ExtensionManagementUtility::extRelPath('crawler') . 'icon_tx_crawler_configuration.gif'
+            ExtensionManagementUtility::extRelPath('crawler').'icon_tx_crawler_configuration.gif'
         );
 
         return $icon;

Classes/Task/CrawlerQueueTask.php

Spacing +2 added lines, -2 removed lines

@@ -92,7 +92,7 @@ 
             $this->startPage = 0;
         }
 
-        $_SERVER['argv'] = array($_SERVER['argv'][0], $this->startPage,'-ss', '-d', $this->depth, '-o', self::MODE, '-conf', implode(',', $this->configuration));
+        $_SERVER['argv'] = array($_SERVER['argv'][0], $this->startPage, '-ss', '-d', $this->depth, '-o', self::MODE, '-conf', implode(',', $this->configuration));
     }
 
 
@@ -109,6 +109,6 @@ 
             $this->startPage = 0;
         }
 
-        return implode(',', $this->configuration) . ' (depth: ' . $this->depth . ', startPage:' . $this->startPage . ')';
+        return implode(',', $this->configuration).' (depth: '.$this->depth.', startPage:'.$this->startPage.')';
     }
 }
\ No newline at end of file

domain/queue/class.tx_crawler_domain_queue_repository.php

Spacing +14 added lines, -14 removed lines

@@ -37,7 +37,7 @@ 
 	 * @return tx_crawler_domain_queue_entry $entry
 	 */
 	public function findYoungestEntryForProcess(tx_crawler_domain_process $process) {
-		return $this->getFirstOrLastObjectByProcess($process,'exec_time ASC');
+		return $this->getFirstOrLastObjectByProcess($process, 'exec_time ASC');
 	}
 
 	/**
@@ -47,7 +47,7 @@ 
 	 * @return tx_crawler_domain_queue_entry
 	 */
 	public function findOldestEntryForProcess(tx_crawler_domain_process $process) {
-		return $this->getFirstOrLastObjectByProcess($process,'exec_time DESC');
+		return $this->getFirstOrLastObjectByProcess($process, 'exec_time DESC');
 	}
 
 
@@ -60,15 +60,15 @@ 
 	 */
 	protected function getFirstOrLastObjectByProcess($process, $orderby) {
 		$db = $this->getDB();
-		$where = 'process_id_completed='.$db->fullQuoteStr($process->getProcess_id(),$this->tableName).
+		$where = 'process_id_completed='.$db->fullQuoteStr($process->getProcess_id(), $this->tableName).
 				 ' AND exec_time > 0 ';
 		$limit = 1;
 		$groupby = '';
 
-		$res 	= $db->exec_SELECTgetRows('*','tx_crawler_queue',$where,$groupby,$orderby,$limit);
-		if($res) {
-			$first 	= $res[0];
-		}else{
+		$res = $db->exec_SELECTgetRows('*', 'tx_crawler_queue', $where, $groupby, $orderby, $limit);
+		if ($res) {
+			$first = $res[0];
+		} else {
 			$first = array();
 		}
 		$resultObject = new tx_crawler_domain_queue_entry($first);
@@ -83,7 +83,7 @@ 
 	 */
 	public function countExtecutedItemsByProcess($process) {
 
-		return $this->countItemsByWhereClause('exec_time > 0 AND process_id_completed = '.$this->getDB()->fullQuoteStr($process->getProcess_id(),$this->tableName));
+		return $this->countItemsByWhereClause('exec_time > 0 AND process_id_completed = '.$this->getDB()->fullQuoteStr($process->getProcess_id(), $this->tableName));
 	}
 
 	/**
@@ -93,7 +93,7 @@ 
 	 * @return int
 	 */
 	public function countNonExecutedItemsByProcess($process) {
-		return $this->countItemsByWhereClause('exec_time = 0 AND process_id = '.$this->getDB()->fullQuoteStr($process->getProcess_id(),$this->tableName));
+		return $this->countItemsByWhereClause('exec_time = 0 AND process_id = '.$this->getDB()->fullQuoteStr($process->getProcess_id(), $this->tableName));
 	}
 
 	/**
@@ -135,8 +135,8 @@ 
 	 */
 	protected function countItemsByWhereClause($where) {
 		$db 	= $this->getDB();
-		$rs 	= $db->exec_SELECTquery('count(*) as anz',$this->tableName,$where);
-		$res 	= $db->sql_fetch_assoc($rs);
+		$rs 	= $db->exec_SELECTquery('count(*) as anz', $this->tableName, $where);
+		$res = $db->sql_fetch_assoc($rs);
 
 		return $res['anz'];
 	}
@@ -202,7 +202,7 @@ 
 			$res = $db->exec_SELECTquery(
 				'configuration, count(*) as c',
 				$this->tableName,
-				'set_id in ('. implode(',',$setIds).') AND scheduled < '.time(),
+				'set_id in ('.implode(',', $setIds).') AND scheduled < '.time(),
 				'configuration'
 			);
 			while ($row = $db->sql_fetch_assoc($res)) {
@@ -247,7 +247,7 @@ 
 	 * @author Fabrizio Branca <fabrizio.branca@aoemedia.de>
 	 * @since 2010-11-16
 	 */
-	public function getLastProcessedEntries($selectFields='*', $limit='100') {
+	public function getLastProcessedEntries($selectFields = '*', $limit = '100') {
 		$db = $this->getDB();
 		$res = $db->exec_SELECTquery(
 			$selectFields,
@@ -279,7 +279,7 @@ 
 		$res = $db->exec_SELECTquery(
 			'process_id_completed, min(exec_time) as start, max(exec_time) as end, count(*) as urlcount',
 			$this->tableName,
-			'exec_time != 0 and exec_time >= '.intval($start). ' and exec_time <= ' . intval($end),
+			'exec_time != 0 and exec_time >= '.intval($start).' and exec_time <= '.intval($end),
 			'process_id_completed'
 		);
 

domain/queue/class.tx_crawler_domain_queue_entry.php

Spacing +1 added lines, -1 removed lines

@@ -36,7 +36,7 @@
 	 * @author Timo Schmidt <timo.schmidt@aoemedia.de>
 	 * @return int
 	 */
-	public function getExecutionTime(){
+	public function getExecutionTime() {
 		return $this->row['exec_time'];
 	}
 

domain/process/class.tx_crawler_domain_process_repository.php

Spacing +4 added lines, -4 removed lines

@@ -59,12 +59,12 @@ 
 			$this->tableName,
 			$where,
 			'',
-			htmlspecialchars($orderField) . ' ' . htmlspecialchars($orderDirection),
+			htmlspecialchars($orderField).' '.htmlspecialchars($orderDirection),
 			self::getLimitFromItemCountAndOffset($itemCount, $offset)
 		);
 
 		if (is_array($rows)) {
-			foreach($rows as $row) {
+			foreach ($rows as $row) {
 				$collection->append(\TYPO3\CMS\Core\Utility\GeneralUtility::makeInstance($this->objectClassname, $row));
 			}
 		}
@@ -99,7 +99,7 @@ 
 	 * @return integer
 	 */
 	public function countNotTimeouted($ttl) {
-		return $this->countByWhere('deleted = 0 AND ttl > ' . intval($ttl));
+		return $this->countByWhere('deleted = 0 AND ttl > '.intval($ttl));
 	}
 
 	/**
@@ -113,7 +113,7 @@ 
 	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;
+		$limit = $offset.', '.$itemCount;
 
 		return $limit;
 	}

domain/process/class.tx_crawler_domain_process.php

Spacing +1 added lines, -1 removed lines

@@ -151,7 +151,7 @@
 		// TODO: use class constants for these states
 		if ($this->getActive() && $this->getProgress() < 100) {
 			$stage = 'running';
-		} elseif(!$this->getActive() && $this->getProgress() < 100) {
+		} elseif (!$this->getActive() && $this->getProgress() < 100) {
 			$stage = 'cancelled';
 		} else {
 			$stage = 'completed';

Classes/Task/CrawlMultiProcessTask.php

Spacing +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
     public function execute()
     {
         $processManager = new \tx_crawler_domain_process_manager();
-        $timeout = is_int($this->timeOut) ? (int)$this->timeOut : 1800;
+        $timeout = is_int($this->timeOut) ? (int) $this->timeOut : 1800;
 
         try {
             $processManager->multiProcess($timeout);