rcm

@@ -16,3 +16,11 @@

     mode: 0644

     local_file: hello_world.php

     desired_state: present

+

+- services:

+  - name: apache2

+    dependencies:

+    - packages:

+      - name: libapache2-mod-php5

+    - files:

+      - path: /tmp/hello_world.php

@@ -0,0 +1,26 @@

+- packages:

+  - name: apache2

+    version: 2.4.18-2ubuntu3.8

+    desired_state: installed

+  - name: php5

+    version: 5.5.9+dfsg-1ubuntu4.25

+    desired_state: installed

+  - name: libapache2-mod-php5

+    version: 5.5.9+dfsg-1ubuntu4.25

+    desired_state: installed

+

+- files:

+  - path: /tmp/hello_world.php

+    owner: apache2

+    group: apache2

+    mode: 0644

+    local_file: hello_world.php

+    desired_state: present

+

+- services:

+  - name: apache2

+    dependencies:

+    - packages:

+      - name: libapache2-mod-php5

+    - files:

+      - path: /tmp/hello_world.php

@@ -0,0 +1,2 @@

+module RCM

+end

@@ -0,0 +1,69 @@

+require_relative '../rcm_utils'

+

+module RCM

+  class Apt

+    APT_GET = '/usr/bin/apt-get'.freeze

+    DPKG_QUERY = '/usr/bin/dpkg-query'.freeze

+    APT_CACHE = '/usr/bin/apt-cache'.freeze

+

+    def update()

+      status = ::RCM.cmd("#{APT_GET} update")

+      raise "Updating apt cache failed. \n\n#{status[:error]}\n\nstdout:\n#{status[:output]}"

+    end

+

+    def status(pkg_name)

+      ::RCM.cmd("#{DPKG_QUERY} --status #{pkg_name}")

+    end

+

+    def install(pkg_name, version = '')

+      name = ''

+      version_string = "=#{version}" unless version.empty?

+      if pkg_name.is_a?(String)

+        name = pkg_name

+        version_string = "=#{version}" unless version.empty?

+      elsif pkg_name.is_a?(::RCM::Package)

+        name = pkg_name.name

+        v = pkg_name.version

+        version_string = "=#{v}" unless v.empty?

+      end

+

+      ::RCM.cmd("#{APT_GET} install --yes #{name}#{version_string}")

+    end

+

+    def multi_install(pkgs)

+      raise 'multi_install expects array of ::RCM.Package' unless pkgs.is_a?(Array)

+

+      # Construct string of packages to install in one go.

+      pkgs_string = ''

+      pkgs.each do |pkg|

+        version_string = "=#{pkg.version}" unless pkg.version.empty?

+        pkgs_string += "#{pkg.name}#{version_string} "

+      end

+

+      ::RCM.cmd("#{APT_GET} install --yes #{pkgs_string}")

+    end

+

+    def get_versions(pkg_name)

+      name = ''

+      if pkg_name.is_a?(String)

+        name = pkg_name

+      elsif pkg_name.is_a?(::RCM::Package)

+        name = pkg_name.name

+      end

+      status = ::RCM.cmd("#{APT_CACHE} madison #{name}")

+      return [] if !status[:output] || status[:output] =~ /Unable to locate package/

+

+      # Collect all versions by splitting on new line, and then collecting second

+      # field from every line with delimiter ' | '

+      available_versions = status[:output].split("\n").collect { |l| l.split(' | ')[1] }

+      available_versions.uniq

+    end

+

+    def remove(pkg_name)

+      # Remove is idempotent and returns with success even if package is not installed.

+      status = ::RCM.cmd("#{APT_GET} remove --yes #{pkg_name}")

+      error_message = "Removing #{pkg_name} failed!\n\nstderr:\n#{status[:error]}\n\nstdout:\n#{status[:output]}"

+      raise error_message unless status[:exit_code] == 0

+    end

+  end

+end

@@ -0,0 +1,2 @@

+module RCM

+end

@@ -0,0 +1,31 @@

+module RCM

+  class File

+    attr_accessor :path, :owner, :group, :mode, :checksum

+

+    def ==(other)

+      return false unless other.is_a?(RCM::File)

+

+      @path == other.path &&

+          @owner == other.owner &&

+          @group == other.group &&

+          @mode == other.mode &&

+          @checksum == other.checksum

+    end

+

+    def initialize(path, owner, group, mode, checksum)

+      @path = path

+      @owner = owner

+      @group = group

+      @mode = mode

+      @checksum = checksum

+    end

+

+    def to_s

+      "Path = #{@path}\n" +

+      "Owner = #{@owner}\n" +

+      "Group = #{@group}\n" +

+      "Mode = #{@mode}\n" +

+      "Checksum = #{@checksum}"

+    end

+  end

+end

@@ -0,0 +1,29 @@

+module RCM

+  class Package

+    attr_accessor :name, :version, :state

+

+    # Public state constants

+    INSTALLED = 'installed'.freeze

+    REMOVED = 'removed'.freeze

+

+    def ==(other)

+      return false unless other.is_a?(RCM::Package)

+

+      @name == other.name &&

+      @version == other.version &&

+      @state == other.state

+    end

+

+    def initialize(name, version, state)

+      @name = name

+      @version = version

+      @state = state

+    end

+

+    def to_s

+      "Name = #{@name}\n" +

+      "Version = #{@version}\n" +

+      "State = #{@state}\n"

+    end

+  end

+end

@@ -1,6 +1,6 @@

 module RCM

   class Service

-    attr_accessor :name, :installed, :definition_path, :running, :enabled

+    attr_accessor :name, :installed, :definition_path, :running, :enabled, :depends

     def ==(other)

       return false unless other.is_a?(RCM::Service)

@@ -1,43 +0,0 @@

-module RCM

-  class File

-    attr_accessor :path, :owner, :group, :mode, :local_content_md5, :target_content_md5, :current_state, :desired_state

-

-    def ==(other)

-      return false unless other.is_a?(RCM::File)

-

-      @path == other.path &&

-          @owner == other.owner &&

-          @group == other.group &&

-          @mode == other.mode &&

-          @content_md5 == other.content_md5 &&

-          @desired_state == other.desired_state &&

-          @current_state == other.current_state

-    end

-

-    def initialize(path, owner, group, mode, local_content_md5, target_content_md5, current_state, desired_state)

-      @path = path

-      @owner = owner

-      @group = group

-      @mode = mode

-      @local_content_md5 = local_content_md5

-      @target_content_md5 = target_content_md5

-      @current_state = current_state

-      @desired_state = desired_state

-    end

-

-    def lackin(other)

-      raise 'not implemented.'

-    end

-

-    def to_s

-      "Path = #{@path}\n" +

-      "Owner = #{@owner}\n" +

-      "Group = #{@group}\n" +

-      "Mode = #{@mode}\n" +

-      "Local Content MD5 = #{@local_content_md5}\n" +

-      "Target Content MD5 = #{@target_content_md5}\n" +

-      "Desired State = #{@desired_state}\n" +

-      "Current State = #{@current_state}"

-    end

-  end

-end

@@ -1,29 +0,0 @@

-module RCM

-  class Package

-    attr_accessor :name, :version, :current_state, :desired_state

-

-    def ==(other)

-      return false unless other.is_a?(RCM::Package)

-

-      @installed = other.installed &&

-      @name == other.name &&

-      @version == other.version &&

-      @current_state == other.current_state &&

-      @desired_state == other.desired_state

-    end

-

-    def initialize(name, version, current_state, desired_state)

-      @name = name

-      @version = version

-      @current_state = current_state

-      @desired_state = desired_state

-    end

-

-    def to_s

-      "Name = #{@name}\n" +

-      "Version = #{@version}\n" +

-      "Current State = #{@current_state}\n" +

-      "Desired State = #{@desired_state}"

-    end

-  end

-end

@@ -1,21 +1,22 @@

 require 'open3'

 module RCM

-  module_function :cmd

   def cmd(command)

     stdin, stdout, stderr, wait_thr = Open3.popen3(command)

     output = stdout.gets(nil)

     stdout.close

-    errors = stderr.gets(nil)

+    error = stderr.gets(nil)

     stderr.close

     exit_code = Integer(wait_thr.value)

     {

       exit_code: exit_code,

       output: output,

-      errors: errors

+      error: error

     }

   end

+

+  module_function :cmd

 end

@@ -1,6 +1,7 @@

-require_relative 'rcm_file'

-require_relative 'rcm_package'

-require_relative 'rcm_service'

+require_relative 'objects/rcm_file'

+require_relative 'objects/rcm_package'

+require_relative 'objects/rcm_service'

+require_relative 'managers/rcm_package_manager'

 require 'yaml'

 module RCM

@@ -9,42 +10,72 @@ module RCM

   SERVICES = 'services'

   @@wanted = {

-    PACKAGES => [],

-    FILES => [],

-    SERVICES => []

+    PACKAGES => {},

+    FILES => {},

+    SERVICES => {}

   }

   @@got = {

+    PACKAGES => {},

+    FILES => {},

+    SERVICES => {}

+  }

+

+  @@crackalackin = {

       PACKAGES => [],

       FILES => [],

       SERVICES => []

   }

-  def converge(old_state, new_state)

-    if old_state.is_a?(RCM::File)

+  @@pkg_mgr = ::RCM::Apt.new()

+

+  def self.parse_packages(markup)

+    markup.each do |d|

+      # ensure package version exists, if mentioned.

+      version = d.fetch('version', '')

+      desired_state = d.fetch('desired_state', ::RCM::Package::INSTALLED)

+

+      valid_package_states = [::RCM::Package::INSTALLED, ::RCM::Package::REMOVED]

+

+      if (valid_package_states & [desired_state]).empty?

+        raise "Unknown desired_state: #{desired_state}. Valid states: #{valid_package_states.join(', ')}"

       end

+      unless version.empty?

+        available_versions = @@pkg_mgr.get_versions(d['name'])

+        if (available_versions & [version]).empty?

+          raise "\n\n#{d['name']} = #{version} is not available.\nAvailable versions: #{available_versions.join(', ')}"

+        end

+      end

+      p = RCM::Package.new(d['name'], version, desired_state)

+      @@wanted[PACKAGES][d['name']] = p

+    end

   end

-  def whachuwant()

+

+  def whachuwant() # or parse_config

+    env = ENV.fetch('ENVIRONMENT', '')

     # Consume config from YAML, and convert it to usable objects in @@wanted.

-    raise 'config.yaml not found.' unless ::File.file?('config.yaml')

+    config_file = env.empty? ? 'config.yaml' : "config_#{env}.yaml"

+

+    raise "#{config_file} not found." unless ::File.readable?(config_file)

-    config = YAML.load_file('config.yaml')

+    config = YAML.load_file(config_file)

     config.each do |yaml_objects|

       yaml_objects.each do |coll, defs|

         case coll

         when PACKAGES

+          parse_packages(defs)

+

+        when FILES

           defs.each do |d|

-            p = RCM::Package.new(d['name'], d['version'], 'idk', d['desired_state'])

-            @@wanted[PACKAGES].push(p)

+            f = RCM::File.new(d['path'], d['owner'], d['group'], d['mode'], 'idk')

+            @@wanted[FILES][d['path']] = f

           end

-        when FILES

+        when SERVICES

           defs.each do |d|

-            f = RCM::File.new(d['path'], d['owner'], d['group'], d['mode'], 'idk',

-                              'idk', 'idk', d[''])

-            @@wanted[FILES].push(f)

+            puts d

           end

         end

       end

@@ -52,12 +83,49 @@ module RCM

   end

-  def whachugot()

+  def whachugot() # or get_current_state

+    @@wanted[PACKAGES].each do |name, p|

+      state = ::RCM::Package::REMOVED

+      version = 'idk'

+      begin

+        status = @@pkg_mgr.status(p.name)

+

+        if status[:exit_code] == 0

+          state = ::RCM::Package::INSTALLED if status[:output] =~ 'ok installed'

+          version = /Version: (?<version>\d+.+)/.match(status[:output])[:version]

+        end

+

+        current_pkg = ::RCM::Package.new(name, version, state)

+

+        @@got[PACKAGES][name] = current_pkg

+      rescue Exception => e

+        puts e.message

+      end

+    end

+  end

+

+  def crackalackin_packages()

+    @@wanted[PACKAGES].each do |pkg_name, pkg_obj|

+      current_pkg = @@got[PACKAGES][pkg_name]

+

+      next if current_pkg.state == ::RCM::Package::INSTALLED &&

+          current_pkg.version == pkg_obj.version

+      # Set the version correctly

+      current_pkg.version = pkg_obj.version

+      @@crackalackin[PACKAGES].push(current_pkg)

     end

-  module_function :whachuwant, :whachugot

+    puts @@crackalackin[PACKAGES]

+  end

+

+  def cracka_stop_lackin()

+    puts 'not implemented'

+  end

+  module_function :whachuwant, :whachugot, :crackalackin_packages, :cracka_stop_lackin

 end

 RCM.whachuwant

+RCM.whachugot

+RCM.crackalackin_packages