process.lua 3.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118
  1. --- Process functions for orgs
  2. function modpol.orgs:call_module(module_slug, initiator, config, result)
  3. if not modpol.modules[module_slug] then
  4. modpol.ocutil.log('Error in ' .. self.name .. ':call_module -> module "' .. module_slug .. '" not found')
  5. return
  6. end
  7. local empty_index = nil
  8. -- linear search for empty process slots (lazy deletion)
  9. for k, v in ipairs(self.processes) do
  10. if v == 'deleted' then
  11. empty_index = k
  12. break
  13. end
  14. end
  15. local index
  16. -- attempts to fill empty spots in list, otherwise appends to end
  17. if empty_index then
  18. index = empty_index
  19. else
  20. index = #self.processes + 1
  21. end
  22. local module = modpol.modules[module_slug]
  23. -- sets default values for undeclared config variables
  24. if modpol.util.num_pairs(module.config) > 0 and config then
  25. for k, v in pairs(module.config) do
  26. if config[k] == nil then
  27. config[k] = v
  28. end
  29. end
  30. end
  31. -- setting default params
  32. local new_process = {
  33. metatable = {__index = module},
  34. initiator = initiator,
  35. org = self,
  36. id = index,
  37. config = config,
  38. data = module.data,
  39. slug = module_slug
  40. }
  41. setmetatable(new_process, new_process.metatable)
  42. self.processes[index] = new_process
  43. self.processes[index]:initiate(result)
  44. local msg = "Initiating "..module_slug..
  45. " process id "..index.." in org "..self.name
  46. return index
  47. end
  48. function modpol.orgs:delete_process(id)
  49. if self.processes[id]
  50. and self.processes[id] ~= "deleted" then
  51. local msg = "Deleting "..self.processes[id].slug..
  52. " process id "..id.." in org "..self.name
  53. self:record(msg, self.processes[id].slug)
  54. self:wipe_pending_actions(id)
  55. self.processes[id] = 'deleted'
  56. end
  57. end
  58. function modpol.orgs:add_pending_action(process_id, user, callback)
  59. self.pending[user] = self.pending[user] or {}
  60. self.pending[user][process_id] = callback
  61. modpol.interactions.message(
  62. user, "New pending action in org "..self.name)
  63. end
  64. function modpol.orgs:remove_pending_action(process_id, user)
  65. if self.pending[user] then
  66. self.pending[user][process_id] = nil
  67. end
  68. end
  69. function modpol.orgs:wipe_pending_actions(process_id)
  70. for user in pairs(self.pending) do
  71. self.pending[user][process_id] = nil
  72. end
  73. end
  74. function modpol.orgs:has_pending_actions(user)
  75. -- next() will return the next pair in a table
  76. -- if next() returns nil, the table is empty
  77. if not self.pending[user] then
  78. return false
  79. else
  80. if not next(self.pending[user]) then
  81. return false
  82. else
  83. return true
  84. end
  85. end
  86. end
  87. function modpol.orgs:interact(process_id, user)
  88. local process = self.processes[process_id]
  89. if self.pending[user] then
  90. local callback = self.pending[user][process_id]
  91. if callback and process ~= "deleted" then
  92. -- get data in case callback ends process
  93. local slug = self.processes[process_id].slug
  94. -- run callback
  95. process[callback](process, user)
  96. -- record org data
  97. local msg = "Updating "..slug..
  98. " process id "..process_id.." in org "..self.name
  99. self:record(msg, slug)
  100. end
  101. end
  102. end