Module: DockerCore::Shell

Defined in:
lib/docker_core.rb

Class Method Summary collapse

Class Method Details

.architecture ⇒ Object 



416
417
418
419
420
 
# File 'lib/docker_core.rb', line 416

def self.architecture
  hash = { x86: '386', x86_64: 'amd64', armhf: 'armv6', armv7l: 'armv7', aarch64: 'arm64' }
  machine = "#{Etc.uname[:machine]}"
  return hash.fetch(machine.to_sym, machine)
end

.change_mode(mode, *arguments) ⇒ Object

Parameters:

  • arguments (Array<String>)
  • mode (String, Integer) 


448
449
450
451
452
 
# File 'lib/docker_core.rb', line 448

def self.change_mode(mode, *arguments)
  self.find_paths(*arguments).each do |path|
    FileUtils.chmod_R(mode, path, force: true)
  end
end

.change_owner(*arguments, user: USER, group: GROUP) ⇒ Object

Parameters:

  • arguments (Array<String>)
  • user (String) (defaults to: USER)
  • group (String) (defaults to: GROUP) 


440
441
442
443
444
 
# File 'lib/docker_core.rb', line 440

def self.change_owner(*arguments, user: USER, group: GROUP)
  self.find_paths(*arguments).each do |path|
    FileUtils.chown_R(user, group, path, force: true)
  end
end

.clear_folders(*arguments, mode: nil) ⇒ Object

Parameters:

  • arguments (Array<String>)
  • mode (Integer, nil) (defaults to: nil) 


640
641
642
643
 
# File 'lib/docker_core.rb', line 640

def self.clear_folders(*arguments, mode: nil)
  self.remove_paths(*arguments)
  self.make_folders(*arguments, mode: mode)
end

.deflate_file(file, path, echo: false) ⇒ Object

Parameters:

  • file (String)
  • path (String)
  • echo (Boolean) (defaults to: false) 


603
604
605
606
607
608
609
610
 
# File 'lib/docker_core.rb', line 603

def self.deflate_file(file, path, echo: false)
  Zlib::GzipWriter.open(file, Zlib::BEST_COMPRESSION) do

    # @type [Zlib::GzipWriter] writer
  |writer|
    writer.write(self.tape_archive(path, echo: echo))
  end
end

.download_file(uri, file) ⇒ Object

Parameters:

  • uri (String)
  • file (String) 


512
513
514
515
516
 
# File 'lib/docker_core.rb', line 512

def self.download_file(uri, file)
  uri = self.resolve_link(uri)
  content = Net::HTTP.get(URI(uri))
  return File.binwrite(file, content)
end

.find_paths(*arguments) ⇒ Array<String>

Parameters:

  • arguments (Array<String>)

Returns:

  • (Array<String>) 


429
430
431
432
433
434
435
 
# File 'lib/docker_core.rb', line 429

def self.find_paths(*arguments)
  return Dir.glob(arguments.flatten, File::FNM_DOTMATCH).map do |item|
    next File.path(item)
  end.filter do |item|
    next false == %w[. ..].include?(File.basename(item))
  end.uniq
end

.github_latest_version(repository) ⇒ Object

Parameters:

  • repository (String) 


646
647
648
649
650
651
 
# File 'lib/docker_core.rb', line 646

def self.github_latest_version(repository)
  uri = URI("https://api.github.com/repos/#{repository}/releases/latest")
  data = JSON.parse(Net::HTTP.get(uri))['tag_name']
  return "#{data}"

end

.inflate_file(file, path, echo: false) ⇒ Object

Parameters:

  • file (String)
  • path (String)
  • echo (Boolean) (defaults to: false) 


555
556
557
558
559
560
561
562
 
# File 'lib/docker_core.rb', line 555

def self.inflate_file(file, path, echo: false)
  Zlib::GzipReader.open(file) do

    # @type [Zlib::GzipReader] reader
  |reader|
    self.unpack_archive(reader, path, echo: echo)
  end
end

.is_active_unit(unit) ⇒ Object

Parameters:

  • unit (String) 


423
424
425
 
# File 'lib/docker_core.rb', line 423

def self.is_active_unit(unit)
  return 'active' == Process.capture("systemctl is-active #{unit}").downcase
end

.link_logs(stdout: '', stderr: '') ⇒ Object

Parameters:

  • stdout (String) (defaults to: '')
  • stderr (String) (defaults to: '') 


626
627
628
629
630
631
632
633
634
635
636
 
# File 'lib/docker_core.rb', line 626

def self.link_logs(stdout: '', stderr: '')
  if '' != stdout
    File.symlink('/dev/stdout', File.path(stdout))
  end

  if '' != stderr
    File.symlink('/dev/stderr', File.path(stderr))
  end

  return
end

.make_folders(*arguments, mode: nil) ⇒ Object

Parameters:

  • arguments (Array<String>)
  • mode (Integer, nil) (defaults to: nil) 


456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
 
# File 'lib/docker_core.rb', line 456

def self.make_folders(*arguments, mode: nil)
  stack = []
  paths = arguments.map do |path|
    next File.path(path)
  end.uniq

  paths.each do |path|
    until path == stack.last
      stack << path
      path = File.dirname(path)
    end
  end

  stack.uniq.each do |path|
    if File.exist?(path) && false == File.directory?(path)
      File.delete(path)
    end
  end

  FileUtils.mkdir_p(paths, mode: mode)
end

.move_paths(source, target) ⇒ Object

Parameters:

  • source (String, Array<String>)
  • target (String) 


487
488
489
490
 
# File 'lib/docker_core.rb', line 487

def self.move_paths(source, target)
  paths = [source].flatten
  FileUtils.mv(self.find_paths(*paths), target)
end

.remove_paths(*arguments) ⇒ Object

Parameters:

  • arguments (Array<String>) 


479
480
481
482
483
 
# File 'lib/docker_core.rb', line 479

def self.remove_paths(*arguments)
  self.find_paths(*arguments).each do |path|
    FileUtils.rm_rf(path)
  end
end

.resolve_link(uri, max_redirect = 10) ⇒ Object

Parameters:

  • uri (String)
  • max_redirect (Integer) (defaults to: 10) 


494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
 
# File 'lib/docker_core.rb', line 494

def self.resolve_link(uri, max_redirect = 10)
  response = Net::HTTP.get_response(URI.parse(uri))

  if false == response.is_a?(Net::HTTPRedirection)
    return uri
  end

  max_redirect = max_redirect - 1

  if 0 == max_redirect
    Error.maximum_redirect
  end

  return self.resolve_link(response['location'], max_redirect)
end

.tape_archive(path, echo: false) ⇒ Object

Parameters:

  • path (String)
  • echo (Boolean) (defaults to: false) 


566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
 
# File 'lib/docker_core.rb', line 566

def self.tape_archive(path, echo: false)
  io = StringIO.new('')
  offset = path.size + 1

  Gem::Package::TarWriter.new(io) do

    # @type [Gem::Package::TarWriter] writer
  |writer|
    self.find_paths(File.join(path, '**/*')).each do |name|
      mode = File.stat(name).mode
      file = name.slice(offset ..)

      if echo
        Color.echo(": #{file}", Color::GREEN)
      end

      if File.directory?(name)
        writer.mkdir(file, mode)
        next
      end

      if File.file?(name)
        writer.add_file(file, mode) do |stream|
          stream.write(File.binread(name))
        end
        next
      end
    end
  end

  io.rewind
  return io.string
end

.unpack_archive(io, path, echo: false) ⇒ Object

Parameters:

  • io (Object)
  • path (String)
  • echo (Boolean) (defaults to: false) 


521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
 
# File 'lib/docker_core.rb', line 521

def self.unpack_archive(io, path, echo: false)
  Gem::Package::TarReader.new(io) do

    # @type [Gem::Package::TarReader] reader
  |reader|
    reader.rewind
    reader.each do |entry|
      # @type [Gem::Package::TarHeader] header
      header = entry.header
      mode = header.mode
      file = File.join(path, entry.full_name)

      if echo
        Color.echo(": #{file}", Color::GREEN)
      end

      if entry.directory?
        self.make_folders(file, mode: mode)
        next
      end

      if entry.file?
        self.make_folders(File.dirname(file))
        File.binwrite(file, entry.read)
        self.change_mode(mode, file)
        next
      end
    end
  end
end

.update_user(uid: 500, gid: 500) ⇒ Object

Parameters:

  • uid (Integer) (defaults to: 500)
  • gid (Integer) (defaults to: 500) 


614
615
616
617
618
619
620
621
622
 
# File 'lib/docker_core.rb', line 614

def self.update_user(uid: 500, gid: 500)
  uid = ENV.fetch('DOCKER_CORE_UID', uid)
  gid = ENV.fetch('DOCKER_CORE_GID', gid)

  Process.run('deluser', USER, throw: false)
  Process.run('delgroup', GROUP, throw: false)
  Process.run('addgroup', { system: true, gid: gid }, GROUP)
  Process.run('adduser', { system: true, 'disabled-password': true, 'no-create-home': true, ingroup: GROUP, gecos: USER, shell: '/bin/bash', uid: uid }, USER)
end