console.php

Ir a la documentación de este archivo.

<?php
require CORE_PATH . 'kumbia/util.php';
require CORE_PATH . 'kumbia/kumbia_exception.php';
require CORE_PATH . 'kumbia/config.php';
require CORE_PATH . 'kumbia/load.php';

class Console
{
    private static function _getConsoleArgs($argv)
    {
        $args = array(array());

        foreach($argv as $p) {
            if(is_string($p) && preg_match("/--([a-z_0-9]+)[=](.+)/", $p, $regs)){
                // carga en el array de parametros nombrados
                $args[0][$regs[1]] = $regs[2];
            } else {
                // lo carga como argumento simple
                $args[] = $p;
            }
        }
        
        return $args;
    }
    
    public static function load($console_name)
    {
        // nombre de la clase de consola
        $Console = Util::camelcase($console_name) . 'Console';
        
        if(!class_exists($Console)) {
            // intenta carga el archivo de consola
            $file = APP_PATH . "extensions/console/{$console_name}_console.php";
            
            if(!is_file($file)) {
                $file = CORE_PATH . "console/{$console_name}_console.php";
                
                if(!is_file($file)) {
                    throw new KumbiaException('Consola "' . $file . '" no se encontro');
                }
            }
            
            // incluye la consola
            include_once $file;
        }
        
        // crea la instancia de objeto
        $console = new $Console();
        
        // inicializa la consola
        if(method_exists($console, 'initialize')) {
            $console->initialize();
        }
        
        return $console;
    }
    
    public static function dispatch($argv)
    {    
        // Elimino el nombre de archivo del array de argumentos
        array_shift($argv);
    
        // obtiene el nombre de consola
        $console_name = array_shift($argv);
        if(!$console_name) {
            throw new KumbiaException('No ha indicado la consola a ejecutar');
        }

        // obtiene el nombre de comando a ejecutar
        $command = array_shift($argv);
        if(!$command) {
            $command = 'main';
        }

        // Obtiene los argumentos para la consola, el primer argumento
        // es el array de parametros nombrados para terminal
        $args = self::_getConsoleArgs($argv);
        
        // verifica el path de aplicacion
        if(isset($args[0]['path'])) {
            $dir = realpath($args[0]['path']);
            if(!$dir) {
                throw new KumbiaException("La ruta \"{$args[0]['path']}\" es invalida");
            }
            // elimina el parametro path del array
            unset($args[0]['path']);
        } else {
            // obtiene el directorio de trabajo actual
            $dir = getcwd();
        }
        
        // define el path de la aplicacion
        define('APP_PATH', rtrim($dir, '/') . '/');
    
                // lee la configuracion
                $config = Config::read('config');

                // constante que indica si la aplicacion se encuentra en produccion
                define('PRODUCTION', $config['application']['production']);
        
        // crea la consola
        $console = self::load($console_name);
        
        // verifica que exista el comando en la consola
        if(!method_exists($console, $command)) {
            throw new KumbiaException("El comando \"$command\" no existe para la consola \"$console_name\"");
        }
        
                // si se intenta ejecutar 
                if($command == 'initialize') {
                        throw new KumbiaException("El comando initialize es un comando reservado");
                }
                
        // verifica los parametros para la accion de consola
        $reflectionMethod = new ReflectionMethod($console, $command);
                if(count($args) < $reflectionMethod->getNumberOfRequiredParameters()){
                        throw new KumbiaException("Número de parametros erroneo para ejecutar el comando \"$command\" en la consola \"$console_name\"");
                }
        
        // ejecuta el comando
        call_user_func_array(array($console, $command), $args);
    }
    
    public static function input($message, $values=NULL)
    {
        // abre la entrada
        $stdin = fopen('php://stdin', 'r');
        
        do {
            // imprime el mensaje
            echo $message;
            
            // lee la linea desde el terminal
            $data = str_replace(PHP_EOL, '', fgets($stdin));
        } while($values && !in_array($data, $values));
        
        // cierra el recurso
        fclose($stdin);
        
        return $data;
    }
}