module Api::V1::InboxesHelper def inbox_name(channel) return channel.try(:bot_name) if channel.is_a?(Channel::Telegram) permitted_params[:name] end def validate_email_channel(attributes) channel_data = permitted_params(attributes)[:channel] validate_imap(channel_data) validate_smtp(channel_data) end private def validate_imap(channel_data) return unless channel_data.key?('imap_enabled') && channel_data[:imap_enabled] Mail.defaults do retriever_method :imap, { address: channel_data[:imap_address], port: channel_data[:imap_port], user_name: channel_data[:imap_login], password: channel_data[:imap_password], enable_ssl: channel_data[:imap_enable_ssl] } end check_imap_connection(channel_data) end def validate_smtp(channel_data) return unless channel_data.key?('smtp_enabled') && channel_data[:smtp_enabled] smtp = Net::SMTP.new(channel_data[:smtp_address], channel_data[:smtp_port]) set_smtp_encryption(channel_data, smtp) check_smtp_connection(channel_data, smtp) end def check_imap_connection(channel_data) Mail.connection {} # rubocop:disable:block rescue SocketError => e raise StandardError, I18n.t('errors.inboxes.imap.socket_error') rescue Net::IMAP::NoResponseError => e raise StandardError, I18n.t('errors.inboxes.imap.no_response_error') rescue Errno::EHOSTUNREACH => e raise StandardError, I18n.t('errors.inboxes.imap.host_unreachable_error') rescue Net::OpenTimeout => e raise StandardError, I18n.t('errors.inboxes.imap.connection_timed_out_error', address: channel_data[:imap_address], port: channel_data[:imap_port]) rescue Net::IMAP::Error => e raise StandardError, I18n.t('errors.inboxes.imap.connection_closed_error') rescue StandardError => e raise StandardError, e.message ensure Rails.logger.error e if e.present? end def check_smtp_connection(channel_data, smtp) smtp.start(channel_data[:smtp_domain], channel_data[:smtp_login], channel_data[:smtp_password], channel_data[:smtp_authentication]&.to_sym || :login) smtp.finish end def set_smtp_encryption(channel_data, smtp) if channel_data[:smtp_enable_ssl_tls] set_enable_tls(channel_data, smtp) elsif channel_data[:smtp_enable_starttls_auto] set_enable_starttls_auto(channel_data, smtp) end end def set_enable_starttls_auto(channel_data, smtp) return unless smtp.respond_to?(:enable_starttls_auto) if channel_data[:smtp_openssl_verify_mode] context = enable_openssl_mode(channel_data[:smtp_openssl_verify_mode]) smtp.enable_starttls_auto(context) else smtp.enable_starttls_auto end end def set_enable_tls(channel_data, smtp) return unless smtp.respond_to?(:enable_tls) if channel_data[:smtp_openssl_verify_mode] context = enable_openssl_mode(channel_data[:smtp_openssl_verify_mode]) smtp.enable_tls(context) else smtp.enable_tls end end def enable_openssl_mode(smtp_openssl_verify_mode) openssl_verify_mode = "OpenSSL::SSL::VERIFY_#{smtp_openssl_verify_mode.upcase}".constantize if smtp_openssl_verify_mode.is_a?(String) context = Net::SMTP.default_ssl_context context.verify_mode = openssl_verify_mode context end def account_channels_method { 'web_widget' => Current.account.web_widgets, 'api' => Current.account.api_channels, 'email' => Current.account.email_channels, 'line' => Current.account.line_channels, 'telegram' => Current.account.telegram_channels, 'whatsapp' => Current.account.whatsapp_channels, 'sms' => Current.account.sms_channels }[permitted_params[:channel][:type]] end def validate_limit return unless Current.account.inboxes.count >= Current.account.usage_limits[:inboxes] render_payment_required('Account limit exceeded. Upgrade to a higher plan') end end