WorkflowService::getAdditionalDefinitionsFor() - Code Metrics - Inspection of "Feature type based workflow. Assign workflows to d..." - silverstripe-australia/advancedworkflow - Measure and Improve Code Quality continuously with Scrutinizer

Completed
Pull Request — master (#239)

unknown
created 2016-01-21 00:01 UTC
WorkflowService::getAdditionalDefinitionsFor() B

↳ Parent: WorkflowService
Complexity

Conditions	7
Paths	6
Size

Total Lines	17
Code Lines	11
Duplication

Lines	0
Ratio	0 %
Metric	Value
dl	0
loc	17
rs	8.2222
cc	7
eloc	11
nc	6
nop	1
<?php

/**
 * A central point for interacting with workflows
 *
 * @author  [email protected]
 * @license BSD License (http://silverstripe.org/bsd-license/)
 * @package advancedworkflow
 */
class WorkflowService implements PermissionProvider {
namespace YourVendor;

class YourClass { }
	
	/**
	 * An array of templates that we can create from
	 * 
	 * @var array
	 */
	protected $templates;
	
	public function  __construct() {
	}

	
	/**
	 * Set the list of templates that can be created
	 * 
	 * @param type $templates 
	 */
	public function setTemplates($templates) {
		$this->templates = $templates;

	}
	
	/**
	 * Return the list of available templates
	 * @return type 
	 */
	public function getTemplates() {
		return $this->templates;
	}
	
	/**
	 * Get a template by name
	 * 
	 * @param string $name 
	 * @return WorkflowTemplate
	 */
	public function getNamedTemplate($name) {
		if($importedTemplate = singleton('WorkflowDefinitionImporter')->getImportedWorkflows($name)) {
			return $importedTemplate;
		}
		
		if (!is_array($this->templates)) {
			return;
		}
		foreach ($this->templates as $template) {
			if ($template->getName() == $name) {
				return $template;
			}
		}
	}

	/**
	 * Gets the workflow definition for a given dataobject, if there is one
	 * 
	 * Will recursively query parent elements until it finds one, if available
	 *
	 * @param DataObject $dataObject
	 */
	public function getDefinitionFor(DataObject $dataObject) {
		if ($dataObject->hasExtension('WorkflowApplicable') || $dataObject->hasExtension('FileWorkflowApplicable')) {
			if ($dataObject->WorkflowDefinitionID) {
				return DataObject::get_by_id('WorkflowDefinition', $dataObject->WorkflowDefinitionID);
			}
			if ($dataObject->ParentID) {
				return $this->getDefinitionFor($dataObject->Parent());

			}
			if ($dataObject->hasMethod('workflowParent')) {
				$obj = $dataObject->workflowParent();
				if ($obj) {
					return $this->getDefinitionFor($obj);
				}
			}
		}
		return null;
	}

	/**
	 * Gets additional workflow definition for a given dataobject, if there is one
	 *
	 * Will recursively query parent elements until it finds one, if available
	 *
	 * @param DataObject $dataObject
	 */
	public function getAdditionalDefinitionsFor(DataObject $dataObject) {
		if ($dataObject->hasExtension('WorkflowApplicable') || $dataObject->hasExtension('FileWorkflowApplicable')) {
			if ($dataObject->AdditionalWorkflowDefinitions()->count()) {
				return $dataObject->AdditionalWorkflowDefinitions();
			}
			if ($dataObject->ParentID) {
				return $this->getAdditionalDefinitionsFor($dataObject->Parent());

			}
			if ($dataObject->hasMethod('workflowParent')) {
				$obj = $dataObject->workflowParent();
				if ($obj) {
					return $this->getAdditionalDefinitionsFor($obj);
				}
			}
		}
		return null;
	}

	/**
	 *	Retrieves a workflow definition by ID for a data object.
	 *
	 *	@param data object
	 *	@param integer
	 *	@return workflow definition
	 */

	public function getDefinitionByID($object, $workflowID) {

		// Make sure the correct extensions have been applied to the data object.

		$workflow = null;
		if($object->hasExtension('WorkflowApplicable') || $object->hasExtension('FileWorkflowApplicable')) {

			$workflow = null;
			// Validate the workflow ID against the data object.
			if($object->WorkflowDefinitionID == $workflowID) {
				$workflow = DataObject::get_by_id('WorkflowDefinition', $workflowID);
			} else {
				$additionalDefinitions = $this->getAdditionalDefinitionsFor($object);
				if($additionalDefinitions) $workflow = $additionalDefinitions->byID($workflowID);
			}
		}
		return $workflow;
	}

	/**
	 *	Retrieves and collates the workflow definitions for a data object, where the first element will be the main workflow definition.
	 *
	 *	@param data object
	 *	@return array
	 */

	public function getDefinitionsFor($object) {

		// Retrieve the main workflow definition.

		$default = $this->getDefinitionFor($object);
		if($default) {
			$additionalDefinitions = $this->getAdditionalDefinitionsFor($object);
			// Merge the additional workflow definitions.
			return is_a($additionalDefinitions, 'ManyManyList')
				? array_merge(array($default),$additionalDefinitions->toArray())
				: array($default);
		}
		return null;
	}

	/**
	 * Gets the workflow for the given item
	 *
	 * The item can be
	 *
	 * a data object in which case the ActiveWorkflow will be returned,
	 * an action, in which case the Workflow will be returned
	 * an integer, in which case the workflow with that ID will be returned
	 *
	 * @param mixed $item
	 *
	 * @return WorkflowInstance
	 */
	public function getWorkflowFor($item, $includeComplete = false) {
		$id = $item;
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}

		if ($item instanceof WorkflowAction) {
			$id = $item->WorkflowID;
<?php

/**
 * @property int $x
 * @property int $y
 * @property string $text
 */
class MyLabel
{
    private $properties;

    private $allowedProperties = array('x', 'y', 'text');

    public function __get($name)
    {
        if (isset($properties[$name]) && in_array($name, $this->allowedProperties)) {
            return $properties[$name];
        } else {
            return null;
        }
    }

    public function __set($name, $value)
    {
        if (in_array($name, $this->allowedProperties)) {
            $properties[$name] = $value;
        } else {
            throw new \LogicException("Property $name is not defined.");
        }
    }

}
			return DataObject::get_by_id('WorkflowInstance', $id);
		} else if (is_object($item) && ($item->hasExtension('WorkflowApplicable') || $item->hasExtension('FileWorkflowApplicable'))) {
			$filter = sprintf('"TargetClass" = \'%s\' AND "TargetID" = %d', ClassInfo::baseDataClass($item), $item->ID);
			$complete = $includeComplete ? 'OR "WorkflowStatus" = \'Complete\' ' : '';
			return DataObject::get_one('WorkflowInstance', $filter . ' AND ("WorkflowStatus" = \'Active\' OR "WorkflowStatus"=\'Paused\' ' . $complete . ')');
		}
	}

	/**
	 * Get all the workflow action instances for an item
	 *
	 * @return DataObjectSet
	 */
	public function getWorkflowHistoryFor($item, $limit = null){
		if($active = $this->getWorkflowFor($item, true)){
			$limit = $limit ? "0,$limit" : '';
			return $active->Actions('', 'ID DESC ', null, $limit);	

		}
	}

	/**
	 * Get all the available workflow definitions
	 *
	 * @return DataList
	 */
	public function getDefinitions() {
		return DataList::create('WorkflowDefinition');
	}

	/**
	 * Given a transition ID, figure out what should happen to
	 * the given $subject.
	 *
	 * In the normal case, this will load the current workflow instance for the object
	 * and then transition as expected. However, in some cases (eg to start the workflow)
	 * it is necessary to instead create a new instance. 
	 *
	 * @param DataObject $target
	 * @param int $transitionId
	 */
	public function executeTransition(DataObject $target, $transitionId) {
		$workflow   = $this->getWorkflowFor($target);
		$transition = DataObject::get_by_id('WorkflowTransition', $transitionId);

		if(!$transition) {
			throw new Exception(_t('WorkflowService.INVALID_TRANSITION_ID', "Invalid transition ID $transitionId"));
		}

		if(!$workflow) {
			throw new Exception(_t('WorkflowService.INVALID_WORKFLOW_TARGET', "A transition was executed on a target that does not have a workflow."));
		}

		if($transition->Action()->WorkflowDefID != $workflow->DefinitionID) {
<?php

/**
 * @property int $x
 * @property int $y
 * @property string $text
 */
class MyLabel
{
    private $properties;

    private $allowedProperties = array('x', 'y', 'text');

    public function __get($name)
    {
        if (isset($properties[$name]) && in_array($name, $this->allowedProperties)) {
            return $properties[$name];
        } else {
            return null;
        }
    }

    public function __set($name, $value)
    {
        if (in_array($name, $this->allowedProperties)) {
            $properties[$name] = $value;
        } else {
            throw new \LogicException("Property $name is not defined.");
        }
    }

}
			throw new Exception(_t('WorkflowService.INVALID_TRANSITION_WORKFLOW', "Transition #$transition->ID is not attached to workflow #$workflow->ID."));
		}

		$workflow->performTransition($transition);

	}

	/**
	 * Starts the workflow for the given data object, assuming it or a parent has
	 * a definition specified. 
	 * 
	 * @param DataObject $object
	 */
	public function startWorkflow(DataObject $object, $workflowID = null) {
		$existing = $this->getWorkflowFor($object);
		if ($existing) {
			throw new ExistingWorkflowException(_t('WorkflowService.EXISTING_WORKFLOW_ERROR', "That object already has a workflow running"));
		}

		$definition = null;
		if($workflowID) {

			// Retrieve the workflow definition that has been triggered.

			$definition = $this->getDefinitionByID($object, $workflowID);
		}
		if(is_null($definition)) {

			// Fall back to the main workflow definition.

			$definition = $this->getDefinitionFor($object);
		}

		if ($definition) {
			$instance = new WorkflowInstance();
			$instance->beginWorkflow($definition, $object);
			$instance->execute();
		}
	}
	
	/**
	 * Get all the workflows that this user is responsible for
	 * 
	 * @param Member $user 
	 *				The user to get workflows for
	 * 
	 * @return ArrayList
	 *				The list of workflow instances this user owns
	 */
	public function usersWorkflows(Member $user) {
		
		$groupIds = $user->Groups()->column('ID');
		
		$groupInstances = null;
		
		$filter = array('');
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}
		
		if (is_array($groupIds)) {
			$groupInstances = DataList::create('WorkflowInstance')
				->filter(array('Group.ID:ExactMatchMulti' => $groupIds))
				->where('"WorkflowStatus" != \'Complete\'');
		}

		$userInstances = DataList::create('WorkflowInstance')
			->filter(array('Users.ID:ExactMatch' => $user->ID))
			->where('"WorkflowStatus" != \'Complete\'');

		if ($userInstances) {
			$userInstances = $userInstances->toArray();
		} else {
			$userInstances = array();
		}
		
		if ($groupInstances) {
			$groupInstances = $groupInstances->toArray();
		} else {
			$groupInstances = array();
		}

		$all = array_merge($groupInstances, $userInstances);
		
		return ArrayList::create($all);
	}

	/**
	 * Get items that the passed-in user has awaiting for them to action
	 * 
	 * @param Member $member
/**
 * @param array $germany
 * @param array $island
 * @param array $italy
 */
function finale($germany, $island) {
    return "2:1";
}
	 * @return DataList $userInstances
	 */
	public function userPendingItems(Member $user) {
		// Don't restrict anything for ADMIN users
		$userInstances = DataList::create('WorkflowInstance')
			->where('"WorkflowStatus" != \'Complete\'')
			->sort('LastEdited DESC');

		if(Permission::checkMember($user, 'ADMIN')) {
			return $userInstances;
		}
		$instances = new ArrayList();
		foreach($userInstances as $inst) {
			$instToArray = $inst->getAssignedMembers();
			if(!count($instToArray)>0 || !in_array($user->ID,$instToArray->column())) {
				continue;
			}
			$instances->push($inst);
		}
		
		return $instances;
class Author {
    private $name;

    public function __construct($name) {
        $this->name = $name;
    }

    public function getName() {
        return $this->name;
    }
}

abstract class Post {
    public function getAuthor() {
        return 'Johannes';
    }
}

class BlogPost extends Post {
    public function getAuthor() {
        return new Author('Johannes');
    }
}

class ForumPost extends Post { /* ... */ }

function my_function(Post $post) {
    echo strtoupper($post->getAuthor());
}
	}

	/**
	 * Get items that the passed-in user has submitted for workflow review
	 *
	 * @param Member $member
/**
 * @param array $germany
 * @param array $island
 * @param array $italy
 */
function finale($germany, $island) {
    return "2:1";
}
	 * @return DataList $userInstances
	 */
	public function userSubmittedItems(Member $user) {
		$userInstances = DataList::create('WorkflowInstance')
			->where('"WorkflowStatus" != \'Complete\'')
			->sort('LastEdited DESC');

		// Restrict the user if they're not an ADMIN.
		if(!Permission::checkMember($user, 'ADMIN')) {
			$userInstances = $userInstances->filter('InitiatorID:ExactMatch', $user->ID);
		}

		return $userInstances;
	}
	
	/**
	 * Generate a workflow definition based on a template
	 * 
	 * @param WorkflowDefinition $definition
	 * @param string $templateName 
	 */
	public function defineFromTemplate(WorkflowDefinition $definition, $templateName) {
		$template = null;
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}
		/* @var $template WorkflowTemplate */
		
		if (!is_array($this->templates)) {
			return;
		}

		$template = $this->getNamedTemplate($templateName);		
		
		if (!$template) {
			return;
		}

		$template->createRelations($definition);
		
		// Set the version and do the write at the end so that we don't trigger an infinite loop!!
		$definition->Description = $template->getDescription();
<?php

/**
 * @property int $x
 * @property int $y
 * @property string $text
 */
class MyLabel
{
    private $properties;

    private $allowedProperties = array('x', 'y', 'text');

    public function __get($name)
    {
        if (isset($properties[$name]) && in_array($name, $this->allowedProperties)) {
            return $properties[$name];
        } else {
            return null;
        }
    }

    public function __set($name, $value)
    {
        if (in_array($name, $this->allowedProperties)) {
            $properties[$name] = $value;
        } else {
            throw new \LogicException("Property $name is not defined.");
        }
    }

}
		$definition->TemplateVersion = $template->getVersion();
<?php

/**
 * @property int $x
 * @property int $y
 * @property string $text
 */
class MyLabel
{
    private $properties;

    private $allowedProperties = array('x', 'y', 'text');

    public function __get($name)
    {
        if (isset($properties[$name]) && in_array($name, $this->allowedProperties)) {
            return $properties[$name];
        } else {
            return null;
        }
    }

    public function __set($name, $value)
    {
        if (in_array($name, $this->allowedProperties)) {
            $properties[$name] = $value;
        } else {
            throw new \LogicException("Property $name is not defined.");
        }
    }

}
		$definition->RemindDays = $template->getRemindDays();
<?php

/**
 * @property int $x
 * @property int $y
 * @property string $text
 */
class MyLabel
{
    private $properties;

    private $allowedProperties = array('x', 'y', 'text');

    public function __get($name)
    {
        if (isset($properties[$name]) && in_array($name, $this->allowedProperties)) {
            return $properties[$name];
        } else {
            return null;
        }
    }

    public function __set($name, $value)
    {
        if (in_array($name, $this->allowedProperties)) {
            $properties[$name] = $value;
        } else {
            throw new \LogicException("Property $name is not defined.");
        }
    }

}
		$definition->Sort = $template->getSort();
<?php

/**
 * @property int $x
 * @property int $y
 * @property string $text
 */
class MyLabel
{
    private $properties;

    private $allowedProperties = array('x', 'y', 'text');

    public function __get($name)
    {
        if (isset($properties[$name]) && in_array($name, $this->allowedProperties)) {
            return $properties[$name];
        } else {
            return null;
        }
    }

    public function __set($name, $value)
    {
        if (in_array($name, $this->allowedProperties)) {
            $properties[$name] = $value;
        } else {
            throw new \LogicException("Property $name is not defined.");
        }
    }

}
		$definition->write();
		return $definition;
	}

	/**
	 * Reorders actions within a definition
	 *
	 * @param WorkflowDefinition|WorkflowAction $objects
	 *				The objects to be reordered
	 * @param array $newOrder
	 *				An array of IDs of the actions in the order they should be.
	 */
	public function reorder($objects, $newOrder) {
		$sortVals = array_values($objects->map('ID', 'Sort')->toArray());
		sort($sortVals);

		// save the new ID values - but only use existing sort values to prevent
		// conflicts with items not in the table
		foreach($newOrder as $key => $id) {
			if (!$id) {
				continue;
			}
			$object = $objects->find('ID', $id);
			$object->Sort = $sortVals[$key];
			$object->write();
		}
	}

	/**
	 * 
	 * @return array
	 */
	public function providePermissions() {
		return array(
			'CREATE_WORKFLOW' => array(
				'name' => _t('AdvancedWorkflow.CREATE_WORKFLOW', 'Create workflow'),
				'category' => _t('AdvancedWorkflow.ADVANCED_WORKFLOW', 'Advanced Workflow'),
				'help' => _t('AdvancedWorkflow.CREATE_WORKFLOW_HELP', 'Users can create workflow definitions'),
				'sort' => 0
			),
			'DELETE_WORKFLOW' => array(
				'name' => _t('AdvancedWorkflow.DELETE_WORKFLOW', 'Delete workflow'),
				'category' => _t('AdvancedWorkflow.ADVANCED_WORKFLOW', 'Advanced Workflow'),
				'help' => _t('AdvancedWorkflow.DELETE_WORKFLOW_HELP', 'Users can delete workflow definitions and active workflows'),
				'sort' => 0
			),
			'APPLY_WORKFLOW' => array(
				'name' => _t('AdvancedWorkflow.APPLY_WORKFLOW', 'Apply workflow'),
				'category' => _t('AdvancedWorkflow.ADVANCED_WORKFLOW', 'Advanced Workflow'),
				'help' => _t('AdvancedWorkflow.APPLY_WORKFLOW_HELP', 'Users can apply workflows to items'),
				'sort' => 0
			),
			'VIEW_ACTIVE_WORKFLOWS' => array(
				'name'     => _t('AdvancedWorkflow.VIEWACTIVE', 'View active workflows'),
				'category' => _t('AdvancedWorkflow.ADVANCED_WORKFLOW', 'Advanced Workflow'),
				'help'     => _t('AdvancedWorkflow.VIEWACTIVEHELP', 'Users can view active workflows via the workflows admin panel'),
				'sort'     => 0
			),
			'REASSIGN_ACTIVE_WORKFLOWS' => array(
				'name'     => _t('AdvancedWorkflow.REASSIGNACTIVE', 'Reassign active workflows'),
				'category' => _t('AdvancedWorkflow.ADVANCED_WORKFLOW', 'Advanced Workflow'),
				'help'     => _t('AdvancedWorkflow.REASSIGNACTIVEHELP', 'Users can reassign active workflows to different users and groups'),
				'sort'     => 0
			)
		);
	}
	
}

class ExistingWorkflowException extends Exception {};
namespace YourVendor;

class YourClass { }

silverstripe-australia / advancedworkflow

Pull Request — master (#239)

WorkflowService::getAdditionalDefinitionsFor() B

Complexity

Size

Duplication

Duplication Side-by-Side

Filter issues like
