spacepaste

Paste details

reply | raw | toggle line wrapping

/lib/service.lua

  1.  
  2. local c = require('component')
  3. local text = require('text')
  4. local event = require('event')
  5. local process = require('process')
  6. local unicode = require('unicode')
  7. local computer = require('computer')
  8. local serialization = require('serialization')
  11. local service = {}
  12. local log_gpu
  13. local cursorX, cursorY = 1, 1
  15. do
  16. local config_file = io.open('/etc/service-log.cfg')
  17. if config_file then
  18. local data = serialization.unserialize(config_file:read('*a'))
  19. log_gpu = c.proxy(c.get(data.gpu))
  20. local success, msg = log_gpu.bind(c.get(data.screen))
  21. if not success then
  22. error(msg)
  23. end
  24. if data.resolution then
  25. log_gpu.setResolution(table.unpack(data.resolution))
  26. end
  27. config_file:close()
  28. end
  29. end
  31. function service.log(msg, ...)
  32. local value = string.format('[%08.0f] ' .. msg .. '\n',
  33. computer.uptime(), ...)
  34. if not log_gpu then
  35. return
  36. end
  37. value = text.detab(value)
  38. local w, h = log_gpu.getResolution()
  39. if not w then
  40. return -- gpu lost its screen but the signal wasn't processed yet.
  41. end
  42. local line, nl
  43. repeat
  44. local wrapAfter, margin = math.huge, math.huge
  45. wrapAfter, margin = w - (cursorX - 1), w
  46. line, value, nl = text.wrap(value, wrapAfter, margin)
  47. log_gpu.set(cursorX, cursorY, line)
  48. cursorX = cursorX + unicode.wlen(line)
  49. if nl or cursorX > w then
  50. cursorX = 1
  51. cursorY = cursorY + 1
  52. end
  53. if cursorY > h then
  54. log_gpu.copy(1, 1, w, h, 0, -1)
  55. log_gpu.fill(1, h, w, 1, " ")
  56. cursorY = h
  57. end
  58. until not value
  59. end
  61. local function step_coroutine(c, return_on_error)
  62. local status = coroutine.status(c)
  63. if status == 'dead' then
  64. return false
  65. elseif status ~= 'suspended' then
  66. return true
  67. end
  68. local t = {coroutine.resume(c)}
  69. if not t[1] then
  70. service.log('problem in %s: %s', c, t[2])
  71. service.log('%s', debug.traceback(c))
  72. if return_on_error then
  73. return false
  74. else
  75. error('coroutine failure')
  76. end
  77. else
  78. return true
  79. end
  80. end
  82. function service.periodic(name, period, f, env)
  83. local t
  84. local want_up = false
  85. local function service_coroutine()
  86. while true do
  87. local c = coroutine.create(f)
  88. while true do
  89. if not step_coroutine(c) then
  90. break
  91. end
  92. coroutine.yield()
  93. end
  94. end
  95. end
  96. function start_service()
  97. if t then
  98. return
  99. end
  100. local c = process.spawn(service_coroutine)
  101. local function step()
  102. if not step_coroutine(c, true) then
  103. stop_service()
  104. end
  105. end
  106. t = event.timer(period, step, math.huge)
  107. service.log('Started %s', name)
  108. end
  109. local function stop_service()
  110. if not t then
  111. return
  112. end
  113. event.cancel(t)
  114. t = nil
  115. service.log('Stopped %s', name)
  116. if want_up then
  117. start_service()
  118. end
  119. end
  120. function env.start()
  121. want_up = true
  122. start_service()
  123. end
  124. function env.stop()
  125. want_up = false
  126. stop_service()
  127. end
  128. function env.status()
  129. if t then
  130. print('running')
  131. else
  132. print('stopped')
  133. end
  134. end
  135. end
  137. return service
  138.  

an extra bit in /lib/process.lua

  1.  
  2. function process.spawn(f, env, name, path)
  3. checkArg(1, f, "function")
  4. checkArg(2, env, "table", "nil")
  5. checkArg(3, name, "string", "nil")
  6. checkArg(4, path, "string", "nil")
  8. local process = findProcess()
  9. if process then
  10. env = env or process.env
  11. end
  12. if not path then
  13. path = '<function>'
  14. end
  15. env = setmetatable({}, {__index=env or _G})
  16. local thread = coroutine_create(f)
  17. running[thread] = {
  18. path = path,
  19. command = name,
  20. env = env,
  21. data = setmetatable({}, {__index=process and process.data or nil}),
  22. parent = process,
  23. instances = setmetatable({}, {__mode="v"})
  24. }
  25. return thread
  26. end
  27.  

/etc/rc.d/autocraft.lua

  1.  
  2. local serialization = require('serialization')
  3. local sides = require('sides')
  4. local computer = require('computer')
  5. local c = require('component')
  6. local service = require('service')
  8. local log = service.log
  10. local controller = c.me_controller
  12. local required_levels = {
  13. ['Wool'] = 8,
  14. ['Transistor'] = 10,
  15. ['Microchip (Tier 1)'] = 10,
  16. ['Microchip (Tier 2)'] = 10,
  17. ['Microchip (Tier 3)'] = 10,
  18. ['Iron Nugget'] = 10,
  19. ['Gold Nugget'] = 10,
  20. ['Basic Universal Cable'] = 32,
  21. ['Ultimate Universal Cable'] = 32,
  22. ['Redstone Torch'] = 4,
  23. ['Machine Frame (Basic)'] = 2,
  24. ['Redstone Reception Coil'] = 2,
  25. ['Paper'] = {128, 256},
  26. ['Book'] = {128, 256},
  27. ['ME Glass Cable - Fluix'] = 32,
  28. ['Logic Processor'] = 4,
  29. ['Calculation Processor'] = 4,
  30. ['Engineering Processor'] = 4,
  31. ['Speed Upgrade'] = 8,
  32. ['Energy Upgrade'] = 8,
  33. ['ME Smart Cable - Fluix'] = 8,
  34. ['ME Dense Cable - Fluix'] = 8,
  35. ['ME Storage Housing'] = 2,
  36. ['Arithmetic Logic Unit (ALU)'] = 2,
  37. ['Control Unit (CU)'] = 2,
  38. ['EEPROM (Lua BIOS)'] = 2,
  39. ['EEPROM'] = 2,
  40. ['Printed Silicon'] = {128, 256},
  41. }
  43. function ensure_level(label, desired)
  44. local filter = {label = label}
  45. local items = controller.getItemsInNetwork(filter)
  46. local count = 0
  47. for i = 1, items.n do
  48. count = count + items[i].size
  49. end
  50. local lower_bound = desired
  51. if type(desired) == 'table' then
  52. lower_bound, desired = table.unpack(desired)
  53. end
  54. if count >= lower_bound then
  55. return
  56. end
  57. local crafting = controller.getCraftables(filter)[1]
  58. if not crafting then
  59. log('No crafting available for %s', label)
  60. return
  61. end
  62. local stack_size = crafting.getItemStack().size
  63. local n_jobs = math.ceil((desired - count) / stack_size)
  64. log('Crafting %s (%d → %d)',
  65. label, count, count + stack_size * n_jobs, n_jobs)
  66. local status = crafting.request(desired - count)
  67. while not (status.isCanceled() or status.isDone()) do
  68. os.sleep(1)
  69. end
  70. end
  72. function tick()
  73. for label, count in pairs(required_levels) do
  74. ensure_level(label, count)
  75. coroutine.yield()
  76. end
  77. end
  79. service.periodic('autocraft', 0.1, tick, _ENV)
  80.  

/etc/rc.d/export-damaged.lua

  1.  
  2. local serialization = require('serialization')
  3. local sides = require('sides')
  4. local computer = require('computer')
  5. local c = require('component')
  6. local service = require('service')
  8. local controller = c.me_controller
  9. local export = c.me_exportbus
  10. local db = c.database
  12. local label_patterns = {
  13. 'Boots',
  14. 'Leggings',
  15. 'Chestplate',
  16. 'Helmet',
  17. '^Bow$',
  18. 'Fishing Rod',
  19. 'Sword',
  20. 'Pickaxe',
  21. 'Shovel',
  22. 'Axe',
  23. 'Shears',
  24. }
  26. function label_ok(item)
  27. for _, pattern in pairs(label_patterns) do
  28. if item.label:find(pattern) then
  29. return true
  30. end
  31. end
  32. return false
  33. end
  35. function clear_whole_db()
  36. for i = 1, 9 do
  37. db.clear(i)
  38. end
  39. end
  41. function export_relevant_items()
  42. local items = controller.getItemsInNetwork()
  43. local n_done = 0
  44. for i = 1, items.n do
  45. local item = items[i]
  46. if label_ok(item) and item.damage > 0 and not item.enchantments then
  47. controller.store(item, db.address)
  48. n_done = n_done + 1
  49. if n_done >= 9 then
  50. break
  51. end
  52. end
  53. end
  54. for i = 1, 9 do
  55. local item = db.get(i)
  56. if not item then
  57. break
  58. end
  59. service.log('Exporting %s@%d', item.label, item.damage)
  60. export.setExportConfiguration(sides.back, i, db.address, i)
  61. end
  62. end
  64. function tick()
  65. clear_whole_db()
  66. export_relevant_items()
  67. end
  69. service.periodic('export-damaged', 10, tick, _ENV)
  70.  
Powered by spacepaste. Paste removal.