bea76a4801
one place; restore listening to single process mode in resque; move the exception handling to inside the method, rather than around the intializer, and log when resque errors happen in development in single process mode
89 lines
2.9 KiB
Ruby
89 lines
2.9 KiB
Ruby
# Copyright (c) 2010, Diaspora Inc. This file is
|
|
# licensed under the Affero General Public License version 3 or later. See
|
|
# the COPYRIGHT file.
|
|
#
|
|
class Notification < ActiveRecord::Base
|
|
require File.join(Rails.root, 'lib/diaspora/web_socket')
|
|
include Diaspora::Socketable
|
|
|
|
belongs_to :recipient, :class_name => 'User'
|
|
has_many :notification_actors, :dependent => :destroy
|
|
has_many :actors, :class_name => 'Person', :through => :notification_actors, :source => :person
|
|
belongs_to :target, :polymorphic => true
|
|
|
|
def self.for(recipient, opts={})
|
|
self.where(opts.merge!(:recipient_id => recipient.id)).order('updated_at desc')
|
|
end
|
|
|
|
def self.notify(recipient, target, actor)
|
|
if target.respond_to? :notification_type
|
|
if note_type = target.notification_type(recipient, actor)
|
|
if(target.is_a? Comment) || (target.is_a? Like)
|
|
n = note_type.concatenate_or_create(recipient, target.parent, actor, note_type)
|
|
elsif(target.is_a? Reshare)
|
|
n = note_type.concatenate_or_create(recipient, target.root, actor, note_type)
|
|
else
|
|
n = note_type.make_notification(recipient, target, actor, note_type)
|
|
end
|
|
if n
|
|
n.email_the_user(target, actor) if n
|
|
n.socket_to_user(recipient, :actor => actor) if n
|
|
n
|
|
else
|
|
nil
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
def email_the_user(target, actor)
|
|
self.recipient.mail(self.mail_job, self.recipient_id, actor.id, target.id)
|
|
end
|
|
|
|
|
|
def mail_job
|
|
raise NotImplementedError.new('Subclass this.')
|
|
end
|
|
|
|
private
|
|
def self.concatenate_or_create(recipient, target, actor, notification_type)
|
|
return nil if post_visiblity_is_hidden?(recipient, target)
|
|
if n = notification_type.where(:target_id => target.id,
|
|
:target_type => target.class.base_class,
|
|
:recipient_id => recipient.id,
|
|
:unread => true).first
|
|
|
|
begin
|
|
n.actors = n.actors | [actor]
|
|
n.unread = true
|
|
n.save!
|
|
rescue ActiveRecord::RecordNotUnique
|
|
nil
|
|
end
|
|
n
|
|
else
|
|
make_notification(recipient, target, actor, notification_type)
|
|
end
|
|
end
|
|
|
|
|
|
def self.make_notification(recipient, target, actor, notification_type)
|
|
return nil if post_visiblity_is_hidden?(recipient, target)
|
|
n = notification_type.new(:target => target,
|
|
:recipient_id => recipient.id)
|
|
n.actors = n.actors | [actor]
|
|
n.unread = false if target.is_a? Request
|
|
n.save!
|
|
n
|
|
end
|
|
|
|
#horrible hack that should not be here!
|
|
def self.post_visiblity_is_hidden?(recipient, post)
|
|
return false unless post.is_a?(Post)
|
|
|
|
contact = recipient.contact_for(post.author)
|
|
return false unless contact && recipient && post
|
|
pv = PostVisibility.where(:contact_id => contact.id, :post_id => post.id).first
|
|
pv.present? ? pv.hidden? : false
|
|
end
|
|
end
|