lib/azure/service_bus/serialization.rb in azure-0.5.0 vs lib/azure/service_bus/serialization.rb in azure-0.6.0
- old
+ new
@@ -1,160 +1,160 @@
-#-------------------------------------------------------------------------
-# Copyright (c) Microsoft. All rights reserved.
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-#--------------------------------------------------------------------------
-require 'nokogiri'
-
-require "azure/service_bus/queue"
-require "azure/service_bus/topic"
-require "azure/service_bus/subscription"
-require "azure/service_bus/rule"
-
-require "azure/service/enumeration_results"
-
-module Azure
- module ServiceBus
- module Serialization
- module ClassMethods
-
- 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
-
- 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
-
- def resource_to_xml(resource, entry)
- doc = Nokogiri::XML::Builder.new 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
-
- 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
-
- 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
-
- 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
-
- def resources_from_xml_with_next_link(resource, xml)
- feed = Nokogiri::XML(xml).remove_namespaces!
- values = Azure::Service::EnumerationResults.new((feed / 'entry').map {|node| resource_from_xml(resource, node) })
-
- next_token = nil
- next_uri = feed.xpath("//link[@rel='next']/@href")
- if next_uri != nil && next_uri.length > 0
- u = URI.parse(next_uri.to_s)
- p = CGI.parse(u.query)
-
- if p['skip'] || p['top']
- next_token = { }
- next_token[:top] = p['top'] if p['top']
- next_token[:skip] = p['skip'] if p['skip']
- end
- end
-
- values.continuation_token = next_token
- values
- end
-
- def to_bool(s)
- (s || "").downcase == 'true'
- end
-
- 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
-
- def expect_node(node_name, xml)
- raise "Xml is not a #{node_name} node." unless xml.name == node_name
- end
- end
-
- extend ClassMethods
-
- def self.included( other )
- other.extend( ClassMethods )
- end
- end
- end
-end
+#-------------------------------------------------------------------------
+# # Copyright (c) Microsoft and contributors. All rights reserved.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#--------------------------------------------------------------------------
+require 'nokogiri'
+
+require "azure/service_bus/queue"
+require "azure/service_bus/topic"
+require "azure/service_bus/subscription"
+require "azure/service_bus/rule"
+
+require "azure/service/enumeration_results"
+
+module Azure
+ module ServiceBus
+ module Serialization
+ module ClassMethods
+
+ 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
+
+ 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
+
+ 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
+
+ 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
+
+ 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
+
+ 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
+
+ def resources_from_xml_with_next_link(resource, xml)
+ feed = Nokogiri::XML(xml).remove_namespaces!
+ values = Azure::Service::EnumerationResults.new((feed / 'entry').map {|node| resource_from_xml(resource, node) })
+
+ next_token = nil
+ next_uri = feed.xpath("//link[@rel='next']/@href")
+ if next_uri != nil && next_uri.length > 0
+ u = URI.parse(next_uri.to_s)
+ p = CGI.parse(u.query)
+
+ if p['skip'] || p['top']
+ next_token = { }
+ next_token[:top] = p['top'] if p['top']
+ next_token[:skip] = p['skip'] if p['skip']
+ end
+ end
+
+ values.continuation_token = next_token
+ values
+ end
+
+ def to_bool(s)
+ (s || "").downcase == 'true'
+ end
+
+ 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
+
+ def expect_node(node_name, xml)
+ raise "Xml is not a #{node_name} node." unless xml.name == node_name
+ end
+ end
+
+ extend ClassMethods
+
+ def self.included( other )
+ other.extend( ClassMethods )
+ end
+ end
+ end
+end