Class: UDPRest::Client

Inherits:
Object
  • Object
show all
Defined in:
lib/udp_rest.rb

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(host, port) ⇒ Client

Returns a new instance of Client.



99
100
101
102
103
104
105
106
 
# File 'lib/udp_rest.rb', line 99

def initialize(host, port)
	@max_packet_size = 512

	self.host = host
	self.port = port
	self.socket = UDPSocket.new
	self.timeout = 5.0
end

Instance Attribute Details

#host ⇒ Object

Returns the value of attribute host.



94
95
96
 
# File 'lib/udp_rest.rb', line 94

def host
  @host
end

#port ⇒ Object

Returns the value of attribute port.



95
96
97
 
# File 'lib/udp_rest.rb', line 95

def port
  @port
end

#socket ⇒ Object

Returns the value of attribute socket.



96
97
98
 
# File 'lib/udp_rest.rb', line 96

def socket
  @socket
end

#timeout ⇒ Object

Returns the value of attribute timeout.



97
98
99
 
# File 'lib/udp_rest.rb', line 97

def timeout
  @timeout
end

Class Method Details

.get(url) ⇒ Object 



134
135
136
 
# File 'lib/udp_rest.rb', line 134

def self.get(url)
	self.uhttp('GET', url)
end

.uhttp(req_method, url) ⇒ Object 



121
122
123
124
125
126
127
128
129
130
131
132
 
# File 'lib/udp_rest.rb', line 121

def self.uhttp(req_method, url)
	uri = URI(url)
	client = self.new(uri.host, uri.port || 80)
	
	req = UHTTPRequest.new
	req.req_method = req_method
	req.path = uri.path
	req.query = uri.query

	packet = client.send_text(req.to_s)
	UHTTPResponse.parse(packet.text)
end

Instance Method Details

#send_text(text) ⇒ Object 



108
109
110
111
112
113
114
115
116
117
118
119
 
# File 'lib/udp_rest.rb', line 108

def send_text(text)
	thread = WorkerThread.new.start :timeout => self.timeout do
		self.socket.send(text, 0, self.host, self.port)
		response_data = self.socket.recvfrom(@max_packet_size)
		UDPPacket.new(response_data)
	end

	thread.join
	packet = thread.value
	raise "Request Timeout (#{host}:#{port})" if packet.nil?
	return packet
end