module Azure::ServiceBus::Serialization::ClassMethods

Public Instance Methods

expect_node(node_name, xml) click to toggle source
# File lib/azure/service_bus/serialization.rb, line 149
def expect_node(node_name, xml)
  raise "Xml is not a #{node_name} node." unless xml.name == node_name
end
handle_rule_description_element(element, description) click to toggle source
# File lib/azure/service_bus/serialization.rb, line 92
def handle_rule_description_element(element, description)
  if element.name == "Filter" or element.name == "Action"
    value = {}
    value[:type] = element["type"]
    element.children.each do |child|
      if child.name == "SqlExpression"
        value[:sql_expression] = child.content
      elsif child.name == "CompatibilityLevel"
        value[:compatibility_level] = child.content
      elsif child.name == "CorrelationId"
        value[:correlation_id] = child.content
      end
    end
    description[element.name] = value
  end
end
resource_from_xml(resource, node) click to toggle source
# File lib/azure/service_bus/serialization.rb, line 71
def resource_from_xml(resource, node)
  resource = resource.to_s.capitalize

  name = (node % "title").text

  Azure::ServiceBus.const_get(resource).new(name) do |r|
    r.id          = URI((node % "id").text) if (node % "id")
    r.published   = Time.parse((node % "published").text) if (node % "published")
    r.updated     = Time.parse((node % "updated").text) if (node % "updated")
    r.author_name = (node % "author/name").text if (node % "author/name")

    r.description = (node / "content/#{resource}Description *").each_with_object({}) do |element, description|
      if resource == "Rule"
        handle_rule_description_element element, description
      else
        description[element.name] = element.text
      end
    end
  end
end
resource_to_xml(resource, entry) click to toggle source
# File lib/azure/service_bus/serialization.rb, line 52
def resource_to_xml(resource, entry)
  doc = Nokogiri::XML::Builder.new(:encoding => "UTF-8") do |xml|
    xml.entry(:xmlns => 'http://www.w3.org/2005/Atom') {
      xml.content(:type => 'application/xml') {
        xml.send("#{resource.to_s.capitalize}Description", 'xmlns' => 'http://schemas.microsoft.com/netservices/2010/10/servicebus/connect', 'xmlns:i' => 'http://www.w3.org/2001/XMLSchema-instance') {
          if resource == :rule
            rule_to_xml xml, entry
          else
            entry.get_props.each do |p|
              xml.send(p[0], p[1].to_s)
            end
          end
        }
      }
    }
  end
  doc.to_xml
end
resources_from_xml(resource, xml) click to toggle source
# File lib/azure/service_bus/serialization.rb, line 109
def resources_from_xml(resource, xml)
  feed = Nokogiri::XML(xml).remove_namespaces!
  values = (feed / 'entry').map {|node| resource_from_xml(resource, node) }
  values.class.module_eval { attr_accessor :next_link}
  values.next_link = feed.xpath("//link[@rel='next']/@href")
  values
end
rule_aspect_to_xml(xml, aspect_name, rule) click to toggle source
# File lib/azure/service_bus/serialization.rb, line 35
def rule_aspect_to_xml(xml, aspect_name, rule)
  aspect = rule.description[aspect_name].dup
  xml.send(aspect_name, "i:type" => aspect.delete(:type)) {
    aspect.each { |k,v|
      if k == :sql_expression
        k = "SqlExpression"
      elsif k == :compatibility_level
        k = "CompatibilityLevel"
      elsif k == :correlation_id
        k = "CorrelationId"
      end

      xml.send(k, v)
    }
  }
end
rule_to_xml(xml, rule) click to toggle source
# File lib/azure/service_bus/serialization.rb, line 30
def rule_to_xml(xml, rule)
  rule_aspect_to_xml xml, 'Filter', rule if rule.filter
  rule_aspect_to_xml xml, 'Action', rule if rule.action
end
slopify(xml) click to toggle source
# File lib/azure/service_bus/serialization.rb, line 142
def slopify(xml)
  node = (xml.is_a? String) ? Nokogiri.Slop(xml).root : xml
  node.slop! if node.is_a? Nokogiri::XML::Document unless node.respond_to? :method_missing
  node = node.root if node.is_a? Nokogiri::XML::Document
  node
end
to_bool(s) click to toggle source
# File lib/azure/service_bus/serialization.rb, line 138
def to_bool(s)
  (s || "").downcase == 'true'
end