liquid_feedback_frontend
view model/issue.lua @ 548:8af806af86a0
Added issue related preloading to issue show and initiative view
| author | bsw |
|---|---|
| date | Tue May 29 20:45:58 2012 +0200 (2012-05-29) |
| parents | 57a261a81c5a |
| children | 42d070777353 |
line source
1 Issue = mondelefant.new_class()
2 Issue.table = 'issue'
4 Issue:add_reference{
5 mode = 'm1',
6 to = "Area",
7 this_key = 'area_id',
8 that_key = 'id',
9 ref = 'area',
10 }
12 Issue:add_reference{
13 mode = 'm1',
14 to = "Policy",
15 this_key = 'policy_id',
16 that_key = 'id',
17 ref = 'policy',
18 }
20 Issue:add_reference{
21 mode = '1m',
22 to = "Initiative",
23 this_key = 'id',
24 that_key = 'issue_id',
25 ref = 'initiatives',
26 back_ref = 'issue'
27 }
29 Issue:add_reference{
30 mode = '1m',
31 to = "Interest",
32 this_key = 'id',
33 that_key = 'issue_id',
34 ref = 'interests',
35 back_ref = 'issue',
36 default_order = '"id"'
37 }
39 Issue:add_reference{
40 mode = '1m',
41 to = "Supporter",
42 this_key = 'id',
43 that_key = 'issue_id',
44 ref = 'supporters',
45 back_ref = 'issue',
46 default_order = '"id"'
47 }
49 Issue:add_reference{
50 mode = '1m',
51 to = "DirectVoter",
52 this_key = 'id',
53 that_key = 'issue_id',
54 ref = 'direct_voters',
55 back_ref = 'issue',
56 default_order = '"member_id"'
57 }
59 Issue:add_reference{
60 mode = '1m',
61 to = "Vote",
62 this_key = 'id',
63 that_key = 'issue_id',
64 ref = 'votes',
65 back_ref = 'issue',
66 default_order = '"member_id", "initiative_id"'
67 }
69 Issue:add_reference{
70 mode = '1m',
71 to = "Delegation",
72 this_key = 'id',
73 that_key = 'issue_id',
74 ref = 'delegations',
75 back_ref = 'issue'
76 }
78 Issue:add_reference{
79 mode = 'mm',
80 to = "Member",
81 this_key = 'id',
82 that_key = 'id',
83 connected_by_table = 'interest',
84 connected_by_this_key = 'issue_id',
85 connected_by_that_key = 'member_id',
86 ref = 'members'
87 }
89 Issue:add_reference{
90 mode = 'mm',
91 to = "Member",
92 this_key = 'id',
93 that_key = 'id',
94 connected_by_table = 'direct_interest_snapshot',
95 connected_by_this_key = 'issue_id',
96 connected_by_that_key = 'member_id',
97 ref = 'interested_members_snapshot'
98 }
100 Issue:add_reference{
101 mode = 'mm',
102 to = "Member",
103 this_key = 'id',
104 that_key = 'id',
105 connected_by_table = 'direct_voter',
106 connected_by_this_key = 'issue_id',
107 connected_by_that_key = 'member_id',
108 ref = 'direct_voters'
109 }
111 Issue:add_reference{
112 mode = "11",
113 to = mondelefant.class_prototype,
114 this_key = "id",
115 that_key = "issue_id",
116 ref = "member_info",
117 back_ref = "issue",
118 selector_generator = function(list, options)
119 assert(options.member_id, "member_id mandatory for member_info")
120 local ids = { sep = ", " }
121 for i, object in ipairs(list) do
122 local id = object.id
123 if id ~= nil then
124 ids[#ids+1] = {"?", id}
125 end
126 end
127 local sub_selector = Issue:get_db_conn():new_selector()
128 if #ids == 0 then
129 return sub_selector:empty_list_mode()
130 end
131 sub_selector:from("issue")
132 sub_selector:add_field("issue.id", "issue_id")
133 sub_selector:add_field{ '(delegation_info(?, null, null, issue.id, ?)).*', options.member_id, options.trustee_id }
134 sub_selector:add_where{ 'issue.id IN ($)', ids }
136 local selector = Issue:get_db_conn():new_selector()
137 selector:add_from("issue")
138 selector:join(sub_selector, "delegation_info", "delegation_info.issue_id = issue.id")
139 selector:left_join("member", "first_trustee", "first_trustee.id = delegation_info.first_trustee_id")
140 selector:left_join("member", "other_trustee", "other_trustee.id = delegation_info.other_trustee_id")
141 selector:add_field("delegation_info.*")
142 selector:add_field("first_trustee.name", "first_trustee_name")
143 selector:add_field("other_trustee.name", "other_trustee_name")
144 selector:left_join("direct_voter", nil, { "direct_voter.issue_id = issue.id AND direct_voter.member_id = ?", options.member_id })
145 selector:add_field("direct_voter.member_id NOTNULL", "direct_voted")
146 return selector
147 end
148 }
150 function Issue.list:load_everything_for_member_id(member_id)
151 local areas = self:load("area")
152 areas:load("unit")
153 self:load("policy")
154 self:load("member_info", { member_id = member_id })
155 end
157 function Issue.object:load_everything_for_member_id(member_id)
158 local areas = self:load("area")
159 areas:load("unit")
160 self:load("policy")
161 self:load("member_info", { member_id = member_id })
162 end
164 function Issue:get_state_name_for_state(value)
165 local state_name_table = {
166 new = _"New",
167 accepted = _"Discussion",
168 frozen = _"Frozen",
169 voting = _"Voting",
170 finished = _"Finished",
171 cancelled = _"Cancelled"
172 }
173 return state_name_table[value] or value or ''
174 end
176 function Issue:get_search_selector(search_string)
177 return self:new_selector()
178 :join('"initiative"', nil, '"initiative"."issue_id" = "issue"."id"')
179 :join('"draft"', nil, '"draft"."initiative_id" = "initiative"."id"')
180 :add_where{ '"initiative"."text_search_data" @@ "text_search_query"(?) OR "draft"."text_search_data" @@ "text_search_query"(?)', search_string, search_string }
181 :add_group_by('"issue"."id"')
182 :add_group_by('"issue"."state"')
183 :add_group_by('"issue"."area_id"')
184 :add_group_by('"issue"."policy_id"')
185 :add_group_by('"issue"."created"')
186 :add_group_by('"issue"."accepted"')
187 :add_group_by('"issue"."half_frozen"')
188 :add_group_by('"issue"."fully_frozen"')
189 :add_group_by('"issue"."closed"')
190 :add_group_by('"issue"."ranks_available"')
191 :add_group_by('"issue"."status_quo_schulze_rank"')
192 :add_group_by('"issue"."cleaned"')
193 :add_group_by('"issue"."snapshot"')
194 :add_group_by('"issue"."latest_snapshot_event"')
195 :add_group_by('"issue"."population"')
196 :add_group_by('"issue"."voter_count"')
197 :add_group_by('"issue"."admission_time"')
198 :add_group_by('"issue"."discussion_time"')
199 :add_group_by('"issue"."verification_time"')
200 :add_group_by('"issue"."voting_time"')
201 :add_group_by('"_interest"."member_id"')
202 :add_group_by("_delegating_interest.delegate_member_ids")
203 --:set_distinct()
204 end
206 function Issue:modify_selector_for_state(initiatives_selector, state)
207 if state == "new" then
208 initiatives_selector:add_where("issue.accepted ISNULL AND issue.closed ISNULL")
209 elseif state == "accepted" then
210 initiatives_selector:add_where("issue.accepted NOTNULL AND issue.half_frozen ISNULL AND issue.closed ISNULL")
211 elseif state == "frozen" then
212 initiatives_selector:add_where("issue.half_frozen NOTNULL AND issue.fully_frozen ISNULL AND issue.closed ISNULL")
213 elseif state == "voting" then
214 initiatives_selector:add_where("issue.fully_frozen NOTNULL AND issue.closed ISNULL")
215 elseif state == "finished" then
216 initiatives_selector:add_where("issue.fully_frozen NOTNULL AND issue.closed NOTNULL")
217 elseif state == "cancelled" then
218 initiatives_selector:add_where("issue.fully_frozen ISNULL AND issue.closed NOTNULL")
219 else
220 error("Invalid state")
221 end
222 end
224 function Issue.object_get:state()
225 if self.closed then
226 if self.fully_frozen then
227 return "finished"
228 else
229 return "cancelled"
230 end
231 elseif self.fully_frozen then
232 return "voting"
233 elseif self.half_frozen then
234 return "frozen"
235 elseif self.accepted then
236 return "accepted"
237 else
238 return "new"
239 end
241 end
243 function Issue.object_get:state_name()
244 return Issue:get_state_name_for_state(self.state)
245 end
247 function Issue.object_get:state_time_left()
248 local state = self.state
249 local last_event_time
250 local duration
251 if state == "new" then
252 last_event_time = self.created
253 duration = self.admission_time
254 elseif state == "accepted" then
255 last_event_time = self.accepted
256 duration = self.discussion_time
257 elseif state == "frozen" then
258 last_event_time = self.half_frozen
259 duration = self.verification_time
260 elseif state == "voting" then
261 last_event_time = self.fully_frozen
262 duration = self.voting_time
263 end
264 return db:query{ "SELECT ?::timestamp + ?::interval - CURRENT_TIMESTAMP(0) as time_left", last_event_time, duration }[1].time_left
265 end
267 function Issue.object_get:next_states()
268 local state = self.state
269 local next_states
270 if state == "new" then
271 next_states = { "accepted", "cancelled" }
272 elseif state == "accepted" then
273 next_states = { "frozen" }
274 elseif state == "frozen" then
275 next_states = { "voting" }
276 elseif state == "voting" then
277 next_states = { "finished" }
278 end
279 return next_states
280 end
282 function Issue.object_get:next_states_names()
283 local next_states = self.next_states
284 if not next_states then
285 return
286 end
287 local state_names = {}
288 for i, state in ipairs(self.next_states) do
289 state_names[#state_names+1] = Issue:get_state_name_for_state(state)
290 end
291 return table.concat(state_names, ", ")
292 end
294 function Issue.object_get:etherpad_url()
295 return config.etherpad.base_url .. "p/" .. config.etherpad.group_id .. "$Issue" .. self.id
296 end