kohana-migrations/classes/controller/minion.php

<?php

/**
 * Controller for interacting with minion on the cli
 *
 * @author Matt Button <matthew@sigswitch.com>
 **/
class Controller_Minion extends Controller
{
	/**
	 * Prevent Minion from being run over http
	 */
	public function before()
	{
		if( ! Kohana::$is_cli)
		{
			throw new Request_Exception("Minion can only be ran from the cli");
		}

		return parent::before();
	}

	/**
	 * Prints out the help for a specific task
	 *
	 */
	public function action_help()
	{
		$tasks = Minion_Util::compile_task_list(Kohana::list_files('classes/minion/task'));
		$task  = $this->request->param('task');
		$view  = NULL;

		if(empty($task))
		{
			$view = new View('minion/help/list');

			$view->tasks = $tasks;
		}
		else
		{
			$class = Minion_Util::convert_task_to_class_name($task);

			if( ! class_exists($class))
			{
				echo View::factory('minion/help/error')
					->set('error', 'Task "'.$task.'" does not exist');

				exit(1);
			}

			$inspector = new ReflectionClass($class);

			list($description, $tags) = Minion_Util::parse_doccomment($inspector->getDocComment());

			$view = View::factory('minion/help/task')
				->set('description', $description)
				->set('tags', (array) $tags)
				->set('task', $task);
		}

		echo $view;
	}

	/**
	 * Handles the request to execute a task.
	 *
	 * Responsible for parsing the tasks to execute & also any config items that 
	 * should be passed to the tasks
	 */
	public function action_execute()
	{
		$tasks = trim($this->request->param('task'));

		if(empty($tasks))
			return $this->action_help();

		$tasks = explode(',', $tasks);

		$master = new Minion_Master;

		$options = $master->load($tasks)->get_config_options();

		$config = array();

		// Allow the user to specify config for each task, namespacing each 
		// config option with the name of the task that "owns" it
		foreach($options as $task_name => $task_options)
		{
			$namespace = $task_name.Minion_Util::$task_separator;

			// Namespace each config option
			foreach($task_options as $i => $task_option)
			{
				$task_options[$i] = $namespace.$task_option;
			}

			// Get any config options the user's passed
			$task_config = call_user_func_array(array('CLI', 'options'), $task_options);

			if( ! empty($task_config))
			{
				$namespace_length = strlen($namespace);

				// Strip the namespace off all the config options
				foreach($task_config as $key => $value)
				{
					$config[$task_name][substr($key, $namespace_length)] = $value;
				}
			}
		}

		$master->execute($config);
	}
}