JobEntityValidatorService::isSchedulePropertyValid() - Code Metrics - Inspection of "code style and coverage" - trivago/chapi - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Branch — feature/add_container_job_supp... (a90b83)

by Marc

created 2016-11-07 09:39 UTC

isSchedulePropertyValid() B

↳ Parent: JobEntityValidatorService

Complexity

Conditions	6
Paths	4

Size

Total Lines	22
Code Lines	9

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	11
CRAP Score	6

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
c	1
b	0
f	0
dl	0
loc	22
ccs	11
cts	11
cp	1
rs	8.6737
cc	6
eloc	9
nc	4
nop	1
crap	6

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

namespace Chapi\Service\JobRepository;

use Chapi\Component\DatePeriod\DatePeriodFactoryInterface;
use Chapi\Entity\Chronos\JobEntity;
use Chapi\Exception\DatePeriodException;

class JobEntityValidatorService implements JobEntityValidatorServiceInterface
{
    const REG_EX_VALID_NAME = '/^[a-zA-Z0-9_-]*$/';

    /**
     * @var DatePeriodFactoryInterface
     */
    private $oDatePeriodFactory;

    /**
     * @param DatePeriodFactoryInterface $oDatePeriodFactory
     */
    public function __construct(
        DatePeriodFactoryInterface $oDatePeriodFactory
    )
    {
        $this->oDatePeriodFactory = $oDatePeriodFactory;
    }

    /**
     * @param JobEntity $oJobEntity
     * @return bool
     */
    public function isEntityValid(JobEntity $oJobEntity)
    {
        return (!in_array(false, $this->validateJobEntity($oJobEntity)));
    }

    /**
     * @param JobEntity $oJobEntity
     * @return array
     */
    public function validateJobEntity(JobEntity $oJobEntity)
    {
        $_aValidProperties = [];

        foreach ($oJobEntity as $_sProperty => $mValue)
        {
            switch ($_sProperty)
            {
                case 'name':
                    $_aValidProperties[$_sProperty] = $this->isNamePropertyValid($mValue);
                    break;

                case 'command':
                case 'description':
                case 'owner':
                case 'ownerName':
                    $_aValidProperties[$_sProperty] = (!empty($oJobEntity->{$_sProperty}));
                    break;

                case 'epsilon':
                    $_aValidProperties[$_sProperty] = $this->isEpsilonPropertyValid($oJobEntity);
                    break;

                case 'async':
                case 'disabled':
                case 'softError':
                case 'highPriority':
                    $_aValidProperties[$_sProperty] = (is_bool($oJobEntity->{$_sProperty}));
                    break;

                case 'schedule':
                    $_aValidProperties[$_sProperty] = $this->isSchedulePropertyValid($oJobEntity);
                    break;

                case 'parents':
                    $_aValidProperties[$_sProperty] = (is_array($oJobEntity->{$_sProperty}));
                    break;

                case 'retries':
                    $_aValidProperties[$_sProperty] = ($oJobEntity->{$_sProperty} >= 0);
                    break;

                case 'constraints':
                    $_aValidProperties[$_sProperty] = $this->isConstraintsPropertyValid($mValue);
                    break;

                case 'container':
                    $_aValidProperties[$_sProperty] = $this->isContainerPropertyValid($mValue);
                    break;
            }
        }

        return $_aValidProperties;
    }

    /**
     * @param JobEntity $oJobEntity
     * @return array
     */
    public function getInvalidProperties(JobEntity $oJobEntity)
    {
        $_aValidationFields = $this->validateJobEntity($oJobEntity);

        $_aInvalidFields = [];
        foreach ($_aValidationFields as $_sProperty => $_bIsValid)
        {
            if (false == $_bIsValid)
            {
                $_aInvalidFields[] = $_sProperty;
            }
        }

        return $_aInvalidFields;
    }

    /**
     * @param string $sName
     * @return bool
     */
    private function isNamePropertyValid($sName)
    {
        return (!empty($sName) && preg_match(self::REG_EX_VALID_NAME, $sName));
    }

    /**
     * @param JobEntity $oJobEntity
     * @return bool
     */
    private function isSchedulePropertyValid(JobEntity $oJobEntity)
    {
        if (empty($oJobEntity->schedule) && !empty($oJobEntity->parents))
        {
            return true;
        }

        if (!empty($oJobEntity->schedule) && empty($oJobEntity->parents))
        {
            try
            {
                $_oDataPeriod = $this->oDatePeriodFactory->createDatePeriod($oJobEntity->schedule, $oJobEntity->scheduleTimeZone);
                return (false !== $_oDataPeriod);
            }
            catch (DatePeriodException $oException)
            {
                // invalid: Iso8601 is not valid and/or DatePeriodFactory is able to create a valid DatePeriod
            }
        }

        return false;
    }

    /**
     * @param JobEntity $oJobEntity
     * @return bool
     */
    private function isEpsilonPropertyValid(JobEntity $oJobEntity)
    {
        if ($oJobEntity->isSchedulingJob() && !empty($oJobEntity->epsilon))
        {
            try
            {
                $_oDateIntervalEpsilon = new \DateInterval($oJobEntity->epsilon);
                $_iIntervalEpsilon = (int) $_oDateIntervalEpsilon->format('%Y%M%D%H%I%S');
                
                if ($_iIntervalEpsilon > 30) // if epsilon > "PT30S"
                {
                    $_oIso8601Entity = $this->oDatePeriodFactory->createIso8601Entity($oJobEntity->schedule);

                    $_oDateIntervalScheduling = new \DateInterval($_oIso8601Entity->sInterval);
                    $_iIntervalScheduling = (int) $_oDateIntervalScheduling->format('%Y%M%D%H%I%S');
                    
                    return ($_iIntervalScheduling > $_iIntervalEpsilon);
                }

                // if epsilon is less or equal than 30sec the not empty check is enough
                return true;
            }
            catch (\Exception $_oException)
            {
                // can't init \DateInterval instance
                return false;
            }
        }

        // else
        return (!empty($oJobEntity->epsilon));
    }

    /**
     * @param array $aConstraints
     * @return bool
     */
    private function isConstraintsPropertyValid(array $aConstraints)
    {
        if (!empty($aConstraints))
        {
            foreach ($aConstraints as $_aConstraint)
            {
                if (!is_array($_aConstraint) || count($_aConstraint) != 3)
                {
                    return false;
                }
            }
        }

        return true;
    }

    /**
     * @param JobEntity\ContainerEntity $oContainer
     * @return bool
     *
     * @see http://mesos.github.io/chronos/docs/api.html#adding-a-docker-job
     * This contains the subfields for the Docker container:
     *  type (required), image (required), forcePullImage (optional), network (optional),
     *  and volumes (optional)
     */
    private function isContainerPropertyValid($oContainer)
    {
        if (is_null($oContainer))
        {
            return true;
        }

        if (is_object($oContainer))
        {
            if (empty($oContainer->type) || empty($oContainer->image))
            {
                return false;
            }
            
            if (!is_null($oContainer->volumes) && !is_array($oContainer->volumes))
            {
                return false;
            }

            foreach ($oContainer->volumes as $_oVolume)
$collection = json_decode($data, true);
if ( ! is_array($collection)) {
    throw new \RuntimeException('$collection must be an array.');
}

foreach ($collection as $item) { /** ... */ }
            {
                if (!in_array($_oVolume->mode, ['RO', 'RW']))
                {
                    return false;
                }
            }

            return true;
        }
        
        return false;
    }
}

1		<?php
2		/**
3		* @package: chapi
4		*
5		* @author: msiebeneicher
6		* @since: 2015-07-31
7		*
8		*/
9
10		namespace Chapi\Service\JobRepository;
11
12		use Chapi\Component\DatePeriod\DatePeriodFactoryInterface;
13		use Chapi\Entity\Chronos\JobEntity;
14		use Chapi\Exception\DatePeriodException;
15
16		class JobEntityValidatorService implements JobEntityValidatorServiceInterface
17		{
18		const REG_EX_VALID_NAME = '/^[a-zA-Z0-9_-]*$/';
19
20		/**
21		* @var DatePeriodFactoryInterface
22		*/
23		private $oDatePeriodFactory;
24
25		/**
26		* @param DatePeriodFactoryInterface $oDatePeriodFactory
27		*/
28	13	public function __construct(
29		DatePeriodFactoryInterface $oDatePeriodFactory
30		)
31		{
32	13	$this->oDatePeriodFactory = $oDatePeriodFactory;
33	13	}
34
35		/**
36		* @param JobEntity $oJobEntity
37		* @return bool
38		*/
39	12	public function isEntityValid(JobEntity $oJobEntity)
40		{
41	12	return (!in_array(false, $this->validateJobEntity($oJobEntity)));
42		}
43
44		/**
45		* @param JobEntity $oJobEntity
46		* @return array
47		*/
48	13	public function validateJobEntity(JobEntity $oJobEntity)
49		{
50	13	$_aValidProperties = [];
51
52	13	foreach ($oJobEntity as $_sProperty => $mValue)
53		{
54		switch ($_sProperty)
55		{
56	13	case 'name':
57	13	$_aValidProperties[$_sProperty] = $this->isNamePropertyValid($mValue);
58	13	break;
59
60	13	case 'command':
61	13	case 'description':
62	13	case 'owner':
63	13	case 'ownerName':
64	13	$_aValidProperties[$_sProperty] = (!empty($oJobEntity->{$_sProperty}));
65	13	break;
66
67	13	case 'epsilon':
68	13	$_aValidProperties[$_sProperty] = $this->isEpsilonPropertyValid($oJobEntity);
69	13	break;
70
71	13	case 'async':
72	13	case 'disabled':
73	13	case 'softError':
74	13	case 'highPriority':
75	13	$_aValidProperties[$_sProperty] = (is_bool($oJobEntity->{$_sProperty}));
76	13	break;
77
78	13	case 'schedule':
79	13	$_aValidProperties[$_sProperty] = $this->isSchedulePropertyValid($oJobEntity);
80	13	break;
81
82	13	case 'parents':
83	13	$_aValidProperties[$_sProperty] = (is_array($oJobEntity->{$_sProperty}));
84	13	break;
85
86	13	case 'retries':
87	13	$_aValidProperties[$_sProperty] = ($oJobEntity->{$_sProperty} >= 0);
88	13	break;
89
90	13	case 'constraints':
91	13	$_aValidProperties[$_sProperty] = $this->isConstraintsPropertyValid($mValue);
92	13	break;
93
94	13	case 'container':
95	13	$_aValidProperties[$_sProperty] = $this->isContainerPropertyValid($mValue);
96	13	break;
97		}
98	13	}
99
100	13	return $_aValidProperties;
101		}
102
103		/**
104		* @param JobEntity $oJobEntity
105		* @return array
106		*/
107	1	public function getInvalidProperties(JobEntity $oJobEntity)
108		{
109	1	$_aValidationFields = $this->validateJobEntity($oJobEntity);
110
111	1	$_aInvalidFields = [];
112	1	foreach ($_aValidationFields as $_sProperty => $_bIsValid)
113		{
114	1	if (false == $_bIsValid)
115	1	{
116	1	$_aInvalidFields[] = $_sProperty;
117	1	}
118	1	}
119
120	1	return $_aInvalidFields;
121		}
122
123		/**
124		* @param string $sName
125		* @return bool
126		*/
127	13	private function isNamePropertyValid($sName)
128		{
129	13	return (!empty($sName) && preg_match(self::REG_EX_VALID_NAME, $sName));
130		}
131
132		/**
133		* @param JobEntity $oJobEntity
134		* @return bool
135		*/
136	13	private function isSchedulePropertyValid(JobEntity $oJobEntity)
137		{
138	13	if (empty($oJobEntity->schedule) && !empty($oJobEntity->parents))
139	13	{
140	1	return true;
141		}
142
143	12	if (!empty($oJobEntity->schedule) && empty($oJobEntity->parents))
144	12	{
145		try
146		{
147	11	$_oDataPeriod = $this->oDatePeriodFactory->createDatePeriod($oJobEntity->schedule, $oJobEntity->scheduleTimeZone);
148	11	return (false !== $_oDataPeriod);
149		}
150	1	catch (DatePeriodException $oException)
151		{
152		// invalid: Iso8601 is not valid and/or DatePeriodFactory is able to create a valid DatePeriod
153		}
154	1	}
155
156	2	return false;
157		}
158
159		/**
160		* @param JobEntity $oJobEntity
161		* @return bool
162		*/
163	13	private function isEpsilonPropertyValid(JobEntity $oJobEntity)
164		{
165	13	if ($oJobEntity->isSchedulingJob() && !empty($oJobEntity->epsilon))
166	13	{
167		try
168		{
169	11	$_oDateIntervalEpsilon = new \DateInterval($oJobEntity->epsilon);
170	10	$_iIntervalEpsilon = (int) $_oDateIntervalEpsilon->format('%Y%M%D%H%I%S');
171
172	10	if ($_iIntervalEpsilon > 30) // if epsilon > "PT30S"
173	10	{
174	9	$_oIso8601Entity = $this->oDatePeriodFactory->createIso8601Entity($oJobEntity->schedule);
175
176	9	$_oDateIntervalScheduling = new \DateInterval($_oIso8601Entity->sInterval);
177	9	$_iIntervalScheduling = (int) $_oDateIntervalScheduling->format('%Y%M%D%H%I%S');
178
179	9	return ($_iIntervalScheduling > $_iIntervalEpsilon);
180		}
181
182		// if epsilon is less or equal than 30sec the not empty check is enough
183	1	return true;
184		}
185	1	catch (\Exception $_oException)
186		{
187		// can't init \DateInterval instance
188	1	return false;
189		}
190		}
191
192		// else
193	3	return (!empty($oJobEntity->epsilon));
194		}
195
196		/**
197		* @param array $aConstraints
198		* @return bool
199		*/
200	13	private function isConstraintsPropertyValid(array $aConstraints)
201		{
202	13	if (!empty($aConstraints))
203	13	{
204	1	foreach ($aConstraints as $_aConstraint)
205		{
206	1	if (!is_array($_aConstraint) \|\| count($_aConstraint) != 3)
207	1	{
208	1	return false;
209		}
210	1	}
211	1	}
212
213	13	return true;
214		}
215
216		/**
217		* @param JobEntity\ContainerEntity $oContainer
218		* @return bool
219		*
220		* @see http://mesos.github.io/chronos/docs/api.html#adding-a-docker-job
221		* This contains the subfields for the Docker container:
222		* type (required), image (required), forcePullImage (optional), network (optional),
223		* and volumes (optional)
224		*/
225	13	private function isContainerPropertyValid($oContainer)
226		{
227	13	if (is_null($oContainer))
228	13	{
229	10	return true;
230		}
231
232	3	if (is_object($oContainer))
233	3	{
234	2	if (empty($oContainer->type) \|\| empty($oContainer->image))
235	2	{
236	1	return false;
237		}
238
239	2	if (!is_null($oContainer->volumes) && !is_array($oContainer->volumes))
240	2	{
241		return false;
242		}
243
244	2	foreach ($oContainer->volumes as $_oVolume)
		0 ignored issues – show Bug introduced 2016-11-04 16:23 UTC by Report Bug Copy Issue Report The expression `$oContainer->volumes` of type `null\|array` is not guaranteed to be traversable. How about adding an additional type check? There are different options of fixing this problem. If you want to be on the safe side, you can add an additional type-check: $collection = json_decode($data, true); if ( ! is_array($collection)) { throw new \RuntimeException('$collection must be an array.'); } foreach ($collection as $item) { /** ... / } If you are sure that the expression is traversable, you might want to add a doc comment cast* to improve IDE auto-completion and static analysis: /** @var array $collection / $collection = json_decode($data, true); foreach ($collection as $item) { /* .. / } Mark the issue as a false-positive*: Just hover the remove button, in the top-right corner of this issue for more options. Loading history...
245		{
246	2	if (!in_array($_oVolume->mode, ['RO', 'RW']))
247	2	{
248	1	return false;
249		}
250	2	}
251
252	2	return true;
253		}
254
255	2	return false;
256		}
257		}

trivago / chapi

GitHub Access Token became invalid

Branch — feature/add_container_job_supp... (a90b83)

isSchedulePropertyValid() B

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like