process.lua 2.6 KB

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