--rm metest.lua ; wget https://files.rurido.de/raw/136 metest.lua

local sides = require("sides");

--configuration

local cfg = { pullStackSize = 1000000, --min size of stacks to pull from me, 0 to disable exportSide = sides.top, --export bus side -> top, bottom, front, back, left, right, unknown meResponseTime = 5 --time in sec to wait for me to push items };

--program routine

local c = require("component"); local p = require("process"); local event = require("event"); local thread = require("thread");

local db = nil; local me = nil; local ex = nil; local im = nil;

function main()

if not c.isAvailable("database") then
    print("Missing component: Database");
    return;
end
db = c.database;

if not c.isAvailable("me_controller") then
   print("Missing component: ME Controller");
   return;
end
me = c.me_controller; --primary

if not c.isAvailable("me_exportbus") then
    print("Missing component: ME Exportbus") ;
    return;
end
ex = c.me_exportbus --primaryff8484ff8484

--[[
if not c.isAvailable("me_importbus") then
    print("Missing component: ME Importbus");
    return;
end
im = c.me_importbus --primary
--]]

--init done

print("ME Network (Connected to ME Network #" .. me.address .. ")");
print("├──ME Controller");
print("│  ├──CPUs: " .. #me.getCpus());
print("│  ├──Energy: " .. me.getEnergyStored() .. " / " .. me.getMaxEnergyStored());
print("│  ├──Power:");
print("│  │  ├──Str/Max: " .. me.getStoredPower() .. " / " .. me.getMaxStoredPower());
print("│  │  ├──In/Out: +" .. me.getAvgPowerInjection() .. " / -" .. me.getAvgPowerUsage());
print("│  │  └──Idle Use: -" .. me.getIdlePowerUsage());
print("│  ├──Items: " .. #me.getItemsInNetwork());
print("│  ├──Fluids: " .. #me.getFluidsInNetwork());
print("│  ├──Gases: " .. #me.getGasesInNetwork());
print("│  └──Recipes: " .. #me.getCraftables());
--print("├──ME Import Bus");
print("└──ME Export Bus");
print();
--[[
print(" . . . ");
print("TODO");

print("DEBUG-ME-MEMBERS");
for key,value in pairs(me) do
    if type(value) == "function" then
        print(" " .. key .. " -> " .. debug.getinfo(value));
    else
        print(" " .. key .. " -> " .. tostring(value));
    end

end
--]]

print("PullStackSize: " .. cfg.pullStackSize);

--[[local cleanupThread = thread.create(function()
    event.pull("interrupted");
    print("cleaning up resources");
end);


local workerThread = thread.create(function()--]]
    print("Worker started");
    print("Stop with [CTRL]+[ALT]+[C] (Hard Interrupt)");
    local lastItem = nil;
    while true do
        local foundItem = false;

        for key,item in pairs(me.getItemsInNetwork()) do
            os.sleep(0);

            if type(item) == "table" and item.size >= cfg.pullStackSize then 

                print("Next Item: " .. item.label .. " (x" .. item.size .. ")");

                --printDebug(item);

                foundItem = true;

                if trimItem(lastItem) ~= trimItem(item) then
                    ex.setExportConfiguration(cfg.exportSide);
                    print("Cleared Export-Bus configuration");

                    stored = storeInDb(item);

                else
                    print("Last item == current");
                    stored = true;
                end

                if not stored then --db.get(1) == nil then
                    print("Failed to store Item Info to DB");
                else
                    print("Stored Item Info to DB: " .. db.get(1).label);

                    ex.setExportConfiguration(cfg.exportSide, 1, db.address, 1);
                    print("Set Export-Bus configuration: " .. ex.getExportConfiguration(cfg.exportSide, 1).label);

                    ex.exportIntoSlot(cfg.exportSide, 1);
                    print("Triggered Export");

                    lastItem = item;

                    os.sleep(cfg.meResponseTime);

                end

            end
        end

        if foundItem == false then

            print("No Item found using configured properties");

            ex.setExportConfiguration(cfg.exportSide);
            print("Cleared Export-Bus configuration");

        end

    end
--[[end)

thread.waitForAny({cleanupThread, workerThread});--]]
os.exit(0); -- closes all remaining threads

end

function storeInDb(item) for i = 0, 10, 1 do db.clear(1); local dbItem = trimItem(item); me.store(dbItem, db.address, 1, 1); if db.get(1) ~= nil then print("Stored after " .. i+1 .. " attempt(s)"); return true; else os.sleep(0);--NOP --os.execute("sleep 1"); end end

return false;

end

function trimItem(item)

if item == nil then
   return nil; 
end

return {
    label = item.label,
    name = item.name,
    damage = item.damage
};

end

function pause() print(); term.write("Press any key to continue "); term.read(); print();
end

function printDebug(val, spaces)

if spaces == nil then
   spaces = ""; 
end

if string.len(spaces) >= 16 then
    print(spaces .. "RECURSION_LIMIT");
    return; 
end

if val == nil then
    print(spaces .. "NIL");
    return;
end

print(spaces .. tostring(val));
if type(val) == "table" then
    for key,value in pairs(val) do
        print(spaces .. tostring(key) .. " -> " .. tostring(value));
        if type(value) == "function" or type(value) == "table" then
            printDebug(value, "  " .. spaces);
        end
    end
end

end

p.info().data.signal = function(...) print("Caught hard interrupt, terminating...");

ex.setExportConfiguration(cfg.exportSide);
print("Cleared Export-Bus configuration");

os.exit();

end

main();