1
0
مراية لـ https://github.com/postalserver/postal.git تم المزامنة 2026-01-16 21:23:37 +00:00

style(rubocop): Style/SafeNavigation

هذا الالتزام موجود في:
Adam Cooke
2024-02-10 23:12:21 +00:00
الأصل 04a34831c7
التزام 00a02f2655
6 ملفات معدلة مع 17 إضافات و23 حذوفات

عرض الملف

@@ -84,11 +84,6 @@ Style/ConditionalAssignment:
Style/EmptyMethod: Style/EmptyMethod:
EnforcedStyle: expanded EnforcedStyle: expanded
# We do not wish to auto correct unused method arguments because that can be a
# pain. These should just be flagged for manual intervention.
Lint/UnusedMethodArgument:
AutoCorrect: false
# As above, just flag them. # As above, just flag them.
Lint/UnusedBlockArgument: Lint/UnusedBlockArgument:
AutoCorrect: false AutoCorrect: false
@@ -179,3 +174,6 @@ Metrics/BlockLength:
Metrics/ClassLength: Metrics/ClassLength:
Enabled: false Enabled: false
Lint/UnusedMethodArgument:
Enabled: false

عرض الملف

@@ -7,9 +7,9 @@ structure :message do
expansion(:status) do expansion(:status) do
{ {
status: o.status, status: o.status,
last_delivery_attempt: o.last_delivery_attempt ? o.last_delivery_attempt.to_f : nil, last_delivery_attempt: o.last_delivery_attempt&.to_f,
held: o.held, held: o.held,
hold_expiry: o.hold_expiry ? o.hold_expiry.to_f : nil hold_expiry: o.hold_expiry&.to_f
} }
end end

عرض الملف

@@ -5,8 +5,7 @@ class SendWebhookJob < Postal::Job
def perform def perform
if server = Server.find(params["server_id"]) if server = Server.find(params["server_id"])
new_items = {} new_items = {}
if params["payload"] params["payload"]&.each do |key, value|
params["payload"].each do |key, value|
next unless key.to_s =~ /\A_(\w+)/ next unless key.to_s =~ /\A_(\w+)/
begin begin
@@ -14,7 +13,6 @@ class SendWebhookJob < Postal::Job
rescue Postal::MessageDB::Message::NotFound rescue Postal::MessageDB::Message::NotFound
end end
end end
end
new_items.each do |key, value| new_items.each do |key, value|
params["payload"].delete("_#{key}") params["payload"].delete("_#{key}")

عرض الملف

@@ -430,15 +430,13 @@ class UnqueueMessageJob < Postal::Job
if defined?(Sentry) if defined?(Sentry)
Sentry.capture_exception(e, extra: { job_id: self.id, server_id: queued_message.server_id, message_id: queued_message.message_id }) Sentry.capture_exception(e, extra: { job_id: self.id, server_id: queued_message.server_id, message_id: queued_message.message_id })
end end
if queued_message.message queued_message.message&.create_delivery("Error",
queued_message.message.create_delivery("Error",
details: "An internal error occurred while sending " \ details: "An internal error occurred while sending " \
"this message. This message will be retried " \ "this message. This message will be retried " \
"automatically.", "automatically.",
output: "#{e.class}: #{e.message}", log_id: "J-#{self.id}") output: "#{e.class}: #{e.message}", log_id: "J-#{self.id}")
end end
end end
end
else else
log "Couldn't get lock for message #{params['id']}. I won't do this." log "Couldn't get lock for message #{params['id']}. I won't do this."

عرض الملف

@@ -335,7 +335,7 @@ module Postal
# Return the recipient domain for this message # Return the recipient domain for this message
# #
def recipient_domain def recipient_domain
rcpt_to ? rcpt_to.split("@").last : nil rcpt_to&.split("@")&.last
end end
# #

عرض الملف

@@ -380,7 +380,7 @@ module Postal
else else
idata = idata.to_s.sub(/\A\.\./, ".") idata = idata.to_s.sub(/\A\.\./, ".")
if @credential && @credential.server.log_smtp_data? if @credential&.server&.log_smtp_data?
# We want to log if enabled # We want to log if enabled
else else
log "Not logging further message data." log "Not logging further message data."