Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
branch: master
Fetching contributors…

Cannot retrieve contributors at this time

executable file 243 lines (191 sloc) 6.471 kb
#!/usr/bin/env ruby
# USAGE: ruby qparser.rb amqp-0.8.xml > amqp-definitions-0-8.js
require 'rubygems'
require 'nokogiri'
require 'erb'
require 'pathname'
require 'yaml'
require 'active_support'
require 'json'
class InputError < StandardError; end
def spec_details(doc)
# AMQP spec details
spec_details = {}
root = doc.at('amqp')
spec_details['major'] = root['major']
spec_details['minor'] = root['minor']
spec_details['revision'] = root['revision'] || '0'
spec_details['port'] = root['port']
spec_details['comment'] = root['comment'] || 'No comment'
spec_details
end
def jscase(s)
t = s.gsub(/\s|-/, '_').camelcase
t[0] = t[0].downcase
t
end
def process_constants(doc)
# AMQP constants
constants = {}
doc.xpath('//constant').each do |element|
constants[element['value'].to_i] = jscase(element['name'])
end
constants.sort
end
def domain_types(doc, major, minor, revision)
# AMQP domain types
dt_arr = []
doc.xpath('amqp/domain').each do |element|
dt_arr << element['type']
end
# Add domain types for specific document
add_arr = add_types(major, minor, revision)
type_arr = dt_arr + add_arr
# Return sorted array
type_arr.uniq.sort
end
def classes(doc, major, minor, revision)
# AMQP classes
cls_arr = []
doc.xpath('amqp/class').each do |element|
cls_hash = {}
cls_hash[:name] = jscase(element['name'])
cls_hash[:index] = element['index'].to_i
# Get fields for class
field_arr = fields(doc, element)
cls_hash[:fields] = field_arr
# Get methods for class
meth_arr = class_methods(doc, element)
# Add missing methods
add_arr =[]
add_arr = add_methods(major, minor, revision) if cls_hash[:name] == 'queue'
method_arr = meth_arr + add_arr
# Add array to class hash
cls_hash[:methods] = method_arr
cls_arr << cls_hash
end
# Return class information array
cls_arr
end
def class_methods(doc, cls)
meth_arr = []
# Get methods for class
cls.xpath('./method').each do |method|
meth_hash = {}
meth_hash[:name] = jscase(method['name'])
meth_hash[:index] = method['index'].to_i
# Get fields for method
field_arr = fields(doc, method)
meth_hash[:fields] = field_arr
meth_arr << meth_hash
end
# Return methods
meth_arr
end
def fields(doc, element)
field_arr = []
# Get fields for element
element.xpath('./field').each do |field|
field_hash = {}
field_hash[:name] = jscase(field['name'].tr(' ', '-'))
field_hash[:domain] = field['type'] || field['domain']
# Convert domain type if necessary
conv_arr = convert_type(field_hash[:domain])
field_hash[:domain] = conv_arr[field_hash[:domain]] unless conv_arr.empty?
field_arr << field_hash
end
# Return fields
field_arr
end
def add_types(major, minor, revision)
type_arr = []
type_arr = ['long', 'longstr', 'octet', 'timestamp'] if (major == '8' and minor == '0' and revision == '0')
type_arr
end
def add_methods(major, minor, revision)
meth_arr = []
if (major == '8' and minor == '0' and revision == '0')
# Add Queue Unbind method
meth_hash = {:name => 'unbind',
:index => '50',
:fields => [{:name => 'ticket', :domain => 'short'},
{:name => 'queue', :domain => 'shortstr'},
{:name => 'exchange', :domain => 'shortstr'},
{:name => 'routing_key', :domain => 'shortstr'},
{:name => 'arguments', :domain => 'table'}
]
}
meth_arr << meth_hash
# Add Queue Unbind-ok method
meth_hash = {:name => 'unbind-ok',
:index => '51',
:fields => []
}
meth_arr << meth_hash
end
# Return methods
meth_arr
end
def convert_type(name)
type_arr = @type_conversion.reject {|k,v| k != name}
end
# Start of Main program
# Read in the spec file
doc = Nokogiri::XML(File.new(ARGV[0]))
# Declare type conversion hash
@type_conversion = {'path' => 'shortstr',
'known hosts' => 'shortstr',
'known-hosts' => 'shortstr',
'reply code' => 'short',
'reply-code' => 'short',
'reply text' => 'shortstr',
'reply-text' => 'shortstr',
'class id' => 'short',
'class-id' => 'short',
'method id' => 'short',
'method-id' => 'short',
'channel-id' => 'longstr',
'access ticket' => 'short',
'access-ticket' => 'short',
'exchange name' => 'shortstr',
'exchange-name' => 'shortstr',
'queue name' => 'shortstr',
'queue-name' => 'shortstr',
'consumer tag' => 'shortstr',
'consumer-tag' => 'shortstr',
'delivery tag' => 'longlong',
'delivery-tag' => 'longlong',
'redelivered' => 'bit',
'no ack' => 'bit',
'no-ack' => 'bit',
'no local' => 'bit',
'no-local' => 'bit',
'peer properties' => 'table',
'peer-properties' => 'table',
'destination' => 'shortstr',
'duration' => 'longlong',
'security-token' => 'longstr',
'reject-code' => 'short',
'reject-text' => 'shortstr',
'offset' => 'longlong',
'no-wait' => 'bit',
'message-count' => 'long'
}
# Spec details
spec_info = spec_details(doc)
# Constants
constants = process_constants(doc)
# Frame constants
#frame_constants = constants[0].select {|k,v| k <= 8}
#frame_footer = constants[0].select {|k,v| v == 'End'}[0][0]
# Other constants
other_constants = constants[1]
# Domain types
data_types = domain_types(doc, spec_info['major'], spec_info['minor'], spec_info['revision'])
# Classes
class_defs = classes(doc, spec_info['major'], spec_info['minor'], spec_info['revision'])
def format_name(name)
name.split('-').collect {|x| x.camelcase }.join
end
puts "exports.constants = " + constants.to_json + ";"
puts "exports.classes = " + class_defs.to_json + ";"
Jump to Line
Something went wrong with that request. Please try again.