123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282 |
- # Copyright (C) 2012-2016 Zammad Foundation, http://zammad-foundation.org/
- class ChannelsEmailController < ApplicationController
- prepend_before_action { authentication_check(permission: 'admin.channel_email') }
- def index
- system_online_service = Setting.get('system_online_service')
- account_channel_ids = []
- notification_channel_ids = []
- email_address_ids = []
- not_used_email_address_ids = []
- accounts_fixed = []
- assets = {}
- Channel.order(:id).each { |channel|
- if system_online_service && channel.preferences && channel.preferences['online_service_disable']
- email_addresses = EmailAddress.where(channel_id: channel.id)
- email_addresses.each { |email_address|
- accounts_fixed.push email_address
- }
- next
- end
- if channel.area == 'Email::Account'
- account_channel_ids.push channel.id
- assets = channel.assets(assets)
- elsif channel.area == 'Email::Notification' && channel.active
- notification_channel_ids.push channel.id
- assets = channel.assets(assets)
- end
- }
- EmailAddress.all.each { |email_address|
- next if system_online_service && email_address.preferences && email_address.preferences['online_service_disable']
- email_address_ids.push email_address.id
- assets = email_address.assets(assets)
- if !email_address.channel_id || !email_address.active || !Channel.find_by(id: email_address.channel_id)
- not_used_email_address_ids.push email_address.id
- end
- }
- render json: {
- accounts_fixed: accounts_fixed,
- assets: assets,
- account_channel_ids: account_channel_ids,
- notification_channel_ids: notification_channel_ids,
- email_address_ids: email_address_ids,
- not_used_email_address_ids: not_used_email_address_ids,
- channel_driver: {
- email: EmailHelper.available_driver,
- },
- config: {
- notification_sender: Setting.get('notification_sender'),
- }
- }
- end
- def probe
- # probe settings based on email and password
- result = EmailHelper::Probe.full(
- email: params[:email],
- password: params[:password],
- folder: params[:folder],
- )
- # verify if user+host already exists
- if result[:result] == 'ok'
- return if account_duplicate?(result)
- end
- render json: result
- end
- def outbound
- # verify access
- return if params[:channel_id] && !check_access(params[:channel_id])
- # connection test
- render json: EmailHelper::Probe.outbound(params, params[:email])
- end
- def inbound
- # verify access
- return if params[:channel_id] && !check_access(params[:channel_id])
- # connection test
- result = EmailHelper::Probe.inbound(params)
- # check account duplicate
- return if account_duplicate?({ setting: { inbound: params } }, params[:channel_id])
- render json: result
- end
- def verify
- email = params[:email] || params[:meta][:email]
- email = email.downcase
- channel_id = params[:channel_id]
- # verify access
- return if channel_id && !check_access(channel_id)
- # check account duplicate
- return if account_duplicate?({ setting: { inbound: params[:inbound] } }, channel_id)
- # check delivery for 30 sek.
- result = EmailHelper::Verify.email(
- outbound: params[:outbound],
- inbound: params[:inbound],
- sender: email,
- subject: params[:subject],
- )
- if result[:result] != 'ok'
- render json: result
- return
- end
- # fallback
- if !params[:group_id]
- params[:group_id] = Group.first.id
- end
- # update account
- if channel_id
- channel = Channel.find(channel_id)
- channel.update_attributes(
- options: {
- inbound: params[:inbound],
- outbound: params[:outbound],
- },
- group_id: params[:group_id],
- last_log_in: nil,
- last_log_out: nil,
- status_in: 'ok',
- status_out: 'ok',
- )
- render json: result
- return
- end
- # create new account
- channel = Channel.create(
- area: 'Email::Account',
- options: {
- inbound: params[:inbound],
- outbound: params[:outbound],
- },
- group_id: params[:group_id],
- last_log_in: nil,
- last_log_out: nil,
- status_in: 'ok',
- status_out: 'ok',
- active: true,
- )
- # remember address && set channel for email address
- address = EmailAddress.find_by(email: email)
- # if we are on initial setup, use already exisiting dummy email address
- if Channel.count == 1
- address = EmailAddress.first
- end
- if address
- address.update_attributes(
- realname: params[:meta][:realname],
- email: email,
- active: true,
- channel_id: channel.id,
- )
- else
- address = EmailAddress.create(
- realname: params[:meta][:realname],
- email: email,
- active: true,
- channel_id: channel.id,
- )
- end
- render json: result
- end
- def enable
- channel = Channel.find_by(id: params[:id], area: 'Email::Account')
- channel.active = true
- channel.save!
- render json: {}
- end
- def disable
- channel = Channel.find_by(id: params[:id], area: 'Email::Account')
- channel.active = false
- channel.save!
- render json: {}
- end
- def destroy
- channel = Channel.find_by(id: params[:id], area: 'Email::Account')
- channel.destroy
- render json: {}
- end
- def group
- check_access
- channel = Channel.find_by(id: params[:id], area: 'Email::Account')
- channel.group_id = params[:group_id]
- channel.save!
- render json: {}
- end
- def notification
- check_online_service
- adapter = params[:adapter].downcase
- email = Setting.get('notification_sender')
- # connection test
- result = EmailHelper::Probe.outbound(params, email)
- # save settings
- if result[:result] == 'ok'
- Channel.where(area: 'Email::Notification').each { |channel|
- active = false
- if adapter =~ /^#{channel.options[:outbound][:adapter]}$/i
- active = true
- channel.options = {
- outbound: {
- adapter: adapter,
- options: params[:options],
- },
- }
- channel.status_out = 'ok'
- channel.last_log_out = nil
- end
- channel.active = active
- channel.save
- }
- end
- render json: result
- end
- private
- def account_duplicate?(result, channel_id = nil)
- Channel.where(area: 'Email::Account').each { |channel|
- next if !channel.options
- next if !channel.options[:inbound]
- next if !channel.options[:inbound][:adapter]
- next if channel.options[:inbound][:adapter] != result[:setting][:inbound][:adapter]
- next if channel.options[:inbound][:options][:host] != result[:setting][:inbound][:options][:host]
- next if channel.options[:inbound][:options][:user] != result[:setting][:inbound][:options][:user]
- next if channel.id.to_s == channel_id.to_s
- render json: {
- result: 'duplicate',
- message: 'Account already exists!',
- }
- return true
- }
- false
- end
- def check_online_service
- return true if !Setting.get('system_online_service')
- raise Exceptions::NotAuthorized
- end
- def check_access(id = nil)
- if !id
- id = params[:id]
- end
- return true if !Setting.get('system_online_service')
- channel = Channel.find(id)
- return true if channel.preferences && !channel.preferences[:online_service_disable]
- raise Exceptions::NotAuthorized
- end
- end
|