From 56bf23a88b1397d8648a18a32770b32c084aa017 Mon Sep 17 00:00:00 2001 From: Peter Kozak Date: Wed, 13 Mar 2013 06:49:01 -0400 Subject: api methods added --- lib/freeswitch_event.rb | 35 ++++++++++++++++++++++++++++++++++- 1 file changed, 34 insertions(+), 1 deletion(-) (limited to 'lib/freeswitch_event.rb') diff --git a/lib/freeswitch_event.rb b/lib/freeswitch_event.rb index 68d9df2..6745bef 100644 --- a/lib/freeswitch_event.rb +++ b/lib/freeswitch_event.rb @@ -103,8 +103,41 @@ class FreeswitchEvent end class FreeswitchAPI - def self.execute(command, arguments, bgapi = false) + 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' -- cgit v1.2.3 From 98bfa93ef9a9383a6c0585a081178bb45f6a4097 Mon Sep 17 00:00:00 2001 From: Peter Kozak Date: Wed, 13 Mar 2013 10:04:38 -0400 Subject: read chunks --- lib/freeswitch_event.rb | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) (limited to 'lib/freeswitch_event.rb') diff --git a/lib/freeswitch_event.rb b/lib/freeswitch_event.rb index 6745bef..5f961be 100644 --- a/lib/freeswitch_event.rb +++ b/lib/freeswitch_event.rb @@ -129,8 +129,12 @@ class FreeswitchAPI 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); + while content_length > result['_BODY'].to_s.length + body = event.read(content_length - result['_BODY'].to_s.length) + if body.blank? + break + end + result['_BODY'] = result['_BODY'].to_s + body; end event.close() return result -- cgit v1.2.3 From a14a948cce2380ecf5d15d92dad2324ea8d24c65 Mon Sep 17 00:00:00 2001 From: Peter Kozak Date: Thu, 14 Mar 2013 00:08:51 -0400 Subject: use GsParameter --- lib/freeswitch_event.rb | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) (limited to 'lib/freeswitch_event.rb') diff --git a/lib/freeswitch_event.rb b/lib/freeswitch_event.rb index 5f961be..89d8ea0 100644 --- a/lib/freeswitch_event.rb +++ b/lib/freeswitch_event.rb @@ -15,7 +15,11 @@ class FreeswitchEventSocket return false end - def connect(password = DEFAULT_PASSWORD, event_host = DEFAULT_HOST, event_port = DEFAULT_PORT) + def connect(password = nil, event_host = nil, event_port = nil) + event_host = event_host || GsParameter.get('host', 'event_socket', 'client') || GsParameter.get('listen-ip', 'event_socket', 'settings') || DEFAULT_HOST + event_port = event_port || GsParameter.get('port', 'event_socket', 'client') || GsParameter.get('listen-port', 'event_socket', 'settings') || DEFAULT_PORT + password = password || GsParameter.get('password', 'event_socket', 'client') || GsParameter.get('password', 'event_socket', 'settings') || DEFAULT_PASSWORD + begin @socket = TCPSocket.open(event_host, event_port) rescue -- cgit v1.2.3