2014-02-03 19:23:00 +00:00
|
|
|
# Copyright (C) 2012-2014 Zammad Foundation, http://zammad-foundation.org/
|
2013-06-12 15:59:58 +00:00
|
|
|
|
2012-09-20 12:08:02 +00:00
|
|
|
class Channel < ApplicationModel
|
2012-04-13 13:51:10 +00:00
|
|
|
store :options
|
2015-08-29 11:46:48 +00:00
|
|
|
store :preferences
|
2012-04-13 13:51:10 +00:00
|
|
|
|
2015-08-28 08:19:27 +00:00
|
|
|
after_create :email_address_check
|
|
|
|
after_update :email_address_check
|
|
|
|
after_destroy :email_address_check
|
|
|
|
|
2015-08-28 00:53:14 +00:00
|
|
|
=begin
|
|
|
|
|
|
|
|
fetch all accounts
|
|
|
|
|
|
|
|
Channel.fetch
|
|
|
|
|
|
|
|
=end
|
|
|
|
|
2012-04-10 14:06:46 +00:00
|
|
|
def self.fetch
|
2015-08-28 00:53:14 +00:00
|
|
|
channels = Channel.where('active = ? AND area LIKE ?', true, '%::Account')
|
|
|
|
channels.each(&:fetch)
|
2012-04-10 14:06:46 +00:00
|
|
|
end
|
2015-08-28 00:53:14 +00:00
|
|
|
|
|
|
|
=begin
|
|
|
|
|
|
|
|
fetch one account
|
|
|
|
|
|
|
|
channel = Channel.where(area: 'Email::Account').first
|
|
|
|
channel.fetch
|
|
|
|
|
|
|
|
=end
|
|
|
|
|
|
|
|
def fetch
|
|
|
|
|
|
|
|
adapter = options[:adapter]
|
|
|
|
adapter_options = options
|
|
|
|
if options[:options]
|
|
|
|
adapter_options = options[:options]
|
|
|
|
elsif options[:inbound] && options[:inbound][:adapter]
|
|
|
|
adapter = options[:inbound][:adapter]
|
|
|
|
adapter_options = options[:inbound][:options]
|
|
|
|
end
|
|
|
|
|
|
|
|
begin
|
|
|
|
|
|
|
|
# we need to require each channel backend individually otherwise we get a
|
|
|
|
# 'warning: toplevel constant Twitter referenced by Channel::Driver::Twitter' error e.g.
|
|
|
|
# so we have to convert the channel name to the filename via Rails String.underscore
|
|
|
|
# http://stem.ps/rails/2015/01/25/ruby-gotcha-toplevel-constant-referenced-by.html
|
|
|
|
require "channel/driver/#{adapter.to_filename}"
|
|
|
|
|
|
|
|
driver_class = Object.const_get("Channel::Driver::#{adapter.to_classname}")
|
|
|
|
driver_instance = driver_class.new
|
|
|
|
driver_instance.fetch(adapter_options, self)
|
|
|
|
self.status_in = 'ok'
|
|
|
|
self.last_log_in = ''
|
|
|
|
save
|
|
|
|
rescue => e
|
|
|
|
error = "Can't use Channel::Driver::#{adapter.to_classname}: #{e.inspect}"
|
|
|
|
logger.error error
|
|
|
|
logger.error e.backtrace
|
|
|
|
self.status_in = 'error'
|
|
|
|
self.last_log_in = error
|
|
|
|
save
|
|
|
|
end
|
|
|
|
|
|
|
|
end
|
|
|
|
|
|
|
|
=begin
|
|
|
|
|
|
|
|
send via account
|
|
|
|
|
|
|
|
channel = Channel.where(area: 'Email::Account').first
|
|
|
|
channel.deliver(mail_params, notification)
|
|
|
|
|
|
|
|
=end
|
|
|
|
|
|
|
|
def deliver(mail_params, notification = false)
|
|
|
|
|
|
|
|
adapter = options[:adapter]
|
|
|
|
adapter_options = options
|
|
|
|
if options[:options]
|
|
|
|
adapter_options = options[:options]
|
|
|
|
elsif options[:outbound] && options[:outbound][:adapter]
|
|
|
|
adapter = options[:outbound][:adapter]
|
|
|
|
adapter_options = options[:outbound][:options]
|
|
|
|
end
|
|
|
|
|
2015-08-28 01:08:55 +00:00
|
|
|
result = nil
|
|
|
|
|
2015-08-28 00:53:14 +00:00
|
|
|
begin
|
|
|
|
|
|
|
|
# we need to require each channel backend individually otherwise we get a
|
|
|
|
# 'warning: toplevel constant Twitter referenced by Channel::Driver::Twitter' error e.g.
|
|
|
|
# so we have to convert the channel name to the filename via Rails String.underscore
|
|
|
|
# http://stem.ps/rails/2015/01/25/ruby-gotcha-toplevel-constant-referenced-by.html
|
|
|
|
require "channel/driver/#{adapter.to_filename}"
|
|
|
|
|
|
|
|
driver_class = Object.const_get("Channel::Driver::#{adapter.to_classname}")
|
|
|
|
driver_instance = driver_class.new
|
2015-08-28 01:08:55 +00:00
|
|
|
result = driver_instance.send(adapter_options, mail_params, notification)
|
2015-08-28 00:53:14 +00:00
|
|
|
self.status_out = 'ok'
|
|
|
|
self.last_log_out = ''
|
|
|
|
save
|
|
|
|
rescue => e
|
|
|
|
error = "Can't use Channel::Driver::#{adapter.to_classname}: #{e.inspect}"
|
|
|
|
logger.error error
|
|
|
|
logger.error e.backtrace
|
|
|
|
self.status_out = 'error'
|
|
|
|
self.last_log_out = error
|
|
|
|
save
|
|
|
|
end
|
2015-08-28 01:08:55 +00:00
|
|
|
result
|
2015-08-28 00:53:14 +00:00
|
|
|
end
|
|
|
|
|
2015-08-28 08:19:27 +00:00
|
|
|
private
|
|
|
|
|
|
|
|
def email_address_check
|
|
|
|
|
|
|
|
# reset non existing channel_ids
|
|
|
|
EmailAddress.channel_cleanup
|
|
|
|
end
|
|
|
|
|
2013-06-12 15:59:58 +00:00
|
|
|
end
|