مراية لـ
https://github.com/postalserver/postal.git
تم المزامنة 2026-01-18 05:49:47 +00:00
ensure that we only try to log exceptions when raven is available
هذا الالتزام موجود في:
@@ -417,7 +417,9 @@ class UnqueueMessageJob < Postal::Job
|
|||||||
e.backtrace.each { |e| log("#{log_prefix} #{e}") }
|
e.backtrace.each { |e| log("#{log_prefix} #{e}") }
|
||||||
queued_message.retry_later
|
queued_message.retry_later
|
||||||
log "#{log_prefix} Queued message was unlocked"
|
log "#{log_prefix} Queued message was unlocked"
|
||||||
Raven.capture_exception(e, :extra => {:job_id => self.id, :server_id => queued_message.server_id, :message_id => queued_message.message_id})
|
if defined?(Raven)
|
||||||
|
Raven.capture_exception(e, :extra => {:job_id => self.id, :server_id => queued_message.server_id, :message_id => queued_message.message_id})
|
||||||
|
end
|
||||||
if queued_message.message
|
if queued_message.message
|
||||||
queued_message.message.create_delivery("Error", :details => "An internal error occurred while sending this message. This message will be retried automatically. This this persists, contact support for assistance.", :output => "#{e.class}: #{e.message}", :log_id => "J-#{self.id}")
|
queued_message.message.create_delivery("Error", :details => "An internal error occurred while sending this message. This message will be retried automatically. This this persists, contact support for assistance.", :output => "#{e.class}: #{e.message}", :log_id => "J-#{self.id}")
|
||||||
end
|
end
|
||||||
|
|||||||
@@ -27,7 +27,9 @@ module Postal
|
|||||||
n.notify!(:short_message => message_without_ansi, :log_name => @log_name, :facility => 'postal', :application_name => 'postal', :process_name => ENV['PROC_NAME'], :pid => Process.pid)
|
n.notify!(:short_message => message_without_ansi, :log_name => @log_name, :facility => 'postal', :application_name => 'postal', :process_name => ENV['PROC_NAME'], :pid => Process.pid)
|
||||||
rescue => e
|
rescue => e
|
||||||
# Can't log this to GELF. Soz.
|
# Can't log this to GELF. Soz.
|
||||||
Raven.capture_exception(e)
|
if defined?(Raven)
|
||||||
|
Raven.capture_exception(e)
|
||||||
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
true
|
true
|
||||||
|
|||||||
@@ -108,7 +108,9 @@ module Postal
|
|||||||
rescue BadRequest
|
rescue BadRequest
|
||||||
# We couldn't read a proper HTTP request, disconnect the client
|
# We couldn't read a proper HTTP request, disconnect the client
|
||||||
rescue => e
|
rescue => e
|
||||||
Raven.capture_exception(e)
|
if defined?(Raven)
|
||||||
|
Raven.capture_exception(e)
|
||||||
|
end
|
||||||
ensure
|
ensure
|
||||||
@socket.close rescue nil
|
@socket.close rescue nil
|
||||||
@raw_socket.close rescue nil
|
@raw_socket.close rescue nil
|
||||||
|
|||||||
@@ -37,7 +37,9 @@ module Postal
|
|||||||
rescue => e
|
rescue => e
|
||||||
# Somethign else went wrong. We don't want to stop the image loading though because
|
# Somethign else went wrong. We don't want to stop the image loading though because
|
||||||
# this is our problem. Log this exception though.
|
# this is our problem. Log this exception though.
|
||||||
Raven.capture_exception(e)
|
if defined?(Raven)
|
||||||
|
Raven.capture_exception(e)
|
||||||
|
end
|
||||||
end
|
end
|
||||||
source_image = request.params['src']
|
source_image = request.params['src']
|
||||||
if source_image.nil?
|
if source_image.nil?
|
||||||
|
|||||||
@@ -25,7 +25,9 @@ module Postal
|
|||||||
rescue IO::WaitReadable, Errno::EINTR
|
rescue IO::WaitReadable, Errno::EINTR
|
||||||
# Never mind, guess the client went away
|
# Never mind, guess the client went away
|
||||||
rescue => e
|
rescue => e
|
||||||
Raven.capture_exception(e)
|
if defined?(Raven)
|
||||||
|
Raven.capture_exception(e)
|
||||||
|
end
|
||||||
client_io.close rescue nil
|
client_io.close rescue nil
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|||||||
@@ -51,7 +51,9 @@ module Postal
|
|||||||
if Rails.env.development?
|
if Rails.env.development?
|
||||||
raise
|
raise
|
||||||
else
|
else
|
||||||
Raven.capture_exception(e)
|
if defined?(Raven)
|
||||||
|
Raven.capture_exception(e)
|
||||||
|
end
|
||||||
@actioned = false
|
@actioned = false
|
||||||
@tracked_links = 0
|
@tracked_links = 0
|
||||||
@tracked_images = 0
|
@tracked_images = 0
|
||||||
|
|||||||
@@ -170,7 +170,9 @@ module Postal
|
|||||||
safe_rset
|
safe_rset
|
||||||
rescue => e
|
rescue => e
|
||||||
log "#{e.class}: #{e.message}"
|
log "#{e.class}: #{e.message}"
|
||||||
Raven.capture_exception(e, :extra => {:log_id => @log_id, :server_id => message.server.id, :message_id => message.id})
|
if defined?(Raven)
|
||||||
|
Raven.capture_exception(e, :extra => {:log_id => @log_id, :server_id => message.server.id, :message_id => message.id})
|
||||||
|
end
|
||||||
result.type = 'SoftFail'
|
result.type = 'SoftFail'
|
||||||
result.retry = true
|
result.retry = true
|
||||||
result.details = "An error occurred while sending the message to #{destination_host_description}"
|
result.details = "An error occurred while sending the message to #{destination_host_description}"
|
||||||
|
|||||||
@@ -115,7 +115,9 @@ module Postal
|
|||||||
clients[new_io] = client
|
clients[new_io] = client
|
||||||
@epoll.add(new_io, Epoll::IN|Epoll::PRI|Epoll::HUP)
|
@epoll.add(new_io, Epoll::IN|Epoll::PRI|Epoll::HUP)
|
||||||
rescue => e
|
rescue => e
|
||||||
Raven.capture_exception(e, :extra => {:log_id => (client.id rescue nil)})
|
if defined?(Raven)
|
||||||
|
Raven.capture_exception(e, :extra => {:log_id => (client.id rescue nil)})
|
||||||
|
end
|
||||||
logger.error "An error occurred while accepting a new client."
|
logger.error "An error occurred while accepting a new client."
|
||||||
logger.error "#{e.class}: #{e.message}"
|
logger.error "#{e.class}: #{e.message}"
|
||||||
e.backtrace.each do |line|
|
e.backtrace.each do |line|
|
||||||
@@ -192,7 +194,9 @@ module Postal
|
|||||||
end
|
end
|
||||||
rescue => e
|
rescue => e
|
||||||
client_id = client ? client.id : '------'
|
client_id = client ? client.id : '------'
|
||||||
Raven.capture_exception(e, :extra => {:log_id => (client.id rescue nil)})
|
if defined?(Raven)
|
||||||
|
Raven.capture_exception(e, :extra => {:log_id => (client.id rescue nil)})
|
||||||
|
end
|
||||||
logger.error "[#{client_id}] An error occurred while processing data from a client."
|
logger.error "[#{client_id}] An error occurred while processing data from a client."
|
||||||
logger.error "[#{client_id}] #{e.class}: #{e.message}"
|
logger.error "[#{client_id}] #{e.class}: #{e.message}"
|
||||||
e.backtrace.each do |line|
|
e.backtrace.each do |line|
|
||||||
@@ -281,7 +285,9 @@ module Postal
|
|||||||
end
|
end
|
||||||
end
|
end
|
||||||
rescue => e
|
rescue => e
|
||||||
Raven.capture_exception(e, :extra => {:log_id => (client.id rescue nil)})
|
if defined?(Raven)
|
||||||
|
Raven.capture_exception(e, :extra => {:log_id => (client.id rescue nil)})
|
||||||
|
end
|
||||||
logger.error "An error occurred while handling a client."
|
logger.error "An error occurred while handling a client."
|
||||||
logger.error "#{e.class}: #{e.message}"
|
logger.error "#{e.class}: #{e.message}"
|
||||||
e.backtrace.each do |line|
|
e.backtrace.each do |line|
|
||||||
|
|||||||
@@ -52,7 +52,9 @@ module Postal
|
|||||||
klass = message['class_name'].constantize.new(message['id'], message['params'])
|
klass = message['class_name'].constantize.new(message['id'], message['params'])
|
||||||
klass.perform
|
klass.perform
|
||||||
rescue => e
|
rescue => e
|
||||||
Raven.capture_exception(e, :extra => {:job_id => message['id']})
|
if defined?(Raven)
|
||||||
|
Raven.capture_exception(e, :extra => {:job_id => message['id']})
|
||||||
|
end
|
||||||
logger.warn "[#{message['id']}] \e[31m#{e.class}: #{e.message}\e[0m"
|
logger.warn "[#{message['id']}] \e[31m#{e.class}: #{e.message}\e[0m"
|
||||||
e.backtrace.each do |line|
|
e.backtrace.each do |line|
|
||||||
logger.warn "[#{message['id']}] " + line
|
logger.warn "[#{message['id']}] " + line
|
||||||
|
|||||||
المرجع في مشكلة جديدة
حظر مستخدم