summaryrefslogtreecommitdiffstats
path: root/lib/puppet/interface.rb
blob: 64f1bfe49d1ad1d1fff63467f761c3f3c9be7441 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
require 'puppet'
require 'puppet/util/autoload'

class Puppet::Interface
  require 'puppet/interface/action_manager'
  require 'puppet/interface/interface_collection'

  include Puppet::Interface::ActionManager
  extend Puppet::Interface::ActionManager

  include Puppet::Util

  class << self
    # This is just so we can search for actions.  We only use its
    # list of directories to search.
    # Can't we utilize an external autoloader, or simply use the $LOAD_PATH? -pvb
    def autoloader
      @autoloader ||= Puppet::Util::Autoload.new(:application, "puppet/interface")
    end

    def interfaces
      Puppet::Interface::InterfaceCollection.interfaces
    end

    def interface?(name, version)
      Puppet::Interface::InterfaceCollection.interface?(name, version)
    end

    def register(instance)
      Puppet::Interface::InterfaceCollection.register(instance)
    end

    def define(name, version, &blk)
      if interface?(name, version)
        interface = Puppet::Interface::InterfaceCollection[name, version]
        interface.instance_eval(&blk) if blk
      else
        interface = self.new(name, :version => version, &blk)
        Puppet::Interface::InterfaceCollection.register(interface)
        interface.load_actions
      end
      return interface
    end

    alias :[] :define
  end

  attr_accessor :default_format

  def set_default_format(format)
    self.default_format = format.to_sym
  end

  attr_accessor :type, :verb, :version, :arguments, :options
  attr_reader :name

  def initialize(name, options = {}, &block)
    unless options[:version]
      raise ArgumentError, "Interface #{name} declared without version!"
    end

    @name = Puppet::Interface::InterfaceCollection.underscorize(name)

    @default_format = :pson
    options.each { |opt, val| send(opt.to_s + "=", val) }

    instance_eval(&block) if block
  end

  # Try to find actions defined in other files.
  def load_actions
    path = "puppet/interface/#{name}"

    loaded = []
    Puppet::Interface.autoloader.search_directories.each do |dir|
      fdir = ::File.join(dir, path)
      next unless FileTest.directory?(fdir)

      Dir.chdir(fdir) do
        Dir.glob("*.rb").each do |file|
          aname = file.sub(/\.rb/, '')
          if loaded.include?(aname)
            Puppet.debug "Not loading duplicate action '#{aname}' for '#{name}' from '#{fdir}/#{file}'"
            next
          end
          loaded << aname
          Puppet.debug "Loading action '#{aname}' for '#{name}' from '#{fdir}/#{file}'"
          require "#{path}/#{aname}"
        end
      end
    end
  end

  def to_s
    "Puppet::Interface(#{name}, :version => #{version.inspect})"
  end
end