Class: Session::Sh

Inherits:
AbstractSession show all
Defined in:
lib/session.rb

Overview

class AbstractSession

Direct Known Subclasses

Bash

Constant Summary collapse

DEFAULT_PROG = 
'sh'
ECHO = 
'echo'

Instance Attribute Summary collapse

Attributes inherited from AbstractSession

#debug, #errproc, #history, #opts, #outproc, #prog, #stderr, #stdin, #stdout, #threads, #track_history, #use_open3, #use_spawn

Instance Method Summary collapse

Methods inherited from AbstractSession

#__fork, #__popen3, #close!, default_prog, default_prog=, #getopt, #hasopt, init, #initialize, #ready?

Constructor Details

This class inherits a constructor from Session::AbstractSession

Instance Attribute Details

#status ⇒ Object (readonly) Also known as: exit_status, exitstatus

Returns the value of attribute status.



442
443
444
 
# File 'lib/session.rb', line 442

def status
  @status
end

Instance Method Details

#clear ⇒ Object 



446
447
448
449
450
451
452
453
 
# File 'lib/session.rb', line 446

def clear
  stdin.puts "#{ ECHO } __clear__ 1>&2"
  stdin.puts "#{ ECHO } __clear__"
  stdin.flush
  while((line = stderr.gets) and line !~ %r/__clear__/o); end
  while((line = stdout.gets) and line !~ %r/__clear__/o); end
  self
end

#execute(command, redirects = {}, &block) ⇒ Object 



509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
 
# File 'lib/session.rb', line 509

def execute(command, redirects = {}, &block)
# setup redirect on stdin
  rin = redirects[:i] || redirects[:in] || redirects[:stdin] || 
         redirects['stdin'] || redirects['i'] || redirects['in'] ||
         redirects[0] || redirects['0']

  if rin
    tmp = 
      begin
        Tempfile::new rand.to_s
      rescue
        Tempfile::new rand.to_s
      end

    begin
      tmp.write(
        if rin.respond_to? 'read'
          rin.read
        elsif rin.respond_to? 'to_s'
          rin.to_s
        else
          rin
        end
      )
      tmp.flush
      command = "{ #{ command } ;} < #{ tmp.path }"
      #puts command
      super(command, redirects, &block)
    ensure
      tmp.close! if tmp 
    end

  else
    super
  end
end

#get_status ⇒ Object 



466
467
468
469
470
471
472
473
 
# File 'lib/session.rb', line 466

def get_status
  @status = get_var '__exit_status__' 
  unless @status =~ /^\s*\d+\s*$/o
    raise ExecutionError, "could not determine exit status from <#{ @status.inspect }>"
  end

  @status = Integer @status
end

#get_var(name) ⇒ Object 



478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
 
# File 'lib/session.rb', line 478

def get_var name
  stdin.puts "#{ ECHO } \"#{ name }=${#{ name }}\""
  stdin.flush

  var = nil
  while((line = stdout.gets))
    m = %r/#{ name }\s*=\s*(.*)/.match line
    if m
      var = m[1] 
      raise ExecutionError, "could not determine <#{ name }> from <#{ line.inspect }>" unless var
      break
    end
  end

  var
end

#path ⇒ Object 



494
495
496
497
 
# File 'lib/session.rb', line 494

def path 
  var = get_var 'PATH'
  var.strip.split %r/:/o
end

#path=(arg) ⇒ Object 



498
499
500
501
502
503
504
505
506
507
508
 
# File 'lib/session.rb', line 498

def path= arg 
  case arg
    when Array
      arg = arg.join ':'
    else
      arg = arg.to_s.strip
  end

  set_var 'PATH', "'#{ arg }'"
  self.path
end

#send_command(cmd) ⇒ Object 



454
455
456
457
458
459
460
461
462
463
464
465
 
# File 'lib/session.rb', line 454

def send_command cmd
  stdin.printf "%s '%s' 1>&2\n", ECHO, cmd.begin_err
  stdin.printf "%s '%s' \n", ECHO, cmd.begin_out
 
  stdin.printf "%s\n", cmd.cmd
  stdin.printf "export __exit_status__=$?\n"

  stdin.printf "%s '%s' 1>&2\n", ECHO, cmd.end_err
  stdin.printf "%s '%s' \n", ECHO, cmd.end_out
 
  stdin.flush
end

#set_var(name, value) ⇒ Object 



474
475
476
477
 
# File 'lib/session.rb', line 474

def set_var name, value
  stdin.puts "export #{ name }=#{ value }"
  stdin.flush
end