class FreeswitchEventSocket DEFAULT_HOST = "127.0.0.1" DEFAULT_PORT = 8021 DEFAULT_PASSWORD = "ClueCon" DEFAULT_SOCKET_TIMEOUT = 20 @socket = nil def auth(password) self.command("auth #{password}") result = self.result() if result && result["Reply-Text"] == "+OK accepted" return true end return false end def connect(password = DEFAULT_PASSWORD, event_host = DEFAULT_HOST, event_port = DEFAULT_PORT) begin @socket = TCPSocket.open(event_host, event_port) rescue return false end if not @socket return false end result = self.result() if result && result["Content-Type"] == "auth/request" then if not self.auth(password) return false end end return true end def command(command) @socket.puts("#{command}\n\n") end def close() @socket.close end def read(read_bytes=1024) return @socket.recv(read_bytes) end def result() reply = self.read() if reply.class == String message = Hash.new() header, body = reply.split("\n\n", 2) if ! body.blank? message['_BODY'] = body end header.split("\n").each do |line| key, value = line.split(/\: */, 2) message[key] = value end return message end return nil end end class FreeswitchEvent def initialize(event_type) @event_type = event_type @event_header = Array.new() @event_body = nil @event_header.push("sendevent #{@event_type}") end def add_header(name, value) @event_header.push("#{name}: #{value}") end def add_body(body) @event_body = body end def fire() if @event_body && @event_body.length > 0 self.add_header("content-length", @event_body.length); end event = FreeswitchEventSocket.new() if event && event.connect() event.command(@event_header.join("\n")) event.command( @event_body) result = event.result() event.close() if result && result["Reply-Text"] == "+OK" return true end end return false end end class FreeswitchAPI def self.api_result(result) if not result return nil end if result['Content-Type'] == 'api/response' if result['_BODY'].blank? return nil elsif result['_BODY'] =~ /^\+OK/ return true elsif result['_BODY'] =~ /^\-ERR/ return false else return result['_BODY'] end end return nil end def self.api(command, *arguments) event = FreeswitchEventSocket.new() if event && event.connect() event.command("api #{command} #{arguments.join(' ')}") result = event.result() content_length = result['Content-Length'].to_i if content_length > 0 && result['_BODY'].blank? result['_BODY'] = event.read(content_length); end event.close() return result end end def self.execute(command, arguments, bgapi = false) event = FreeswitchEventSocket.new() if event && event.connect() api = bgapi ? 'bgapi' : 'api' event.command( "#{api} #{command} #{arguments}") result = event.result() if result && result["Content-Type"] == 'api/response' && result["_BODY"].blank? result = event.result() end event.close() if result if result.has_key?('Reply-Text') && result['Reply-Text'] =~ /^\+OK/ if result.has_key?('Job-UUID') && ! result['Job-UUID'].blank? return result['Job-UUID']; else return true; end elsif result.has_key?('_BODY') && result['_BODY'] =~ /^\+OK/ return true; end end end return false end def self.channel_variable_get(channel_uuid, variable_name) result = nil event = FreeswitchEventSocket.new() if event && event.connect() event.command( "api uuid_getvar #{channel_uuid} #{variable_name}") event_result = event.result() if event_result && event_result["Content-Type"] == 'api/response' && event_result["Content-Length"].to_i > 0 result = event.read(event_result["Content-Length"].to_i) end event.close() end return result end end