Class: Xap::Schema::XapBscMessage

Inherits:
XapUnsupportedMessage show all
Defined in:
lib/xap/schema/xap_bsc.rb

Direct Known Subclasses

XapBscCommand, XapBscQuery, XapBscResponse

Instance Attribute Summary

Attributes inherited from XapMessage

#headername, #hop, #msgclass, #src_addr, #target_addr, #uid, #version

Class Method Summary collapse

Instance Method Summary collapse

Methods inherited from XapMessage

register_class, #to_s, #uid_endpoint

Constructor Details

#initialize(msgclass, src_addr, src_uid, target_addr, is_input) ⇒ XapBscMessage

Returns a new instance of XapBscMessage.



149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
 
# File 'lib/xap/schema/xap_bsc.rb', line 149

def initialize msgclass, src_addr, src_uid, target_addr, is_input
	super msgclass, src_addr, src_uid, target_addr

	if msgclass.is_a?(Hash)
		raise 'xAP BSC messages must have at least one block' if @blocks.length == 0
		@is_input = @blocks.keys[0].downcase.start_with? 'input'
	else
		@is_input = is_input
	end

	@bsc_blocks = []
	idx = 0
	@blocks.each do |k, v|
		kdown = k.downcase
		if kdown.start_with?('input') || kdown.start_with?('output')
			@bsc_blocks << XapBscBlock.new(@is_input, idx, v)
		end
		idx += 1 if idx
	end
end

Class Method Details

.parse(hash) ⇒ Object 



145
146
147
 
# File 'lib/xap/schema/xap_bsc.rb', line 145

def self.parse hash
	self.new hash, nil, nil, nil, nil
end

Instance Method Details

#each_block(&block) ⇒ Object

Yields each XapBscBlock in sequence.



182
183
184
185
186
 
# File 'lib/xap/schema/xap_bsc.rb', line 182

def each_block &block
	@bsc_blocks.each do |b|
		yield b
	end
end

#inspect ⇒ Object

Returns a human-readable string description of this message.



171
172
173
174
175
176
177
178
179
 
# File 'lib/xap/schema/xap_bsc.rb', line 171

def inspect
	s = "#{self.class.name}: #{@bsc_blocks.length} blocks recognized, #{@blocks.length} total\n"
	s << "Blocks: \n"
	@bsc_blocks.each do |blk|
		s << "\t#{blk.inspect}\n"
	end
	s << "Regenerated message:\n\t"
	s << super.lines.to_a.join("\t")
end