123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101 |
- function modpol.orgs:call_module(module_name, initiator, config, result)
- if not modpol.modules[module_name] then
- modpol.ocutil.log('Error in ' .. self.name .. ':call_module -> module "' .. module_name .. '" not found')
- return
- end
- local empty_index = nil
- -- linear search for empty process slots (lazy deletion)
- for k, v in ipairs(self.processes) do
- if v == 'deleted' then
- empty_index = k
- break
- end
- end
- local index
- -- attempts to fill empty spots in list, otherwise appends to end
- if empty_index then
- index = empty_index
- else
- index = #self.processes + 1
- end
- local module = modpol.modules[module_name]
- -- sets default values for undeclared config variables
- if module.config then
- for k, v in pairs(module.config) do
- if config[k] == nil then
- config[k] = v
- end
- end
- end
- -- setting default params
- local new_process = {
- metatable = {__index = module},
- initiator = initiator,
- org = self,
- id = index,
- config = config,
- name = module_name
- }
- -- copying default fields from setup
- for k, v in pairs(module.setup) do
- new_process[k] = v
- end
- setmetatable(new_process, new_process.metatable)
- self.processes[index] = new_process
- self.processes[index]:initiate(result)
- return index
- end
- function modpol.orgs:delete_process(id)
- self.processes[id] = 'deleted'
- end
- function modpol.orgs:add_pending_action(process_id, user, callback)
- self.pending[user] = self.pending[user] or {}
- self.pending[user][process_id] = callback
- end
- function modpol.orgs:remove_pending_action(process_id, user)
- if self.pending[user] then
- self.pending[user][process_id] = nil
- end
- end
- function modpol.orgs:wipe_pending_actions(process_id)
- for user in pairs(self.pending) do
- self.pending[user][process_id] = nil
- end
- end
- function modpol.orgs:has_pending_actions()
- -- next() will return the next pair in a table
- -- if next() returns nil, the table is empty
- if not self.pending[user] then
- return false
- else
- if not next(self.pending[user]) then
- return false
- else
- return true
- end
- end
- end
- function modpol.orgs:interact(process_id, user)
- local process = self.processes[process_id]
- if self.pending[user] then
- local callback = self.pending[user][process_id]
- if callback then
- process[callback](process, user)
- end
- end
- end
|