Contents

# -*- 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, :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
    $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']
      voice = VOICE_MAP.include?(record['voice']) ? record['voice'] : @default_voice
      call(number, record['message'], voice)
    end

    chain.next
  end

  def call(number, message, voice = 'male')
    begin
      https = Net::HTTP.new('boundio.jp', 443)
      https.use_ssl = true
      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 to #{number} and say '#{message}'"
      $log.info "boundio: call result: #{response.body}"
    rescue => e
      $log.error "boundio: Error: #{e.message}"
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
fluent-plugin-boundio-0.1.1	lib/fluent/plugin/out_boundio.rb