--- /dev/null
+#!/usr/bin/env rspec
+
+require 'spec_helper'
+
+module MCollective
+ module DDL
+ describe AgentDDL do
+ before :each do
+ Cache.delete!(:ddl) rescue nil
+ @ddl = DDL.new("rspec", :agent, false)
+ @ddl.metadata(:name => "name", :description => "description", :author => "author", :license => "license", :version => "version", :url => "url", :timeout => "timeout")
+ end
+
+ describe "#input" do
+ it "should validate that an :optional property is set" do
+ expect { @ddl.input(:x, {:y => 1}) }.to raise_error("Input needs a :optional property")
+ end
+ end
+
+ describe "#set_default_input_arguments" do
+ before do
+ @ddl.action(:test, :description => "rspec")
+ @ddl.instance_variable_set("@current_entity", :test)
+
+ @ddl.input(:optional, :prompt => "prompt", :description => "descr",
+ :type => :string, :optional => true, :validation => "",
+ :maxlength => 1, :default => "default")
+ @ddl.input(:required, :prompt => "prompt", :description => "descr",
+ :type => :string, :optional => false, :validation => "",
+ :maxlength => 1, :default => "default")
+ end
+
+ it "should correctly add default arguments to required inputs" do
+ args = {}
+
+ @ddl.set_default_input_arguments(:test, args)
+
+ args.should == {:required => "default"}
+ end
+
+ it "should not override any existing arguments" do
+ args = {:required => "specified"}
+
+ @ddl.set_default_input_arguments(:test, args)
+
+ args.should == {:required => "specified"}
+ end
+ end
+
+ describe "#validate_rpc_request" do
+ it "should ensure the action is known" do
+ @ddl.action(:test, :description => "rspec")
+
+ expect {
+ @ddl.validate_rpc_request(:fail, {})
+ }.to raise_code(:PLMC29, :action => :fail, :plugin => "rspec")
+
+ @ddl.validate_rpc_request(:test, {})
+ end
+
+ it "should check all required arguments are present" do
+ @ddl.action(:test, :description => "rspec")
+ @ddl.instance_variable_set("@current_entity", :test)
+ @ddl.input(:optional, :prompt => "prompt", :description => "descr",
+ :type => :string, :optional => true, :validation => "",
+ :maxlength => 1)
+ @ddl.input(:required, :prompt => "prompt", :description => "descr",
+ :type => :string, :optional => false, :validation => "",
+ :maxlength => 1)
+
+ @ddl.stubs(:validate_input_argument).returns(true)
+
+ expect {
+ @ddl.validate_rpc_request(:test, {})
+ }.to raise_code(:PLMC30, :action => :test, :key => :required)
+
+ @ddl.validate_rpc_request(:test, {:required => "f"}).should == true
+ end
+
+ it "should input validate every supplied key" do
+ @ddl.action(:test, :description => "rspec")
+ @ddl.instance_variable_set("@current_entity", :test)
+ @ddl.input(:optional, :prompt => "prompt", :description => "descr",
+ :type => :string, :optional => true, :validation => "",
+ :maxlength => 1)
+ @ddl.input(:required, :prompt => "prompt", :description => "descr",
+ :type => :string, :optional => false, :validation => "",
+ :maxlength => 1)
+
+
+ @ddl.expects(:validate_input_argument).with(@ddl.entities[:test][:input], :required, "f")
+ @ddl.expects(:validate_input_argument).with(@ddl.entities[:test][:input], :optional, "f")
+
+ @ddl.validate_rpc_request(:test, {:required => "f", :optional => "f"}).should == true
+ end
+ end
+
+ describe "#is_function" do
+ before :each do
+ PluginManager.expects(:find).with("aggregate").returns(["plugin"])
+ end
+
+ it "should return true if the aggregate function is present" do
+ @ddl.is_function?("plugin").should == true
+ end
+
+ it "should return false if the aggregate function is not present" do
+ @ddl.is_function?("no_plugin").should == false
+ end
+ end
+
+ describe "#method_missing" do
+ it "should call super if the aggregate plugin isn't present" do
+ expect{
+ @ddl.test
+ }.to raise_error(NoMethodError)
+ end
+
+ it "should call super if @process_aggregate_function is false" do
+ expect{
+ result = @ddl.test(:value)
+ }.to raise_error(NoMethodError)
+ end
+
+ it "should return the function hash" do
+ Config.instance.mode = :client
+ @ddl.instance_variable_set(:@process_aggregate_functions, true)
+ result = @ddl.method_missing(:test_function, :rspec)
+ result.should == {:args => [:rspec], :function => :test_function }
+ end
+ end
+
+ describe "#actions" do
+ it "should return the correct list of actions" do
+ @ddl.action(:test1, :description => "rspec")
+ @ddl.action(:test2, :description => "rspec")
+
+ @ddl.actions.sort.should == [:test1, :test2]
+ end
+ end
+
+ describe "#action_interface" do
+ it "should return the correct interface" do
+ @ddl.action(:test1, :description => "rspec")
+ @ddl.action_interface(:test1).should == {:description=>"rspec", :output=>{}, :input=>{}, :action=>:test1, :display=>:failed}
+ end
+ end
+
+ describe "#display" do
+ it "should ensure a valid display property is set" do
+ @ddl.action(:test, :description => "rspec")
+ @ddl.instance_variable_set("@current_entity", :test)
+
+ [:ok, :failed, :flatten, :always].each do |display|
+ @ddl.display(display)
+
+ action = @ddl.action_interface(:test)
+ action[:display].should == display
+ end
+
+ expect {
+ @ddl.display(:foo)
+ }.to raise_error(/Display preference foo is not valid/)
+ end
+ end
+
+ describe "#summarize" do
+ before :each do
+ @block_result = nil
+ @block = Proc.new{@block_result = :success}
+ end
+
+ after :each do
+ @block_result = nil
+ end
+
+ it "should call the block parameter if config mode is not server" do
+ Config.instance.mode = :client
+ result = @ddl.summarize(&@block)
+ @block_result.should == :success
+ end
+
+ it "should not call the block parameter if config mode is server" do
+ Config.instance.mode = :server
+ result = @ddl.summarize(&@block)
+ @block_result.should == nil
+ end
+ end
+
+ describe "#aggregate" do
+ it "should raise an exception if aggregate format isn't a hash" do
+ expect{
+ @ddl.aggregate(:foo, :format)
+ }.to raise_code(:PLMC28)
+ end
+
+ it "should raise an exception if format hash does not include a :format key" do
+ expect{
+ @ddl.aggregate(:foo, {})
+ }.to raise_code(:PLMC27)
+ end
+
+ it "should raise an exception if aggregate function is not a hash" do
+ expect{
+ @ddl.aggregate(:foo)
+ }.to raise_code(:PLMC26)
+ end
+
+ it "should raise an exception if function hash does not include a :args key" do
+ expect{
+ @ddl.stubs(:entities).returns({nil => {:action => :foo}})
+ @ddl.aggregate({})
+ }.to raise_code(:PLMC25, :action => :foo)
+ end
+
+ it "should correctly add an aggregate function to the function array" do
+ @ddl.stubs(:entities).returns({nil => {:aggregate => nil}})
+ @ddl.aggregate({:function => :foo, :args => [:bar]})
+ @ddl.entities.should == {nil => {:aggregate => [{:function => :foo, :args => [:bar]}]}}
+ end
+ end
+
+ describe "#action" do
+ it "should ensure a description is set" do
+ expect {
+ @ddl.action("act", {})
+ }.to raise_error("Action needs a :description property")
+ end
+
+ it "should create a default action structure" do
+ @ddl.action("act", :description => "rspec")
+
+ action = @ddl.action_interface("act")
+
+ action.class.should == Hash
+ action[:action].should == "act"
+ action[:input].should == {}
+ action[:output].should == {}
+ action[:display].should == :failed
+ action[:description].should == "rspec"
+ end
+
+ it "should call a block if one is given and set the correct action name" do
+ @ddl.action("act", :description => "rspec") { @ddl.instance_variable_get("@current_entity").should == "act" }
+ end
+ end
+ end
+ end
+end
Code Review / packages / precise / mcollective.git / blobdiff