person_notifier.rb
2.59 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
class PersonNotifier
def initialize(person)
@person = person
end
def self.schedule_all_next_notification_mail
Delayed::Job.enqueue(NotifyAllJob.new) unless NotifyAllJob.exists?
end
def schedule_next_notification_mail
dispatch_notification_mail if !NotifyJob.exists?(@person.id)
end
def dispatch_notification_mail
Delayed::Job.enqueue(NotifyJob.new(@person.id), nil, @person.notification_time.hours.from_now) if @person.notification_time>0
end
def reschedule_next_notification_mail
return nil unless @person.setting_changed?(:notification_time) || @person.setting_changed?(:last_notification)
NotifyJob.find(@person.id).delete_all
schedule_next_notification_mail
end
def notify
if @person.notification_time && @person.notification_time > 0
from = @person.last_notification || DateTime.now - @person.notification_time.hours
notifications = @person.tracked_notifications.find(:all, :conditions => ["created_at > ?", from])
Noosfero.with_locale @person.environment.default_language do
Mailer::deliver_content_summary(@person, notifications) unless notifications.empty?
end
@person.settings[:last_notification] = DateTime.now
@person.save!
end
end
class NotifyAllJob
def self.exists?
Delayed::Job.where(:handler => "--- !ruby/object:PersonNotifier::NotifyAllJob {}\n\n").count > 0
end
def perform
Person.find_each {|person| person.notifier.schedule_next_notification_mail }
end
end
class NotifyJob < Struct.new(:person_id)
def self.exists?(person_id)
!find(person_id).empty?
end
def self.find(person_id)
Delayed::Job.where(:handler => "--- !ruby/struct:PersonNotifier::NotifyJob \nperson_id: #{person_id}\n")
end
def perform
Person.find(person_id).notifier.notify
end
def on_permanent_failure
person = Person.find(person_id)
person.notifier.dispatch_notification_mail
end
end
class Mailer < ActionMailer::Base
add_template_helper(PersonNotifierHelper)
def session
{:theme => nil}
end
def content_summary(person, notifications)
@current_theme = 'default'
@profile = person
recipients person.email
from "#{@profile.environment.name} <#{@profile.environment.contact_email}>"
subject _("[%s] Network Activity") % [@profile.environment.name]
body :recipient => @profile.nickname || @profile.name,
:environment => @profile.environment.name,
:url => @profile.environment.top_url,
:notifications => notifications
content_type "text/html"
end
end
end