@@ -129,12 +129,12 @@ |
||
| 129 | 129 | ? 100 / $oJobEntity->successCount * $oJobEntity->errorCount |
| 130 | 130 | : 100; |
| 131 | 131 | |
| 132 | - $_aJobInfoText[] = 'errors rate: ' . round($_fErrorRate, 2) . '%'; |
|
| 132 | + $_aJobInfoText[] = 'errors rate: '.round($_fErrorRate, 2).'%'; |
|
| 133 | 133 | } |
| 134 | 134 | |
| 135 | 135 | if ($oJobEntity->errorsSinceLastSuccess > 0) |
| 136 | 136 | { |
| 137 | - $_aJobInfoText[] = 'errors since last success:' . $oJobEntity->errorsSinceLastSuccess; |
|
| 137 | + $_aJobInfoText[] = 'errors since last success:'.$oJobEntity->errorsSinceLastSuccess; |
|
| 138 | 138 | } |
| 139 | 139 | |
| 140 | 140 | return (!empty($_aJobInfoText)) |
@@ -99,7 +99,7 @@ discard block |
||
| 99 | 99 | $this->loadParameterConfig($this->getWorkingDir(), '.chapiconfig', $_oContainer); |
| 100 | 100 | |
| 101 | 101 | // load services |
| 102 | - $_oLoader = new YamlFileLoader($_oContainer, new FileLocator(__DIR__ . self::FOLDER_RESOURCES)); |
|
| 102 | + $_oLoader = new YamlFileLoader($_oContainer, new FileLocator(__DIR__.self::FOLDER_RESOURCES)); |
|
| 103 | 103 | $_oLoader->load('services.yml'); |
| 104 | 104 | |
| 105 | 105 | self::$oContainer = $_oContainer; |
@@ -114,8 +114,8 @@ discard block |
||
| 114 | 114 | protected function isAppRunable() |
| 115 | 115 | { |
| 116 | 116 | if ( |
| 117 | - !file_exists($this->getHomeDir() . DIRECTORY_SEPARATOR . 'parameters.yml') |
|
| 118 | - && !file_exists($this->getWorkingDir() . DIRECTORY_SEPARATOR . '.chapiconfig') |
|
| 117 | + !file_exists($this->getHomeDir().DIRECTORY_SEPARATOR.'parameters.yml') |
|
| 118 | + && !file_exists($this->getWorkingDir().DIRECTORY_SEPARATOR.'.chapiconfig') |
|
| 119 | 119 | ) // one file have to exist |
| 120 | 120 | { |
| 121 | 121 | $this->oOutput->writeln(sprintf( |
@@ -141,7 +141,7 @@ discard block |
||
| 141 | 141 | $_sHomeDir = getenv('CHAPI_HOME'); |
| 142 | 142 | if (!$_sHomeDir) |
| 143 | 143 | { |
| 144 | - $_sHomeDir = CommandUtils::getOsHomeDir() . DIRECTORY_SEPARATOR . '.chapi'; |
|
| 144 | + $_sHomeDir = CommandUtils::getOsHomeDir().DIRECTORY_SEPARATOR.'.chapi'; |
|
| 145 | 145 | } |
| 146 | 146 | |
| 147 | 147 | CommandUtils::hasCreateDirectoryIfNotExists($_sHomeDir); |
@@ -154,7 +154,7 @@ discard block |
||
| 154 | 154 | */ |
| 155 | 155 | protected function getCacheDir() |
| 156 | 156 | { |
| 157 | - $_sCacheDir = $this->getHomeDir() . DIRECTORY_SEPARATOR . 'cache'; |
|
| 157 | + $_sCacheDir = $this->getHomeDir().DIRECTORY_SEPARATOR.'cache'; |
|
| 158 | 158 | CommandUtils::hasCreateDirectoryIfNotExists($_sCacheDir); |
| 159 | 159 | |
| 160 | 160 | return $_sCacheDir; |
@@ -176,7 +176,7 @@ discard block |
||
| 176 | 176 | private function loadParameterConfig($sPath, $sFile, $oContainer) |
| 177 | 177 | { |
| 178 | 178 | // load local parameters |
| 179 | - if (file_exists($sPath . DIRECTORY_SEPARATOR . $sFile)) |
|
| 179 | + if (file_exists($sPath.DIRECTORY_SEPARATOR.$sFile)) |
|
| 180 | 180 | { |
| 181 | 181 | $_oLoader = new YamlFileLoader($oContainer, new FileLocator($sPath)); |
| 182 | 182 | $_oLoader->load($sFile); |
@@ -73,7 +73,7 @@ discard block |
||
| 73 | 73 | $_iStartTime = ($_sStartTime == null) ? $_iCurrentTime : strtotime($_sStartTime); |
| 74 | 74 | if ($_sStartTime != null && $_iStartTime < $_iCurrentTime) |
| 75 | 75 | { |
| 76 | - $_iStartTime = strtotime($_sStartTime . ' + 24 hours'); |
|
| 76 | + $_iStartTime = strtotime($_sStartTime.' + 24 hours'); |
|
| 77 | 77 | } |
| 78 | 78 | |
| 79 | 79 | $_iEndTime = ($_sEndTime == null) ? $_iStartTime + 7200 : strtotime($_sEndTime); |
@@ -95,7 +95,7 @@ discard block |
||
| 95 | 95 | $_oTable = new Table($this->oOutput); |
| 96 | 96 | $_oTable->setHeaders(array( |
| 97 | 97 | 'Job', |
| 98 | - 'Timeline for ' . date('Y-m-d H:i', $iStartTime) . ' till ' . date('Y-m-d H:i', $iEndTime) |
|
| 98 | + 'Timeline for '.date('Y-m-d H:i', $iStartTime).' till '.date('Y-m-d H:i', $iEndTime) |
|
| 99 | 99 | )); |
| 100 | 100 | |
| 101 | 101 | $_aJobs = $this->getJobsWhichShouldStartInPeriod($iStartTime, $iEndTime); |
@@ -163,7 +163,7 @@ discard block |
||
| 163 | 163 | |
| 164 | 164 | $oTable->addRow( |
| 165 | 165 | array( |
| 166 | - str_repeat(' ', $iCurrentChildLevel) . '|_ ' . $_sChildJobName, |
|
| 166 | + str_repeat(' ', $iCurrentChildLevel).'|_ '.$_sChildJobName, |
|
| 167 | 167 | $this->getTimelineStr( |
| 168 | 168 | $oDisplayPeriod, |
| 169 | 169 | $oJobDatePeriod, |
@@ -317,7 +317,7 @@ discard block |
||
| 317 | 317 | { |
| 318 | 318 | if ($iJobStartTimeDelay > 0) |
| 319 | 319 | { |
| 320 | - $_oJobTime->add(new \DateInterval('PT' . $iJobStartTimeDelay . 'S')); |
|
| 320 | + $_oJobTime->add(new \DateInterval('PT'.$iJobStartTimeDelay.'S')); |
|
| 321 | 321 | } |
| 322 | 322 | |
| 323 | 323 | $_aStartTimes[$_oJobTime->format('YmdHi')] = $_oJobTime; |
@@ -36,7 +36,7 @@ discard block |
||
| 36 | 36 | md5($sCachePrefix), |
| 37 | 37 | 0, |
| 38 | 38 | 6 |
| 39 | - ) . '.'; |
|
| 39 | + ).'.'; |
|
| 40 | 40 | } |
| 41 | 41 | |
| 42 | 42 | /** |
@@ -47,7 +47,7 @@ discard block |
||
| 47 | 47 | */ |
| 48 | 48 | public function set($sKey, $mValue, $iTTL = 0) |
| 49 | 49 | { |
| 50 | - return $this->oDoctrineCache->save($this->sCachePrefix . $sKey, $mValue, $iTTL); |
|
| 50 | + return $this->oDoctrineCache->save($this->sCachePrefix.$sKey, $mValue, $iTTL); |
|
| 51 | 51 | } |
| 52 | 52 | |
| 53 | 53 | /** |
@@ -56,8 +56,8 @@ discard block |
||
| 56 | 56 | */ |
| 57 | 57 | public function get($sKey) |
| 58 | 58 | { |
| 59 | - return ($this->oDoctrineCache->contains($this->sCachePrefix . $sKey)) |
|
| 60 | - ? $this->oDoctrineCache->fetch($this->sCachePrefix . $sKey) |
|
| 59 | + return ($this->oDoctrineCache->contains($this->sCachePrefix.$sKey)) |
|
| 60 | + ? $this->oDoctrineCache->fetch($this->sCachePrefix.$sKey) |
|
| 61 | 61 | : null |
| 62 | 62 | ; |
| 63 | 63 | } |
@@ -68,6 +68,6 @@ discard block |
||
| 68 | 68 | */ |
| 69 | 69 | public function delete($sKey) |
| 70 | 70 | { |
| 71 | - return $this->oDoctrineCache->delete($this->sCachePrefix . $sKey); |
|
| 71 | + return $this->oDoctrineCache->delete($this->sCachePrefix.$sKey); |
|
| 72 | 72 | } |
| 73 | 73 | } |
| 74 | 74 | \ No newline at end of file |
@@ -347,6 +347,9 @@ |
||
| 347 | 347 | } |
| 348 | 348 | |
| 349 | 349 | |
| 350 | + /** |
|
| 351 | + * @param string $sJobFile |
|
| 352 | + */ |
|
| 350 | 353 | private function dumpFileWithGroup($sJobFile, JobEntityInterface $oJobEntity, $bAdd = true) |
| 351 | 354 | { |
| 352 | 355 | $_sGroupConfig = file_get_contents($sJobFile); |
@@ -161,7 +161,7 @@ discard block |
||
| 161 | 161 | $_sJobPath = $oJobEntity->getKey(); |
| 162 | 162 | } |
| 163 | 163 | |
| 164 | - return $this->sRepositoryDir . DIRECTORY_SEPARATOR . $_sJobPath . '.json'; |
|
| 164 | + return $this->sRepositoryDir.DIRECTORY_SEPARATOR.$_sJobPath.'.json'; |
|
| 165 | 165 | } |
| 166 | 166 | |
| 167 | 167 | /** |
@@ -176,7 +176,7 @@ discard block |
||
| 176 | 176 | throw new \RuntimeException(sprintf('Path "%s" is not valid', $sPath)); |
| 177 | 177 | } |
| 178 | 178 | |
| 179 | - $_aTemp = Glob::glob(rtrim($sPath, DIRECTORY_SEPARATOR) . DIRECTORY_SEPARATOR . '*'); |
|
| 179 | + $_aTemp = Glob::glob(rtrim($sPath, DIRECTORY_SEPARATOR).DIRECTORY_SEPARATOR.'*'); |
|
| 180 | 180 | |
| 181 | 181 | foreach ($_aTemp as $_sPath) |
| 182 | 182 | { |
@@ -27,7 +27,7 @@ |
||
| 27 | 27 | */ |
| 28 | 28 | public static function setAllPossibleProperties($oData, $oTarget) |
| 29 | 29 | { |
| 30 | - foreach($oData as $attrName => $attrValue) |
|
| 30 | + foreach ($oData as $attrName => $attrValue) |
|
| 31 | 31 | { |
| 32 | 32 | // dont set array or objects. |
| 33 | 33 | // Because this would need further type information to properly set. |
@@ -82,7 +82,7 @@ discard block |
||
| 82 | 82 | */ |
| 83 | 83 | public function removeJob($sJobName) |
| 84 | 84 | { |
| 85 | - $_oResponse = $this->oHttpClient->delete('/scheduler/job/' . $sJobName); |
|
| 85 | + $_oResponse = $this->oHttpClient->delete('/scheduler/job/'.$sJobName); |
|
| 86 | 86 | return ($_oResponse->getStatusCode() == 204); |
| 87 | 87 | } |
| 88 | 88 | |
@@ -91,7 +91,7 @@ discard block |
||
| 91 | 91 | */ |
| 92 | 92 | public function getJobStats($sJobName) |
| 93 | 93 | { |
| 94 | - return $this->sendGetJsonRequest('/scheduler/job/stat/' . $sJobName); |
|
| 94 | + return $this->sendGetJsonRequest('/scheduler/job/stat/'.$sJobName); |
|
| 95 | 95 | } |
| 96 | 96 | |
| 97 | 97 | /** |
@@ -133,6 +133,9 @@ |
||
| 133 | 133 | return !(count($arr) == count(array_unique($arr))); |
| 134 | 134 | } |
| 135 | 135 | |
| 136 | + /** |
|
| 137 | + * @param integer $iImmediateChildren |
|
| 138 | + */ |
|
| 136 | 139 | private function isDependencyCircular(MarathonAppEntity $oEntity, $iImmediateChildren, &$path=[]) |
| 137 | 140 | { |
| 138 | 141 | // Invariant: path will not have duplicates for acyclic dependency tree |
@@ -72,7 +72,7 @@ discard block |
||
| 72 | 72 | } |
| 73 | 73 | |
| 74 | 74 | // check if dependency is satisfied |
| 75 | - if ( $_oJobEntityLocal->isDependencyJob()) |
|
| 75 | + if ($_oJobEntityLocal->isDependencyJob()) |
|
| 76 | 76 | { |
| 77 | 77 | try { |
| 78 | 78 | $circular = $this->isDependencyCircular($_oJobEntityLocal, count($_oJobEntityLocal->dependencies)); |
@@ -84,10 +84,10 @@ discard block |
||
| 84 | 84 | return false; |
| 85 | 85 | } |
| 86 | 86 | } |
| 87 | - catch(\Exception $e) |
|
| 87 | + catch (\Exception $e) |
|
| 88 | 88 | { |
| 89 | 89 | $this->oLogger->error(sprintf( |
| 90 | - 'Job %s cannot be added to remote : %s',$sAppId, $e->getMessage() |
|
| 90 | + 'Job %s cannot be added to remote : %s', $sAppId, $e->getMessage() |
|
| 91 | 91 | )); |
| 92 | 92 | return false; |
| 93 | 93 | } |
@@ -133,7 +133,7 @@ discard block |
||
| 133 | 133 | return !(count($arr) == count(array_unique($arr))); |
| 134 | 134 | } |
| 135 | 135 | |
| 136 | - private function isDependencyCircular(MarathonAppEntity $oEntity, $iImmediateChildren, &$path=[]) |
|
| 136 | + private function isDependencyCircular(MarathonAppEntity $oEntity, $iImmediateChildren, &$path = []) |
|
| 137 | 137 | { |
| 138 | 138 | // Invariant: path will not have duplicates for acyclic dependency tree |
| 139 | 139 | if ($this->hasDuplicates($path)) |
@@ -186,7 +186,7 @@ discard block |
||
| 186 | 186 | // for B intermediate Child will be 2. |
| 187 | 187 | // when we process D, it will be reduced to 1 and with C to 0 |
| 188 | 188 | // then we will pop B to generate path [A, E] when we reach E. |
| 189 | - $iImmediateChildren = $iImmediateChildren -1; |
|
| 189 | + $iImmediateChildren = $iImmediateChildren - 1; |
|
| 190 | 190 | if ($iImmediateChildren == 0) |
| 191 | 191 | { |
| 192 | 192 | array_pop($path); |
@@ -98,8 +98,8 @@ |
||
| 98 | 98 | } |
| 99 | 99 | |
| 100 | 100 | /** |
| 101 | - * @param $sMethod |
|
| 102 | - * @param $sUrl |
|
| 101 | + * @param string $sMethod |
|
| 102 | + * @param string $sUrl |
|
| 103 | 103 | * @param $mData |
| 104 | 104 | * @return HttpGuzzlResponse |
| 105 | 105 | */ |
@@ -63,7 +63,7 @@ discard block |
||
| 63 | 63 | catch (ClientException $oException) // 400 level errors |
| 64 | 64 | { |
| 65 | 65 | throw new HttpConnectionException( |
| 66 | - sprintf('Client error: Calling %s returned %d', $this->oGuzzelClient->getConfig('base_uri') . $sUrl, $oException->getCode()), |
|
| 66 | + sprintf('Client error: Calling %s returned %d', $this->oGuzzelClient->getConfig('base_uri').$sUrl, $oException->getCode()), |
|
| 67 | 67 | $oException->getCode(), |
| 68 | 68 | $oException |
| 69 | 69 | ); |
@@ -71,7 +71,7 @@ discard block |
||
| 71 | 71 | catch (ServerException $oException) // 500 level errors |
| 72 | 72 | { |
| 73 | 73 | throw new HttpConnectionException( |
| 74 | - sprintf('Server error: Calling %s returned %d', $this->oGuzzelClient->getConfig('base_uri') . $sUrl, $oException->getCode()), |
|
| 74 | + sprintf('Server error: Calling %s returned %d', $this->oGuzzelClient->getConfig('base_uri').$sUrl, $oException->getCode()), |
|
| 75 | 75 | $oException->getCode(), |
| 76 | 76 | $oException |
| 77 | 77 | ); |
@@ -79,7 +79,7 @@ discard block |
||
| 79 | 79 | catch (TooManyRedirectsException $oException) // too many redirects to follow |
| 80 | 80 | { |
| 81 | 81 | throw new HttpConnectionException( |
| 82 | - sprintf('Request to %s failed due to too many redirects', $this->oGuzzelClient->getConfig('base_uri') . $sUrl), |
|
| 82 | + sprintf('Request to %s failed due to too many redirects', $this->oGuzzelClient->getConfig('base_uri').$sUrl), |
|
| 83 | 83 | HttpConnectionException::ERROR_CODE_TOO_MANY_REDIRECT_EXCEPTION, |
| 84 | 84 | $oException |
| 85 | 85 | ); |
@@ -87,7 +87,7 @@ discard block |
||
| 87 | 87 | catch (ConnectException $oException) // networking error |
| 88 | 88 | { |
| 89 | 89 | throw new HttpConnectionException( |
| 90 | - sprintf('Cannot connect to %s due to some networking error', $this->oGuzzelClient->getConfig('base_uri') . $sUrl), |
|
| 90 | + sprintf('Cannot connect to %s due to some networking error', $this->oGuzzelClient->getConfig('base_uri').$sUrl), |
|
| 91 | 91 | HttpConnectionException::ERROR_CODE_CONNECT_EXCEPTION, |
| 92 | 92 | $oException |
| 93 | 93 | ); |
@@ -95,7 +95,7 @@ discard block |
||
| 95 | 95 | catch (RequestException $oException) // networking error (connection timeout, DNS errors, etc.) |
| 96 | 96 | { |
| 97 | 97 | throw new HttpConnectionException( |
| 98 | - sprintf('Cannot connect to %s due to networking error', $this->oGuzzelClient->getConfig('base_uri') . $sUrl), |
|
| 98 | + sprintf('Cannot connect to %s due to networking error', $this->oGuzzelClient->getConfig('base_uri').$sUrl), |
|
| 99 | 99 | HttpConnectionException::ERROR_CODE_REQUEST_EXCEPTION, |
| 100 | 100 | $oException |
| 101 | 101 | ); |
@@ -103,7 +103,7 @@ discard block |
||
| 103 | 103 | catch (\Exception $oException) |
| 104 | 104 | { |
| 105 | 105 | throw new HttpConnectionException( |
| 106 | - sprintf('Can\'t get response from "%s"', $this->oGuzzelClient->getConfig('base_uri') . $sUrl), |
|
| 106 | + sprintf('Can\'t get response from "%s"', $this->oGuzzelClient->getConfig('base_uri').$sUrl), |
|
| 107 | 107 | HttpConnectionException::ERROR_CODE_UNKNOWN, |
| 108 | 108 | $oException |
| 109 | 109 | ); |