liquid_feedback_frontend

annotate model/event.lua @ 1158:e9f6ae14bc72

find changesets by author, revision, files, or words in the commit message
Updated event notifications and moved code from config to prefork initializer
author bsw
date Tue Mar 24 11:50:08 2015 +0100 (2015-03-24)
parents c037558f6610
children dafce7add549
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@972 48 return Issue:get_state_name_for_state(self.state)
bsw@405 49 end
bsw@405 50
bsw@592 51 function Event.object:send_notification()
bsw@592 52
bsw@363 53 local members_to_notify = Member:new_selector()
bsw@363 54 :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 55 :add_where("member.activated NOTNULL AND member.notify_email NOTNULL")
bsw@726 56 -- SAFETY FIRST, NEVER send notifications for events more then 3 days in past or future
bsw@726 57 :add_where("now() - event_seen_by_member.occurrence BETWEEN '-3 days'::interval AND '3 days'::interval")
bsw@866 58 -- do not notify a member about the events caused by the member
bsw@866 59 :add_where("event_seen_by_member.member_id ISNULL OR event_seen_by_member.member_id != member.id")
bsw@363 60 :exec()
bsw@363 61
bsw@1158 62 io.stderr:write("Sending notifications for event #{id} to #{num} members", { id = self.id, num = #members_to_notify })
bsw@363 63
bsw@287 64 local url
bsw@287 65
bsw@405 66 for i, member in ipairs(members_to_notify) do
bsw@405 67 local subject
bsw@405 68 local body = ""
bsw@405 69
bsw@405 70 locale.do_with(
bsw@405 71 { lang = member.lang or config.default_lang or 'en' },
bsw@405 72 function()
bsw@1104 73
bsw@1104 74 local suggestion
bsw@1104 75 if self.suggestion_id then
bsw@1104 76 suggestion = Suggestion:by_id(self.suggestion_id)
bsw@1104 77 if not suggestion then
bsw@1104 78 return
bsw@1104 79 end
bsw@1104 80 end
bsw@1104 81
bsw@1104 82 subject = config.mail_subject_prefix .. " " .. self.event_name
bsw@405 83 body = body .. _("[event mail] Unit: #{name}", { name = self.issue.area.unit.name }) .. "\n"
bsw@405 84 body = body .. _("[event mail] Area: #{name}", { name = self.issue.area.name }) .. "\n"
bsw@405 85 body = body .. _("[event mail] Issue: ##{id}", { id = self.issue_id }) .. "\n\n"
bsw@405 86 body = body .. _("[event mail] Policy: #{policy}", { policy = self.issue.policy.name }) .. "\n\n"
bsw@405 87 body = body .. _("[event mail] Event: #{event}", { event = self.event_name }) .. "\n\n"
bsw@405 88 body = body .. _("[event mail] Phase: #{phase}", { phase = self.state_name }) .. "\n\n"
bsw@405 89
bsw@405 90 if self.initiative_id then
bsw@405 91 url = request.get_absolute_baseurl() .. "initiative/show/" .. self.initiative_id .. ".html"
bsw@405 92 elseif self.suggestion_id then
bsw@405 93 url = request.get_absolute_baseurl() .. "suggestion/show/" .. self.suggestion_id .. ".html"
bsw@405 94 else
bsw@405 95 url = request.get_absolute_baseurl() .. "issue/show/" .. self.issue_id .. ".html"
bsw@405 96 end
bsw@405 97
bsw@405 98 body = body .. _("[event mail] URL: #{url}", { url = url }) .. "\n\n"
bsw@405 99
bsw@405 100 if self.initiative_id then
bsw@405 101 local initiative = Initiative:by_id(self.initiative_id)
bsw@405 102 body = body .. _("i#{id}: #{name}", { id = initiative.id, name = initiative.name }) .. "\n\n"
bsw@405 103 else
bsw@405 104 local initiative_count = Initiative:new_selector()
bsw@405 105 :add_where{ "initiative.issue_id = ?", self.issue_id }
bsw@405 106 :count()
bsw@405 107 local initiatives = Initiative:new_selector()
bsw@405 108 :add_where{ "initiative.issue_id = ?", self.issue_id }
bsw@405 109 :add_order_by("initiative.supporter_count DESC")
bsw@405 110 :limit(3)
bsw@405 111 :exec()
bsw@405 112 for i, initiative in ipairs(initiatives) do
bsw@405 113 body = body .. _("i#{id}: #{name}", { id = initiative.id, name = initiative.name }) .. "\n"
bsw@405 114 end
bsw@405 115 if initiative_count - 3 > 0 then
bsw@764 116 body = body .. _("and #{count} more initiatives", { count = initiative_count - 3 }) .. "\n"
bsw@405 117 end
bsw@405 118 body = body .. "\n"
bsw@405 119 end
bsw@405 120
bsw@1104 121 if suggestion then
bsw@405 122 body = body .. _("#{name}\n\n", { name = suggestion.name })
bsw@405 123 end
bsw@287 124
bsw@405 125 local success = net.send_mail{
bsw@405 126 envelope_from = config.mail_envelope_from,
bsw@405 127 from = config.mail_from,
bsw@405 128 reply_to = config.mail_reply_to,
bsw@405 129 to = member.notify_email,
bsw@406 130 subject = subject,
bsw@405 131 content_type = "text/plain; charset=UTF-8",
bsw@405 132 content = body
bsw@405 133 }
bsw@405 134
bsw@405 135 end
bsw@405 136 )
bsw@287 137 end
bsw@287 138
bsw@287 139 end
bsw@287 140
bsw@363 141 function Event:send_next_notification()
bsw@363 142
bsw@363 143 local notification_sent = NotificationSent:new_selector()
bsw@363 144 :optional_object_mode()
bsw@363 145 :for_update()
bsw@363 146 :exec()
bsw@363 147
bsw@363 148 local last_event_id = 0
bsw@363 149 if notification_sent then
bsw@363 150 last_event_id = notification_sent.event_id
bsw@363 151 end
bsw@363 152
bsw@287 153 local event = Event:new_selector()
bsw@363 154 :add_where{ "event.id > ?", last_event_id }
bsw@287 155 :add_order_by("event.id")
bsw@287 156 :limit(1)
bsw@287 157 :optional_object_mode()
bsw@287 158 :exec()
bsw@287 159
bsw@287 160 if event then
bsw@363 161 if last_event_id == 0 then
bsw@363 162 db:query{ "INSERT INTO notification_sent (event_id) VALUES (?)", event.id }
bsw@363 163 else
bsw@363 164 db:query{ "UPDATE notification_sent SET event_id = ?", event.id }
bsw@363 165 end
bsw@287 166
bsw@287 167 event:send_notification()
bsw@364 168
bsw@1158 169 if config.notification_handler_func then
bsw@1158 170 config.notification_handler_func(event)
bsw@1158 171 end
bsw@1158 172
bsw@364 173 return true
bsw@287 174
bsw@287 175 end
bsw@287 176
bsw@364 177 end
bsw@364 178
bsw@1158 179 function Event:send_pending_notifications()
bsw@1158 180 while true do
bsw@1158 181 if not Event:send_next_notification() then
bsw@1158 182 break
bsw@1158 183 end
bsw@1158 184 end
bsw@1158 185 end
bsw@1158 186
bsw@364 187 function Event:send_notifications_loop()
bsw@364 188
bsw@364 189 while true do
bsw@364 190 local did_work = Event:send_next_notification()
bsw@364 191 if not did_work then
bsw@1158 192 print "Sleeping 5 second"
bsw@1158 193 os.execute("sleep 5")
bsw@364 194 end
bsw@364 195 end
bsw@364 196
bsw@287 197 end

Impressum / About Us