BridgeFileSystem::getJobs() - Code Metrics - Inspection of "Feature/add marathon support" - trivago/chapi - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#68)

by Marc

created 2017-03-01 14:25 UTC

BridgeFileSystem::getJobs() A

↳ Parent: BridgeFileSystem

Complexity

Conditions	2
Paths	2

Size

Total Lines	9
Code Lines	5

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	5
CRAP Score	2

Importance

Changes

Metric	Value
dl	0
loc	9
ccs	5
cts	5
cp	1
rs	9.6666
c	0
b	0
f	0
cc	2
eloc	5
nc	2
nop	0
crap	2

<?php
/**
 * @package: chapi
 *
 * @author:  msiebeneicher
 * @since:   2015-07-29
 *
 */

namespace Chapi\Service\JobRepository;

use Chapi\Component\Cache\CacheInterface;
use Chapi\Entity\Chronos\ChronosJobEntity;
use Chapi\Entity\JobEntityInterface;
use Chapi\Entity\Marathon\MarathonAppEntity;
use Chapi\Exception\JobLoadException;
use Symfony\Component\Filesystem\Filesystem;
use Webmozart\Glob\Glob;

class BridgeFileSystem implements BridgeInterface
{
    /**
     * @var Filesystem
     */
    private $oFileSystemService;

    /**
     * @var CacheInterface
     */
    private $oCache;

    /**
     * @var string
     */
    private $sRepositoryDir = '';

    /**
     * @var string[]
     */
    private $aDirectorySeparators = ['.', ':', '-', '\\'];

    /**
     * @var array
     */
    private $aJobFileMap = [];

    /**
     * @var array
     */
    private $aGroupedApps = [];

    /**
     * @param Filesystem $oFileSystemService
     * @param CacheInterface $oCache
     * @param string $sRepositoryDir
     */
    public function __construct(
        Filesystem $oFileSystemService,
        CacheInterface $oCache,
        $sRepositoryDir
    )
    {
        $this->oFileSystemService = $oFileSystemService;
        $this->oCache = $oCache;
        $this->sRepositoryDir = $sRepositoryDir;
    }

    /**
     * @return JobEntityInterface[]
     */
    public function getJobs()
    {
        if (empty($this->aJobFileMap))
        {
            $_aJobFiles = $this->getJobFilesFromFileSystem($this->sRepositoryDir);
            return $this->loadJobsFromFileContent($_aJobFiles, true);
        }
        return $this->loadJobsFromFileContent($this->aJobFileMap, false);
    }

    /**
     * @param ChronosJobEntity|JobEntityInterface $oJobEntity
     * @return bool
     * @throws JobLoadException
     */
    public function addJob(JobEntityInterface $oJobEntity)
    {
        // generate job file path by name
        $_sJobFile = $this->generateJobFilePath($oJobEntity);

        if ($this->hasDumpFile($_sJobFile, $oJobEntity))
        {
            $this->setJobFileToMap($oJobEntity->getKey(), $_sJobFile);
            return true;
        }

        return false;
    }

    /**
     * @param JobEntityInterface $oJobEntity
     * @return bool
     */
    public function updateJob(JobEntityInterface $oJobEntity)
    {
        if (in_array($oJobEntity->getKey(), $this->aGroupedApps))
        {
            // marathon's group case where app belongs to a group file
            return $this->dumpFileWithGroup(
                $this->getJobFileFromMap($oJobEntity->getKey()),
                $oJobEntity
            );
        }
        return $this->hasDumpFile(
            $this->getJobFileFromMap($oJobEntity->getKey()),
            $oJobEntity
        );
    }

    /**
     * @param ChronosJobEntity|JobEntityInterface $oJobEntity
     * @return bool
     */
    public function removeJob(JobEntityInterface $oJobEntity)
    {
        if (in_array($oJobEntity->getKey(), $this->aGroupedApps))
        {
            $_sJobFile = $this->getJobFileFromMap($oJobEntity->getKey());
            $this->dumpFileWithGroup(
                $_sJobFile,
                $oJobEntity,
                false
            );

            unset($this->aJobFileMap[$oJobEntity->getKey()]);
            return true;
        }

        $_sJobFile = $this->getJobFileFromMap($oJobEntity->getKey());
        $this->oFileSystemService->remove($_sJobFile);

        return $this->hasUnsetJobFileFromMap($oJobEntity->getKey(), $_sJobFile);
    }

    /**
     * @param JobEntityInterface $oJobEntity
     * @return string
     */
    private function generateJobFilePath(JobEntityInterface $oJobEntity)
    {
        if ($oJobEntity->getEntityType() == JobEntityInterface::CHRONOS_TYPE)
        {
            $_sJobPath = str_replace(
                $this->aDirectorySeparators,
                DIRECTORY_SEPARATOR,
                $oJobEntity->getKey()
            );
        }
        else
        {
            $_sJobPath = $oJobEntity->getKey();
        }

        return $this->sRepositoryDir . DIRECTORY_SEPARATOR . $_sJobPath . '.json';
    }

    /**
     * @param string $sPath
     * @param array $aJobFiles
     * @return array
     */
    private function getJobFilesFromFileSystem($sPath, array &$aJobFiles = [])
    {
        if (!is_dir($sPath))
        {
            throw new \RuntimeException(sprintf('Path "%s" is not valid', $sPath));
        }

        $_aTemp = Glob::glob(rtrim($sPath, DIRECTORY_SEPARATOR) . DIRECTORY_SEPARATOR . '*');

        foreach ($_aTemp as $_sPath)
        {
            if (is_file($_sPath) && preg_match('~\.json~i', $_sPath))
            {
                $aJobFiles[] = $_sPath;
            } elseif (is_dir($_sPath))
            {
                $this->getJobFilesFromFileSystem($_sPath, $aJobFiles);
            }
        }

        return $aJobFiles;
    }

    /**
     * @param string $sJobName
     * @param string $sJobFile
     * @throws JobLoadException
     */
    private function setJobFileToMap($sJobName, $sJobFile)
    {
        // set path to job file map
        if (isset($this->aJobFileMap[$sJobName]))
        {
            throw new JobLoadException(
                sprintf('The jobname "%s" already exists. Jobnames have to be unique - Please check your local jobfiles for duplicate entries.', $sJobName),
                JobLoadException::ERROR_CODE_DUPLICATE_JOB_ID
            );
        }

        $this->aJobFileMap[$sJobName] = $sJobFile;
    }

    /**
     * @param string $sJobName
     * @return string
     * @throws \RuntimeException
     */
    private function getJobFileFromMap($sJobName)
    {
        if (!isset($this->aJobFileMap[$sJobName]))
        {
            throw new \RuntimeException(sprintf('Can\'t find file for job "%s"', $sJobName));
        }
        return $this->aJobFileMap[$sJobName];
    }

    /**
     * @param string $sJobName
     * @param string $sJobFile
     * @return bool
     * @throws \RuntimeException
     */
    private function hasUnsetJobFileFromMap($sJobName, $sJobFile = '')
    {
        $_sJobFile = (!empty($sJobFile)) ? $sJobFile : $this->getJobFileFromMap($sJobName);
        if (file_exists($_sJobFile))
        {
            throw new \RuntimeException(sprintf('Job file "%s" for job "%s" still exists.', $_sJobFile, $sJobName));
        }

        // unset path from job file map
        unset($this->aJobFileMap[$sJobName]);
        return true;
    }

    /**
     * @param array $aJobFiles
     * @param bool $bSetToFileMap
     * @return JobEntityInterface[]
     * @throws JobLoadException
     */
    private function loadJobsFromFileContent(array $aJobFiles, $bSetToFileMap)
    {
        $_aJobs = [];

        foreach ($aJobFiles as $_sJobFilePath)
        {
            $_aJobEntities = [];
            // remove comment blocks
            $_aTemp = json_decode(
                preg_replace(
                    '~\/\*(.*?)\*\/~mis',
                    '',
                    file_get_contents($_sJobFilePath)
                )
            );

            if ($_aTemp)
            {
                if (property_exists($_aTemp, 'name')) // chronos
                {
                    $_aJobEntities[] = new ChronosJobEntity($_aTemp);

                } else if (property_exists($_aTemp, 'id')) //marathon
                {
                    foreach ($this->getMarathonEntitiesForConfig($_aTemp) as $_oApp)
                    {
                        $_aJobEntities[] = $_oApp;
                    }
                } else {
                    throw new JobLoadException(
                        'Could not distinguish job as either chronos or marathon',
                        JobLoadException::ERROR_CODE_UNKNOWN_ENTITY_TYPE
                    );
                }

                /** @var JobEntityInterface $_oJobEntity */
                foreach ($_aJobEntities as $_oJobEntity)
                {
                    if ($bSetToFileMap)
                    {
                        // set path to job file map
                        $this->setJobFileToMap($_oJobEntity->getKey(), $_sJobFilePath);
                    }

                    $_aJobs[] = $_oJobEntity;
                }

            }
            else
            {
                throw new JobLoadException(
                    sprintf('Unable to load json job data from "%s". Please check if the json is valid.', $_sJobFilePath),
                    JobLoadException::ERROR_CODE_NO_VALID_JSON
                );
            }
        }

        return $_aJobs;
    }


    private function getMarathonEntitiesForConfig($aEntityData)
    {
        $_aRet = [];
        if (property_exists($aEntityData, 'apps'))
        {
            // store individual apps like single apps
            foreach ($aEntityData->apps as $_oApp)
            {
                $_oGroupEntity = new MarathonAppEntity($_oApp);
                $this->aGroupedApps[] = $_oApp->id;
                $_aRet[] = $_oGroupEntity;
            }
        }
        else
        {
            $_aRet[] = new MarathonAppEntity($aEntityData);
        }
        return $_aRet;
    }

    /**
     * @param string $sJobFile
     * @param JobEntityInterface $oJobEntity
     * @return bool
     */
    private function hasDumpFile($sJobFile, JobEntityInterface $oJobEntity)
    {
        $this->oFileSystemService->dumpFile(
            $sJobFile,
            json_encode($oJobEntity, JSON_PRETTY_PRINT | JSON_UNESCAPED_SLASHES)
        );

        return (file_exists($sJobFile));
    }


    private function dumpFileWithGroup($sJobFile, JobEntityInterface $oJobEntity, $bAdd = true)

    {
        $_sGroupConfig = file_get_contents($sJobFile);

        $_oDecodedConfig = json_decode(preg_replace(
            '~\/\*(.*?)\*\/~mis',
            '',
            $_sGroupConfig
        ));

        if (!property_exists($_oDecodedConfig, 'apps'))
        {
            throw new \RuntimeException(sprintf(
                'Job file %s does not contain group configuration. But, "%s" belongs to group %s',
                $sJobFile,
                $oJobEntity->getKey(),
                $_oDecodedConfig->id
            ));
        }

        $_bAppFound = false;
        foreach ($_oDecodedConfig->apps as $key => $_oApp)
        {
            if ($_oApp->id == $oJobEntity->getKey())
            {
                if (!$bAdd)
                {
                    array_splice($_oDecodedConfig->apps, $key, 1);
                    if (count($_oDecodedConfig->apps) == 0)
                    {
                        $this->oFileSystemService->remove($sJobFile);
                        $iIndex = array_search($oJobEntity->getKey(), $this->aGroupedApps);
                        if ($iIndex)
                        {
                            unset($this->aGroupedApps[$iIndex]);
                        }
                        return false;
                    }
                } else {
                    $_oDecodedConfig->apps[$key] = $oJobEntity;
                }
                $_bAppFound = true;
            }
        }

        if (!$_bAppFound)
        {
            throw new \RuntimeException(sprintf(
                'Could update job. job %s could not be found in the group file %s.',
                $oJobEntity->getKey(),
                $sJobFile
            ));
        }

        $_sUpdatedConfig = json_encode($_oDecodedConfig, JSON_PRETTY_PRINT | JSON_UNESCAPED_SLASHES);

        $this->oFileSystemService->dumpFile(
            $sJobFile,
            $_sUpdatedConfig
        );

        return (file_exists($sJobFile));
    }
}

1		<?php
2		/**
3		* @package: chapi
4		*
5		* @author: msiebeneicher
6		* @since: 2015-07-29
7		*
8		*/
9
10		namespace Chapi\Service\JobRepository;
11
12		use Chapi\Component\Cache\CacheInterface;
13		use Chapi\Entity\Chronos\ChronosJobEntity;
14		use Chapi\Entity\JobEntityInterface;
15		use Chapi\Entity\Marathon\MarathonAppEntity;
16		use Chapi\Exception\JobLoadException;
17		use Symfony\Component\Filesystem\Filesystem;
18		use Webmozart\Glob\Glob;
19
20		class BridgeFileSystem implements BridgeInterface
21		{
22		/**
23		* @var Filesystem
24		*/
25		private $oFileSystemService;
26
27		/**
28		* @var CacheInterface
29		*/
30		private $oCache;
31
32		/**
33		* @var string
34		*/
35		private $sRepositoryDir = '';
36
37		/**
38		* @var string[]
39		*/
40		private $aDirectorySeparators = ['.', ':', '-', '\\'];
41
42		/**
43		* @var array
44		*/
45		private $aJobFileMap = [];
46
47		/**
48		* @var array
49		*/
50		private $aGroupedApps = [];
51
52		/**
53		* @param Filesystem $oFileSystemService
54		* @param CacheInterface $oCache
55		* @param string $sRepositoryDir
56		*/
57	9	public function __construct(
58		Filesystem $oFileSystemService,
59		CacheInterface $oCache,
60		$sRepositoryDir
61		)
62		{
63	9	$this->oFileSystemService = $oFileSystemService;
64	9	$this->oCache = $oCache;
65	9	$this->sRepositoryDir = $sRepositoryDir;
66	9	}
67
68		/**
69		* @return JobEntityInterface[]
70		*/
71	8	public function getJobs()
72		{
73	8	if (empty($this->aJobFileMap))
74		{
75	8	$_aJobFiles = $this->getJobFilesFromFileSystem($this->sRepositoryDir);
76	8	return $this->loadJobsFromFileContent($_aJobFiles, true);
77		}
78	4	return $this->loadJobsFromFileContent($this->aJobFileMap, false);
79		}
80
81		/**
82		* @param ChronosJobEntity\|JobEntityInterface $oJobEntity
83		* @return bool
84		* @throws JobLoadException
85		*/
86	2	public function addJob(JobEntityInterface $oJobEntity)
87		{
88		// generate job file path by name
89	2	$_sJobFile = $this->generateJobFilePath($oJobEntity);
90
91	2	if ($this->hasDumpFile($_sJobFile, $oJobEntity))
92		{
93	2	$this->setJobFileToMap($oJobEntity->getKey(), $_sJobFile);
94	2	return true;
95		}
96
97		return false;
98		}
99
100		/**
101		* @param JobEntityInterface $oJobEntity
102		* @return bool
103		*/
104	3	public function updateJob(JobEntityInterface $oJobEntity)
105		{
106	3	if (in_array($oJobEntity->getKey(), $this->aGroupedApps))
107		{
108		// marathon's group case where app belongs to a group file
109	1	return $this->dumpFileWithGroup(
110	1	$this->getJobFileFromMap($oJobEntity->getKey()),
111		$oJobEntity
112		);
113		}
114	2	return $this->hasDumpFile(
115	2	$this->getJobFileFromMap($oJobEntity->getKey()),
116		$oJobEntity
117		);
118		}
119
120		/**
121		* @param ChronosJobEntity\|JobEntityInterface $oJobEntity
122		* @return bool
123		*/
124	3	public function removeJob(JobEntityInterface $oJobEntity)
125		{
126	3	if (in_array($oJobEntity->getKey(), $this->aGroupedApps))
127		{
128	1	$_sJobFile = $this->getJobFileFromMap($oJobEntity->getKey());
129	1	$this->dumpFileWithGroup(
130		$_sJobFile,
131		$oJobEntity,
132	1	false
133		);
134
135	1	unset($this->aJobFileMap[$oJobEntity->getKey()]);
136	1	return true;
137		}
138
139	2	$_sJobFile = $this->getJobFileFromMap($oJobEntity->getKey());
140	2	$this->oFileSystemService->remove($_sJobFile);
141
142	2	return $this->hasUnsetJobFileFromMap($oJobEntity->getKey(), $_sJobFile);
143		}
144
145		/**
146		* @param JobEntityInterface $oJobEntity
147		* @return string
148		*/
149	2	private function generateJobFilePath(JobEntityInterface $oJobEntity)
150		{
151	2	if ($oJobEntity->getEntityType() == JobEntityInterface::CHRONOS_TYPE)
152		{
153	1	$_sJobPath = str_replace(
154	1	$this->aDirectorySeparators,
155	1	DIRECTORY_SEPARATOR,
156	1	$oJobEntity->getKey()
157		);
158		}
159		else
160		{
161	1	$_sJobPath = $oJobEntity->getKey();
162		}
163
164	2	return $this->sRepositoryDir . DIRECTORY_SEPARATOR . $_sJobPath . '.json';
165		}
166
167		/**
168		* @param string $sPath
169		* @param array $aJobFiles
170		* @return array
171		*/
172	8	private function getJobFilesFromFileSystem($sPath, array &$aJobFiles = [])
173		{
174	8	if (!is_dir($sPath))
175		{
176		throw new \RuntimeException(sprintf('Path "%s" is not valid', $sPath));
177		}
178
179	8	$_aTemp = Glob::glob(rtrim($sPath, DIRECTORY_SEPARATOR) . DIRECTORY_SEPARATOR . '*');
180
181	8	foreach ($_aTemp as $_sPath)
182		{
183	7	if (is_file($_sPath) && preg_match('~\.json~i', $_sPath))
184		{
185	6	$aJobFiles[] = $_sPath;
186	6	} elseif (is_dir($_sPath))
187		{
188	7	$this->getJobFilesFromFileSystem($_sPath, $aJobFiles);
189		}
190		}
191
192	8	return $aJobFiles;
193		}
194
195		/**
196		* @param string $sJobName
197		* @param string $sJobFile
198		* @throws JobLoadException
199		*/
200	7	private function setJobFileToMap($sJobName, $sJobFile)
201		{
202		// set path to job file map
203	7	if (isset($this->aJobFileMap[$sJobName]))
204		{
205	1	throw new JobLoadException(
206	1	sprintf('The jobname "%s" already exists. Jobnames have to be unique - Please check your local jobfiles for duplicate entries.', $sJobName),
207	1	JobLoadException::ERROR_CODE_DUPLICATE_JOB_ID
208		);
209		}
210
211	7	$this->aJobFileMap[$sJobName] = $sJobFile;
212	7	}
213
214		/**
215		* @param string $sJobName
216		* @return string
217		* @throws \RuntimeException
218		*/
219	4	private function getJobFileFromMap($sJobName)
220		{
221	4	if (!isset($this->aJobFileMap[$sJobName]))
222		{
223		throw new \RuntimeException(sprintf('Can\'t find file for job "%s"', $sJobName));
224		}
225	4	return $this->aJobFileMap[$sJobName];
226		}
227
228		/**
229		* @param string $sJobName
230		* @param string $sJobFile
231		* @return bool
232		* @throws \RuntimeException
233		*/
234	2	private function hasUnsetJobFileFromMap($sJobName, $sJobFile = '')
235		{
236	2	$_sJobFile = (!empty($sJobFile)) ? $sJobFile : $this->getJobFileFromMap($sJobName);
237	2	if (file_exists($_sJobFile))
238		{
239		throw new \RuntimeException(sprintf('Job file "%s" for job "%s" still exists.', $_sJobFile, $sJobName));
240		}
241
242		// unset path from job file map
243	2	unset($this->aJobFileMap[$sJobName]);
244	2	return true;
245		}
246
247		/**
248		* @param array $aJobFiles
249		* @param bool $bSetToFileMap
250		* @return JobEntityInterface[]
251		* @throws JobLoadException
252		*/
253	8	private function loadJobsFromFileContent(array $aJobFiles, $bSetToFileMap)
254		{
255	8	$_aJobs = [];
256
257	8	foreach ($aJobFiles as $_sJobFilePath)
258		{
259	8	$_aJobEntities = [];
260		// remove comment blocks
261	8	$_aTemp = json_decode(
262		preg_replace(
263	8	'~\/\(.?)\*\/~mis',
264	8	'',
265		file_get_contents($_sJobFilePath)
266		)
267		);
268
269	8	if ($_aTemp)
270		{
271	7	if (property_exists($_aTemp, 'name')) // chronos
272		{
273	4	$_aJobEntities[] = new ChronosJobEntity($_aTemp);
274
275	4	} else if (property_exists($_aTemp, 'id')) //marathon
276		{
277	4	foreach ($this->getMarathonEntitiesForConfig($_aTemp) as $_oApp)
278		{
279	4	$_aJobEntities[] = $_oApp;
280		}
281		} else {
282		throw new JobLoadException(
283		'Could not distinguish job as either chronos or marathon',
284		JobLoadException::ERROR_CODE_UNKNOWN_ENTITY_TYPE
285		);
286		}
287
288		/** @var JobEntityInterface $_oJobEntity */
289	7	foreach ($_aJobEntities as $_oJobEntity)
290		{
291	7	if ($bSetToFileMap)
292		{
293		// set path to job file map
294	5	$this->setJobFileToMap($_oJobEntity->getKey(), $_sJobFilePath);
295		}
296
297	7	$_aJobs[] = $_oJobEntity;
298		}
299
300		}
301		else
302		{
303	1	throw new JobLoadException(
304	1	sprintf('Unable to load json job data from "%s". Please check if the json is valid.', $_sJobFilePath),
305	8	JobLoadException::ERROR_CODE_NO_VALID_JSON
306		);
307		}
308		}
309
310	6	return $_aJobs;
311		}
312
313
314	4	private function getMarathonEntitiesForConfig($aEntityData)
315		{
316	4	$_aRet = [];
317	4	if (property_exists($aEntityData, 'apps'))
318		{
319		// store individual apps like single apps
320	2	foreach ($aEntityData->apps as $_oApp)
321		{
322	2	$_oGroupEntity = new MarathonAppEntity($_oApp);
323	2	$this->aGroupedApps[] = $_oApp->id;
324	2	$_aRet[] = $_oGroupEntity;
325		}
326		}
327		else
328		{
329	2	$_aRet[] = new MarathonAppEntity($aEntityData);
330		}
331	4	return $_aRet;
332		}
333
334		/**
335		* @param string $sJobFile
336		* @param JobEntityInterface $oJobEntity
337		* @return bool
338		*/
339	2	private function hasDumpFile($sJobFile, JobEntityInterface $oJobEntity)
340		{
341	2	$this->oFileSystemService->dumpFile(
342		$sJobFile,
343	2	json_encode($oJobEntity, JSON_PRETTY_PRINT \| JSON_UNESCAPED_SLASHES)
344		);
345
346	2	return (file_exists($sJobFile));
347		}
348
349
350	2	private function dumpFileWithGroup($sJobFile, JobEntityInterface $oJobEntity, $bAdd = true)
		0 ignored issues – show Coding Style introduced 2017-02-01 12:21 UTC by Report Bug Copy Issue Report `function dumpFileWithGroup()` does not seem to conform to the naming convention (`^(?:is\|has\|should\|may\|supports)`). This check examines a number of code elements and verifies that they conform to the given naming conventions. You can set conventions for local variables, abstract classes, utility classes, constant, properties, methods, parameters, interfaces, classes, exceptions and special methods. Loading history...
351		{
352	2	$_sGroupConfig = file_get_contents($sJobFile);
353
354	2	$_oDecodedConfig = json_decode(preg_replace(
355	2	'~\/\(.?)\*\/~mis',
356	2	'',
357		$_sGroupConfig
358		));
359
360	2	if (!property_exists($_oDecodedConfig, 'apps'))
361		{
362		throw new \RuntimeException(sprintf(
363		'Job file %s does not contain group configuration. But, "%s" belongs to group %s',
364		$sJobFile,
365		$oJobEntity->getKey(),
366		$_oDecodedConfig->id
367		));
368		}
369
370	2	$_bAppFound = false;
371	2	foreach ($_oDecodedConfig->apps as $key => $_oApp)
372		{
373	2	if ($_oApp->id == $oJobEntity->getKey())
374		{
375	2	if (!$bAdd)
376		{
377	1	array_splice($_oDecodedConfig->apps, $key, 1);
378	1	if (count($_oDecodedConfig->apps) == 0)
379		{
380		$this->oFileSystemService->remove($sJobFile);
381		$iIndex = array_search($oJobEntity->getKey(), $this->aGroupedApps);
382		if ($iIndex)
383		{
384		unset($this->aGroupedApps[$iIndex]);
385		}
386	1	return false;
387		}
388		} else {
389	1	$_oDecodedConfig->apps[$key] = $oJobEntity;
390		}
391	2	$_bAppFound = true;
392		}
393		}
394
395	2	if (!$_bAppFound)
396		{
397		throw new \RuntimeException(sprintf(
398		'Could update job. job %s could not be found in the group file %s.',
399		$oJobEntity->getKey(),
400		$sJobFile
401		));
402		}
403
404	2	$_sUpdatedConfig = json_encode($_oDecodedConfig, JSON_PRETTY_PRINT \| JSON_UNESCAPED_SLASHES);
405
406	2	$this->oFileSystemService->dumpFile(
407		$sJobFile,
408		$_sUpdatedConfig
409		);
410
411	2	return (file_exists($sJobFile));
412		}
413		}

trivago / chapi

GitHub Access Token became invalid

Pull Request — master (#68)

BridgeFileSystem::getJobs() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like