lib/fluent/plugin/out_boundio.rb in fluent-plugin-boundio-0.0.2 vs lib/fluent/plugin/out_boundio.rb in fluent-plugin-boundio-0.1.1

@@ -1,48 +1,54 @@
 # -*- coding: utf-8 -*-
 class Fluent::BoundioOutput < Fluent::Output
   Fluent::Plugin.register_output('boundio', self)
 
+  VOICE_MAP = {'female' => 0, 'male' => 1}
+
   config_param :user_serial_id, :string
   config_param :user_key, :string, :default => nil # Optional at this time
   config_param :api_key, :string
-  config_param :default_number, :string
+  config_param :default_number, :string, :default => nil
+  config_param :default_voice, :string, :default => 'male'
   config_param :developer_tool, :string, :default => 'no'
 
   def initialize
     super
-
     require 'uri'
     require 'net/https'
   end
 
   def configure(conf)
     super
+    unless VOICE_MAP.include?(@default_voice)
+      raise Fluent::ConfigError, "boundio: invalid value for default_voice(male/female): #{@default_voice}"
+    end
     @developer_tool = Fluent::Config.bool_value(@developer_tool) || false
-    @voice_type = 1
+    $log.info "boundio: using developer tool api" if @developer_tool
   end
 
   def emit(tag, es, chain)
     es.each do |time,record|
       number = record['number'].nil? ? @default_number : record['number']
-      call(number, record['message'])
+      voice = VOICE_MAP.include?(record['voice']) ? record['voice'] : @default_voice
+      call(number, record['message'], voice)
     end
 
     chain.next
   end
 
-  def call(number, message)
+  def call(number, message, voice = 'male')
     begin
       https = Net::HTTP.new('boundio.jp', 443)
       https.use_ssl = true
-      cast = "file_d(#{message}, #{@voice_type})"
-      query = 'key=' + @api_key + '&tel_to=' + number + '&cast=' + cast
+      cast = "file_d(#{message}, #{VOICE_MAP[voice]})"
+      query = 'key=' + @api_key + '&tel_to=' + number.gsub('-','') + '&cast=' + cast
       path = @developer_tool ? '/api/vd2/' : '/api/v2/'
       response = https.post(path + @user_serial_id + '/call', URI.escape(query))
-      $log.info "boundio makeing a call: #{path} #{message} "
-      $log.info "boundio call result: #{response.body}"
+      $log.info "boundio: makeing a call to #{number} and say '#{message}'"
+      $log.info "boundio: call result: #{response.body}"
     rescue => e
-      $log.error("Boundio Error: #{e.message}")
+      $log.error "boundio: Error: #{e.message}"
     end
   end
 end