| OLD | NEW |
| (Empty) |
| 1 # Copyright 2011 Google Inc. All Rights Reserved. | |
| 2 # | |
| 3 # Licensed under the Apache License, Version 2.0 (the "License"); | |
| 4 # you may not use this file except in compliance with the License. | |
| 5 # You may obtain a copy of the License at | |
| 6 # | |
| 7 # http://www.apache.org/licenses/LICENSE-2.0 | |
| 8 # | |
| 9 # Unless required by applicable law or agreed to in writing, software | |
| 10 # distributed under the License is distributed on an "AS IS" BASIS, | |
| 11 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | |
| 12 # See the License for the specific language governing permissions and | |
| 13 # limitations under the License. | |
| 14 | |
| 15 import os | |
| 16 import platform | |
| 17 import shutil | |
| 18 import signal | |
| 19 import sys | |
| 20 import tarfile | |
| 21 import tempfile | |
| 22 | |
| 23 from boto import config | |
| 24 from gslib.command import Command | |
| 25 from gslib.command import COMMAND_NAME | |
| 26 from gslib.command import COMMAND_NAME_ALIASES | |
| 27 from gslib.command import CONFIG_REQUIRED | |
| 28 from gslib.command import FILE_URIS_OK | |
| 29 from gslib.command import MAX_ARGS | |
| 30 from gslib.command import MIN_ARGS | |
| 31 from gslib.command import PROVIDER_URIS_OK | |
| 32 from gslib.command import SUPPORTED_SUB_ARGS | |
| 33 from gslib.command import URIS_START_ARG | |
| 34 from gslib.exception import CommandException | |
| 35 from gslib.help_provider import HELP_NAME | |
| 36 from gslib.help_provider import HELP_NAME_ALIASES | |
| 37 from gslib.help_provider import HELP_ONE_LINE_SUMMARY | |
| 38 from gslib.help_provider import HELP_TEXT | |
| 39 from gslib.help_provider import HelpType | |
| 40 from gslib.help_provider import HELP_TYPE | |
| 41 | |
| 42 _detailed_help_text = (""" | |
| 43 <B>SYNOPSIS</B> | |
| 44 gsutil update [-f] [uri] | |
| 45 | |
| 46 | |
| 47 <B>DESCRIPTION</B> | |
| 48 The gsutil update command downloads the latest gsutil release, checks its | |
| 49 version, and offers to let you update to it if it differs from the version | |
| 50 you're currently running. | |
| 51 | |
| 52 Once you say "Y" to the prompt of whether to install the update, the gsutil | |
| 53 update command locates where the running copy of gsutil is installed, | |
| 54 unpacks the new version into an adjacent directory, moves the previous version | |
| 55 aside, moves the new version to where the previous version was installed, | |
| 56 and removes the moved-aside old version. Because of this, users are cautioned | |
| 57 not to store data in the gsutil directory, since that data will be lost | |
| 58 when you update gsutil. (Some users change directories into the gsutil | |
| 59 directory to run the command. We advise against doing that, for this reason.) | |
| 60 | |
| 61 By default gsutil update will retrieve the new code from | |
| 62 gs://pub/gsutil.tar.gz, but you can optionally specify a URI to use | |
| 63 instead. This is primarily used for distributing pre-release versions of | |
| 64 the code to a small group of early test users. | |
| 65 | |
| 66 | |
| 67 <B>OPTIONS</B> | |
| 68 -f Forces the update command to offer to let you update, even if you | |
| 69 have the most current copy already. This can be useful if you have | |
| 70 a corrupted local copy. | |
| 71 """) | |
| 72 | |
| 73 | |
| 74 class UpdateCommand(Command): | |
| 75 """Implementation of gsutil update command.""" | |
| 76 | |
| 77 # Command specification (processed by parent class). | |
| 78 command_spec = { | |
| 79 # Name of command. | |
| 80 COMMAND_NAME : 'update', | |
| 81 # List of command name aliases. | |
| 82 COMMAND_NAME_ALIASES : ['refresh'], | |
| 83 # Min number of args required by this command. | |
| 84 MIN_ARGS : 0, | |
| 85 # Max number of args required by this command, or NO_MAX. | |
| 86 MAX_ARGS : 1, | |
| 87 # Getopt-style string specifying acceptable sub args. | |
| 88 SUPPORTED_SUB_ARGS : 'f', | |
| 89 # True if file URIs acceptable for this command. | |
| 90 FILE_URIS_OK : False, | |
| 91 # True if provider-only URIs acceptable for this command. | |
| 92 PROVIDER_URIS_OK : False, | |
| 93 # Index in args of first URI arg. | |
| 94 URIS_START_ARG : 0, | |
| 95 # True if must configure gsutil before running command. | |
| 96 CONFIG_REQUIRED : True, | |
| 97 } | |
| 98 help_spec = { | |
| 99 # Name of command or auxiliary help info for which this help applies. | |
| 100 HELP_NAME : 'update', | |
| 101 # List of help name aliases. | |
| 102 HELP_NAME_ALIASES : ['refresh'], | |
| 103 # Type of help: | |
| 104 HELP_TYPE : HelpType.COMMAND_HELP, | |
| 105 # One line summary of this help. | |
| 106 HELP_ONE_LINE_SUMMARY : 'Update to the latest gsutil release', | |
| 107 # The full help text. | |
| 108 HELP_TEXT : _detailed_help_text, | |
| 109 } | |
| 110 | |
| 111 def _ExplainIfSudoNeeded(self, tf, dirs_to_remove): | |
| 112 """Explains what to do if sudo needed to update gsutil software. | |
| 113 | |
| 114 Happens if gsutil was previously installed by a different user (typically if | |
| 115 someone originally installed in a shared file system location, using sudo). | |
| 116 | |
| 117 Args: | |
| 118 tf: Opened TarFile. | |
| 119 dirs_to_remove: List of directories to remove. | |
| 120 | |
| 121 Raises: | |
| 122 CommandException: if errors encountered. | |
| 123 """ | |
| 124 system = platform.system() | |
| 125 # If running under Windows we don't need (or have) sudo. | |
| 126 if system.lower().startswith('windows'): | |
| 127 return | |
| 128 | |
| 129 user_id = os.getuid() | |
| 130 if (os.stat(self.gsutil_bin_dir).st_uid == user_id | |
| 131 and os.stat(self.boto_lib_dir).st_uid == user_id): | |
| 132 return | |
| 133 | |
| 134 # Won't fail - this command runs after main startup code that insists on | |
| 135 # having a config file. | |
| 136 config_files = ' '.join(self.config_file_list) | |
| 137 self._CleanUpUpdateCommand(tf, dirs_to_remove) | |
| 138 raise CommandException( | |
| 139 ('Since it was installed by a different user previously, you will need ' | |
| 140 'to update using the following commands.\nYou will be prompted for ' | |
| 141 'your password, and the install will run as "root". If you\'re unsure ' | |
| 142 'what this means please ask your system administrator for help:' | |
| 143 '\n\tchmod 644 %s\n\tsudo env BOTO_CONFIG=%s gsutil update' | |
| 144 '\n\tchmod 600 %s') % (config_files, config_files, config_files), | |
| 145 informational=True) | |
| 146 | |
| 147 # This list is checked during gsutil update by doing a lowercased | |
| 148 # slash-left-stripped check. For example "/Dev" would match the "dev" entry. | |
| 149 unsafe_update_dirs = [ | |
| 150 'applications', 'auto', 'bin', 'boot', 'desktop', 'dev', | |
| 151 'documents and settings', 'etc', 'export', 'home', 'kernel', 'lib', | |
| 152 'lib32', 'library', 'lost+found', 'mach_kernel', 'media', 'mnt', 'net', | |
| 153 'null', 'network', 'opt', 'private', 'proc', 'program files', 'python', | |
| 154 'root', 'sbin', 'scripts', 'srv', 'sys', 'system', 'tmp', 'users', 'usr', | |
| 155 'var', 'volumes', 'win', 'win32', 'windows', 'winnt', | |
| 156 ] | |
| 157 | |
| 158 def _EnsureDirsSafeForUpdate(self, dirs): | |
| 159 """Throws Exception if any of dirs is known to be unsafe for gsutil update. | |
| 160 | |
| 161 This provides a fail-safe check to ensure we don't try to overwrite | |
| 162 or delete any important directories. (That shouldn't happen given the | |
| 163 way we construct tmp dirs, etc., but since the gsutil update cleanup | |
| 164 uses shutil.rmtree() it's prudent to add extra checks.) | |
| 165 | |
| 166 Args: | |
| 167 dirs: List of directories to check. | |
| 168 | |
| 169 Raises: | |
| 170 CommandException: If unsafe directory encountered. | |
| 171 """ | |
| 172 for d in dirs: | |
| 173 if not d: | |
| 174 d = 'null' | |
| 175 if d.lstrip(os.sep).lower() in self.unsafe_update_dirs: | |
| 176 raise CommandException('EnsureDirsSafeForUpdate: encountered unsafe ' | |
| 177 'directory (%s); aborting update' % d) | |
| 178 | |
| 179 def _CleanUpUpdateCommand(self, tf, dirs_to_remove): | |
| 180 """Cleans up temp files etc. from running update command. | |
| 181 | |
| 182 Args: | |
| 183 tf: Opened TarFile. | |
| 184 dirs_to_remove: List of directories to remove. | |
| 185 | |
| 186 """ | |
| 187 tf.close() | |
| 188 self._EnsureDirsSafeForUpdate(dirs_to_remove) | |
| 189 for directory in dirs_to_remove: | |
| 190 try: | |
| 191 shutil.rmtree(directory) | |
| 192 except OSError as e: | |
| 193 # Ignore errors while attempting to remove old dirs under Windows. They | |
| 194 # happen because of Windows exclusive file locking, and the update | |
| 195 # actually succeeds but just leaves the old versions around in the | |
| 196 # user's temp dir. | |
| 197 if not platform.system().lower().startswith('windows'): | |
| 198 raise | |
| 199 | |
| 200 # Command entry point. | |
| 201 def RunCommand(self): | |
| 202 for cfg_var in ('is_secure', 'https_validate_certificates'): | |
| 203 if (config.has_option('Boto', cfg_var) | |
| 204 and not config.getboolean('Boto', cfg_var)): | |
| 205 raise CommandException('Your boto configuration has %s = False. ' | |
| 206 'The update command\ncannot be run this way, for
' | |
| 207 'security reasons.' % cfg_var) | |
| 208 dirs_to_remove = [] | |
| 209 # Retrieve gsutil tarball and check if it's newer than installed code. | |
| 210 # TODO: Store this version info as metadata on the tarball object and | |
| 211 # change this command's implementation to check that metadata instead of | |
| 212 # downloading the tarball to check the version info. | |
| 213 tmp_dir = tempfile.mkdtemp() | |
| 214 dirs_to_remove.append(tmp_dir) | |
| 215 os.chdir(tmp_dir) | |
| 216 print 'Checking for software update...' | |
| 217 if len(self.args): | |
| 218 update_from_uri_str = self.args[0] | |
| 219 if not update_from_uri_str.endswith('.tar.gz'): | |
| 220 raise CommandException( | |
| 221 'The update command only works with tar.gz files.') | |
| 222 else: | |
| 223 update_from_uri_str = 'gs://pub/gsutil.tar.gz' | |
| 224 self.command_runner.RunNamedCommand('cp', [update_from_uri_str, | |
| 225 'file://gsutil.tar.gz'], | |
| 226 self.headers, self.debug) | |
| 227 # Note: tf is closed in _CleanUpUpdateCommand. | |
| 228 tf = tarfile.open('gsutil.tar.gz') | |
| 229 tf.errorlevel = 1 # So fatal tarball unpack errors raise exceptions. | |
| 230 tf.extract('./gsutil/VERSION') | |
| 231 | |
| 232 ver_file = open('gsutil/VERSION', 'r') | |
| 233 try: | |
| 234 latest_version_string = ver_file.read().rstrip('\n') | |
| 235 finally: | |
| 236 ver_file.close() | |
| 237 | |
| 238 force_update = False | |
| 239 if self.sub_opts: | |
| 240 for o, unused_a in self.sub_opts: | |
| 241 if o == '-f': | |
| 242 force_update = True | |
| 243 if not force_update and self.gsutil_ver == latest_version_string: | |
| 244 self._CleanUpUpdateCommand(tf, dirs_to_remove) | |
| 245 if len(self.args): | |
| 246 raise CommandException('You already have %s installed.' % | |
| 247 update_from_uri_str, informational=True) | |
| 248 else: | |
| 249 raise CommandException('You already have the latest gsutil release ' | |
| 250 'installed.', informational=True) | |
| 251 | |
| 252 print(('This command will update to the "%s" version of\ngsutil at %s') % | |
| 253 (latest_version_string, self.gsutil_bin_dir)) | |
| 254 self._ExplainIfSudoNeeded(tf, dirs_to_remove) | |
| 255 | |
| 256 answer = raw_input('Proceed? [y/N] ') | |
| 257 if not answer or answer.lower()[0] != 'y': | |
| 258 self._CleanUpUpdateCommand(tf, dirs_to_remove) | |
| 259 raise CommandException('Not running update.', informational=True) | |
| 260 | |
| 261 # Ignore keyboard interrupts during the update to reduce the chance someone | |
| 262 # hitting ^C leaves gsutil in a broken state. | |
| 263 signal.signal(signal.SIGINT, signal.SIG_IGN) | |
| 264 | |
| 265 # self.gsutil_bin_dir lists the path where the code should end up (like | |
| 266 # /usr/local/gsutil), which is one level down from the relative path in the | |
| 267 # tarball (since the latter creates files in ./gsutil). So, we need to | |
| 268 # extract at the parent directory level. | |
| 269 gsutil_bin_parent_dir = os.path.dirname(self.gsutil_bin_dir) | |
| 270 | |
| 271 # Extract tarball to a temporary directory in a sibling to gsutil_bin_dir. | |
| 272 old_dir = tempfile.mkdtemp(dir=gsutil_bin_parent_dir) | |
| 273 new_dir = tempfile.mkdtemp(dir=gsutil_bin_parent_dir) | |
| 274 dirs_to_remove.append(old_dir) | |
| 275 dirs_to_remove.append(new_dir) | |
| 276 self._EnsureDirsSafeForUpdate(dirs_to_remove) | |
| 277 try: | |
| 278 tf.extractall(path=new_dir) | |
| 279 except Exception, e: | |
| 280 self._CleanUpUpdateCommand(tf, dirs_to_remove) | |
| 281 raise CommandException('Update failed: %s.' % e) | |
| 282 | |
| 283 # For enterprise mode (shared/central) installation, users with | |
| 284 # different user/group than the installation user/group must be | |
| 285 # able to run gsutil so we need to do some permissions adjustments | |
| 286 # here. Since enterprise mode is not not supported for Windows | |
| 287 # users, we can skip this step when running on Windows, which | |
| 288 # avoids the problem that Windows has no find or xargs command. | |
| 289 system = platform.system() | |
| 290 if not system.lower().startswith('windows'): | |
| 291 # Make all files and dirs in updated area readable by other | |
| 292 # and make all directories executable by other. These steps | |
| 293 os.system('chmod -R o+r ' + new_dir) | |
| 294 os.system('find ' + new_dir + ' -type d | xargs chmod o+x') | |
| 295 | |
| 296 # Make main gsutil script readable and executable by other. | |
| 297 os.system('chmod o+rx ' + os.path.join(new_dir, 'gsutil')) | |
| 298 | |
| 299 # Move old installation aside and new into place. | |
| 300 os.rename(self.gsutil_bin_dir, old_dir + os.sep + 'old') | |
| 301 os.rename(new_dir + os.sep + 'gsutil', self.gsutil_bin_dir) | |
| 302 self._CleanUpUpdateCommand(tf, dirs_to_remove) | |
| 303 signal.signal(signal.SIGINT, signal.SIG_DFL) | |
| 304 print 'Update complete.' | |
| 305 return 0 | |
| OLD | NEW |