مراية لـ
https://github.com/postalserver/postal.git
تم المزامنة 2026-01-19 14:19:48 +00:00
@@ -256,7 +256,7 @@ class UnqueueMessageJob < Postal::Job
|
|||||||
|
|
||||||
if result.retry
|
if result.retry
|
||||||
log "#{log_prefix} Message requeued for trying later."
|
log "#{log_prefix} Message requeued for trying later."
|
||||||
queued_message.retry_later(result.retry.is_a?(Fixnum) ? result.retry : nil)
|
queued_message.retry_later(result.retry.is_a?(Integer) ? result.retry : nil)
|
||||||
queued_message.allocate_ip_address
|
queued_message.allocate_ip_address
|
||||||
queued_message.update_column(:ip_address_id, queued_message.ip_address&.id)
|
queued_message.update_column(:ip_address_id, queued_message.ip_address&.id)
|
||||||
else
|
else
|
||||||
@@ -419,7 +419,7 @@ class UnqueueMessageJob < Postal::Job
|
|||||||
queued_message.message.create_delivery(result.type, :details => result.details, :output => result.output, :sent_with_ssl => result.secure, :log_id => result.log_id, :time => result.time)
|
queued_message.message.create_delivery(result.type, :details => result.details, :output => result.output, :sent_with_ssl => result.secure, :log_id => result.log_id, :time => result.time)
|
||||||
if result.retry
|
if result.retry
|
||||||
log "#{log_prefix} Message requeued for trying later."
|
log "#{log_prefix} Message requeued for trying later."
|
||||||
queued_message.retry_later(result.retry.is_a?(Fixnum) ? result.retry : nil)
|
queued_message.retry_later(result.retry.is_a?(Integer) ? result.retry : nil)
|
||||||
else
|
else
|
||||||
log "#{log_prefix} Processing complete"
|
log "#{log_prefix} Processing complete"
|
||||||
queued_message.destroy
|
queued_message.destroy
|
||||||
|
|||||||
@@ -348,7 +348,7 @@ module Postal
|
|||||||
|
|
||||||
def hash_to_sql(hash, joiner = ', ')
|
def hash_to_sql(hash, joiner = ', ')
|
||||||
hash.map do |key, value|
|
hash.map do |key, value|
|
||||||
if value.is_a?(Array) && value.all? { |v| v.is_a?(Fixnum) }
|
if value.is_a?(Array) && value.all? { |v| v.is_a?(Integer) }
|
||||||
"`#{key}` IN (#{value.join(', ')})"
|
"`#{key}` IN (#{value.join(', ')})"
|
||||||
elsif value.is_a?(Array)
|
elsif value.is_a?(Array)
|
||||||
escaped_values = value.map { |v| escape(v) }.join(', ')
|
escaped_values = value.map { |v| escape(v) }.join(', ')
|
||||||
|
|||||||
@@ -6,7 +6,7 @@ module Postal
|
|||||||
end
|
end
|
||||||
|
|
||||||
def self.find_one(database, query)
|
def self.find_one(database, query)
|
||||||
query = {:id => query.to_i} if query.is_a?(Fixnum)
|
query = {:id => query.to_i} if query.is_a?(Integer)
|
||||||
if message = database.select('messages', :where => query, :limit => 1).first
|
if message = database.select('messages', :where => query, :limit => 1).first
|
||||||
Message.new(database, message)
|
Message.new(database, message)
|
||||||
else
|
else
|
||||||
|
|||||||
المرجع في مشكلة جديدة
حظر مستخدم