Class: RPC::Clients::Socket

Inherits:

Object

• Object
• RPC::Clients::Socket

show all

Defined in:

lib/rpc/lib/rpc/clients/socket.rb

Instance Method Summary (collapse)

• - (Boolean) async?
• - (Object) connect
• - (Object) disconnect
• - (Socket) initialize(uri) constructor

  A new instance of Socket.

• - (Object) run(&block)
• - (Object) send(data)

  TODO: support for notifications, probably refactor send to: def send(encoder, data).

9
10
11
12
13
14

# File 'lib/rpc/lib/rpc/clients/socket.rb', line 9

def initialize(uri)
  @uri = URI.parse(uri)

  # Localhost doesn't work for me for some reason.
  @uri.host = "127.0.0.1" if @uri.host.eql?("localhost")
end

45
46
47

# File 'lib/rpc/lib/rpc/clients/socket.rb', line 45

def async?
  false
end

16
17
18
19
20

# File 'lib/rpc/lib/rpc/clients/socket.rb', line 16

def connect
  @client = TCPSocket.new(@uri.host, @uri.port)
rescue Errno::ECONNREFUSED
  raise Errno::ECONNREFUSED.new("You have to start the server first!")
end

22
23
24

# File 'lib/rpc/lib/rpc/clients/socket.rb', line 22

def disconnect
  @client.close
end

26
27
28
29
30

# File 'lib/rpc/lib/rpc/clients/socket.rb', line 26

def run(&block)
  self.connect
  block.call
  self.disconnect
end

binary = encoder.encode(data)
@client.puts(binary)
@client.readline if data[:id]

39
40
41
42
43

# File 'lib/rpc/lib/rpc/clients/socket.rb', line 39

def send(data)
  @client.puts(data)
  @client.readline
  # TODO: sync vs. async: @socket.read or a callback and a loop
end