GitHub-Mirror/huginn
2
0
Fork 0
mirror of https://github.com/Fishwaldo/huginn.git synced 2025-03-17 12:21:31 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Indentation

Browse source
This commit is contained in:
Rishabh Jain 2013-05-04 23:28:46 +05:30
parent bd11e43dbc
commit abd2d39269
1 changed files with 37 additions and 37 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

74
app/models/agents/twilio_agent.rb
View file

@ -2,48 +2,48 @@ require 'rubygems'
require 'twilio-ruby'
module Agents
class TwilioAgent < Agent
class TwilioAgent < Agent
default_schedule "every_10m"
default_schedule "every_10m"
description <<-MD
The TwilioAgent collects any events sent to it and send them via text message.
Add more info
MD
description <<-MD
The TwilioAgent collects any events sent to it and send them via text message.
Add more info
MD
def default_options
{
:account_sid => "ACxxxxxxxxxxxxxxxxxxxxxxxxxxxxx",
:auth_token => "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx",
:senderscell => "xxxxxxxxxx",
:receiverscell => "xxxxxxxxxx",
:expected_receive_period_in_days => "x"
}
end
def default_options
{
:account_sid => "ACxxxxxxxxxxxxxxxxxxxxxxxxxxxxx",
:auth_token => "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx",
:senderscell => "xxxxxxxxxx",
:receiverscell => "xxxxxxxxxx",
:expected_receive_period_in_days => "x"
}
end
def validate_options
errors.add(:base, "account_sid,auth_token,senderscell,receiverscell are all required") unless options[:account_sid].present? && options[:auth_token].present? && options[:senderscell].present? && options[:receiverscell].present? && options[:expected_receive_period_in_days].present?
end
def validate_options
errors.add(:base, "account_sid,auth_token,senderscell,receiverscell are all required") unless options[:account_sid].present? && options[:auth_token].present? && options[:senderscell].present? && options[:receiverscell].present? && options[:expected_receive_period_in_days].present?
end
def receive(incoming_events)
incoming_events.each do |event|
self.memory[:queue] ||= [] # If memory[:queue] is not true, assign [] to it, a || a = b
self.memory[:queue] << event.payload # Append
end
end
def receive(incoming_events)
incoming_events.each do |event|
self.memory[:queue] ||= [] # If memory[:queue] is not true, assign [] to it, a || a = b
self.memory[:queue] << event.payload # Append
end
end
def working?
last_receive_at && last_receive_at > options[:expected_receive_period_in_days].to_i.days.ago
end
def working?
last_receive_at && last_receive_at > options[:expected_receive_period_in_days].to_i.days.ago
end
def check
if self.memory[:queue] && self.memory[:queue].length > 0
@client = Twilio::REST::Client.new options[:account_sid],options[:auth_token]
self.memory[:queue].each do |text|
@client.account.sms.messages.create(:from=>options[:senderscell],:to=>options[:receiverscell],:body=>"#{text[:message]}")
end
self.memory[:queue] = []
end
end
end
def check
if self.memory[:queue] && self.memory[:queue].length > 0
@client = Twilio::REST::Client.new options[:account_sid],options[:auth_token]
self.memory[:queue].each do |text|
@client.account.sms.messages.create(:from=>options[:senderscell],:to=>options[:receiverscell],:body=>"#{text[:message]}")
end
self.memory[:queue] = []
end
end
end
end