Class: Msf::Aggregator::ServerProxy

Inherits:
Service
  • Object
show all
Defined in:
lib/msf/aggregator.rb

Instance Method Summary collapse

Constructor Details

#initialize(host, port) ⇒ ServerProxy

Returns a new instance of ServerProxy.



69
70
71
72
73
 
# File 'lib/msf/aggregator.rb', line 69

def initialize(host, port)
  @host = host
  @port = port
  @client = MessagePack::RPC::Client.new(@host, @port)
end

Instance Method Details

#add_cable(type, host, port, certificate = nil) ⇒ Object 



106
107
108
109
110
 
# File 'lib/msf/aggregator.rb', line 106

def add_cable(type, host, port, certificate = nil)
  @client.call(:add_cable, type, host, port, certificate)
rescue MessagePack::RPC::TimeoutError => e
  Logger.log(e.to_s)
end

#available? ⇒ Boolean

Returns:

  • (Boolean) 


75
76
77
78
79
 
# File 'lib/msf/aggregator.rb', line 75

def available?
  @client.call(:available?)
rescue MessagePack::RPC::ConnectionTimeoutError => e
  false
end

#available_addresses ⇒ Object 



124
125
126
127
128
 
# File 'lib/msf/aggregator.rb', line 124

def available_addresses
  @client.call(:available_addresses)
rescue MessagePack::RPC::TimeoutError => e
  Logger.log(e.to_s)
end

#cables ⇒ Object 



87
88
89
90
91
 
# File 'lib/msf/aggregator.rb', line 87

def cables
  @client.call(:cables)
rescue MessagePack::RPC::TimeoutError => e
  Logger.log(e.to_s)
end

#obtain_session(payload, lhost, lport) ⇒ Object 



94
95
96
97
98
 
# File 'lib/msf/aggregator.rb', line 94

def obtain_session(payload, lhost, lport)
  @client.call(:obtain_session, payload, lhost, lport)
rescue MessagePack::RPC::TimeoutError => e
  Logger.log(e.to_s)
end

#register_default(lhost, lport, payload_list) ⇒ Object 



118
119
120
121
122
 
# File 'lib/msf/aggregator.rb', line 118

def register_default(lhost, lport, payload_list)
  @client.call(:register_default, lhost, lport, payload_list)
rescue MessagePack::RPC::TimeoutError => e
  Logger.log(e.to_s)
end

#release_session(payload) ⇒ Object 



100
101
102
103
104
 
# File 'lib/msf/aggregator.rb', line 100

def release_session(payload)
  @client.call(:release_session, payload)
rescue MessagePack::RPC::TimeoutError => e
  Logger.log(e.to_s)
end

#remove_cable(host, port) ⇒ Object 



112
113
114
115
116
 
# File 'lib/msf/aggregator.rb', line 112

def remove_cable(host, port)
  @client.call(:remove_cable, host, port)
rescue MessagePack::RPC::TimeoutError => e
  Logger.log(e.to_s)
end

#sessions ⇒ Object 



81
82
83
84
85
 
# File 'lib/msf/aggregator.rb', line 81

def sessions
  @client.call(:sessions)
rescue MessagePack::RPC::TimeoutError => e
  Logger.log(e.to_s)
end

#stop ⇒ Object 



130
131
132
 
# File 'lib/msf/aggregator.rb', line 130

def stop
  @client.close
end