rev |
line source |
bsw/jbe@0
|
1 Initiative = mondelefant.new_class()
|
bsw/jbe@0
|
2 Initiative.table = 'initiative'
|
bsw/jbe@0
|
3
|
bsw/jbe@0
|
4 Initiative:add_reference{
|
bsw/jbe@0
|
5 mode = 'm1',
|
bsw/jbe@0
|
6 to = "Issue",
|
bsw/jbe@0
|
7 this_key = 'issue_id',
|
bsw/jbe@0
|
8 that_key = 'id',
|
bsw/jbe@0
|
9 ref = 'issue',
|
bsw/jbe@0
|
10 }
|
bsw/jbe@0
|
11
|
bsw/jbe@0
|
12 Initiative:add_reference{
|
bsw/jbe@0
|
13 mode = '1m',
|
bsw/jbe@0
|
14 to = "Draft",
|
bsw/jbe@0
|
15 this_key = 'id',
|
bsw/jbe@0
|
16 that_key = 'initiative_id',
|
bsw/jbe@0
|
17 ref = 'drafts',
|
bsw/jbe@0
|
18 back_ref = 'initiative',
|
bsw/jbe@19
|
19 default_order = '"id" DESC'
|
bsw/jbe@0
|
20 }
|
bsw/jbe@0
|
21
|
bsw/jbe@0
|
22 Initiative:add_reference{
|
bsw/jbe@0
|
23 mode = '1m',
|
bsw/jbe@0
|
24 to = "Suggestion",
|
bsw/jbe@0
|
25 this_key = 'id',
|
bsw/jbe@0
|
26 that_key = 'initiative_id',
|
bsw/jbe@0
|
27 ref = 'suggestions',
|
bsw/jbe@0
|
28 back_ref = 'initiative',
|
bsw/jbe@0
|
29 }
|
bsw/jbe@0
|
30
|
bsw/jbe@0
|
31 Initiative:add_reference{
|
bsw/jbe@0
|
32 mode = '1m',
|
bsw/jbe@0
|
33 to = "Initiator",
|
bsw/jbe@0
|
34 this_key = 'id',
|
bsw/jbe@0
|
35 that_key = 'initiative_id',
|
bsw/jbe@0
|
36 ref = 'initiators',
|
bsw@10
|
37 back_ref = 'initiative'
|
bsw/jbe@0
|
38 }
|
bsw/jbe@0
|
39
|
bsw/jbe@0
|
40 Initiative:add_reference{
|
bsw/jbe@0
|
41 mode = '1m',
|
bsw/jbe@0
|
42 to = "Supporter",
|
bsw/jbe@0
|
43 this_key = 'id',
|
bsw/jbe@0
|
44 that_key = 'initiative_id',
|
bsw/jbe@0
|
45 ref = 'supporters',
|
bsw/jbe@0
|
46 back_ref = 'initiative',
|
bsw/jbe@0
|
47 default_order = '"id"'
|
bsw/jbe@0
|
48 }
|
bsw/jbe@0
|
49
|
bsw/jbe@0
|
50 Initiative:add_reference{
|
bsw/jbe@0
|
51 mode = '1m',
|
bsw/jbe@0
|
52 to = "Opinion",
|
bsw/jbe@0
|
53 this_key = 'id',
|
bsw/jbe@0
|
54 that_key = 'initiative_id',
|
bsw/jbe@0
|
55 ref = 'opinions',
|
bsw/jbe@0
|
56 back_ref = 'initiative',
|
bsw/jbe@0
|
57 default_order = '"id"'
|
bsw/jbe@0
|
58 }
|
bsw/jbe@0
|
59
|
bsw/jbe@0
|
60 Initiative:add_reference{
|
bsw/jbe@0
|
61 mode = '1m',
|
bsw/jbe@0
|
62 to = "Vote",
|
bsw/jbe@0
|
63 this_key = 'id',
|
bsw/jbe@0
|
64 that_key = 'initiative_id',
|
bsw/jbe@0
|
65 ref = 'votes',
|
bsw/jbe@0
|
66 back_ref = 'initiative',
|
bsw/jbe@0
|
67 default_order = '"member_id"'
|
bsw/jbe@0
|
68 }
|
bsw/jbe@0
|
69
|
bsw/jbe@0
|
70 Initiative:add_reference{
|
bsw@10
|
71 mode = 'm1',
|
bsw@10
|
72 to = "Initiative",
|
bsw@10
|
73 this_key = 'suggested_initiative_id',
|
bsw@10
|
74 that_key = 'id',
|
bsw@10
|
75 ref = 'suggested_initiative',
|
bsw@10
|
76 }
|
bsw@10
|
77
|
bsw@10
|
78 Initiative:add_reference{
|
bsw/jbe@0
|
79 mode = 'mm',
|
bsw/jbe@0
|
80 to = "Member",
|
bsw/jbe@0
|
81 this_key = 'id',
|
bsw/jbe@0
|
82 that_key = 'id',
|
bsw/jbe@0
|
83 connected_by_table = '"initiator"',
|
bsw/jbe@0
|
84 connected_by_this_key = 'initiative_id',
|
bsw/jbe@0
|
85 connected_by_that_key = 'member_id',
|
bsw/jbe@0
|
86 ref = 'initiating_members'
|
bsw/jbe@0
|
87 }
|
bsw/jbe@0
|
88
|
bsw/jbe@0
|
89 Initiative:add_reference{
|
bsw/jbe@0
|
90 mode = 'mm',
|
bsw/jbe@0
|
91 to = "Member",
|
bsw/jbe@0
|
92 this_key = 'id',
|
bsw/jbe@0
|
93 that_key = 'id',
|
bsw/jbe@0
|
94 connected_by_table = '"supporter"',
|
bsw/jbe@0
|
95 connected_by_this_key = 'initiative_id',
|
bsw/jbe@0
|
96 connected_by_that_key = 'member_id',
|
bsw/jbe@0
|
97 ref = 'supporting_members'
|
bsw/jbe@0
|
98 }
|
bsw/jbe@0
|
99
|
bsw@3
|
100 Initiative:add_reference{
|
bsw@3
|
101 mode = 'mm',
|
bsw@3
|
102 to = "Member",
|
bsw@3
|
103 this_key = 'id',
|
bsw@3
|
104 that_key = 'id',
|
bsw@3
|
105 connected_by_table = 'direct_supporter_snapshot',
|
bsw@3
|
106 connected_by_this_key = 'initiative_id',
|
bsw@3
|
107 connected_by_that_key = 'member_id',
|
bsw@3
|
108 ref = 'supporting_members_snapshot'
|
bsw@3
|
109 }
|
bsw@3
|
110
|
bsw@551
|
111 Initiative:add_reference{
|
bsw@551
|
112 mode = "11",
|
bsw@551
|
113 to = mondelefant.class_prototype,
|
bsw@551
|
114 this_key = "id",
|
bsw@551
|
115 that_key = "initiative_id",
|
bsw@551
|
116 ref = "member_info",
|
bsw@551
|
117 back_ref = "initiative",
|
bsw@551
|
118 selector_generator = function(list, options)
|
bsw@551
|
119 assert(options.member_id, "member_id mandatory for member_info")
|
bsw@551
|
120 local ids = { sep = ", " }
|
bsw@551
|
121 local issue_ids = { sep = ", " }
|
bsw@551
|
122 for i, object in ipairs(list) do
|
bsw@551
|
123 local id = object.id
|
bsw@551
|
124 if id ~= nil then
|
bsw@551
|
125 ids[#ids+1] = {"?", id}
|
bsw@551
|
126 issue_ids[#issue_ids+1] = { "?", object.issue_id }
|
bsw@551
|
127 end
|
bsw@551
|
128 end
|
bsw@551
|
129
|
bsw@551
|
130 local sub_selector = Issue:get_db_conn():new_selector()
|
bsw@551
|
131 if #ids == 0 then
|
bsw@551
|
132 return sub_selector:empty_list_mode()
|
bsw@551
|
133 end
|
bsw@551
|
134 sub_selector:from("issue")
|
bsw@551
|
135 sub_selector:add_field("issue.id", "issue_id")
|
bsw@551
|
136 sub_selector:add_field{ '(delegation_info(?, null, null, issue.id, ?)).*', options.member_id, options.trustee_id }
|
bsw@551
|
137 sub_selector:add_where{ 'issue.id IN ($)', issue_ids }
|
bsw@551
|
138
|
bsw@551
|
139 local selector = Initiative:get_db_conn():new_selector()
|
bsw@551
|
140 selector:add_from("initiative")
|
bsw@551
|
141 selector:add_field("initiative.id", "initiative_id")
|
bsw@551
|
142 selector:join("issue", nil, "issue.id = initiative.issue_id")
|
bsw@551
|
143 selector:join(sub_selector, "delegation_info", "delegation_info.issue_id = issue.id")
|
bsw@551
|
144 selector:add_field("delegation_info.*")
|
bsw@551
|
145
|
bsw@551
|
146 selector:left_join("supporter", nil, "supporter.initiative_id = initiative.id AND supporter.member_id = delegation_info.participating_member_id")
|
bsw@551
|
147
|
bsw@551
|
148 selector:left_join("delegating_interest_snapshot", "delegating_interest_s", { "delegating_interest_s.event = issue.latest_snapshot_event AND delegating_interest_s.issue_id = issue.id AND delegating_interest_s.member_id = ?", options.member_id })
|
bsw@551
|
149
|
bsw@551
|
150 selector:left_join("direct_supporter_snapshot", "supporter_s", { "supporter_s.event = issue.latest_snapshot_event AND supporter_s.initiative_id = initiative.id AND (supporter_s.member_id = ? OR supporter_s.member_id = delegating_interest_s.delegate_member_ids[array_upper(delegating_interest_s.delegate_member_ids, 1)])", options.member_id })
|
bsw@551
|
151
|
bsw@551
|
152 selector:add_field("CASE WHEN issue.fully_frozen ISNULL AND issue.closed ISNULL THEN supporter.member_id NOTNULL ELSE supporter_s.member_id NOTNULL END", "supported")
|
bsw@551
|
153 selector:add_field({ "CASE WHEN issue.fully_frozen ISNULL AND issue.closed ISNULL THEN delegation_info.own_participation AND supporter.member_id NOTNULL ELSE supporter_s.member_id = ? END", options.member_id }, "directly_supported")
|
bsw@551
|
154
|
bsw@551
|
155 selector:add_field("CASE WHEN issue.fully_frozen ISNULL AND issue.closed ISNULL THEN supporter.member_id NOTNULL AND NOT EXISTS(SELECT 1 FROM critical_opinion WHERE critical_opinion.initiative_id = initiative.id AND critical_opinion.member_id = delegation_info.participating_member_id) ELSE supporter_s.satisfied NOTNULL END", "satisfied")
|
bsw@551
|
156
|
bsw@551
|
157
|
bsw@551
|
158 --selector:add_field("", "informed")
|
bsw@551
|
159 selector:left_join("initiator", nil, { "initiator.initiative_id = initiative.id AND initiator.member_id = ? AND initiator.accepted", options.member_id })
|
bsw@551
|
160 selector:add_field("initiator.member_id NOTNULL", "initiated")
|
bsw@551
|
161
|
bsw@551
|
162 return selector
|
bsw@551
|
163 end
|
bsw@551
|
164 }
|
bsw@551
|
165
|
bsw@551
|
166 function Initiative.list:load_everything_for_member_id(member_id)
|
bsw@551
|
167 if member_id then
|
bsw@551
|
168 self:load("member_info", { member_id = member_id })
|
bsw@551
|
169 end
|
bsw@551
|
170 end
|
bsw@551
|
171
|
bsw@551
|
172 function Initiative.object:load_everything_for_member_id(member_id)
|
bsw@551
|
173 if member_id then
|
bsw@551
|
174 self:load("member_info", { member_id = member_id })
|
bsw@551
|
175 end
|
bsw@551
|
176 end
|
bsw@551
|
177
|
bsw@551
|
178
|
bsw@551
|
179
|
bsw/jbe@6
|
180
|
bsw@2
|
181 function Initiative:get_search_selector(search_string)
|
bsw/jbe@0
|
182 return self:new_selector()
|
bsw/jbe@6
|
183 :join("draft", nil, "draft.initiative_id = initiative.id")
|
bsw@2
|
184 :add_field( {'"highlight"("initiative"."name", ?)', search_string }, "name_highlighted")
|
bsw/jbe@6
|
185 :add_where{ '"initiative"."text_search_data" @@ "text_search_query"(?) OR "draft"."text_search_data" @@ "text_search_query"(?)', search_string, search_string }
|
bsw/jbe@6
|
186 :add_group_by('"initiative"."id"')
|
bsw/jbe@6
|
187 :add_group_by('"initiative"."issue_id"')
|
bsw/jbe@6
|
188 :add_group_by('"initiative"."name"')
|
bsw/jbe@6
|
189 :add_group_by('"initiative"."discussion_url"')
|
bsw/jbe@6
|
190 :add_group_by('"initiative"."created"')
|
bsw/jbe@6
|
191 :add_group_by('"initiative"."revoked"')
|
bsw@481
|
192 :add_group_by('"initiative"."revoked_by_member_id"')
|
bsw/jbe@6
|
193 :add_group_by('"initiative"."admitted"')
|
bsw/jbe@6
|
194 :add_group_by('"initiative"."supporter_count"')
|
bsw/jbe@6
|
195 :add_group_by('"initiative"."informed_supporter_count"')
|
bsw/jbe@6
|
196 :add_group_by('"initiative"."satisfied_supporter_count"')
|
bsw/jbe@6
|
197 :add_group_by('"initiative"."satisfied_informed_supporter_count"')
|
bsw/jbe@6
|
198 :add_group_by('"initiative"."positive_votes"')
|
bsw/jbe@6
|
199 :add_group_by('"initiative"."negative_votes"')
|
bsw@482
|
200 :add_group_by('"initiative"."direct_majority"')
|
bsw@482
|
201 :add_group_by('"initiative"."indirect_majority"')
|
bsw@482
|
202 :add_group_by('"initiative"."schulze_rank"')
|
bsw@482
|
203 :add_group_by('"initiative"."better_than_status_quo"')
|
bsw@482
|
204 :add_group_by('"initiative"."worse_than_status_quo"')
|
bsw@482
|
205 :add_group_by('"initiative"."reverse_beat_path"')
|
bsw@482
|
206 :add_group_by('"initiative"."multistage_majority"')
|
bsw@482
|
207 :add_group_by('"initiative"."eligible"')
|
bsw@482
|
208 :add_group_by('"initiative"."winner"')
|
bsw/jbe@6
|
209 :add_group_by('"initiative"."rank"')
|
bsw/jbe@19
|
210 :add_group_by('"initiative"."suggested_initiative_id"')
|
bsw/jbe@6
|
211 :add_group_by('"initiative"."text_search_data"')
|
bsw/jbe@6
|
212 :add_group_by('"issue"."population"')
|
bsw/jbe@19
|
213 :add_group_by("_initiator.member_id")
|
bsw/jbe@19
|
214 :add_group_by("_supporter.member_id")
|
bsw@361
|
215 :add_group_by("_direct_supporter_snapshot.member_id")
|
bsw/jbe@0
|
216 end
|
bsw/jbe@0
|
217
|
bsw@558
|
218 function Initiative:selector_for_updated_drafts(member_id)
|
bsw@558
|
219 return Initiative:new_selector()
|
bsw@558
|
220 :join("issue", "_issue_state", "_issue_state.id = initiative.issue_id AND _issue_state.closed ISNULL AND _issue_state.fully_frozen ISNULL")
|
bsw@558
|
221 :join("current_draft", "_current_draft", "_current_draft.initiative_id = initiative.id")
|
bsw@558
|
222 :join("supporter", "supporter", { "supporter.member_id = ? AND supporter.initiative_id = initiative.id AND supporter.draft_id < _current_draft.id", member_id })
|
bsw@558
|
223 :add_where("initiative.revoked ISNULL")
|
bsw@558
|
224 end
|
bsw@2
|
225
|
bsw@2
|
226
|
bsw/jbe@0
|
227 function Initiative.object_get:current_draft()
|
bsw/jbe@0
|
228 return Draft:new_selector()
|
bsw/jbe@0
|
229 :add_where{ '"initiative_id" = ?', self.id }
|
bsw/jbe@0
|
230 :add_order_by('"id" DESC')
|
bsw/jbe@0
|
231 :single_object_mode()
|
bsw/jbe@0
|
232 :exec()
|
bsw/jbe@0
|
233 end
|
bsw/jbe@0
|
234
|
bsw/jbe@0
|
235 function Initiative.object_get:shortened_name()
|
bsw/jbe@0
|
236 local name = self.name
|
bsw/jbe@0
|
237 if #name > 100 then
|
bsw/jbe@0
|
238 name = name:sub(1,100) .. "..."
|
bsw/jbe@0
|
239 end
|
bsw/jbe@0
|
240 return name
|
bsw/jbe@0
|
241 end
|
bsw/jbe@52
|
242
|
bsw/jbe@52
|
243 function Initiative.object_get:initiator_names()
|
bsw/jbe@52
|
244 local members = Member:new_selector()
|
bsw/jbe@52
|
245 :join("initiator", nil, "initiator.member_id = member.id")
|
bsw/jbe@52
|
246 :add_where{ "initiator.initiative_id = ?", self.id }
|
bsw/jbe@52
|
247 :add_where{ "initiator.accepted" }
|
bsw/jbe@52
|
248 :exec()
|
bsw/jbe@52
|
249
|
bsw/jbe@52
|
250 local member_names = {}
|
bsw/jbe@52
|
251 for i, member in ipairs(members) do
|
bsw/jbe@52
|
252 member_names[#member_names+1] = member.name
|
bsw/jbe@52
|
253 end
|
bsw/jbe@52
|
254 return member_names
|
bsw/jbe@52
|
255 end
|
bsw/jbe@52
|
256
|