liquid_feedback_frontend

annotate model/event.lua @ 407:dac54851083d

find changesets by author, revision, files, or words in the commit message
Translation of event message subject added
author bsw
date Thu Mar 08 16:17:58 2012 +0100 (2012-03-08)
parents b297b85dc569
children 7efe31566c11
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@405 12 function Event.object_get:event_name()
bsw@405 13 return ({
bsw@405 14 issue_state_changed = _"Issue reached next phase",
bsw@405 15 initiative_created_in_new_issue = _"New issue",
bsw@405 16 initiative_created_in_existing_issue = _"New initiative in existing issue",
bsw@405 17 initiative_revoked = _"Initiative revoked",
bsw@405 18 new_draft_created = _"New initiative draft",
bsw@405 19 suggestion_created = _"New suggestion"
bsw@405 20 })[self.event]
bsw@405 21 end
bsw@405 22
bsw@405 23 function Event.object_get:state_name()
bsw@405 24 return ({
bsw@405 25 admission = _"New",
bsw@405 26 discussion = _"Discussion",
bsw@405 27 verification = _"Frozen",
bsw@405 28 voting = _"Voting",
bsw@405 29 canceled_revoked_before_accepted = _"Cancelled (before accepted due to revocation)",
bsw@405 30 canceled_issue_not_accepted = _"Cancelled (issue not accepted)",
bsw@405 31 canceled_after_revocation_during_discussion = _"Cancelled (during discussion due to revocation)",
bsw@405 32 canceled_after_revocation_during_verification = _"Cancelled (during verification due to revocation)",
bsw@405 33 calculation = _"Calculation",
bsw@405 34 canceled_no_initiative_admitted = _"Cancelled (no initiative admitted)",
bsw@405 35 finished_without_winner = _"Finished (without winner)",
bsw@405 36 finished_with_winner = "Finished (with winner)"
bsw@405 37 })[self.state]
bsw@405 38 end
bsw@405 39
bsw@287 40 function Event.object:send_notification()
bsw@287 41
bsw@363 42 local members_to_notify = Member:new_selector()
bsw@363 43 :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 44 :add_where("member.activated NOTNULL AND member.notify_email NOTNULL")
bsw@363 45 :exec()
bsw@363 46
bsw@363 47 print (_("Event #{id} -> #{num} members", { id = self.id, num = #members_to_notify }))
bsw@363 48
bsw@363 49
bsw@287 50 local url
bsw@287 51
bsw@405 52 for i, member in ipairs(members_to_notify) do
bsw@405 53 local subject
bsw@405 54 local body = ""
bsw@405 55
bsw@405 56 locale.do_with(
bsw@405 57 { lang = member.lang or config.default_lang or 'en' },
bsw@405 58 function()
bsw@407 59 subject = config.mail_subject_prefix .. " " .. self.event_name
bsw@405 60 body = body .. _("[event mail] Unit: #{name}", { name = self.issue.area.unit.name }) .. "\n"
bsw@405 61 body = body .. _("[event mail] Area: #{name}", { name = self.issue.area.name }) .. "\n"
bsw@405 62 body = body .. _("[event mail] Issue: ##{id}", { id = self.issue_id }) .. "\n\n"
bsw@405 63 body = body .. _("[event mail] Policy: #{policy}", { policy = self.issue.policy.name }) .. "\n\n"
bsw@405 64 body = body .. _("[event mail] Event: #{event}", { event = self.event_name }) .. "\n\n"
bsw@405 65 body = body .. _("[event mail] Phase: #{phase}", { phase = self.state_name }) .. "\n\n"
bsw@405 66
bsw@405 67 if self.initiative_id then
bsw@405 68 url = request.get_absolute_baseurl() .. "initiative/show/" .. self.initiative_id .. ".html"
bsw@405 69 elseif self.suggestion_id then
bsw@405 70 url = request.get_absolute_baseurl() .. "suggestion/show/" .. self.suggestion_id .. ".html"
bsw@405 71 else
bsw@405 72 url = request.get_absolute_baseurl() .. "issue/show/" .. self.issue_id .. ".html"
bsw@405 73 end
bsw@405 74
bsw@405 75 body = body .. _("[event mail] URL: #{url}", { url = url }) .. "\n\n"
bsw@405 76
bsw@405 77 if self.initiative_id then
bsw@405 78 local initiative = Initiative:by_id(self.initiative_id)
bsw@405 79 body = body .. _("i#{id}: #{name}", { id = initiative.id, name = initiative.name }) .. "\n\n"
bsw@405 80 else
bsw@405 81 local initiative_count = Initiative:new_selector()
bsw@405 82 :add_where{ "initiative.issue_id = ?", self.issue_id }
bsw@405 83 :count()
bsw@405 84 local initiatives = Initiative:new_selector()
bsw@405 85 :add_where{ "initiative.issue_id = ?", self.issue_id }
bsw@405 86 :add_order_by("initiative.supporter_count DESC")
bsw@405 87 :limit(3)
bsw@405 88 :exec()
bsw@405 89 for i, initiative in ipairs(initiatives) do
bsw@405 90 body = body .. _("i#{id}: #{name}", { id = initiative.id, name = initiative.name }) .. "\n"
bsw@405 91 end
bsw@405 92 if initiative_count - 3 > 0 then
bsw@405 93 body = body .. _("and #{count} more initiatives", { count = initiative_count }) .. "\n"
bsw@405 94 end
bsw@405 95 body = body .. "\n"
bsw@405 96 end
bsw@405 97
bsw@405 98 if self.suggestion_id then
bsw@405 99 local suggestion = Suggestion:by_id(self.suggestion_id)
bsw@405 100 body = body .. _("#{name}\n\n", { name = suggestion.name })
bsw@405 101 end
bsw@287 102
bsw@405 103 local success = net.send_mail{
bsw@405 104 envelope_from = config.mail_envelope_from,
bsw@405 105 from = config.mail_from,
bsw@405 106 reply_to = config.mail_reply_to,
bsw@405 107 to = member.notify_email,
bsw@406 108 subject = subject,
bsw@405 109 content_type = "text/plain; charset=UTF-8",
bsw@405 110 content = body
bsw@405 111 }
bsw@405 112
bsw@405 113 end
bsw@405 114 )
bsw@287 115 end
bsw@287 116
bsw@287 117 end
bsw@287 118
bsw@363 119 function Event:send_next_notification()
bsw@363 120
bsw@363 121 local notification_sent = NotificationSent:new_selector()
bsw@363 122 :optional_object_mode()
bsw@363 123 :for_update()
bsw@363 124 :exec()
bsw@363 125
bsw@363 126 local last_event_id = 0
bsw@363 127 if notification_sent then
bsw@363 128 last_event_id = notification_sent.event_id
bsw@363 129 end
bsw@363 130
bsw@287 131 local event = Event:new_selector()
bsw@363 132 :add_where{ "event.id > ?", last_event_id }
bsw@287 133 :add_order_by("event.id")
bsw@287 134 :limit(1)
bsw@287 135 :optional_object_mode()
bsw@287 136 :exec()
bsw@287 137
bsw@287 138 if event then
bsw@363 139 if last_event_id == 0 then
bsw@363 140 db:query{ "INSERT INTO notification_sent (event_id) VALUES (?)", event.id }
bsw@363 141 else
bsw@363 142 db:query{ "UPDATE notification_sent SET event_id = ?", event.id }
bsw@363 143 end
bsw@287 144
bsw@287 145 event:send_notification()
bsw@364 146
bsw@364 147 return true
bsw@287 148
bsw@287 149 end
bsw@287 150
bsw@364 151 end
bsw@364 152
bsw@364 153 function Event:send_notifications_loop()
bsw@364 154
bsw@364 155 while true do
bsw@364 156 local did_work = Event:send_next_notification()
bsw@364 157 if not did_work then
bsw@364 158 print "Sleeping 1 second"
bsw@364 159 os.execute("sleep 1")
bsw@364 160 end
bsw@364 161 end
bsw@364 162
bsw@287 163 end

Impressum / About Us