| 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 |