| @@ -1,11 +1,11 @@ | ||
| 1 | 1 | <?php | 
| 2 | 2 | /** | 
| 3 | - * @package: chapi | |
| 4 | - * | |
| 5 | - * @author: msiebeneicher | |
| 6 | - * @since: 2015-07-29 | |
| 7 | - * | |
| 8 | - */ | |
| 3 | + * @package: chapi | |
| 4 | + * | |
| 5 | + * @author: msiebeneicher | |
| 6 | + * @since: 2015-07-29 | |
| 7 | + * | |
| 8 | + */ | |
| 9 | 9 | |
| 10 | 10 | namespace Chapi\Service\JobRepository; | 
| 11 | 11 | |
| @@ -125,7 +125,7 @@ discard block | ||
| 125 | 125 | DIRECTORY_SEPARATOR, | 
| 126 | 126 | $oJobEntity->name | 
| 127 | 127 | ); | 
| 128 | - return $this->sRepositoryDir . DIRECTORY_SEPARATOR . $_sJobPath . '.json'; | |
| 128 | + return $this->sRepositoryDir.DIRECTORY_SEPARATOR.$_sJobPath.'.json'; | |
| 129 | 129 | } | 
| 130 | 130 | |
| 131 | 131 | /** | 
| @@ -140,7 +140,7 @@ discard block | ||
| 140 | 140 |              throw new \RuntimeException(sprintf('Path "%s" is not valid', $sPath)); | 
| 141 | 141 | } | 
| 142 | 142 | |
| 143 | - $_aTemp = Glob::glob(rtrim($sPath, DIRECTORY_SEPARATOR) . DIRECTORY_SEPARATOR . '*'); | |
| 143 | + $_aTemp = Glob::glob(rtrim($sPath, DIRECTORY_SEPARATOR).DIRECTORY_SEPARATOR.'*'); | |
| 144 | 144 | |
| 145 | 145 | foreach ($_aTemp as $_sPath) | 
| 146 | 146 |          { | 
| @@ -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)) | 
| @@ -44,22 +44,22 @@ | ||
| 44 | 44 | private static $sHomeDir = ''; | 
| 45 | 45 | |
| 46 | 46 | /** | 
| 47 | - * Executes the current command. | |
| 48 | - * | |
| 49 | - * This method is not abstract because you can use this class | |
| 50 | - * as a concrete class. In this case, instead of defining the | |
| 51 | - * execute() method, you set the code to execute by passing | |
| 52 | - * a Closure to the setCode() method. | |
| 53 | - * | |
| 54 | - * @param InputInterface $oInput An InputInterface instance | |
| 55 | - * @param OutputInterface $oOutput An OutputInterface instance | |
| 56 | - * | |
| 57 | - * @return integer null or 0 if everything went fine, or an error code | |
| 58 | - * | |
| 59 | - * @throws \LogicException When this abstract method is not implemented | |
| 60 | - * | |
| 61 | - * @see setCode() | |
| 62 | - */ | |
| 47 | + * Executes the current command. | |
| 48 | + * | |
| 49 | + * This method is not abstract because you can use this class | |
| 50 | + * as a concrete class. In this case, instead of defining the | |
| 51 | + * execute() method, you set the code to execute by passing | |
| 52 | + * a Closure to the setCode() method. | |
| 53 | + * | |
| 54 | + * @param InputInterface $oInput An InputInterface instance | |
| 55 | + * @param OutputInterface $oOutput An OutputInterface instance | |
| 56 | + * | |
| 57 | + * @return integer null or 0 if everything went fine, or an error code | |
| 58 | + * | |
| 59 | + * @throws \LogicException When this abstract method is not implemented | |
| 60 | + * | |
| 61 | + * @see setCode() | |
| 62 | + */ | |
| 63 | 63 | protected function execute(InputInterface $oInput, OutputInterface $oOutput) | 
| 64 | 64 |      { | 
| 65 | 65 | $this->oInput = $oInput; | 
| @@ -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); | 
| @@ -136,7 +136,7 @@ discard block | ||
| 136 | 136 |          $_sYaml = $_oDumper->dump(array('parameters' => $aToStore)); | 
| 137 | 137 | |
| 138 | 138 | $_oFileSystem = new Filesystem(); | 
| 139 | - $_oFileSystem->dumpFile($this->getHomeDir() . '/parameters.yml', $_sYaml); | |
| 139 | + $_oFileSystem->dumpFile($this->getHomeDir().'/parameters.yml', $_sYaml); | |
| 140 | 140 | } | 
| 141 | 141 | |
| 142 | 142 | /** | 
| @@ -165,7 +165,7 @@ discard block | ||
| 165 | 165 | private function getParameterValue($sKey, $mDefaultValue = null) | 
| 166 | 166 |      { | 
| 167 | 167 | $_oParser = new Parser(); | 
| 168 | - $_sParameterFile = $this->getHomeDir() . '/parameters.yml'; | |
| 168 | + $_sParameterFile = $this->getHomeDir().'/parameters.yml'; | |
| 169 | 169 | |
| 170 | 170 | if (file_exists($_sParameterFile)) | 
| 171 | 171 |          { | 
| @@ -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 | 
| @@ -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 | /** | 
| @@ -58,7 +58,7 @@ | ||
| 58 | 58 | catch (\Exception $oException) | 
| 59 | 59 |          { | 
| 60 | 60 | throw new HttpConnectionException( | 
| 61 | -                sprintf('Can\'t get response from "%s"', $this->oGuzzelClient->getConfig('base_uri') . $sUrl), | |
| 61 | +                sprintf('Can\'t get response from "%s"', $this->oGuzzelClient->getConfig('base_uri').$sUrl), | |
| 62 | 62 | 0, | 
| 63 | 63 | $oException | 
| 64 | 64 | ); |