rev |
line source |
bsw@286
|
1 Event = mondelefant.new_class()
|
bsw@286
|
2 Event.table = 'event'
|
bsw@286
|
3
|
bsw@286
|
4 Event:add_reference{
|
bsw@286
|
5 mode = 'm1',
|
bsw@286
|
6 to = "Issue",
|
bsw@286
|
7 this_key = 'issue_id',
|
bsw@286
|
8 that_key = 'id',
|
bsw@286
|
9 ref = 'issue',
|
bsw@287
|
10 }
|
bsw@287
|
11
|
bsw@414
|
12 Event:add_reference{
|
bsw@414
|
13 mode = 'm1',
|
bsw@712
|
14 to = "Initiative",
|
bsw@712
|
15 this_key = 'initiative_id',
|
bsw@712
|
16 that_key = 'id',
|
bsw@712
|
17 ref = 'initiative',
|
bsw@712
|
18 }
|
bsw@712
|
19
|
bsw@712
|
20 Event:add_reference{
|
bsw@712
|
21 mode = 'm1',
|
bsw@414
|
22 to = "Suggestion",
|
bsw@414
|
23 this_key = 'suggestion_id',
|
bsw@414
|
24 that_key = 'id',
|
bsw@414
|
25 ref = 'suggestion',
|
bsw@414
|
26 }
|
bsw@414
|
27
|
bsw@414
|
28 Event:add_reference{
|
bsw@414
|
29 mode = 'm1',
|
bsw@414
|
30 to = "Member",
|
bsw@414
|
31 this_key = 'member_id',
|
bsw@414
|
32 that_key = 'id',
|
bsw@414
|
33 ref = 'member',
|
bsw@414
|
34 }
|
bsw@414
|
35
|
bsw@405
|
36 function Event.object_get:event_name()
|
bsw@405
|
37 return ({
|
bsw@405
|
38 issue_state_changed = _"Issue reached next phase",
|
bsw@405
|
39 initiative_created_in_new_issue = _"New issue",
|
bsw@414
|
40 initiative_created_in_existing_issue = _"New initiative",
|
bsw@405
|
41 initiative_revoked = _"Initiative revoked",
|
bsw@405
|
42 new_draft_created = _"New initiative draft",
|
bsw@405
|
43 suggestion_created = _"New suggestion"
|
bsw@405
|
44 })[self.event]
|
bsw@405
|
45 end
|
bsw@405
|
46
|
bsw@405
|
47 function Event.object_get:state_name()
|
bsw@405
|
48 return ({
|
bsw@405
|
49 admission = _"New",
|
bsw@405
|
50 discussion = _"Discussion",
|
bsw@405
|
51 verification = _"Frozen",
|
bsw@405
|
52 voting = _"Voting",
|
bsw@405
|
53 canceled_revoked_before_accepted = _"Cancelled (before accepted due to revocation)",
|
bsw@405
|
54 canceled_issue_not_accepted = _"Cancelled (issue not accepted)",
|
bsw@405
|
55 canceled_after_revocation_during_discussion = _"Cancelled (during discussion due to revocation)",
|
bsw@405
|
56 canceled_after_revocation_during_verification = _"Cancelled (during verification due to revocation)",
|
bsw@405
|
57 calculation = _"Calculation",
|
bsw@405
|
58 canceled_no_initiative_admitted = _"Cancelled (no initiative admitted)",
|
bsw@405
|
59 finished_without_winner = _"Finished (without winner)",
|
bsw@410
|
60 finished_with_winner = _"Finished (with winner)"
|
bsw@405
|
61 })[self.state]
|
bsw@405
|
62 end
|
bsw@405
|
63
|
bsw@592
|
64 function Event.object:send_notification()
|
bsw@592
|
65
|
bsw@363
|
66 local members_to_notify = Member:new_selector()
|
bsw@363
|
67 :join("event_seen_by_member", nil, { "event_seen_by_member.seen_by_member_id = member.id AND event_seen_by_member.notify_level <= member.notify_level AND event_seen_by_member.id = ?", self.id } )
|
bsw@363
|
68 :add_where("member.activated NOTNULL AND member.notify_email NOTNULL")
|
bsw@726
|
69 -- SAFETY FIRST, NEVER send notifications for events more then 3 days in past or future
|
bsw@726
|
70 :add_where("now() - event_seen_by_member.occurrence BETWEEN '-3 days'::interval AND '3 days'::interval")
|
bsw@866
|
71 -- do not notify a member about the events caused by the member
|
bsw@866
|
72 :add_where("event_seen_by_member.member_id ISNULL OR event_seen_by_member.member_id != member.id")
|
bsw@363
|
73 :exec()
|
bsw@363
|
74
|
bsw@363
|
75 print (_("Event #{id} -> #{num} members", { id = self.id, num = #members_to_notify }))
|
bsw@363
|
76
|
bsw@363
|
77
|
bsw@287
|
78 local url
|
bsw@287
|
79
|
bsw@405
|
80 for i, member in ipairs(members_to_notify) do
|
bsw@405
|
81 local subject
|
bsw@405
|
82 local body = ""
|
bsw@405
|
83
|
bsw@405
|
84 locale.do_with(
|
bsw@405
|
85 { lang = member.lang or config.default_lang or 'en' },
|
bsw@405
|
86 function()
|
bsw@407
|
87 subject = config.mail_subject_prefix .. " " .. self.event_name
|
bsw@405
|
88 body = body .. _("[event mail] Unit: #{name}", { name = self.issue.area.unit.name }) .. "\n"
|
bsw@405
|
89 body = body .. _("[event mail] Area: #{name}", { name = self.issue.area.name }) .. "\n"
|
bsw@405
|
90 body = body .. _("[event mail] Issue: ##{id}", { id = self.issue_id }) .. "\n\n"
|
bsw@405
|
91 body = body .. _("[event mail] Policy: #{policy}", { policy = self.issue.policy.name }) .. "\n\n"
|
bsw@405
|
92 body = body .. _("[event mail] Event: #{event}", { event = self.event_name }) .. "\n\n"
|
bsw@405
|
93 body = body .. _("[event mail] Phase: #{phase}", { phase = self.state_name }) .. "\n\n"
|
bsw@405
|
94
|
bsw@405
|
95 if self.initiative_id then
|
bsw@405
|
96 url = request.get_absolute_baseurl() .. "initiative/show/" .. self.initiative_id .. ".html"
|
bsw@405
|
97 elseif self.suggestion_id then
|
bsw@405
|
98 url = request.get_absolute_baseurl() .. "suggestion/show/" .. self.suggestion_id .. ".html"
|
bsw@405
|
99 else
|
bsw@405
|
100 url = request.get_absolute_baseurl() .. "issue/show/" .. self.issue_id .. ".html"
|
bsw@405
|
101 end
|
bsw@405
|
102
|
bsw@405
|
103 body = body .. _("[event mail] URL: #{url}", { url = url }) .. "\n\n"
|
bsw@405
|
104
|
bsw@405
|
105 if self.initiative_id then
|
bsw@405
|
106 local initiative = Initiative:by_id(self.initiative_id)
|
bsw@405
|
107 body = body .. _("i#{id}: #{name}", { id = initiative.id, name = initiative.name }) .. "\n\n"
|
bsw@405
|
108 else
|
bsw@405
|
109 local initiative_count = Initiative:new_selector()
|
bsw@405
|
110 :add_where{ "initiative.issue_id = ?", self.issue_id }
|
bsw@405
|
111 :count()
|
bsw@405
|
112 local initiatives = Initiative:new_selector()
|
bsw@405
|
113 :add_where{ "initiative.issue_id = ?", self.issue_id }
|
bsw@405
|
114 :add_order_by("initiative.supporter_count DESC")
|
bsw@405
|
115 :limit(3)
|
bsw@405
|
116 :exec()
|
bsw@405
|
117 for i, initiative in ipairs(initiatives) do
|
bsw@405
|
118 body = body .. _("i#{id}: #{name}", { id = initiative.id, name = initiative.name }) .. "\n"
|
bsw@405
|
119 end
|
bsw@405
|
120 if initiative_count - 3 > 0 then
|
bsw@764
|
121 body = body .. _("and #{count} more initiatives", { count = initiative_count - 3 }) .. "\n"
|
bsw@405
|
122 end
|
bsw@405
|
123 body = body .. "\n"
|
bsw@405
|
124 end
|
bsw@405
|
125
|
bsw@405
|
126 if self.suggestion_id then
|
bsw@405
|
127 local suggestion = Suggestion:by_id(self.suggestion_id)
|
bsw@405
|
128 body = body .. _("#{name}\n\n", { name = suggestion.name })
|
bsw@405
|
129 end
|
bsw@287
|
130
|
bsw@405
|
131 local success = net.send_mail{
|
bsw@405
|
132 envelope_from = config.mail_envelope_from,
|
bsw@405
|
133 from = config.mail_from,
|
bsw@405
|
134 reply_to = config.mail_reply_to,
|
bsw@405
|
135 to = member.notify_email,
|
bsw@406
|
136 subject = subject,
|
bsw@405
|
137 content_type = "text/plain; charset=UTF-8",
|
bsw@405
|
138 content = body
|
bsw@405
|
139 }
|
bsw@405
|
140
|
bsw@405
|
141 end
|
bsw@405
|
142 )
|
bsw@287
|
143 end
|
bsw@287
|
144
|
bsw@287
|
145 end
|
bsw@287
|
146
|
bsw@363
|
147 function Event:send_next_notification()
|
bsw@363
|
148
|
bsw@363
|
149 local notification_sent = NotificationSent:new_selector()
|
bsw@363
|
150 :optional_object_mode()
|
bsw@363
|
151 :for_update()
|
bsw@363
|
152 :exec()
|
bsw@363
|
153
|
bsw@363
|
154 local last_event_id = 0
|
bsw@363
|
155 if notification_sent then
|
bsw@363
|
156 last_event_id = notification_sent.event_id
|
bsw@363
|
157 end
|
bsw@363
|
158
|
bsw@287
|
159 local event = Event:new_selector()
|
bsw@363
|
160 :add_where{ "event.id > ?", last_event_id }
|
bsw@287
|
161 :add_order_by("event.id")
|
bsw@287
|
162 :limit(1)
|
bsw@287
|
163 :optional_object_mode()
|
bsw@287
|
164 :exec()
|
bsw@287
|
165
|
bsw@287
|
166 if event then
|
bsw@363
|
167 if last_event_id == 0 then
|
bsw@363
|
168 db:query{ "INSERT INTO notification_sent (event_id) VALUES (?)", event.id }
|
bsw@363
|
169 else
|
bsw@363
|
170 db:query{ "UPDATE notification_sent SET event_id = ?", event.id }
|
bsw@363
|
171 end
|
bsw@287
|
172
|
bsw@287
|
173 event:send_notification()
|
bsw@364
|
174
|
bsw@364
|
175 return true
|
bsw@287
|
176
|
bsw@287
|
177 end
|
bsw@287
|
178
|
bsw@364
|
179 end
|
bsw@364
|
180
|
bsw@364
|
181 function Event:send_notifications_loop()
|
bsw@364
|
182
|
bsw@364
|
183 while true do
|
bsw@364
|
184 local did_work = Event:send_next_notification()
|
bsw@364
|
185 if not did_work then
|
bsw@364
|
186 print "Sleeping 1 second"
|
bsw@364
|
187 os.execute("sleep 1")
|
bsw@364
|
188 end
|
bsw@364
|
189 end
|
bsw@364
|
190
|
bsw@287
|
191 end |