Sha256: af6c643162d00a16ce183ead2ffa22f5561810ec06b1cf516cf7e807335bc58a
Contents?: true
Size: 941 Bytes
Versions: 12
Compression:
Stored size: 941 Bytes
Contents
module Notifiable
class NotifierBase
attr_reader :env, :notification
def initialize(env, notification)
@env, @notification = env, notification
end
def send_notification(device_token)
enqueue(device_token)
end
def close
flush
save_receipts
end
protected
def flush
end
def processed(device_token, status)
receipts << {notification_id: self.notification.id, device_token_id: device_token.id, status: status, created_at: DateTime.now}
if receipts.count > Notifiable.notification_status_batch_size
save_receipts
end
end
def test_env?
self.env == "test"
end
private
def receipts
@receipts ||= []
end
def save_receipts
Notifiable::NotificationStatus.bulk_insert! receipts
@receipts = []
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems