X-Git-Url: https://review.fuel-infra.org/gitweb?a=blobdiff_plain;f=lib%2Fmcollective%2Frpc%2Frequest.rb;fp=lib%2Fmcollective%2Frpc%2Frequest.rb;h=5243978786a9ad8aa57d894d8e03c79dacb11bf2;hb=b87d2f4e68281062df1913440ca5753ae63314a9;hp=0000000000000000000000000000000000000000;hpb=ab0ea530b8ac956091f17b104ab2311336cfc250;p=packages%2Fprecise%2Fmcollective.git

diff --git a/lib/mcollective/rpc/request.rb b/lib/mcollective/rpc/request.rb
new file mode 100644
index 0000000..5243978
--- /dev/null
+++ b/lib/mcollective/rpc/request.rb
@@ -0,0 +1,62 @@
+module MCollective
+  module RPC
+    # Simple class to manage compliant requests for MCollective::RPC agents
+    class Request
+      attr_accessor :time, :action, :data, :sender, :agent, :uniqid, :caller, :ddl
+
+      def initialize(msg, ddl)
+        @time = msg[:msgtime]
+        @action = msg[:body][:action]
+        @data = msg[:body][:data]
+        @sender = msg[:senderid]
+        @agent = msg[:body][:agent]
+        @uniqid = msg[:requestid]
+        @caller = msg[:callerid] || "unknown"
+        @ddl = ddl
+      end
+
+      # If data is a hash, quick helper to get access to it's include? method
+      # else returns false
+      def include?(key)
+        return false unless @data.is_a?(Hash)
+        return @data.include?(key)
+      end
+
+      # If no :process_results is specified always respond else respond
+      # based on the supplied property
+      def should_respond?
+        return @data[:process_results] if @data.include?(:process_results)
+
+        return true
+      end
+
+      # If data is a hash, gives easy access to its members, else returns nil
+      def [](key)
+        return nil unless @data.is_a?(Hash)
+        return @data[key]
+      end
+
+      def fetch(key, default)
+        return nil unless @data.is_a?(Hash)
+        return @data.fetch(key, default)
+      end
+
+      def to_hash
+        return {:agent => @agent,
+                :action => @action,
+                :data => @data}
+      end
+
+      # Validate the request against the DDL
+      def validate!
+        @ddl.validate_rpc_request(@action, @data)
+      end
+
+      def to_json
+        to_hash.merge!({:sender   => @sender,
+                        :callerid => @callerid,
+                        :uniqid   => @uniqid}).to_json
+      end
+    end
+  end
+end