WebSVN – Applications.gtt – Diff – /trunk/bibliotheque/pear/PEAR/Command/Channels.php

  * PEAR_Command_Channels (list-channels, update-channels, channel-delete, channel-add,
  * channel-update, channel-info, channel-alias, channel-discover commands)
+ *
  * PHP versions 4 and 5
+ *
- * LICENSE: This source file is subject to version 3.0 of the PHP license
- * that is available through the world-wide-web at the following URI:
- * http://www.php.net/license/3_0.txt.  If you did not receive a copy of
- * the PHP License and are unable to obtain it through the web, please
- * send a note to license@php.net so we can mail you a copy immediately.
- *
  * @category   pear
  * @package    PEAR
  * @author     Stig Bakken <ssb@php.net>
  * @author     Greg Beaver <cellog@php.net>
- * @copyright  1997-2006 The PHP Group
+ * @copyright  1997-2009 The Authors
- * @license    http://www.php.net/license/3_0.txt  PHP License 3.0
+ * @license    http://opensource.org/licenses/bsd-license.php New BSD License
- * @version    CVS: $Id: Channels.php,v 1.46 2006/07/17 18:19:25 pajoye Exp $
  * @link       http://pear.php.net/package/PEAR
  * @since      File available since Release 1.4.0a1
  */
 /**
  * base class
  */
+require_once 'PEAR/Command/Common.php';
-require_once 'PEAR/Command/Common.php';
+define('PEAR_COMMAND_CHANNELS_CHANNEL_EXISTS', -500);
 /**
  * PEAR commands for managing channels.
+ *
  * @category   pear
  * @package    PEAR
  * @author     Greg Beaver <cellog@php.net>
- * @copyright  1997-2006 The PHP Group
+ * @copyright  1997-2009 The Authors
- * @license    http://www.php.net/license/3_0.txt  PHP License 3.0
+ * @license    http://opensource.org/licenses/bsd-license.php New BSD License
- * @version    Release: 1.5.1
+ * @version    Release: 1.10.1
  * @link       http://pear.php.net/package/PEAR
  * @since      Class available since Release 1.4.0a1
  */
-class PEAR_Command_Channels extends PEAR_Command_Common
-{
-    // {{{ properties
+class PEAR_Command_Channels extends PEAR_Command_Common
+{
     var $commands = array(
         'list-channels' => array(
             'summary' => 'List Available Channels',
             'summary' => 'Initialize a Channel from its server',
             'function' => 'doDiscover',
             'shortcut' => 'di',
             'options' => array(),
             'doc' => '[<channel.xml>|<channel name>]
-Initialize a Channel from its server and creates the local channel.xml.
+Initialize a channel from its server and create a local channel.xml.
+If <channel name> is in the format "<username>:<password>@<channel>" then
+<username> and <password> will be set as the login username/password for
+<channel>. Use caution when passing the username/password in this way, as
+it may allow other users on your computer to briefly view your username/
+password via the system\'s process list.
+'
             ),
+        'channel-login' => array(
+            'summary' => 'Connects and authenticates to remote channel server',
+            'shortcut' => 'cli',
+            'function' => 'doLogin',
+            'options' => array(),
+            'doc' => '<channel name>
+Log in to a remote channel server.  If <channel name> is not supplied,
+the default channel is used. To use remote functions in the installer
+that require any kind of privileges, you need to log in first.  The
+username and password you enter here will be stored in your per-user
+PEAR configuration (~/.pearrc on Unix-like systems).  After logging
+in, your username and password will be sent along in subsequent
+operations on the remote server.',
+            ),
+        'channel-logout' => array(
+            'summary' => 'Logs out from the remote channel server',
+            'shortcut' => 'clo',
+            'function' => 'doLogout',
+            'options' => array(),
+            'doc' => '<channel name>
+Logs out from a remote channel server.  If <channel name> is not supplied,
+the default channel is used. This command does not actually connect to the
+remote server, it only deletes the stored username and password from your user
+configuration.',
+            ),
         );
-    // }}}
-    // {{{ constructor
     /**
      * PEAR_Command_Registry constructor.
+     *
      * @access public
      */
-    function PEAR_Command_Channels(&$ui, &$config)
+    function __construct(&$ui, &$config)
     {
-        parent::PEAR_Command_Common($ui, $config);
+        parent::__construct($ui, $config);
-    }
-    // }}}
     // {{{ doList()
     function _sortChannels($a, $b)
+    {
         usort($registered, array(&$this, '_sortchannels'));
         $i = $j = 0;
         $data = array(
             'caption' => 'Registered Channels:',
             'border' => true,
-            'headline' => array('Channel', 'Summary')
+            'headline' => array('Channel', 'Alias', 'Summary')
             );
         foreach ($registered as $channel) {
             $data['data'][] = array($channel->getName(),
+                                    $channel->getAlias(),
-                                      $channel->getSummary());
+                                    $channel->getSummary());
+        }
-        if (count($registered)==0) {
+        if (count($registered) === 0) {
             $data = '(no registered channels)';
+        }
         $this->ui->outputData($data, $command);
         return true;
+    }
     function doUpdateAll($command, $options, $params)
+    {
         $reg = &$this->config->getRegistry();
-        $savechannel = $this->config->get('default_channel');
-        if (isset($options['channel'])) {
-            if (!$reg->channelExists($options['channel'])) {
-                return $this->raiseError('Unknown channel "' . $options['channel'] . '"');
-            }
-            $this->config->set('default_channel', $options['channel']);
-        } else {
-            $this->config->set('default_channel', 'pear.php.net');
-        }
-        $remote = &$this->config->getRemote();
-        $channels = $remote->call('channel.listAll');
+        $channels = $reg->getChannels();
-        if (PEAR::isError($channels)) {
-            $this->config->set('default_channel', $savechannel);
-            return $channels;
-        }
-        if (!is_array($channels) || isset($channels['faultCode'])) {
-            $this->config->set('default_channel', $savechannel);
-            return $this->raiseError("Incorrect channel listing returned from channel '$chan'");
-        }
-        if (!count($channels)) {
+        $success = true;
-            $data = 'no updates available';
-        }
-        $dl = &$this->getDownloader();
-        if (!class_exists('System')) {
-            require_once 'System.php';
-        }
-        $tmpdir = System::mktemp(array('-d'));
         foreach ($channels as $channel) {
-            $channel = $channel[0];
-            $save = $channel;
-            if ($reg->channelExists($channel, true)) {
-                $this->ui->outputData("Updating channel \"$channel\"", $command);
-                $test = $reg->getChannel($channel, true);
-                if (PEAR::isError($test)) {
-                    $this->ui->outputData("Channel '$channel' is corrupt in registry!", $command);
-                    $lastmodified = false;
-                } else {
-                    $lastmodified = $test->lastModified();
-                }
-                PEAR::staticPushErrorHandling(PEAR_ERROR_RETURN);
-                $contents = $dl->downloadHttp('http://' . $test->getName() . '/channel.xml',
-                    $this->ui, $tmpdir, null, $lastmodified);
-                PEAR::staticPopErrorHandling();
-                if (PEAR::isError($contents)) {
-                    $this->ui->outputData('ERROR: Cannot retrieve channel.xml for channel "' .
-                        $test->getName() . '"', $command);
-                    continue;
-                }
-                if (!$contents) {
-                    $this->ui->outputData("Channel \"$channel\" is up-to-date", $command);
-                    continue;
-                }
-                list($contents, $lastmodified) = $contents;
-                $info = implode('', file($contents));
-                if (!$info) {
-                    $this->ui->outputData("Channel \"$channel\" is up-to-date", $command);
-                    continue;
-                }
-                if (!class_exists('PEAR_ChannelFile')) {
-                    require_once 'PEAR/ChannelFile.php';
-                }
-                $channelinfo = new PEAR_ChannelFile;
-                $channelinfo->fromXmlString($info);
-                if ($channelinfo->getErrors()) {
-                    $this->ui->outputData("Downloaded channel data from channel \"$channel\" " .
-                        'is corrupt, skipping', $command);
-                    continue;
-                }
-                $channel = $channelinfo;
-                if ($channel->getName() != $save) {
+            if ($channel->getName() != '__uri') {
-                    $this->ui->outputData('ERROR: Security risk - downloaded channel ' .
-                        'definition file for channel "'
-                        . $channel->getName() . ' from channel "' . $save .
-                        '".  To use anyway, use channel-update', $command);
-                    continue;
-                }
-                $reg->updateChannel($channel, $lastmodified);
-            } else {
-                if ($reg->isAlias($channel)) {
-                    $temp = &$reg->getChannel($channel);
-                    if (PEAR::isError($temp)) {
-                        return $this->raiseError($temp);
-                    }
-                    $temp->setAlias($temp->getName(), true); // set the alias to the channel name
-                    if ($reg->channelExists($temp->getName())) {
-                        $this->ui->outputData('ERROR: existing channel "' . $temp->getName() .
-                            '" is aliased to "' . $channel . '" already and cannot be ' .
-                            're-aliased to "' . $temp->getName() . '" because a channel with ' .
-                            'that name or alias already exists!  Please re-alias and try ' .
-                            'again.', $command);
-                        continue;
-                    }
-                }
-                $this->ui->outputData("Adding new channel \"$channel\"", $command);
                 PEAR::staticPushErrorHandling(PEAR_ERROR_RETURN);
-                $contents = $dl->downloadHttp('http://' . $channel . '/channel.xml',
-                    $this->ui, $tmpdir, null, false);
+                $err = $this->doUpdate('channel-update',
-                PEAR::staticPopErrorHandling();
-                if (PEAR::isError($contents)) {
-                    $this->ui->outputData('ERROR: Cannot retrieve channel.xml for channel "' .
-                        $channel . '"', $command);
+                                          $options,
-                    continue;
-                }
-                list($contents, $lastmodified) = $contents;
-                $info = implode('', file($contents));
-                if (!class_exists('PEAR_ChannelFile')) {
-                    require_once 'PEAR/ChannelFile.php';
+                                          array($channel->getName()));
-                }
-                $channelinfo = new PEAR_Channelfile;
-                $channelinfo->fromXmlString($info);
-                if ($channelinfo->getErrors()) {
+                if (PEAR::isError($err)) {
-                    $this->ui->outputData("Downloaded channel data from channel \"$channel\"" .
-                        ' is corrupt, skipping', $command);
+                    $this->ui->outputData($err->getMessage(), $command);
-                    continue;
+                    $success = false;
-                }
+                } else {
-                $channel = $channelinfo;
-                if ($channel->getName() != $save) {
-                    $this->ui->outputData('ERROR: Security risk - downloaded channel ' .
-                        'definition file for channel "'
-                        . $channel->getName() . '" from channel "' . $save .
-                        '".  To use anyway, use channel-update', $command);
-                    continue;
+                    $success &= $err;
+                }
-                $reg->addChannel($channel, $lastmodified);
+            }
+        }
-        $this->config->set('default_channel', $savechannel);
-        $this->ui->outputData('update-channels complete', $command);
-        return true;
+        return $success;
+    }
     function doInfo($command, $options, $params)
+    {
-        if (sizeof($params) != 1) {
+        if (count($params) !== 1) {
             return $this->raiseError("No channel specified");
+        }
-        $reg = &$this->config->getRegistry();
+        $reg     = &$this->config->getRegistry();
         $channel = strtolower($params[0]);
         if ($reg->channelExists($channel)) {
             $chan = $reg->getChannel($channel);
             if (PEAR::isError($chan)) {
                 return $this->raiseError($chan);
+            }
         } else {
             if (strpos($channel, '://')) {
                 $downloader = &$this->getDownloader();
-                if (!class_exists('System')) {
-                    require_once 'System.php';
-                }
-                $tmpdir = System::mktemp(array('-d'));
+                $tmpdir = $this->config->get('temp_dir');
                 PEAR::staticPushErrorHandling(PEAR_ERROR_RETURN);
                 $loc = $downloader->downloadHttp($channel, $this->ui, $tmpdir);
                 PEAR::staticPopErrorHandling();
                 if (PEAR::isError($loc)) {
-                    return $this->raiseError('Cannot open "' . $channel . '"');
+                    return $this->raiseError('Cannot open "' . $channel .
+                        '" (' . $loc->getMessage() . ')');
                 } else {
                     $contents = implode('', file($loc));
+                }
             } else {
-                if (file_exists($params[0])) {
+                if (!file_exists($params[0])) {
-                    $fp = fopen($params[0], 'r');
-                    if (!$fp) {
-                        return $this->raiseError('Cannot open "' . $params[0] . '"');
-                    }
-                } else {
                     return $this->raiseError('Unknown channel "' . $channel . '"');
+                }
+                $fp = fopen($params[0], 'r');
+                if (!$fp) {
+                    return $this->raiseError('Cannot open "' . $params[0] . '"');
+                }
                 $contents = '';
                 while (!feof($fp)) {
                     $contents .= fread($fp, 1024);
+                }
                 fclose($fp);
+            }
             if (!class_exists('PEAR_ChannelFile')) {
                 require_once 'PEAR/ChannelFile.php';
+            }
             $chan = new PEAR_ChannelFile;
             $chan->fromXmlString($contents);
             $chan->validate();
             if ($errs = $chan->getErrors(true)) {
                 foreach ($errs as $err) {
                     $this->ui->outputData($err['level'] . ': ' . $err['message']);
+                }
                 return $this->raiseError('Channel file "' . $params[0] . '" is not valid');
+            }
+        }
-        if ($chan) {
+        if (!$chan) {
+            return $this->raiseError('Serious error: Channel "' . $params[0] .
+                '" has a corrupted registry entry');
+        }
-            $channel = $chan->getName();
+        $channel = $chan->getName();
-            $caption = 'Channel ' . $channel . ' Information:';
+        $caption = 'Channel ' . $channel . ' Information:';
-            $data1 = array(
+        $data1 = array(
-                'caption' => $caption,
+            'caption' => $caption,
-                'border' => true);
+            'border' => true);
-            $data1['data']['server'] = array('Name and Server', $chan->getName());
+        $data1['data']['server'] = array('Name and Server', $chan->getName());
-            if ($chan->getAlias() != $chan->getName()) {
+        if ($chan->getAlias() != $chan->getName()) {
-                $data1['data']['alias'] = array('Alias', $chan->getAlias());
+            $data1['data']['alias'] = array('Alias', $chan->getAlias());
-            }
+        }
-            $data1['data']['summary'] = array('Summary', $chan->getSummary());
+        $data1['data']['summary'] = array('Summary', $chan->getSummary());
-            $validate = $chan->getValidationPackage();
+        $validate = $chan->getValidationPackage();
-            $data1['data']['vpackage'] = array('Validation Package Name', $validate['_content']);
+        $data1['data']['vpackage'] = array('Validation Package Name', $validate['_content']);
-            $data1['data']['vpackageversion'] =
+        $data1['data']['vpackageversion'] =
-                array('Validation Package Version', $validate['attribs']['version']);
+            array('Validation Package Version', $validate['attribs']['version']);
-            $d = array();
+        $d = array();
-            $d['main'] = $data1;
+        $d['main'] = $data1;
-            $data['data'] = array();
+        $data['data'] = array();
-            $data['caption'] = 'Server Capabilities';
+        $data['caption'] = 'Server Capabilities';
-            $data['headline'] = array('Type', 'Version/REST type', 'Function Name/REST base');
+        $data['headline'] = array('Type', 'Version/REST type', 'Function Name/REST base');
-            $capabilities = $chan->getFunctions('xmlrpc');
-            $soaps = $chan->getFunctions('soap');
-            if ($capabilities || $soaps || $chan->supportsREST()) {
+        if ($chan->supportsREST()) {
-                if ($capabilities) {
-                    if (!isset($capabilities[0])) {
-                        $capabilities = array($capabilities);
-                    }
-                    foreach ($capabilities as $protocol) {
-                        $data['data'][] = array('xmlrpc', $protocol['attribs']['version'],
-                            $protocol['_content']);
-                    }
-                }
-                if ($soaps) {
-                    if (!isset($soaps[0])) {
-                        $soaps = array($soaps);
-                    }
-                    foreach ($soaps as $protocol) {
-                        $data['data'][] = array('soap', $protocol['attribs']['version'],
-                            $protocol['_content']);
-                    }
-                }
-                if ($chan->supportsREST()) {
+            if ($chan->supportsREST()) {
-                    $funcs = $chan->getFunctions('rest');
+                $funcs = $chan->getFunctions('rest');
-                    if (!isset($funcs[0])) {
+                if (!isset($funcs[0])) {
-                        $funcs = array($funcs);
+                    $funcs = array($funcs);
-                    }
+                }
-                    foreach ($funcs as $protocol) {
+                foreach ($funcs as $protocol) {
-                        $data['data'][] = array('rest', $protocol['attribs']['type'],
+                    $data['data'][] = array('rest', $protocol['attribs']['type'],
-                            $protocol['_content']);
+                        $protocol['_content']);
-                    }
+                }
-            } else {
-                $data['data'][] = array('No supported protocols');
+            }
+        } else {
+            $data['data'][] = array('No supported protocols');
+        }
-            $d['protocols'] = $data;
+        $d['protocols'] = $data;
-            $data['data'] = array();
+        $data['data'] = array();
-            $mirrors = $chan->getMirrors();
+        $mirrors = $chan->getMirrors();
-            if ($mirrors) {
+        if ($mirrors) {
-                $data['caption'] = 'Channel ' . $channel . ' Mirrors:';
+            $data['caption'] = 'Channel ' . $channel . ' Mirrors:';
-                unset($data['headline']);
+            unset($data['headline']);
-                foreach ($mirrors as $mirror) {
+            foreach ($mirrors as $mirror) {
-                    $data['data'][] = array($mirror['attribs']['host']);
+                $data['data'][] = array($mirror['attribs']['host']);
-                    $d['mirrors'] = $data;
+                $d['mirrors'] = $data;
-                }
+            }
-                foreach ($mirrors as $mirror) {
+            foreach ($mirrors as $i => $mirror) {
-                    $data['data'] = array();
+                $data['data'] = array();
-                    $data['caption'] = 'Mirror ' . $mirror['attribs']['host'] . ' Capabilities';
+                $data['caption'] = 'Mirror ' . $mirror['attribs']['host'] . ' Capabilities';
-                    $data['headline'] = array('Type', 'Version/REST type', 'Function Name/REST base');
+                $data['headline'] = array('Type', 'Version/REST type', 'Function Name/REST base');
-                    $capabilities = $chan->getFunctions('xmlrpc', $mirror['attribs']['host']);
-                    $soaps = $chan->getFunctions('soap', $mirror['attribs']['host']);
+                if ($chan->supportsREST($mirror['attribs']['host'])) {
-                    if ($capabilities || $soaps || $chan->supportsREST($mirror['attribs']['host'])) {
+                    if ($chan->supportsREST($mirror['attribs']['host'])) {
-                        if ($capabilities) {
-                            if (!isset($capabilities[0])) {
-                                $capabilities = array($capabilities);
-                            }
-                            foreach ($capabilities as $protocol) {
-                                $data['data'][] = array('xmlrpc', $protocol['attribs']['version'],
+                        $funcs = $chan->getFunctions('rest', $mirror['attribs']['host']);
-                                    $protocol['_content']);
-                            }
-                        }
-                        if ($soaps) {
-                            if (!isset($soaps[0])) {
+                        if (!isset($funcs[0])) {
-                                $soaps = array($soaps);
+                            $funcs = array($funcs);
-                            }
-                            foreach ($soaps as $protocol) {
-                                $data['data'][] = array('soap', $protocol['attribs']['version'],
-                                    $protocol['_content']);
-                            }
+                        }
-                        if ($chan->supportsREST($mirror['attribs']['host'])) {
-                            $funcs = $chan->getFunctions('rest', $mirror['attribs']['host']);
-                            if (!isset($funcs[0])) {
-                                $funcs = array($funcs);
-                            }
-                            foreach ($funcs as $protocol) {
+                        foreach ($funcs as $protocol) {
-                                $data['data'][] = array('rest', $protocol['attribs']['type'],
+                            $data['data'][] = array('rest', $protocol['attribs']['type'],
-                                    $protocol['_content']);
+                                $protocol['_content']);
-                            }
+                        }
-                    } else {
-                        $data['data'][] = array('No supported protocols');
+                    }
+                } else {
-                    $d['mirrorprotocols'] = $data;
+                    $data['data'][] = array('No supported protocols');
+                }
+                $d['mirrorprotocols' . $i] = $data;
+            }
-            $this->ui->outputData($d, 'channel-info');
-        } else {
-            return $this->raiseError('Serious error: Channel "' . $params[0] .
-                '" has a corrupted registry entry');
+        }
+        $this->ui->outputData($d, 'channel-info');
+    }
     // }}}
     function doDelete($command, $options, $params)
     {
-        if (sizeof($params) != 1) {
+        if (count($params) !== 1) {
             return $this->raiseError('channel-delete: no channel specified');
+        }
         $reg = &$this->config->getRegistry();
         if (!$reg->channelExists($params[0])) {
             return $this->raiseError('channel-delete: channel "' . $params[0] . '" does not exist');
+        }
         $channel = $reg->channelName($params[0]);
         if ($channel == 'pear.php.net') {
             return $this->raiseError('Cannot delete the pear.php.net channel');
+        }
         if ($channel == 'pecl.php.net') {
             return $this->raiseError('Cannot delete the pecl.php.net channel');
+        }
+        if ($channel == 'doc.php.net') {
+            return $this->raiseError('Cannot delete the doc.php.net channel');
+        }
         if ($channel == '__uri') {
             return $this->raiseError('Cannot delete the __uri pseudo-channel');
+        }
         if (PEAR::isError($err = $reg->listPackages($channel))) {
             return $err;
+        }
         if (count($err)) {
             return $this->raiseError('Channel "' . $channel .
                 '" has installed packages, cannot delete');
+        }
         if (!$reg->deleteChannel($channel)) {
             return $this->raiseError('Channel "' . $channel . '" deletion failed');
         } else {
             $this->config->deleteChannel($channel);
             $this->ui->outputData('Channel "' . $channel . '" deleted', $command);
+        }
+    }
     function doAdd($command, $options, $params)
+    {
-        if (sizeof($params) != 1) {
+        if (count($params) !== 1) {
+            return $this->raiseError('channel-add: no channel file specified');
             return $this->raiseError('channel-add: no channel file specified');
+        if (strpos($params[0], '://')) {
-        if (strpos($params[0], '://')) {
+            $downloader = &$this->getDownloader();
-            $downloader = &$this->getDownloader();
+            $tmpdir = $this->config->get('temp_dir');
+            if (!file_exists($tmpdir)) {
+                require_once 'System.php';
+                PEAR::staticPushErrorHandling(PEAR_ERROR_RETURN);
+                $err = System::mkdir(array('-p', $tmpdir));
+                PEAR::staticPopErrorHandling();
+                if (PEAR::isError($err)) {
+                    return $this->raiseError('channel-add: temp_dir does not exist: "' .
+                        $tmpdir .
+                        '" - You can change this location with "pear config-set temp_dir"');
+                }
+            }
+            if (!is_writable($tmpdir)) {
+                return $this->raiseError('channel-add: temp_dir is not writable: "' .
-            if (!class_exists('System')) {
+                    $tmpdir .
-                require_once 'System.php';
+                    '" - You can change this location with "pear config-set temp_dir"');
+            }
             $tmpdir = System::mktemp(array('-d'));
             PEAR::staticPushErrorHandling(PEAR_ERROR_RETURN);
             $loc = $downloader->downloadHttp($params[0], $this->ui, $tmpdir, null, false);
             PEAR::staticPopErrorHandling();
-            if (PEAR::isError($loc)) {
-                return $this->raiseError('channel-add: Cannot open "' . $params[0] . '"');
+            if (PEAR::isError($loc)) {
-            } else {
-                list($loc, $lastmodified) = $loc;
+                return $this->raiseError('channel-add: Cannot open "' . $params[0] .
+                    '" (' . $loc->getMessage() . ')');
+            }
-                $contents = implode('', file($loc));
+            list($loc, $lastmodified) = $loc;
             $contents = implode('', file($loc));
         } else {
             $lastmodified = $fp = false;
             if (file_exists($params[0])) {
+                $fp = fopen($params[0], 'r');
                 $fp = fopen($params[0], 'r');
             if (!$fp) {
+                return $this->raiseError('channel-add: cannot open "' . $params[0] . '"');
                 return $this->raiseError('channel-add: cannot open "' . $params[0] . '"');
             $contents = '';
             while (!feof($fp)) {
                 $contents .= fread($fp, 1024);
+            }
+            fclose($fp);
             fclose($fp);
         if (!class_exists('PEAR_ChannelFile')) {
+            require_once 'PEAR/ChannelFile.php';
             require_once 'PEAR/ChannelFile.php';
         $channel = new PEAR_ChannelFile;
         PEAR::staticPushErrorHandling(PEAR_ERROR_RETURN);
         $result = $channel->fromXmlString($contents);
                 if ($exit) {
                     return $this->raiseError('channel-add: invalid channel.xml file');
+                }
+            }
+        }
         $reg = &$this->config->getRegistry();
         if ($reg->channelExists($channel->getName())) {
             return $this->raiseError('channel-add: Channel "' . $channel->getName() .
-                '" exists, use channel-update to update entry');
+                '" exists, use channel-update to update entry', PEAR_COMMAND_CHANNELS_CHANNEL_EXISTS);
+        }
         $ret = $reg->addChannel($channel, $lastmodified);
         if (PEAR::isError($ret)) {
             return $ret;
+        }
         if (!$ret) {
             return $this->raiseError('channel-add: adding Channel "' . $channel->getName() .
                 '" to registry failed');
+        }
         $this->config->setChannels($reg->listChannels());
         $this->config->writeConfigFile();
         $this->ui->outputData('Adding Channel "' . $channel->getName() . '" succeeded', $command);
+    }
     function doUpdate($command, $options, $params)
+    {
+        if (count($params) !== 1) {
+            return $this->raiseError("No channel file specified");
+        }
-    {
+        $tmpdir = $this->config->get('temp_dir');
-        if (!class_exists('System')) {
+        if (!file_exists($tmpdir)) {
+            require_once 'System.php';
+            PEAR::staticPushErrorHandling(PEAR_ERROR_RETURN);
+            $err = System::mkdir(array('-p', $tmpdir));
+            PEAR::staticPopErrorHandling();
+            if (PEAR::isError($err)) {
+                return $this->raiseError('channel-add: temp_dir does not exist: "' .
+                    $tmpdir .
+                    '" - You can change this location with "pear config-set temp_dir"');
             require_once 'System.php';
+        }
-        }
-        $tmpdir = System::mktemp(array('-d'));
+        if (!is_writable($tmpdir)) {
-        $reg = &$this->config->getRegistry();
+            return $this->raiseError('channel-add: temp_dir is not writable: "' .
-        if (sizeof($params) != 1) {
+                $tmpdir .
-            return $this->raiseError("No channel file specified");
+                '" - You can change this location with "pear config-set temp_dir"');
+        }
         $reg = &$this->config->getRegistry();
         $lastmodified = false;
         if ((!file_exists($params[0]) || is_dir($params[0]))
               && $reg->channelExists(strtolower($params[0]))) {
             $c = $reg->getChannel(strtolower($params[0]));
             if (PEAR::isError($c)) {
                 return $this->raiseError($c);
+            }
-            }
-            $this->ui->outputData('Retrieving channel.xml from remote server');
+            $this->ui->outputData("Updating channel \"$params[0]\"", $command);
             $dl = &$this->getDownloader(array());
             // if force is specified, use a timestamp of "1" to force retrieval
             $lastmodified = isset($options['force']) ? false : $c->lastModified();
             PEAR::staticPushErrorHandling(PEAR_ERROR_RETURN);
             $contents = $dl->downloadHttp('http://' . $c->getName() . '/channel.xml',
                 $this->ui, $tmpdir, null, $lastmodified);
             PEAR::staticPopErrorHandling();
+            if (PEAR::isError($contents)) {
+                // Attempt to fall back to https
+                $this->ui->outputData("Channel \"$params[0]\" is not responding over http://, failed with message: " . $contents->getMessage());
+                $this->ui->outputData("Trying channel \"$params[0]\" over https:// instead");
+                PEAR::staticPushErrorHandling(PEAR_ERROR_RETURN);
+                $contents = $dl->downloadHttp('https://' . $c->getName() . '/channel.xml',
+                    $this->ui, $tmpdir, null, $lastmodified);
+                PEAR::staticPopErrorHandling();
-            if (PEAR::isError($contents)) {
+                if (PEAR::isError($contents)) {
-                return $this->raiseError('Cannot retrieve channel.xml for channel "' .
+                    return $this->raiseError('Cannot retrieve channel.xml for channel "' .
+                        $c->getName() . '" (' . $contents->getMessage() . ')');
                     $c->getName() . '"');
+            }
             list($contents, $lastmodified) = $contents;
             if (!$contents) {
-                $this->ui->outputData("Channel $params[0] channel.xml is up to date");
+                $this->ui->outputData("Channel \"$params[0]\" is up to date");
                 return;
+            }
             $contents = implode('', file($contents));
             if (!class_exists('PEAR_ChannelFile')) {
                 require_once 'PEAR/ChannelFile.php';
+            }
             $channel = new PEAR_ChannelFile;
             $channel->fromXmlString($contents);
             if (!$channel->getErrors()) {
                 // security check: is the downloaded file for the channel we got it from?
                 if (strtolower($channel->getName()) != strtolower($c->getName())) {
-                    if (isset($options['force'])) {
-                        $this->ui->log(0, 'WARNING: downloaded channel definition file' .
-                            ' for channel "' . $channel->getName() . '" from channel "' .
-                            strtolower($c->getName()) . '"');
-                    } else {
+                    if (!isset($options['force'])) {
                         return $this->raiseError('ERROR: downloaded channel definition file' .
                             ' for channel "' . $channel->getName() . '" from channel "' .
                             strtolower($c->getName()) . '"');
+                    }
+                    $this->ui->log(0, 'WARNING: downloaded channel definition file' .
+                        ' for channel "' . $channel->getName() . '" from channel "' .
                         strtolower($c->getName()) . '"');
+                }
+            }
         } else {
             if (strpos($params[0], '://')) {
                 $dl = &$this->getDownloader();
                 PEAR::staticPushErrorHandling(PEAR_ERROR_RETURN);
                 $loc = $dl->downloadHttp($params[0],
                     $this->ui, $tmpdir, null, $lastmodified);
                 PEAR::staticPopErrorHandling();
                 if (PEAR::isError($loc)) {
-                    return $this->raiseError("Cannot open " . $params[0]);
-                } else {
+                    return $this->raiseError("Cannot open " . $params[0] .
-                    list($loc, $lastmodified) = $loc;
-                    $contents = implode('', file($loc));
+                         ' (' . $loc->getMessage() . ')');
+                }
+                list($loc, $lastmodified) = $loc;
                 $contents = implode('', file($loc));
             } else {
                 $fp = false;
                 if (file_exists($params[0])) {
                     $fp = fopen($params[0], 'r');
+                }
                 if (!$fp) {
                     return $this->raiseError("Cannot open " . $params[0]);
+                }
                 $contents = '';
                 while (!feof($fp)) {
                     $contents .= fread($fp, 1024);
+                }
                 fclose($fp);
+            }
             if (!class_exists('PEAR_ChannelFile')) {
                 require_once 'PEAR/ChannelFile.php';
+            }
             $channel = new PEAR_ChannelFile;
             $channel->fromXmlString($contents);
+        }
         $exit = false;
         if (count($errors = $channel->getErrors(true))) {
             foreach ($errors as $error) {
                 $this->ui->outputData(ucfirst($error['level'] . ': ' . $error['message']));
+            }
             if ($exit) {
                 return $this->raiseError('Invalid channel.xml file');
+            }
+        }
         if (!$reg->channelExists($channel->getName())) {
             return $this->raiseError('Error: Channel "' . $channel->getName() .
                 '" does not exist, use channel-add to add an entry');
+        }
         $ret = $reg->updateChannel($channel, $lastmodified);
         if (PEAR::isError($ret)) {
             return $ret;
+        }
         if (!$ret) {
             return $this->raiseError('Updating Channel "' . $channel->getName() .
                 '" in registry failed');
+        }
         $this->config->setChannels($reg->listChannels());
         $this->config->writeConfigFile();
         $this->ui->outputData('Update of Channel "' . $channel->getName() . '" succeeded');
+    }
         return $a;
+    }
     function doAlias($command, $options, $params)
-    {
-        $reg = &$this->config->getRegistry();
+    {
-        if (sizeof($params) == 1) {
+        if (count($params) === 1) {
             return $this->raiseError('No channel alias specified');
+        }
-        }
-        if (sizeof($params) != 2) {
+        if (count($params) !== 2 || (!empty($params[1]) && $params[1]{0} == '-')) {
             return $this->raiseError(
                 'Invalid format, correct is: channel-alias channel alias');
+        }
         $reg = &$this->config->getRegistry();
+        if (!$reg->channelExists($params[0], true)) {
-        if (!$reg->channelExists($params[0], true)) {
+            $extra = '';
             if ($reg->isAlias($params[0])) {
                 $extra = ' (use "channel-alias ' . $reg->channelName($params[0]) . ' ' .
-                    strtolower($params[1]) . '")';
-            } else {
-                $extra = '';
+                    strtolower($params[1]) . '")';
+            }
             return $this->raiseError('"' . $params[0] . '" is not a valid channel' . $extra);
+        }
         if ($reg->isAlias($params[1])) {
             return $this->raiseError('Channel "' . $reg->channelName($params[1]) . '" is ' .
                 'already aliased to "' . strtolower($params[1]) . '", cannot re-alias');
+        }
-        }
-        $chan = &$reg->getChannel($params[0]);
+        $chan = $reg->getChannel($params[0]);
         if (PEAR::isError($chan)) {
             return $this->raiseError('Corrupt registry?  Error retrieving channel "' . $params[0] .
                 '" information (' . $chan->getMessage() . ')');
+        }
         // make it a local alias
         if (!$chan->setAlias(strtolower($params[1]), true)) {
             return $this->raiseError('Alias "' . strtolower($params[1]) .
                 '" is not a valid channel alias');
+        }
         $reg->updateChannel($chan);
         $this->ui->outputData('Channel "' . $chan->getName() . '" aliased successfully to "' .
             strtolower($params[1]) . '"');
+    }
+    /**
+     * The channel-discover command
+     *
+     * @param string $command command name
+     * @param array  $options option_name => value
+     * @param array  $params  list of additional parameters.
+     *               $params[0] should contain a string with either:
+     *               - <channel name> or
+     *               - <username>:<password>@<channel name>
      * @return null|PEAR_Error
      */
-    function doDiscover($command, $options, $params)
-    {
+    function doDiscover($command, $options, $params)
         $reg = &$this->config->getRegistry();
-        if (sizeof($params) != 1) {
+        if (count($params) !== 1) {
+            return $this->raiseError("No channel server specified");
+        }
-            return $this->raiseError("No channel server specified");
-        }
+        // Look for the possible input format "<username>:<password>@<channel>"
-        if ($reg->channelExists($params[0])) {
+        if (preg_match('/^(.+):(.+)@(.+)\\z/', $params[0], $matches)) {
-            if ($reg->isAlias($params[0])) {
+            $username = $matches[1];
+            $password = $matches[2];
-                return $this->raiseError("A channel alias named \"$params[0]\" " .
+            $channel  = $matches[3];
-                    'already exists, aliasing channel "' . $reg->channelName($params[0])
+        } else {
+            $channel = $params[0];
+        }
+        $reg = &$this->config->getRegistry();
-                    . '"');
+        if ($reg->channelExists($channel)) {
-            } else {
+            if (!$reg->isAlias($channel)) {
+                return $this->raiseError("Channel \"$channel\" is already initialized", PEAR_COMMAND_CHANNELS_CHANNEL_EXISTS);
+            }
+            return $this->raiseError("A channel alias named \"$channel\" " .
-                return $this->raiseError("Channel \"$params[0]\" is already initialized");
+                'already exists, aliasing channel "' . $reg->channelName($channel)
+                . '"');
+        }
-        }
         $this->pushErrorHandling(PEAR_ERROR_RETURN);
-        $err = $this->doAdd($command, $options, array('http://' . $params[0] . '/channel.xml'));
+        $err = $this->doAdd($command, $options, array('http://' . $channel . '/channel.xml'));
+        $this->popErrorHandling();
-        $this->popErrorHandling();
+        if (PEAR::isError($err)) {
+            if ($err->getCode() === PEAR_COMMAND_CHANNELS_CHANNEL_EXISTS) {
+                return $this->raiseError("Discovery of channel \"$channel\" failed (" .
+                    $err->getMessage() . ')');
+            }
+            // Attempt fetch via https
+            $this->ui->outputData("Discovering channel $channel over http:// failed with message: " . $err->getMessage());
+            $this->ui->outputData("Trying to discover channel $channel over https:// instead");
+            $this->pushErrorHandling(PEAR_ERROR_RETURN);
+            $err = $this->doAdd($command, $options, array('https://' . $channel . '/channel.xml'));
+            $this->popErrorHandling();
-        if (PEAR::isError($err)) {
+            if (PEAR::isError($err)) {
+                return $this->raiseError("Discovery of channel \"$channel\" failed (" .
-            return $this->raiseError("Discovery of channel \"$params[0]\" failed (" .
+                    $err->getMessage() . ')');
+            }
+        }
+        // Store username/password if they were given
+        // Arguably we should do a logintest on the channel here, but since
+        // that's awkward on a REST-based channel (even "pear login" doesn't
+        // do it for those), and XML-RPC is deprecated, it's fairly pointless.
+        if (isset($username)) {
+            $this->config->set('username', $username, 'user', $channel);
+            $this->config->set('password', $password, 'user', $channel);
+            $this->config->store();
+            $this->ui->outputData("Stored login for channel \"$channel\" using username \"$username\"", $command);
-                $err->getMessage() . ')');
+        }
+        $this->ui->outputData("Discovery of channel \"$channel\" succeeded", $command);
+    }
+    /**
+     * Execute the 'login' command.
+     *
+     * @param string $command command name
+     * @param array $options option_name => value
+     * @param array $params list of additional parameters
+     *
+     * @return bool TRUE on success or
+     * a PEAR error on failure
+     *
+     * @access public
+     */
+    function doLogin($command, $options, $params)
+    {
+        $reg = &$this->config->getRegistry();
+        // If a parameter is supplied, use that as the channel to log in to
+        $channel = isset($params[0]) ? $params[0] : $this->config->get('default_channel');
+        $chan = $reg->getChannel($channel);
+        if (PEAR::isError($chan)) {
+            return $this->raiseError($chan);
+        }
+        $server   = $this->config->get('preferred_mirror', null, $channel);
+        $username = $this->config->get('username',         null, $channel);
+        if (empty($username)) {
+            $username = isset($_ENV['USER']) ? $_ENV['USER'] : null;
+        }
+        $this->ui->outputData("Logging in to $server.", $command);
+        list($username, $password) = $this->ui->userDialog(
+            $command,
+            array('Username', 'Password'),
+            array('text',     'password'),
+            array($username,  '')
+            );
+        $username = trim($username);
+        $password = trim($password);
+        $ourfile = $this->config->getConfFile('user');
+        if (!$ourfile) {
+            $ourfile = $this->config->getConfFile('system');
+        }
+        $this->config->set('username', $username, 'user', $channel);
+        $this->config->set('password', $password, 'user', $channel);
+        if ($chan->supportsREST()) {
+            $ok = true;
+        }
+        if ($ok !== true) {
+            return $this->raiseError('Login failed!');
+        }
+        $this->ui->outputData("Logged in.", $command);
+        // avoid changing any temporary settings changed with -d
+        $ourconfig = new PEAR_Config($ourfile, $ourfile);
+        $ourconfig->set('username', $username, 'user', $channel);
+        $ourconfig->set('password', $password, 'user', $channel);
+        $ourconfig->store();
+        return true;
+    }
+    /**
+     * Execute the 'logout' command.
+     *
+     * @param string $command command name
+     * @param array $options option_name => value
+     * @param array $params list of additional parameters
+     *
+     * @return bool TRUE on success or
+     * a PEAR error on failure
+     *
+     * @access public
+     */
+    function doLogout($command, $options, $params)
+    {
+        $reg     = &$this->config->getRegistry();
+        // If a parameter is supplied, use that as the channel to log in to
+        $channel = isset($params[0]) ? $params[0] : $this->config->get('default_channel');
+        $chan    = $reg->getChannel($channel);
+        if (PEAR::isError($chan)) {
+            return $this->raiseError($chan);
+        }
+        $server = $this->config->get('preferred_mirror', null, $channel);
+        $this->ui->outputData("Logging out from $server.", $command);
+        $this->config->remove('username', 'user', $channel);
+        $this->config->remove('password', 'user', $channel);
         $this->config->store();
-        $this->ui->outputData("Discovery of channel \"$params[0]\" succeeded", $command);
+        return true;
-    }

Subversion Repositories Applications.gtt

(root)/trunk/bibliotheque/pear/PEAR/Command/Channels.php – Rev 94 → 187