2012-04-13 16:42:25 +00:00
|
|
|
require 'net/pop'
|
2012-04-10 14:06:46 +00:00
|
|
|
|
2012-04-13 16:42:25 +00:00
|
|
|
class Channel::POP3 < Channel::EmailParser
|
|
|
|
include UserInfo
|
2012-04-10 14:06:46 +00:00
|
|
|
|
2012-04-13 16:42:25 +00:00
|
|
|
def fetch (channel)
|
2012-04-13 17:06:09 +00:00
|
|
|
puts "fetching pop3 (#{channel[:options][:host]}/#{channel[:options][:user]})"
|
2012-04-13 16:42:25 +00:00
|
|
|
|
|
|
|
pop = Net::POP3.new( channel[:options][:host], 995 )
|
|
|
|
pop.enable_ssl
|
|
|
|
pop.start( channel[:options][:user], channel[:options][:password] )
|
2012-04-13 17:06:09 +00:00
|
|
|
count = 0
|
|
|
|
count_all = pop.mails.size
|
2012-04-13 16:42:25 +00:00
|
|
|
pop.each_mail do |m|
|
2012-04-13 17:06:09 +00:00
|
|
|
count += 1
|
|
|
|
puts " - message #{count.to_s}/#{count_all.to_s}"
|
|
|
|
|
2012-04-13 16:42:25 +00:00
|
|
|
# delete email from server after article was created
|
2012-05-04 11:33:05 +00:00
|
|
|
if process(channel, m.pop)
|
2012-04-13 16:42:25 +00:00
|
|
|
m.delete
|
|
|
|
end
|
|
|
|
end
|
|
|
|
pop.finish
|
2012-04-13 17:06:09 +00:00
|
|
|
if count == 0
|
|
|
|
puts " - no message"
|
|
|
|
end
|
|
|
|
puts "done"
|
2012-04-13 16:42:25 +00:00
|
|
|
end
|
|
|
|
def send(attr, notification = false)
|
|
|
|
channel = Channel.where( :area => 'Email::Outbound', :active => true ).first
|
|
|
|
begin
|
|
|
|
c = eval 'Channel::' + channel[:adapter] + '.new'
|
|
|
|
c.send(attr, channel, notification)
|
|
|
|
rescue Exception => e
|
|
|
|
puts "can't use " + 'Channel::' + channel[:adapter]
|
|
|
|
puts e.inspect
|
2012-04-10 14:06:46 +00:00
|
|
|
end
|
|
|
|
end
|
2012-04-13 16:42:25 +00:00
|
|
|
end
|