microexpansion/modules/network/autocraft.lua

local me = microexpansion

local pipeworks_craft_time = 1

function me.autocraft_next_start(net)
  -- We use machine reservations to allow simultaneous crafting jobs
  -- todo: implement a limiter or a power consumption or 'crafting
  -- cpus' for realism.
  local parallel = true
  if not parallel and net.pending then
    -- start subsequent autocrafting jobs sequentially.
    -- We really only need zero/not zero for build to queue actions or not
    return net.pending.time[net.pending.max_index]
  end
  return 0
end

function me.start_crafting(pos, step_time)
  local meta = minetest.get_meta(pos)
  local timer = minetest.get_node_timer(pos)
  timer:set(step_time, 0)
end

local function round(v)
  return math.floor(v + 0.5)
end

-- technic_plus doesn't export machine speed.  We
-- use this to know exactly how long a machine will take to process
-- anything, after that time, we know it is done and we can grab the
-- outputs, no polling. We do this for efficiency.
me.speed = {
  ["default:furnace"] = 1,
}

-- Use to wire in how long a machine takes to process something.
function me.set_speed(name, speed)
  me.speed[name] = speed
end

-- Sometimes the poor autocrafter doesn't have infinite input and output room
-- for a craft, break large ones up to fit.
-- Also machine inputs/outputs don't fit.
me.maximums = {
}

-- Allow a maximum craft to be defined to avoid overrunning machine
-- inputs and outputs and the autocrafter inputs and output..
function me.register_max(name, count)
  me.maximums[name] = count
end

-- This reserves a machine for length seconds. This is used to
-- schedule machines and know when they are done processing a job.
-- The jobs run sequentially. A 10 second job followed by a 5 second
-- job will finish at 15 seconds, not 5 seconds.  Return the new start
-- time.  todo: this solves the end and the outputs, but not the
-- inputs.  They can be overloaded and we might have to delay putting
-- things into the machine.
function me.reserve(net, pos, original_start, length)
  if not net.pending then
    net.pending = {}
    net.pending.time = {}
  end
  if not net.pending.busy then
    net.pending.busy = {}
  end
  local free_time = net.pending.busy[pos] or 0
  local start = math.max(free_time, original_start)
  local ending = start + length
  net.pending.busy[pos] = ending
  return start
end

local length = function(a)
  local count = 0
  for k,v in pairs(a) do
    count = count + 1
  end
  return count
end

-- Testing: HV solar is realiable, big loans are screwy.
-- HV batteries are realiable.
local function build(net, cpos, inv, name, count, stack, sink, time)
  -- The autocrafters nor the machines can take really large amounts
  -- of things, help them out.
  local max = me.maximums[name]
  if not max then
    -- If no explicit max, assume this is a pipeworks autocrafter and
    -- it only has 12 outputs.
    max = stack:get_stack_max()*12
  end
  if net.process and net.process[name] then
    max = max * length(net.process[name])
  elseif net.autocrafters[name] then
    max = max * length(net.autocrafters[name])
  end
  me.log("AC: max is "..max , "error")
  if max and count > max then
    local next_time = time
    local built = true
    while count > 1 and built do
      local substack = ItemStack(stack)
      max = math.min(max, count)
      substack:set_count(max)
      local step_time
      built, step_time = build(net, cpos, inv, name, max, substack, sink, time)
      if not built then
        -- we are done, can't craft, so stop
      else
        next_time = math.max(next_time, time + step_time)
      end
      count = count - max
    end
    local step_time = next_time - time
    return built, step_time
  end
  me.log("BUILD: count is "..count.." and stack size is "..stack:get_count(), "error")
  local dat = {}
  local second_output = nil
  local main_action_time = count * pipeworks_craft_time + 1
  if net.process and net.process[name] then
    local machines = net.process[name]
    for k, v in pairs(machines) do
      local mname = minetest.get_node(k).name
      if not me.block_to_typename_map[mname] then
        -- There is no way this can be. Prune.
	-- Would be nice if we had a way to notice blocks going away.
	-- Maybe latch into on_destruct for them?
	net.process[name][k] = nil
        goto continue
      end
      local i = #dat + 1
      dat[i] = {}
      dat[i].apos = k
      dat[i].ipos = v
      dat[i].rinv = minetest.get_meta(dat[i].apos):get_inventory()
      -- todo: figure out if we should use total.
      if i == count then
        break
      end
      ::continue::
    end
    me.log("INT: looking up output "..name, "error")
    local inputs = me.find_by_output(name)
    local machine_name = minetest.get_node(dat[1].apos).name
    local typename = me.block_to_typename_map[machine_name]
    me.log("Looking up "..(typename or "nil").." recipe for a "..(machine_name or nil), "error")
    dat[1].recip = me.get_recipe(typename, inputs)
    me.log("MACHINE: "..machine_name.." typename is "..typename.." and time is "..tostring(dat[1].recip.time), "error")
    dat[1].recip.input = inputs
    -- freezer can produce two outputs, we only care about the first.
    if dat[1].recip.output[1] then
      second_output = dat[1].recip.output[2]
      dat[1].recip.output = dat[1].recip.output[1]
    end
    dat[1].ostack = ItemStack(dat[1].recip.output)
    -- me.log("SEE: "..machine_name.." "..minetest.serialize(technic.recipes))
    local speed = me.speed[machine_name]
    local craft_count = dat[1].ostack:get_count()
    local total = math.ceil(count/craft_count)
    -- Remove the extra machines.  In theory we could remove the busy machines.
    while #dat > total do
      table.remove(dat)
    end
    -- crafting 4 carbon plates misses taking 1 carbon plate on output, make this bigger
    -- we'll try 1 for now, figure out right formula.  1 looks perfect.  128 glue is short by 2
    -- 1  + 1 is a second too slow on the doped for 81., 2 +0 doesn't work, a second shy
    --main_action_time = round((total+2)*dat[1].recip.time/speed) + 1
    --main_action_time = (total+1)*round(dat[1].recip.time/speed) -- one shy
    --main_action_time = total*dat[1].recip.time/speed + 2 -- 2 at 80 shy, 3 at 160 shy
    local subtotal = math.floor((total+#dat-1)/#dat)
    --main_action_time = subtotal*1.025*dat[1].recip.time/speed + 2 -- ok
    --main_action_time = math.ceil(subtotal*1.02*dat[1].recip.time/speed) + 1 -- too fast?
    main_action_time = math.ceil(subtotal*1.02*dat[1].recip.time/speed) + 1.2 -- too fast?
    if second_output then
      second_output = ItemStack(second_output)
      second_output:set_count(second_output:get_count()*total)
    end
    me.log("MACHINE: "..machine_name.." is speed "..speed.." and final time is "..main_action_time, "error")
  elseif net.autocrafters[name] then
    -- fill all recipe slots, wait, grab all output slots
    -- "src" "dst" "recipe" "output"
    local machines = net.autocrafters[name]
    for k, v in pairs(machines) do
      local i = #dat + 1
      dat[i] = {}
      dat[i].apos = k
      dat[i].ipos = v
      dat[i].rinv = minetest.get_meta(dat[i].apos):get_inventory()
      -- TODO: If we set up pipeworks ac, then we remove interface for it and craft
      -- it goes to ac, and dies here. Flush net.autocrafters for all the
      -- attached inventories during interface removal.
      if dat[i].rinv == nil then
        me.log("no inventory", "error")
        return
      end
      dat[i].ostack = dat[i].rinv:get_stack("output", 1)
      if dat[i].ostack:get_name() ~= name then
        -- invalidate it
        net.autocrafters[name][dat[i].apos] = nil
        --me.log("invalidating autocrafter for "..name, "error")
	table.remove(dat)
	if #dat == 0 then
          return
	end
      end
      -- todo: figure out if we should use total.  Test with crafting planks.
      if i == total then
        break
      end
    end
    -- Consider looking up the recipe and finding the replacements that way.
    if name == "technic:copper_coil" or name == "technic:control_logic_unit"
       or name == "technic:solar_panel" then
      second_output = ItemStack("basic_materials:empty_spool 999")
    end
    local craft_count = dat[1].ostack:get_count()
    local total = math.ceil(count/craft_count)
    local subtotal = math.floor((total+#dat-1)/#dat)
    main_action_time = subtotal * pipeworks_craft_time + 1
  else
    me.log("can't craft a "..name, "error")
    return
  end
  for i = 1, #dat do
    dat[i].isink = function(sstack)
      me.log("TIMER: prep inputs, moving "..sstack:get_count().." "..sstack:get_name(), "error")
      return dat[i].rinv:add_item("src", sstack)
    end
  end
  local craft_count = dat[1].ostack:get_count()
  -- These will be returned to the me system
  local extra = ItemStack(name)
  local total = math.ceil(count/craft_count)
  extra:set_count(total*craft_count - count)
  me.log("AC: count "..count.." craft_count "..craft_count.." extra "..extra:get_count(), "error");
  -- we craft a minimum of count, to the multiple of the crafting count
  count = total
  me.log("AC: numcount "..count, "error");
  
  local consume = {}
  if net.process and net.process[name] then
    for i = 1, #dat[1].recip.input do
    local inp = dat[1].recip.input[i]
    me.log("MID: consuming "..inp:get_name().." count: "..count.." inp:getcount: "..inp:get_count(), "error")
    consume[inp:get_name()] = (consume[inp:get_name()] or 0) + count*inp:get_count()
    end
  else
    for i = 1, 9 do
      -- TODO: This assumes that all the crafters have the same exact recipe.
      local inp = dat[1].rinv:get_stack("recipe", i)
      if inp and not inp:is_empty() then
        consume[inp:get_name()] = (consume[inp:get_name()] or 0) + count*inp:get_count()
      end
    end
  end
  local replace = true
  local next_time = {}
  for i = 1, #dat do
    next_time[i] = me.reserve(net, dat[i].apos, time, main_action_time)
  end
  --me.log("RESERVE: "..name.." stime "..time.." step "..main_action_time.." reserve "..next_time[1], "error")
  me.log("PREP: pre count is "..count, "error")
  -- prepwork
  me.log("PREP: count is "..count, "error")
  local prepworkbits = {}
  local previous_ac_size = inv:get_size("ac")
  me.log("PREP: ac size at top is "..previous_ac_size, "error")
  for name, count in pairs(consume) do
    local istack = ItemStack(name)
    if count >= math.pow(2,16) then
      replace = false
      break
    end
    istack:set_count(count)
    local hasit = inv:contains_item("main", istack)
    me.log("ac checking "..name, "error")
    if hasit then
      me.log("ac grabbing "..name, "error")
      local grabbed = me.remove_item(net, inv, "main", istack)
      if grabbed and grabbed:get_count() == count then
        me.log("ac grabbed "..name, "error")
	net.ac_status = net.ac_status .. time.." Grabbed "..count.." "..name..".\n"
	local slot = inv:get_size("ac")+1
	inv:set_size("ac", slot)
	inv:set_stack("ac", slot, grabbed)
	-- and later we do this:
	prepworkbits[function()
	  me.log("PREP: about to move "..name, "error")
	  local stack = inv:get_stack("ac", slot)
	  me.log("PREP: before move actual content of slot "..slot.." is "..stack:get_count().." "..stack:get_name(), "error")
	  local leftovers = 0
	  for i = 1, #dat do
	     -- todo: prove the below is correct.
	     -- This spreads across evenly when craft_count is > 0 (stainless, carbon steel for example).
	     local inner_stack = stack:take_item(count/total*math.floor((total+i-1)/#dat))
             leftovers = leftovers + dat[i].rinv:add_item("src", inner_stack):get_count()
	  end
	  stack:set_count(leftovers)
	  me.log("PREP: post move into real inventory "..stack:get_count().." "..name.." leftovers", "error")
	  inv:set_stack("ac", slot, stack)
	end] = name
	-- and then something moves the size of ac back to before we started
      else
	me.log("ac could not grab "..count.." "..name, "error")
	net.ac_status = net.ac_status .. time.." Could not grab "..count.." "..name..".\n"
	hasit = false
      end
    else
      -- Try and autocraft it
      me.log("AC: recursive crafting "..count.." "..istack:get_count(), "error")
      net.ac_status = net.ac_status .. time.." Need to craft "..count.." "..name..".\n"
      hasit = true
      local final_step_time = 0
      for i = 1, #dat do
	-- todo: prove the below is correct.
	-- Does this spread across evenly when craft_count is > 0 (? for example)?
	-- I think this works, but it is slightly wasteful, but in a good way as
	-- 10 on 10 machines will each craft 1 on craft_count 2 item yielding 10 extra.
        local subcount = math.floor((count+i-1)/#dat)
	local inner_istack = istack
	inner_istack:set_count(subcount)
        local built, step_time = build(net, cpos, inv, name, subcount, inner_istack, dat[i].isink, time)
        if built then
	  next_time[i] = math.max(next_time[i], time + step_time)
	  final_step_time = math.max(final_step_time, step_time)
        else
	  hasit = false
        end
      end
      if hasit then
	net.ac_status = net.ac_status .. time.." Craft "..count.." "..name.." in "..final_step_time.." seconds.\n"
      else
	me.log("can't craft "..istack:get_count().." "..istack:get_name(), "error")
	net.ac_status = net.ac_status .. time.." Can't craft "..count.." "..name..".\n"
      end
    end
    replace = replace and hasit
  end
  local prepwork = function ()
    -- Do all the little bits of prepwork
    for func, name in pairs(prepworkbits) do
      me.log("PREPing: before "..name, "error")
      func()
      me.log("PREPing: done "..name, "error")
    end
  end
  -- end of prepwork
  if not replace then
    -- If we don't have everything, and can't craft it, we're stuck,
    -- do as much as we can, then nothing else
    me.log("missing items", "error")
    -- Existing items are already loaded.
    return
  end
  local tmp_next_time = next_time
  next_time = 0
  for i = 1, #dat do
    next_time = math.max(next_time, tmp_next_time[i])
  end
  local main_action = function() 
    me.log("ACTION: prep for "..stack:get_name(), "error")
    prepwork()
    -- and once we are done with all the postponed work, we can reduce "ac"
    -- lifetimes are more complex than you can imagine.
    -- We use a simple rule. When all done, there is nothing left. At that point,
    -- we can put any leftovers back into the main inventory.
    -- Even this might be too soon, if we have multiple independent crafts going, we
    -- need the last one.
    if previous_ac_size == 0 and false then
      for i = 1,inv:get_size("ac") do
        local stack = inv:get_stack("ac", i)
	if stack:get_count() ~= 0 then
	  me.log("AC: putting "..stack:get_count().." "..stack:get_name().." back into main inventory", "error")
	  local leftovers = me.insert_item(stack, net, inv, "main")
	  if leftovers:get_count() > 0 then
	    -- drop on floor, todo: play sound
            minetest.add_item(cpos, leftovers)
	  end
	end
      end
      me.log("PREP: ac size is now down to "..previous_ac_size, "error")
      inv:set_size("ac", previous_ac_size)
    end
    me.log("ACTION: main for "..stack:get_name(), "error")
    for i = 1, #dat do
    local rmeta = minetest.get_meta(dat[i].apos)

    -- Let's start up the crafter since we loaded it up to run
    if (net.process and net.process[name]) or rmeta:get_int("enabled") == 1 then
      local timer = minetest.get_node_timer(dat[i].apos)
      if not timer:is_started() then
	me.log("TIMER: starting ac now for "..stack:get_name(), "error")
        timer:start(pipeworks_craft_time)
      end
      me.log("TIMER: registering timer for "..stack:get_name(), "error")
      local action_time_step = main_action_time
      local action = function(net)
        me.log("ACTION: post craft for "..stack:get_name(), "error")
	local inner_stack = stack
	-- todo: prove the below is correct.
	-- See extra below for how I think it fails.
	inner_stack:set_count(craft_count*math.floor((total+i-1)/#dat))
	if i == 1 and extra:get_count() > 0 then
	  inner_stack:take_item(extra:get_count())
	end
        me.log("TIMER: moving "..inner_stack:get_count().." "..stack:get_name(), "error")
        -- deal with output and replacements
	local dst_stack = dat[i].rinv:remove_item("dst", inner_stack)
	local ctime = next_time+action_time_step
	if dst_stack:get_count() ~= inner_stack:get_count() then
          me.log("wow, missing items that should have been crafted "..stack:get_name(), "error")
	  -- me.log("saw "..dst_stack:get_count().." items instead of "..inner_stack:get_count().." items", "error")
	  net.ac_status = net.ac_status .. ctime.." Missing "..(inner_stack:get_count()-dst_stack:get_count()).." "..name..", only made "..dst_stack:get_count()..".\n"
	end
	if not dst_stack:is_empty() then
	  me.log("TIMER: inserting "..dst_stack:get_count().." "..dst_stack:get_name(), "error")
	  local leftovers = sink(dst_stack)
	  if leftovers and not leftovers:is_empty() then
	    me.log("autocrafter overflow, backpressuring", "error")
	    net.ac_status = net.ac_status .. ctime.." Backpressure of "..name..".\n"
	    -- If any don't fit, back pressure on the crafter, we don't
	    -- mean to do this, and want to chunk the crafting items smaller
	    dat[i].rinv:add_item("dst", leftovers)
	  end
	end
	if i == 1 and not extra:is_empty() then
	  -- extra is once, not per machine. It will appear in the
	  -- first machine as extra.
	  -- todo: extra I think is broken by switch the dst getter from being count based
	  -- to being total*craft count based.  This leaves extra when we need to craft
	  -- for a recipe that needs less than an even multiple of the craft_count.  Test, broken.
	  dst_stack = dat[i].rinv:remove_item("dst", extra)
	  if dst_stack:get_count() ~= extra:get_count() then
            me.log("wow, missing items that should have been crafted "..stack:get_name(), "error")
	    me.log("saw "..dst_stack:get_count().." items instead of "..extra:get_count().." items", "error")
	    net.ac_status = net.ac_status .. ctime.." Missing "..(extra:get_count() - dst_stack:get_count()).." extra "..name..".\n"
	  end
	  if not dst_stack:is_empty() then
	    local leftovers = me.insert_item(dst_stack, net, inv, "main")
	    net:set_storage_space(true)
	    if leftovers and not leftovers:is_empty() then
	      me.log("autocrafter overflow, backpressuring", "error")
	      net.ac_status = net.ac_status .. ctime.." Backpressure of "..name..".\n"
	      -- If any don't fit, back pressure on the crafter, we don't
	      -- mean to do this, and want to chunk the crafting items smaller
	      dat[i].rinv:add_item("dst", leftovers)
	    end
	  end
	end
	if second_output then
	  local second = dat[i].rinv:remove_item("dst", second_output)
	  if second and not second:is_empty() then
	    local leftovers = me.insert_item(second, net, inv, "main")
	    if leftovers and not leftovers:is_empty() then
	      me.log("autocrafter overflow, backpressuring", "error")
	      net.ac_status = net.ac_status .. ctime.." Backpressure of "..name..".\n"
	      -- If any don't fit, back pressure on the crafter, we don't
	      -- mean to do this, and want to chunk the crafting items smaller
	      dat[i].rinv:add_item("dst", leftovers)
	    end
	  end
	end
        me.log("ACTION: done post craft for "..stack:get_name(), "error")
      end
      local net,cpos = me.get_connected_network(dat[i].ipos)
      me.later(net, cpos, action, next_time + action_time_step)
    end
    end
    me.log("ACTION: main done for "..stack:get_name(), "error")
  end

  local net,cpos = me.get_connected_network(dat[1].ipos)
  -- queue main action for later
  me.log("LATER: main action for "..stack:get_name().." in "..next_time.." seconds", "error")
  me.later(net, cpos, main_action, next_time)

  -- The step time is the prep time and the main_action_time
  local step_time = next_time - time + main_action_time
  return true, step_time
end

-- time is absolute, starting from 0 from the front of a craft or
-- non-zero if a previous craft was running.
function me.later(net, cpos, action, time)
  if not net.pending then
    net.pending = {}
    net.pending.time = {}
  end
  local i = (net.pending.max_index or 0) + 1
  net.pending.max_index = i
  net.pending[i] = action
  net.pending.time[i] = time
  if not net.pending.index then
    net.pending.index = 1
  end
  if i == 1 then
    me.log("TIMER: starting timer to fire at "..time.." seconds", "error")
    me.start_crafting(cpos, time+0.1)
  else
    -- me.log("TIMER: did not start timer for later, index "..i.." at time "..time, "error")
    -- bubble sort the entry back to the right spot
    while i > 1 do
      -- me.log("TIME ds: "..i.." "..net.pending.time[i].." "..net.pending.time[i-1], "error")
      if  tonumber(net.pending.time[i]) and tonumber(net.pending.time[i-1])
          and net.pending.time[i] < net.pending.time[i-1] then
        -- if out of order, swap.  This works as previously the list was sorted
        local t = net.pending.time[i-1]
        net.pending.time[i-1] = net.pending.time[i]
	net.pending.time[i] = t
	t = net.pending[i-1]
	net.pending[i-1] = net.pending[i]
	net.pending[i] = t
	if i == 2 then
	  me.start_crafting(cpos, net.pending.time[1]+0.1)
	end
      else
        break
      end
      i = i - 1
    end
  end
end

function me.autocraft(autocrafterCache, cpos, net, linv, inv, count)
  local ostack = linv:get_stack("output", 1)
  local name = ostack:get_name()
  me.log("crafting "..name.." "..tostring(count), "error")

  local stack = ItemStack(name)
  local craft_count = ostack:get_count()
  me.log("auto: craft_count "..craft_count.." count "..count, "error")
  -- we craft a minimum of count, to the multiple of the crafting count
  count = math.ceil(count/craft_count)
  me.log("auto: count is now "..count, "error")
  stack:set_count(count*craft_count)
  me.log("auto: stack size is now "..stack:get_count(), "error")
  me.log("auto: and build count is "..(count*craft_count), "error")

  -- me.log("autocrafters: "..minetest.serialize(net.autocrafters), "error")

  if not net.process then
    -- rewalk the interfaces on the network to rebuild the machines.
    net:reload_network()
  end
  if net.autocrafters[name] or net.process[name] then
    me.log("using pipeworks autocrafter", "error")
    if not net.pending or not net.ac_status then
      net.ac_status = ""
    end
    local start_time = me.autocraft_next_start(net) or 0
    net.ac_status = net.ac_status .. start_time.." using pipeworks autocrafter\n"
    local sink = function(stack)
      local leftovers = me.insert_item(stack, net, inv, "main")
      net:set_storage_space(true)
      return leftovers
    end
    local built, step_time = build(net, cpos, inv, name, count*craft_count, stack, sink, start_time)
    if built then
      me.log("crafting "..stack:get_count().." "..stack:get_name().." in "..step_time.." seconds", "error")
      net.ac_status = net.ac_status .. start_time.." Crafting "..(count*craft_count).." "..name.." in "..step_time.." seconds.\n"
    else
      me.log("can't craft "..stack:get_count().." "..stack:get_name(), "error")
      net.ac_status = net.ac_status .. start_time.." Can't craft "..(count*craft_count).." "..name..".\n"
    end
    return
  end

  me.log("using microexpansion autocrafter", "error")
  local consume = {}
  for i = 1, 9 do
    local inp = linv:get_stack("recipe", i)
    if inp and inp:get_name() ~= "" then
      consume[inp:get_name()] = (consume[inp:get_name()] or 0) + count*inp:get_count()
    end
  end
  local replace = true
  for name, count in pairs(consume) do
    local stack = ItemStack(name)
    if count >= math.pow(2,16) then
      replace = false
      break
    end
    stack:set_count(count)
    replace = replace and inv:contains_item("main", stack)
  end
  if replace then
    for name, count in pairs(consume) do
      local stack = ItemStack(name)
      stack:set_count(count)
      me.log("REMOVE: "..count.." "..stack:get_name(), "error")
      if not inv:contains_item("main", stack) then
        fixme1()
      end
      local ret = me.remove_item(net, inv, "main", stack)
      if ret:get_count() ~= stack:get_count() then
        me.log("AUTO: found "..(ret:get_count()).." "..(stack:get_name()).." but wanted "..stack:get_count(), "error")
        -- fixme2()
      end
    end
    local leftovers = me.insert_item(stack, net, inv, "main")
    if leftovers:get_count() > 0 then
      -- Ick, no room, just drop on the floor. Maybe player inventory?
      minetest.add_item(cpos, leftovers)
    end
    net:set_storage_space(true)
    -- deal with replacements
    local hash = minetest.hash_node_position(cpos)
    local craft = autocrafterCache[hash] or me.get_craft(cpos, linv, hash)
    for i = 1, 9 do
      if (craft.decremented_input.items[i]:get_count() ~= linv:get_stack("recipe", i):get_count()
	or craft.decremented_input.items[i]:get_name() ~= linv:get_stack("recipe", i):get_name())
	and not craft.decremented_input.items[i]:is_empty() then
	local leftovers = me.insert_item(craft.decremented_input.items[i], net, inv, "main")
	net:set_storage_space(true)
	if leftovers:get_count() > 0 then
	  -- Ick, no room, just drop on the floor. Maybe player inventory?
	  minetest.add_item(cpos, leftovers)
	end
      end
      if replace then
	linv:set_stack("output", 1, craft.output.item)
      else
	linv:set_list("output", {})
      end
    end
  end
end