diff options
| author | Richard Purdie <richard@openedhand.com> | 2005-08-31 10:47:56 +0000 |
|---|---|---|
| committer | Richard Purdie <richard@openedhand.com> | 2005-08-31 10:47:56 +0000 |
| commit | f54da734eb7b69e8e34de505bd89a13479e230e0 (patch) | |
| tree | f796bea6f5683dfe3d591ca5390d12fd78e59c96 /bitbake/lib/bb/shell.py | |
| parent | 4b46c1f6e891b1ddd5968536440b888661fade3e (diff) | |
| download | poky-f54da734eb7b69e8e34de505bd89a13479e230e0.tar.gz | |
Initial population
git-svn-id: https://svn.o-hand.com/repos/poky@2 311d38ba-8fff-0310-9ca6-ca027cbcb966
Diffstat (limited to 'bitbake/lib/bb/shell.py')
| -rw-r--r-- | bitbake/lib/bb/shell.py | 779 |
1 files changed, 779 insertions, 0 deletions
diff --git a/bitbake/lib/bb/shell.py b/bitbake/lib/bb/shell.py new file mode 100644 index 0000000000..97e61e1169 --- /dev/null +++ b/bitbake/lib/bb/shell.py | |||
| @@ -0,0 +1,779 @@ | |||
| 1 | #!/usr/bin/env python | ||
| 2 | # ex:ts=4:sw=4:sts=4:et | ||
| 3 | # -*- tab-width: 4; c-basic-offset: 4; indent-tabs-mode: nil -*- | ||
| 4 | ########################################################################## | ||
| 5 | # | ||
| 6 | # Copyright (C) 2005 Michael 'Mickey' Lauer <mickey@Vanille.de>, Vanille Media | ||
| 7 | # | ||
| 8 | # This program is free software; you can redistribute it and/or modify it under | ||
| 9 | # the terms of the GNU General Public License as published by the Free Software | ||
| 10 | # Foundation; version 2 of the License. | ||
| 11 | # | ||
| 12 | # This program is distributed in the hope that it will be useful, but WITHOUT | ||
| 13 | # ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS | ||
| 14 | # FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. | ||
| 15 | # | ||
| 16 | # You should have received a copy of the GNU General Public License along with | ||
| 17 | # this program; if not, write to the Free Software Foundation, Inc., 59 Temple | ||
| 18 | # Place, Suite 330, Boston, MA 02111-1307 USA. | ||
| 19 | # | ||
| 20 | ########################################################################## | ||
| 21 | |||
| 22 | """ | ||
| 23 | BitBake Shell | ||
| 24 | |||
| 25 | IDEAS: | ||
| 26 | * list defined tasks per package | ||
| 27 | * list classes | ||
| 28 | * toggle force | ||
| 29 | * command to reparse just one (or more) bbfile(s) | ||
| 30 | * automatic check if reparsing is necessary (inotify?) | ||
| 31 | * frontend for bb file manipulation | ||
| 32 | * more shell-like features: | ||
| 33 | - output control, i.e. pipe output into grep, sort, etc. | ||
| 34 | - job control, i.e. bring running commands into background and foreground | ||
| 35 | * start parsing in background right after startup | ||
| 36 | * ncurses interface | ||
| 37 | |||
| 38 | PROBLEMS: | ||
| 39 | * force doesn't always work | ||
| 40 | * readline completion for commands with more than one parameters | ||
| 41 | |||
| 42 | """ | ||
| 43 | |||
| 44 | ########################################################################## | ||
| 45 | # Import and setup global variables | ||
| 46 | ########################################################################## | ||
| 47 | |||
| 48 | try: | ||
| 49 | set | ||
| 50 | except NameError: | ||
| 51 | from sets import Set as set | ||
| 52 | import sys, os, imp, readline, socket, httplib, urllib, commands, popen2, copy, shlex, Queue, fnmatch | ||
| 53 | imp.load_source( "bitbake", os.path.dirname( sys.argv[0] )+"/bitbake" ) | ||
| 54 | from bb import data, parse, build, fatal | ||
| 55 | |||
| 56 | __version__ = "0.5.2" | ||
| 57 | __credits__ = """BitBake Shell Version %s (C) 2005 Michael 'Mickey' Lauer <mickey@Vanille.de> | ||
| 58 | Type 'help' for more information, press CTRL-D to exit.""" % __version__ | ||
| 59 | |||
| 60 | cmds = {} | ||
| 61 | leave_mainloop = False | ||
| 62 | last_exception = None | ||
| 63 | cooker = None | ||
| 64 | parsed = False | ||
| 65 | initdata = None | ||
| 66 | debug = os.environ.get( "BBSHELL_DEBUG", "" ) | ||
| 67 | |||
| 68 | ########################################################################## | ||
| 69 | # Class BitBakeShellCommands | ||
| 70 | ########################################################################## | ||
| 71 | |||
| 72 | class BitBakeShellCommands: | ||
| 73 | """This class contains the valid commands for the shell""" | ||
| 74 | |||
| 75 | def __init__( self, shell ): | ||
| 76 | """Register all the commands""" | ||
| 77 | self._shell = shell | ||
| 78 | for attr in BitBakeShellCommands.__dict__: | ||
| 79 | if not attr.startswith( "_" ): | ||
| 80 | if attr.endswith( "_" ): | ||
| 81 | command = attr[:-1].lower() | ||
| 82 | else: | ||
| 83 | command = attr[:].lower() | ||
| 84 | method = getattr( BitBakeShellCommands, attr ) | ||
| 85 | debugOut( "registering command '%s'" % command ) | ||
| 86 | # scan number of arguments | ||
| 87 | usage = getattr( method, "usage", "" ) | ||
| 88 | if usage != "<...>": | ||
| 89 | numArgs = len( usage.split() ) | ||
| 90 | else: | ||
| 91 | numArgs = -1 | ||
| 92 | shell.registerCommand( command, method, numArgs, "%s %s" % ( command, usage ), method.__doc__ ) | ||
| 93 | |||
| 94 | def _checkParsed( self ): | ||
| 95 | if not parsed: | ||
| 96 | print "SHELL: This command needs to parse bbfiles..." | ||
| 97 | self.parse( None ) | ||
| 98 | |||
| 99 | def _findProvider( self, item ): | ||
| 100 | self._checkParsed() | ||
| 101 | preferred = data.getVar( "PREFERRED_PROVIDER_%s" % item, cooker.configuration.data, 1 ) | ||
| 102 | if not preferred: preferred = item | ||
| 103 | try: | ||
| 104 | lv, lf, pv, pf = cooker.findBestProvider( preferred ) | ||
| 105 | except KeyError: | ||
| 106 | if item in cooker.status.providers: | ||
| 107 | pf = cooker.status.providers[item][0] | ||
| 108 | else: | ||
| 109 | pf = None | ||
| 110 | return pf | ||
| 111 | |||
| 112 | def alias( self, params ): | ||
| 113 | """Register a new name for a command""" | ||
| 114 | new, old = params | ||
| 115 | if not old in cmds: | ||
| 116 | print "ERROR: Command '%s' not known" % old | ||
| 117 | else: | ||
| 118 | cmds[new] = cmds[old] | ||
| 119 | print "OK" | ||
| 120 | alias.usage = "<alias> <command>" | ||
| 121 | |||
| 122 | def buffer( self, params ): | ||
| 123 | """Dump specified output buffer""" | ||
| 124 | index = params[0] | ||
| 125 | print self._shell.myout.buffer( int( index ) ) | ||
| 126 | buffer.usage = "<index>" | ||
| 127 | |||
| 128 | def buffers( self, params ): | ||
| 129 | """Show the available output buffers""" | ||
| 130 | commands = self._shell.myout.bufferedCommands() | ||
| 131 | if not commands: | ||
| 132 | print "SHELL: No buffered commands available yet. Start doing something." | ||
| 133 | else: | ||
| 134 | print "="*35, "Available Output Buffers", "="*27 | ||
| 135 | for index, cmd in enumerate( commands ): | ||
| 136 | print "| %s %s" % ( str( index ).ljust( 3 ), cmd ) | ||
| 137 | print "="*88 | ||
| 138 | |||
| 139 | def build( self, params, cmd = "build" ): | ||
| 140 | """Build a providee""" | ||
| 141 | globexpr = params[0] | ||
| 142 | self._checkParsed() | ||
| 143 | names = globfilter( cooker.status.pkg_pn.keys(), globexpr ) | ||
| 144 | if len( names ) == 0: names = [ globexpr ] | ||
| 145 | print "SHELL: Building %s" % ' '.join( names ) | ||
| 146 | |||
| 147 | oldcmd = cooker.configuration.cmd | ||
| 148 | cooker.configuration.cmd = cmd | ||
| 149 | cooker.build_cache = [] | ||
| 150 | cooker.build_cache_fail = [] | ||
| 151 | |||
| 152 | for name in names: | ||
| 153 | try: | ||
| 154 | cooker.buildProvider( name ) | ||
| 155 | except build.EventException, e: | ||
| 156 | print "ERROR: Couldn't build '%s'" % name | ||
| 157 | global last_exception | ||
| 158 | last_exception = e | ||
| 159 | break | ||
| 160 | |||
| 161 | cooker.configuration.cmd = oldcmd | ||
| 162 | |||
| 163 | build.usage = "<providee>" | ||
| 164 | |||
| 165 | def clean( self, params ): | ||
| 166 | """Clean a providee""" | ||
| 167 | self.build( params, "clean" ) | ||
| 168 | clean.usage = "<providee>" | ||
| 169 | |||
| 170 | def compile( self, params ): | ||
| 171 | """Execute 'compile' on a providee""" | ||
| 172 | self.build( params, "compile" ) | ||
| 173 | compile.usage = "<providee>" | ||
| 174 | |||
| 175 | def configure( self, params ): | ||
| 176 | """Execute 'configure' on a providee""" | ||
| 177 | self.build( params, "configure" ) | ||
| 178 | configure.usage = "<providee>" | ||
| 179 | |||
| 180 | def edit( self, params ): | ||
| 181 | """Call $EDITOR on a providee""" | ||
| 182 | name = params[0] | ||
| 183 | bbfile = self._findProvider( name ) | ||
| 184 | if bbfile is not None: | ||
| 185 | os.system( "%s %s" % ( os.environ.get( "EDITOR", "vi" ), bbfile ) ) | ||
| 186 | else: | ||
| 187 | print "ERROR: Nothing provides '%s'" % name | ||
| 188 | edit.usage = "<providee>" | ||
| 189 | |||
| 190 | def environment( self, params ): | ||
| 191 | """Dump out the outer BitBake environment (see bbread)""" | ||
| 192 | data.emit_env(sys.__stdout__, cooker.configuration.data, True) | ||
| 193 | |||
| 194 | def exit_( self, params ): | ||
| 195 | """Leave the BitBake Shell""" | ||
| 196 | debugOut( "setting leave_mainloop to true" ) | ||
| 197 | global leave_mainloop | ||
| 198 | leave_mainloop = True | ||
| 199 | |||
| 200 | def fetch( self, params ): | ||
| 201 | """Fetch a providee""" | ||
| 202 | self.build( params, "fetch" ) | ||
| 203 | fetch.usage = "<providee>" | ||
| 204 | |||
| 205 | def fileBuild( self, params, cmd = "build" ): | ||
| 206 | """Parse and build a .bb file""" | ||
| 207 | name = params[0] | ||
| 208 | bf = completeFilePath( name ) | ||
| 209 | print "SHELL: Calling '%s' on '%s'" % ( cmd, bf ) | ||
| 210 | |||
| 211 | oldcmd = cooker.configuration.cmd | ||
| 212 | cooker.configuration.cmd = cmd | ||
| 213 | cooker.build_cache = [] | ||
| 214 | cooker.build_cache_fail = [] | ||
| 215 | |||
| 216 | thisdata = copy.deepcopy( initdata ) | ||
| 217 | # Caution: parse.handle modifies thisdata, hence it would | ||
| 218 | # lead to pollution cooker.configuration.data, which is | ||
| 219 | # why we use it on a safe copy we obtained from cooker right after | ||
| 220 | # parsing the initial *.conf files | ||
| 221 | try: | ||
| 222 | bbfile_data = parse.handle( bf, thisdata ) | ||
| 223 | except parse.ParseError: | ||
| 224 | print "ERROR: Unable to open or parse '%s'" % bf | ||
| 225 | else: | ||
| 226 | item = data.getVar('PN', bbfile_data, 1) | ||
| 227 | data.setVar( "_task_cache", [], bbfile_data ) # force | ||
| 228 | try: | ||
| 229 | cooker.tryBuildPackage( os.path.abspath( bf ), item, bbfile_data ) | ||
| 230 | except build.EventException, e: | ||
| 231 | print "ERROR: Couldn't build '%s'" % name | ||
| 232 | global last_exception | ||
| 233 | last_exception = e | ||
| 234 | |||
| 235 | cooker.configuration.cmd = oldcmd | ||
| 236 | fileBuild.usage = "<bbfile>" | ||
| 237 | |||
| 238 | def fileClean( self, params ): | ||
| 239 | """Clean a .bb file""" | ||
| 240 | self.fileBuild( params, "clean" ) | ||
| 241 | fileClean.usage = "<bbfile>" | ||
| 242 | |||
| 243 | def fileEdit( self, params ): | ||
| 244 | """Call $EDITOR on a .bb file""" | ||
| 245 | name = params[0] | ||
| 246 | os.system( "%s %s" % ( os.environ.get( "EDITOR", "vi" ), completeFilePath( name ) ) ) | ||
| 247 | fileEdit.usage = "<bbfile>" | ||
| 248 | |||
| 249 | def fileRebuild( self, params ): | ||
| 250 | """Rebuild (clean & build) a .bb file""" | ||
| 251 | self.fileClean( params ) | ||
| 252 | self.fileBuild( params ) | ||
| 253 | fileRebuild.usage = "<bbfile>" | ||
| 254 | |||
| 255 | def force( self, params ): | ||
| 256 | """Toggle force task execution flag (see bitbake -f)""" | ||
| 257 | cooker.configuration.force = not cooker.configuration.force | ||
| 258 | print "SHELL: Force Flag is now '%s'" % repr( cooker.configuration.force ) | ||
| 259 | |||
| 260 | def help( self, params ): | ||
| 261 | """Show a comprehensive list of commands and their purpose""" | ||
| 262 | print "="*30, "Available Commands", "="*30 | ||
| 263 | allcmds = cmds.keys() | ||
| 264 | allcmds.sort() | ||
| 265 | for cmd in allcmds: | ||
| 266 | function,numparams,usage,helptext = cmds[cmd] | ||
| 267 | print "| %s | %s" % (usage.ljust(30), helptext) | ||
| 268 | print "="*78 | ||
| 269 | |||
| 270 | def lastError( self, params ): | ||
| 271 | """Show the reason or log that was produced by the last BitBake event exception""" | ||
| 272 | if last_exception is None: | ||
| 273 | print "SHELL: No Errors yet (Phew)..." | ||
| 274 | else: | ||
| 275 | reason, event = last_exception.args | ||
| 276 | print "SHELL: Reason for the last error: '%s'" % reason | ||
| 277 | if ':' in reason: | ||
| 278 | msg, filename = reason.split( ':' ) | ||
| 279 | filename = filename.strip() | ||
| 280 | print "SHELL: Dumping log file for last error:" | ||
| 281 | try: | ||
| 282 | print open( filename ).read() | ||
| 283 | except IOError: | ||
| 284 | print "ERROR: Couldn't open '%s'" % filename | ||
| 285 | |||
| 286 | def match( self, params ): | ||
| 287 | """Dump all files or providers matching a glob expression""" | ||
| 288 | what, globexpr = params | ||
| 289 | if what == "files": | ||
| 290 | self._checkParsed() | ||
| 291 | for key in globfilter( cooker.pkgdata.keys(), globexpr ): print key | ||
| 292 | elif what == "providers": | ||
| 293 | self._checkParsed() | ||
| 294 | for key in globfilter( cooker.status.pkg_pn.keys(), globexpr ): print key | ||
| 295 | else: | ||
| 296 | print "Usage: match %s" % self.print_.usage | ||
| 297 | match.usage = "<files|providers> <glob>" | ||
| 298 | |||
| 299 | def new( self, params ): | ||
| 300 | """Create a new .bb file and open the editor""" | ||
| 301 | dirname, filename = params | ||
| 302 | packages = '/'.join( data.getVar( "BBFILES", cooker.configuration.data, 1 ).split('/')[:-2] ) | ||
| 303 | fulldirname = "%s/%s" % ( packages, dirname ) | ||
| 304 | |||
| 305 | if not os.path.exists( fulldirname ): | ||
| 306 | print "SHELL: Creating '%s'" % fulldirname | ||
| 307 | os.mkdir( fulldirname ) | ||
| 308 | if os.path.exists( fulldirname ) and os.path.isdir( fulldirname ): | ||
| 309 | if os.path.exists( "%s/%s" % ( fulldirname, filename ) ): | ||
| 310 | print "SHELL: ERROR: %s/%s already exists" % ( fulldirname, filename ) | ||
| 311 | return False | ||
| 312 | print "SHELL: Creating '%s/%s'" % ( fulldirname, filename ) | ||
| 313 | newpackage = open( "%s/%s" % ( fulldirname, filename ), "w" ) | ||
| 314 | print >>newpackage,"""DESCRIPTION = "" | ||
| 315 | SECTION = "" | ||
| 316 | AUTHOR = "" | ||
| 317 | HOMEPAGE = "" | ||
| 318 | MAINTAINER = "" | ||
| 319 | LICENSE = "GPL" | ||
| 320 | PR = "r0" | ||
| 321 | |||
| 322 | SRC_URI = "" | ||
| 323 | |||
| 324 | #inherit base | ||
| 325 | |||
| 326 | #do_configure() { | ||
| 327 | # | ||
| 328 | #} | ||
| 329 | |||
| 330 | #do_compile() { | ||
| 331 | # | ||
| 332 | #} | ||
| 333 | |||
| 334 | #do_stage() { | ||
| 335 | # | ||
| 336 | #} | ||
| 337 | |||
| 338 | #do_install() { | ||
| 339 | # | ||
| 340 | #} | ||
| 341 | """ | ||
| 342 | newpackage.close() | ||
| 343 | os.system( "%s %s/%s" % ( os.environ.get( "EDITOR" ), fulldirname, filename ) ) | ||
| 344 | new.usage = "<directory> <filename>" | ||
| 345 | |||
| 346 | def pasteBin( self, params ): | ||
| 347 | """Send a command + output buffer to http://pastebin.com""" | ||
| 348 | index = params[0] | ||
| 349 | contents = self._shell.myout.buffer( int( index ) ) | ||
| 350 | status, error, location = sendToPastebin( contents ) | ||
| 351 | if status == 302: | ||
| 352 | print "SHELL: Pasted to %s" % location | ||
| 353 | else: | ||
| 354 | print "ERROR: %s %s" % ( status, error ) | ||
| 355 | pasteBin.usage = "<index>" | ||
| 356 | |||
| 357 | def pasteLog( self, params ): | ||
| 358 | """Send the last event exception error log (if there is one) to http://pastebin.com""" | ||
| 359 | if last_exception is None: | ||
| 360 | print "SHELL: No Errors yet (Phew)..." | ||
| 361 | else: | ||
| 362 | reason, event = last_exception.args | ||
| 363 | print "SHELL: Reason for the last error: '%s'" % reason | ||
| 364 | if ':' in reason: | ||
| 365 | msg, filename = reason.split( ':' ) | ||
| 366 | filename = filename.strip() | ||
| 367 | print "SHELL: Pasting log file to pastebin..." | ||
| 368 | |||
| 369 | status, error, location = sendToPastebin( open( filename ).read() ) | ||
| 370 | |||
| 371 | if status == 302: | ||
| 372 | print "SHELL: Pasted to %s" % location | ||
| 373 | else: | ||
| 374 | print "ERROR: %s %s" % ( status, error ) | ||
| 375 | |||
| 376 | def patch( self, params ): | ||
| 377 | """Execute 'patch' command on a providee""" | ||
| 378 | self.build( params, "patch" ) | ||
| 379 | patch.usage = "<providee>" | ||
| 380 | |||
| 381 | def parse( self, params ): | ||
| 382 | """(Re-)parse .bb files and calculate the dependency graph""" | ||
| 383 | cooker.status = cooker.ParsingStatus() | ||
| 384 | ignore = data.getVar("ASSUME_PROVIDED", cooker.configuration.data, 1) or "" | ||
| 385 | cooker.status.ignored_dependencies = set( ignore.split() ) | ||
| 386 | cooker.handleCollections( data.getVar("BBFILE_COLLECTIONS", cooker.configuration.data, 1) ) | ||
| 387 | |||
| 388 | cooker.collect_bbfiles( cooker.myProgressCallback ) | ||
| 389 | cooker.buildDepgraph() | ||
| 390 | global parsed | ||
| 391 | parsed = True | ||
| 392 | |||
| 393 | |||
| 394 | def getvar( self, params ): | ||
| 395 | """Dump the contents of an outer BitBake environment variable""" | ||
| 396 | var = params[0] | ||
| 397 | value = data.getVar( var, cooker.configuration.data, 1 ) | ||
| 398 | print value | ||
| 399 | getvar.usage = "<variable>" | ||
| 400 | |||
| 401 | def peek( self, params ): | ||
| 402 | """Dump contents of variable defined in providee's metadata""" | ||
| 403 | name, var = params | ||
| 404 | bbfile = self._findProvider( name ) | ||
| 405 | if bbfile is not None: | ||
| 406 | value = cooker.pkgdata[bbfile].getVar( var, 1 ) | ||
| 407 | print value | ||
| 408 | else: | ||
| 409 | print "ERROR: Nothing provides '%s'" % name | ||
| 410 | peek.usage = "<providee> <variable>" | ||
| 411 | |||
| 412 | def poke( self, params ): | ||
| 413 | """Set contents of variable defined in providee's metadata""" | ||
| 414 | name, var, value = params | ||
| 415 | bbfile = self._findProvider( name ) | ||
| 416 | d = cooker.pkgdata[bbfile] | ||
| 417 | if bbfile is not None: | ||
| 418 | data.setVar( var, value, d ) | ||
| 419 | |||
| 420 | # mark the change semi persistant | ||
| 421 | cooker.pkgdata.setDirty(bbfile, d) | ||
| 422 | print "OK" | ||
| 423 | else: | ||
| 424 | print "ERROR: Nothing provides '%s'" % name | ||
| 425 | poke.usage = "<providee> <variable> <value>" | ||
| 426 | |||
| 427 | def print_( self, params ): | ||
| 428 | """Dump all files or providers""" | ||
| 429 | what = params[0] | ||
| 430 | if what == "files": | ||
| 431 | self._checkParsed() | ||
| 432 | for key in cooker.pkgdata.keys(): print key | ||
| 433 | elif what == "providers": | ||
| 434 | self._checkParsed() | ||
| 435 | for key in cooker.status.providers.keys(): print key | ||
| 436 | else: | ||
| 437 | print "Usage: print %s" % self.print_.usage | ||
| 438 | print_.usage = "<files|providers>" | ||
| 439 | |||
| 440 | def python( self, params ): | ||
| 441 | """Enter the expert mode - an interactive BitBake Python Interpreter""" | ||
| 442 | sys.ps1 = "EXPERT BB>>> " | ||
| 443 | sys.ps2 = "EXPERT BB... " | ||
| 444 | import code | ||
| 445 | interpreter = code.InteractiveConsole( dict( globals() ) ) | ||
| 446 | interpreter.interact( "SHELL: Expert Mode - BitBake Python %s\nType 'help' for more information, press CTRL-D to switch back to BBSHELL." % sys.version ) | ||
| 447 | |||
| 448 | def showdata( self, params ): | ||
| 449 | """Execute 'showdata' on a providee""" | ||
| 450 | self.build( params, "showdata" ) | ||
| 451 | showdata.usage = "<providee>" | ||
| 452 | |||
| 453 | def setVar( self, params ): | ||
| 454 | """Set an outer BitBake environment variable""" | ||
| 455 | var, value = params | ||
| 456 | data.setVar( var, value, cooker.configuration.data ) | ||
| 457 | print "OK" | ||
| 458 | setVar.usage = "<variable> <value>" | ||
| 459 | |||
| 460 | def rebuild( self, params ): | ||
| 461 | """Clean and rebuild a .bb file or a providee""" | ||
| 462 | self.build( params, "clean" ) | ||
| 463 | self.build( params, "build" ) | ||
| 464 | rebuild.usage = "<providee>" | ||
| 465 | |||
| 466 | def shell( self, params ): | ||
| 467 | """Execute a shell command and dump the output""" | ||
| 468 | if params != "": | ||
| 469 | print commands.getoutput( " ".join( params ) ) | ||
| 470 | shell.usage = "<...>" | ||
| 471 | |||
| 472 | def stage( self, params ): | ||
| 473 | """Execute 'stage' on a providee""" | ||
| 474 | self.build( params, "stage" ) | ||
| 475 | stage.usage = "<providee>" | ||
| 476 | |||
| 477 | def status( self, params ): | ||
| 478 | """<just for testing>""" | ||
| 479 | print "-" * 78 | ||
| 480 | print "build cache = '%s'" % cooker.build_cache | ||
| 481 | print "build cache fail = '%s'" % cooker.build_cache_fail | ||
| 482 | print "building list = '%s'" % cooker.building_list | ||
| 483 | print "build path = '%s'" % cooker.build_path | ||
| 484 | print "consider_msgs_cache = '%s'" % cooker.consider_msgs_cache | ||
| 485 | print "build stats = '%s'" % cooker.stats | ||
| 486 | if last_exception is not None: print "last_exception = '%s'" % repr( last_exception.args ) | ||
| 487 | print "memory output contents = '%s'" % self._shell.myout._buffer | ||
| 488 | |||
| 489 | def test( self, params ): | ||
| 490 | """<just for testing>""" | ||
| 491 | print "testCommand called with '%s'" % params | ||
| 492 | |||
| 493 | def unpack( self, params ): | ||
| 494 | """Execute 'unpack' on a providee""" | ||
| 495 | self.build( params, "unpack" ) | ||
| 496 | unpack.usage = "<providee>" | ||
| 497 | |||
| 498 | def which( self, params ): | ||
| 499 | """Computes the providers for a given providee""" | ||
| 500 | item = params[0] | ||
| 501 | |||
| 502 | self._checkParsed() | ||
| 503 | |||
| 504 | preferred = data.getVar( "PREFERRED_PROVIDER_%s" % item, cooker.configuration.data, 1 ) | ||
| 505 | if not preferred: preferred = item | ||
| 506 | |||
| 507 | try: | ||
| 508 | lv, lf, pv, pf = cooker.findBestProvider( preferred ) | ||
| 509 | except KeyError: | ||
| 510 | lv, lf, pv, pf = (None,)*4 | ||
| 511 | |||
| 512 | try: | ||
| 513 | providers = cooker.status.providers[item] | ||
| 514 | except KeyError: | ||
| 515 | print "SHELL: ERROR: Nothing provides", preferred | ||
| 516 | else: | ||
| 517 | for provider in providers: | ||
| 518 | if provider == pf: provider = " (***) %s" % provider | ||
| 519 | else: provider = " %s" % provider | ||
| 520 | print provider | ||
| 521 | which.usage = "<providee>" | ||
| 522 | |||
| 523 | ########################################################################## | ||
| 524 | # Common helper functions | ||
| 525 | ########################################################################## | ||
| 526 | |||
| 527 | def completeFilePath( bbfile ): | ||
| 528 | """Get the complete bbfile path""" | ||
| 529 | if not cooker.pkgdata: return bbfile | ||
| 530 | for key in cooker.pkgdata.keys(): | ||
| 531 | if key.endswith( bbfile ): | ||
| 532 | return key | ||
| 533 | return bbfile | ||
| 534 | |||
| 535 | def sendToPastebin( content ): | ||
| 536 | """Send content to http://www.pastebin.com""" | ||
| 537 | mydata = {} | ||
| 538 | mydata["parent_pid"] = "" | ||
| 539 | mydata["format"] = "bash" | ||
| 540 | mydata["code2"] = content | ||
| 541 | mydata["paste"] = "Send" | ||
| 542 | mydata["poster"] = "%s@%s" % ( os.environ.get( "USER", "unknown" ), socket.gethostname() or "unknown" ) | ||
| 543 | params = urllib.urlencode( mydata ) | ||
| 544 | headers = {"Content-type": "application/x-www-form-urlencoded","Accept": "text/plain"} | ||
| 545 | |||
| 546 | conn = httplib.HTTPConnection( "pastebin.com:80" ) | ||
| 547 | conn.request("POST", "/", params, headers ) | ||
| 548 | |||
| 549 | response = conn.getresponse() | ||
| 550 | conn.close() | ||
| 551 | |||
| 552 | return response.status, response.reason, response.getheader( "location" ) or "unknown" | ||
| 553 | |||
| 554 | def completer( text, state ): | ||
| 555 | """Return a possible readline completion""" | ||
| 556 | debugOut( "completer called with text='%s', state='%d'" % ( text, state ) ) | ||
| 557 | |||
| 558 | if state == 0: | ||
| 559 | line = readline.get_line_buffer() | ||
| 560 | if " " in line: | ||
| 561 | line = line.split() | ||
| 562 | # we are in second (or more) argument | ||
| 563 | if line[0] in cmds and hasattr( cmds[line[0]][0], "usage" ): # known command and usage | ||
| 564 | u = getattr( cmds[line[0]][0], "usage" ).split()[0] | ||
| 565 | if u == "<variable>": | ||
| 566 | allmatches = cooker.configuration.data.keys() | ||
| 567 | elif u == "<bbfile>": | ||
| 568 | if cooker.pkgdata is None: allmatches = [ "(No Matches Available. Parsed yet?)" ] | ||
| 569 | else: allmatches = [ x.split("/")[-1] for x in cooker.pkgdata.keys() ] | ||
| 570 | elif u == "<providee>": | ||
| 571 | if cooker.pkgdata is None: allmatches = [ "(No Matches Available. Parsed yet?)" ] | ||
| 572 | else: allmatches = cooker.status.providers.iterkeys() | ||
| 573 | else: allmatches = [ "(No tab completion available for this command)" ] | ||
| 574 | else: allmatches = [ "(No tab completion available for this command)" ] | ||
| 575 | else: | ||
| 576 | # we are in first argument | ||
| 577 | allmatches = cmds.iterkeys() | ||
| 578 | |||
| 579 | completer.matches = [ x for x in allmatches if x[:len(text)] == text ] | ||
| 580 | #print "completer.matches = '%s'" % completer.matches | ||
| 581 | if len( completer.matches ) > state: | ||
| 582 | return completer.matches[state] | ||
| 583 | else: | ||
| 584 | return None | ||
| 585 | |||
| 586 | def debugOut( text ): | ||
| 587 | if debug: | ||
| 588 | sys.stderr.write( "( %s )\n" % text ) | ||
| 589 | |||
| 590 | def columnize( alist, width = 80 ): | ||
| 591 | """ | ||
| 592 | A word-wrap function that preserves existing line breaks | ||
| 593 | and most spaces in the text. Expects that existing line | ||
| 594 | breaks are posix newlines (\n). | ||
| 595 | """ | ||
| 596 | return reduce(lambda line, word, width=width: '%s%s%s' % | ||
| 597 | (line, | ||
| 598 | ' \n'[(len(line[line.rfind('\n')+1:]) | ||
| 599 | + len(word.split('\n',1)[0] | ||
| 600 | ) >= width)], | ||
| 601 | word), | ||
| 602 | alist | ||
| 603 | ) | ||
| 604 | |||
| 605 | def globfilter( names, pattern ): | ||
| 606 | return fnmatch.filter( names, pattern ) | ||
| 607 | |||
| 608 | ########################################################################## | ||
| 609 | # Class MemoryOutput | ||
| 610 | ########################################################################## | ||
| 611 | |||
| 612 | class MemoryOutput: | ||
| 613 | """File-like output class buffering the output of the last 10 commands""" | ||
| 614 | def __init__( self, delegate ): | ||
| 615 | self.delegate = delegate | ||
| 616 | self._buffer = [] | ||
| 617 | self.text = [] | ||
| 618 | self._command = None | ||
| 619 | |||
| 620 | def startCommand( self, command ): | ||
| 621 | self._command = command | ||
| 622 | self.text = [] | ||
| 623 | def endCommand( self ): | ||
| 624 | if self._command is not None: | ||
| 625 | if len( self._buffer ) == 10: del self._buffer[0] | ||
| 626 | self._buffer.append( ( self._command, self.text ) ) | ||
| 627 | def removeLast( self ): | ||
| 628 | if self._buffer: | ||
| 629 | del self._buffer[ len( self._buffer ) - 1 ] | ||
| 630 | self.text = [] | ||
| 631 | self._command = None | ||
| 632 | def lastBuffer( self ): | ||
| 633 | if self._buffer: | ||
| 634 | return self._buffer[ len( self._buffer ) -1 ][1] | ||
| 635 | def bufferedCommands( self ): | ||
| 636 | return [ cmd for cmd, output in self._buffer ] | ||
| 637 | def buffer( self, i ): | ||
| 638 | if i < len( self._buffer ): | ||
| 639 | return "BB>> %s\n%s" % ( self._buffer[i][0], "".join( self._buffer[i][1] ) ) | ||
| 640 | else: return "ERROR: Invalid buffer number. Buffer needs to be in (0, %d)" % ( len( self._buffer ) - 1 ) | ||
| 641 | def write( self, text ): | ||
| 642 | if self._command is not None and text != "BB>> ": self.text.append( text ) | ||
| 643 | if self.delegate is not None: self.delegate.write( text ) | ||
| 644 | def flush( self ): | ||
| 645 | return self.delegate.flush() | ||
| 646 | def fileno( self ): | ||
| 647 | return self.delegate.fileno() | ||
| 648 | def isatty( self ): | ||
| 649 | return self.delegate.isatty() | ||
| 650 | |||
| 651 | ########################################################################## | ||
| 652 | # Class BitBakeShell | ||
| 653 | ########################################################################## | ||
| 654 | |||
| 655 | class BitBakeShell: | ||
| 656 | |||
| 657 | def __init__( self ): | ||
| 658 | """Register commands and set up readline""" | ||
| 659 | self.commandQ = Queue.Queue() | ||
| 660 | self.commands = BitBakeShellCommands( self ) | ||
| 661 | self.myout = MemoryOutput( sys.stdout ) | ||
| 662 | self.historyfilename = os.path.expanduser( "~/.bbsh_history" ) | ||
| 663 | self.startupfilename = os.path.expanduser( "~/.bbsh_startup" ) | ||
| 664 | |||
| 665 | readline.set_completer( completer ) | ||
| 666 | readline.set_completer_delims( " " ) | ||
| 667 | readline.parse_and_bind("tab: complete") | ||
| 668 | |||
| 669 | try: | ||
| 670 | readline.read_history_file( self.historyfilename ) | ||
| 671 | except IOError: | ||
| 672 | pass # It doesn't exist yet. | ||
| 673 | |||
| 674 | print __credits__ | ||
| 675 | |||
| 676 | # save initial cooker configuration (will be reused in file*** commands) | ||
| 677 | global initdata | ||
| 678 | initdata = copy.deepcopy( cooker.configuration.data ) | ||
| 679 | |||
| 680 | def cleanup( self ): | ||
| 681 | """Write readline history and clean up resources""" | ||
| 682 | debugOut( "writing command history" ) | ||
| 683 | try: | ||
| 684 | readline.write_history_file( self.historyfilename ) | ||
| 685 | except: | ||
| 686 | print "SHELL: Unable to save command history" | ||
| 687 | |||
| 688 | def registerCommand( self, command, function, numparams = 0, usage = "", helptext = "" ): | ||
| 689 | """Register a command""" | ||
| 690 | if usage == "": usage = command | ||
| 691 | if helptext == "": helptext = function.__doc__ or "<not yet documented>" | ||
| 692 | cmds[command] = ( function, numparams, usage, helptext ) | ||
| 693 | |||
| 694 | def processCommand( self, command, params ): | ||
| 695 | """Process a command. Check number of params and print a usage string, if appropriate""" | ||
| 696 | debugOut( "processing command '%s'..." % command ) | ||
| 697 | try: | ||
| 698 | function, numparams, usage, helptext = cmds[command] | ||
| 699 | except KeyError: | ||
| 700 | print "SHELL: ERROR: '%s' command is not a valid command." % command | ||
| 701 | self.myout.removeLast() | ||
| 702 | else: | ||
| 703 | if (numparams != -1) and (not len( params ) == numparams): | ||
| 704 | print "Usage: '%s'" % usage | ||
| 705 | return | ||
| 706 | |||
| 707 | result = function( self.commands, params ) | ||
| 708 | debugOut( "result was '%s'" % result ) | ||
| 709 | |||
| 710 | def processStartupFile( self ): | ||
| 711 | """Read and execute all commands found in $HOME/.bbsh_startup""" | ||
| 712 | if os.path.exists( self.startupfilename ): | ||
| 713 | startupfile = open( self.startupfilename, "r" ) | ||
| 714 | for cmdline in startupfile: | ||
| 715 | debugOut( "processing startup line '%s'" % cmdline ) | ||
| 716 | if not cmdline: | ||
| 717 | continue | ||
| 718 | if "|" in cmdline: | ||
| 719 | print "ERROR: '|' in startup file is not allowed. Ignoring line" | ||
| 720 | continue | ||
| 721 | self.commandQ.put( cmdline.strip() ) | ||
| 722 | |||
| 723 | def main( self ): | ||
| 724 | """The main command loop""" | ||
| 725 | while not leave_mainloop: | ||
| 726 | try: | ||
| 727 | if self.commandQ.empty(): | ||
| 728 | sys.stdout = self.myout.delegate | ||
| 729 | cmdline = raw_input( "BB>> " ) | ||
| 730 | sys.stdout = self.myout | ||
| 731 | else: | ||
| 732 | cmdline = self.commandQ.get() | ||
| 733 | if cmdline: | ||
| 734 | allCommands = cmdline.split( ';' ) | ||
| 735 | for command in allCommands: | ||
| 736 | pipecmd = None | ||
| 737 | # | ||
| 738 | # special case for expert mode | ||
| 739 | if command == 'python': | ||
| 740 | sys.stdout = self.myout.delegate | ||
| 741 | self.processCommand( command, "" ) | ||
| 742 | sys.stdout = self.myout | ||
| 743 | else: | ||
| 744 | self.myout.startCommand( command ) | ||
| 745 | if '|' in command: # disable output | ||
| 746 | command, pipecmd = command.split( '|' ) | ||
| 747 | delegate = self.myout.delegate | ||
| 748 | self.myout.delegate = None | ||
| 749 | tokens = shlex.split( command, True ) | ||
| 750 | self.processCommand( tokens[0], tokens[1:] or "" ) | ||
| 751 | self.myout.endCommand() | ||
| 752 | if pipecmd is not None: # restore output | ||
| 753 | self.myout.delegate = delegate | ||
| 754 | |||
| 755 | pipe = popen2.Popen4( pipecmd ) | ||
| 756 | pipe.tochild.write( "\n".join( self.myout.lastBuffer() ) ) | ||
| 757 | pipe.tochild.close() | ||
| 758 | sys.stdout.write( pipe.fromchild.read() ) | ||
| 759 | # | ||
| 760 | except EOFError: | ||
| 761 | |||
| 762 | return | ||
| 763 | except KeyboardInterrupt: | ||
| 764 | |||
| 765 | |||
| 766 | ########################################################################## | ||
| 767 | # Start function - called from the BitBake command line utility | ||
| 768 | ########################################################################## | ||
| 769 | |||
| 770 | def start( aCooker ): | ||
| 771 | global cooker | ||
| 772 | cooker = aCooker | ||
| 773 | bbshell = BitBakeShell() | ||
| 774 | bbshell.processStartupFile() | ||
| 775 | bbshell.main() | ||
| 776 | bbshell.cleanup() | ||
| 777 | |||
| 778 | if __name__ == "__main__": | ||
| 779 | print "SHELL: Sorry, this program should only be called by BitBake." | ||
