STOCKPILE_CONFIG_STOCKPILE_NUMBER = 0,

STOCKPILE_CONFIG_MELT = 1,

STOCKPILE_CONFIG_TRADE = 2,

STOCKPILE_CONFIG_DUMP = 3,

STOCKPILE_CONFIG_TRAIN = 4,

if (!c.isValid())

return -1;

return c.ival(index);

if (!watched_stockpiles.count(stockpile_number))

return;

DEBUG(status, out).print("removing persistent key for stockpile %d\n", stockpile_number);

World::DeletePersistentData(watched_stockpiles[stockpile_number]);

watched_stockpiles.erase(stockpile_number);

DEBUG(status, out).print("initializing %s\n", plugin_name);

commands.push_back(PluginCommand(

plugin_name,

"Automatically mark and route items in monitored stockpiles.",

do_command));

return CR_OK;

is_enabled = enable;

DEBUG(status, out).print("now %s\n", is_enabled ? "enabled" : "disabled");

return CR_OK;

unordered_map<df::building_stockpilest *, PersistentDataItem> &cache) {

for (auto& entry : watched_stockpiles) {

int stockpile_number = entry.first;

PersistentDataItem &c = entry.second;

auto bld = find_stockpile(stockpile_number);

if (!bld || (

!get_config_bool(c, STOCKPILE_CONFIG_MELT) &&

!get_config_bool(c, STOCKPILE_CONFIG_TRADE) &&

!get_config_bool(c, STOCKPILE_CONFIG_DUMP) &&

!get_config_bool(c, STOCKPILE_CONFIG_TRAIN))) {

remove_stockpile_config(out, stockpile_number);

continue;

}

cache.emplace(bld, c);

}

vector<PersistentDataItem> old_data;

World::GetPersistentData(&old_data, "automelt/stockpile/", true);

const size_t num_old_keys = old_data.size();

for (size_t idx = 0; idx < num_old_keys; ++idx) {

auto& old_c = old_data[idx];

int32_t bld_id = get_config_val(old_c, 0);

bool melt_was_on = get_config_bool(old_c, 1);

World::DeletePersistentData(old_c);

auto bld = df::building::find(bld_id);

if (!bld || bld->getType() != df::building_type::Stockpile ||

watched_stockpiles.count(static_cast<df::building_stockpilest *>(bld)->stockpile_number))

continue;

auto &c = ensure_stockpile_config(out, static_cast<df::building_stockpilest *>(bld)->stockpile_number);

set_config_bool(c, STOCKPILE_CONFIG_MELT, melt_was_on);

}

cycle_timestamp = 0;

vector<PersistentDataItem> loaded_persist_data;

World::GetPersistentData(&loaded_persist_data, CONFIG_KEY_PREFIX, true);

watched_stockpiles.clear();

const size_t num_watched_stockpiles = loaded_persist_data.size();

for (size_t idx = 0; idx < num_watched_stockpiles; ++idx) {

auto& c = loaded_persist_data[idx];

watched_stockpiles.emplace(get_config_val(c, STOCKPILE_CONFIG_STOCKPILE_NUMBER), c);

}

migrate_old_keys(out);

return CR_OK;

if (!is_enabled || !Core::getInstance().isWorldLoaded())

return CR_OK;

if (world->frame_counter - cycle_timestamp >= CYCLE_TICKS) {

int32_t melt_count = 0, trade_count = 0, dump_count = 0, train_count = 0;

do_cycle(out, melt_count, trade_count, dump_count, train_count);

if (0 < melt_count)

out.print("logistics: marked %d item(s) for melting\n", melt_count);

if (0 < trade_count)

out.print("logistics: marked %d item(s) for trading\n", trade_count);

if (0 < dump_count)

out.print("logistics: marked %d item(s) for dumping\n", dump_count);

if (0 < train_count)

out.print("logistics: marked %d animal(s) for training\n", dump_count);

}

return CR_OK;

int nargs = 0, int nres = 0,

Lua::LuaLambda && args_lambda = Lua::DEFAULT_LUA_LAMBDA,

Lua::LuaLambda && res_lambda = Lua::DEFAULT_LUA_LAMBDA) {

DEBUG(status).print("calling logistics lua function: '%s'\n", fn_name);

CoreSuspender guard;

auto L = Lua::Core::State;

Lua::StackUnwinder top(L);

if (!out)

out = &Core::getInstance().getConsole();

return Lua::CallLuaModuleFunction(*out, L, "plugins.logistics", fn_name,

nargs, nres,

std::forward<Lua::LuaLambda&&>(args_lambda),

std::forward<Lua::LuaLambda&&>(res_lambda));

CoreSuspender suspend;

bool show_help = false;

if (!call_logistics_lua(&out, "parse_commandline", 1, 1,

[&](lua_State *L) {

Lua::PushVector(L, parameters);

},

[&](lua_State *L) {

show_help = !lua_toboolean(L, -1);

})) {

return CR_FAILURE;

}

return show_help ? CR_WRONG_USAGE : CR_OK;

const string name;

const int32_t stockpile_number;

const bool enabled;

ProcessorStats &stats;

StockProcessor(const string &name, int32_t stockpile_number, bool enabled, ProcessorStats &stats)

: name(name), stockpile_number(stockpile_number), enabled(enabled), stats(stats) { }

virtual bool is_designated(color_ostream &out, df::item *item) = 0;

virtual bool can_designate(color_ostream &out, df::item *item) = 0;

virtual bool designate(color_ostream &out, df::item *item) = 0;

MeltStockProcessor(int32_t stockpile_number, bool enabled, ProcessorStats &stats)

: StockProcessor("melt", stockpile_number, enabled, stats) { }

bool is_designated(color_ostream &out, df::item *item) override {

return item->flags.bits.melt;

}

bool can_designate(color_ostream &out, df::item *item) override {

MaterialInfo mat(item);

if (mat.getCraftClass() != df::craft_material_class::Metal)

return false;

if (item->getType() == df::item_type::BAR)

return false;

for (auto &g : item->general_refs) {

switch (g->getType()) {

case df::general_ref_type::CONTAINS_ITEM:

case df::general_ref_type::UNIT_HOLDER:

case df::general_ref_type::CONTAINS_UNIT:

return false;

case df::general_ref_type::CONTAINED_IN_ITEM:

{

df::item *c = g->getItem();

for (auto &gg : c->general_refs) {

if (gg->getType() == df::general_ref_type::UNIT_HOLDER)

return false;

}

break;

}

default:

break;

}

}

if (item->getQuality() >= df::item_quality::Masterful)

return false;

return true;

}

bool designate(color_ostream &out, df::item *item) override {

insert_into_vector(world->items.other.ANY_MELT_DESIGNATED, &df::item::id, item);

item->flags.bits.melt = 1;

return true;

}

TradeStockProcessor(int32_t stockpile_number, bool enabled, ProcessorStats& stats)

: StockProcessor("trade", stockpile_number, enabled && get_active_trade_depot(), stats),

depot(get_active_trade_depot()) { }

bool is_designated(color_ostream& out, df::item* item) override {

auto ref = Items::getSpecificRef(item, df::specific_ref_type::JOB);

return ref && ref->data.job &&

ref->data.job->job_type == df::job_type::BringItemToDepot;

}

bool can_designate(color_ostream& out, df::item* item) override {

return Items::canTradeWithContents(item);

}

bool designate(color_ostream& out, df::item* item) override {

if (!depot)

return false;

auto href = df::allocate<df::general_ref_building_holderst>();

if (!href)

return false;

auto job = new df::job();

job->job_type = df::job_type::BringItemToDepot;

job->pos = df::coord(depot->centerx, depot->centery, depot->z);

// job <-> item link

if (!Job::attachJobItem(job, item, df::job_item_ref::Hauled)) {

delete job;

delete href;

return false;

}

// job <-> building link

href->building_id = depot->id;

depot->jobs.push_back(job);

job->general_refs.push_back(href);

// add to job list

Job::linkIntoWorld(job);

return true;

}

df::building_tradedepotst * const depot;

static df::building_tradedepotst * get_active_trade_depot() {

// at least one caravan must be approaching or ready to trade

if (!plotinfo->caravans.size())

return NULL;

bool found = false;

for (auto caravan : plotinfo->caravans) {

auto trade_state = caravan->trade_state;

auto time_remaining = caravan->time_remaining;

if ((trade_state == df::caravan_state::T_trade_state::Approaching ||

trade_state == df::caravan_state::T_trade_state::AtDepot) && time_remaining != 0) {

found = true;

break;

}

}

if (!found)

return NULL;

// at least one trade depot must be ready to receive goods

for (auto bld : world->buildings.other.TRADE_DEPOT) {

if (bld->getBuildStage() < bld->getMaxBuildStage())

continue;

if (bld->jobs.size() == 1 &&

bld->jobs[0]->job_type == df::job_type::DestroyBuilding)

continue;

return bld;

}

return NULL;

}

DumpStockProcessor(int32_t stockpile_number, bool enabled, ProcessorStats& stats)

: StockProcessor("dump", stockpile_number, enabled, stats) { }

bool is_designated(color_ostream& out, df::item* item) override {

return item->flags.bits.dump;

}

bool can_designate(color_ostream& out, df::item* item) override {

return true;

}

bool designate(color_ostream& out, df::item* item) override {

item->flags.bits.dump = true;

return true;

}

TrainStockProcessor(int32_t stockpile_number, bool enabled, ProcessorStats& stats)

: StockProcessor("train", stockpile_number, enabled, stats) {}

bool is_designated(color_ostream& out, df::item* item) override {

auto unit = get_caged_unit(item);

return unit && has_training_assignment(unit);

}

bool can_designate(color_ostream& out, df::item* item) override {

auto unit = get_caged_unit(item);

return unit && Units::isTamable(unit) && !Units::isTame(unit)

&& !has_training_assignment(unit);

}

bool designate(color_ostream& out, df::item* item) override {

auto unit = get_caged_unit(item);

if (!unit)

return false;

df::training_assignment *assignment = new df::training_assignment();

assignment->animal_id = unit->id;

assignment->trainer_id = -1;

assignment->flags.bits.any_trainer = true;

insert_into_vector(df::global::plotinfo->equipment.training_assignments,

&df::training_assignment::animal_id, assignment);

return true;

}

static df::unit* get_caged_unit(df::item* item) {

if (item->getType() != df::item_type::CAGE)

return NULL;

auto gref = Items::getGeneralRef(item, df::general_ref_type::CONTAINS_UNIT);

if (!gref)

return NULL;

return gref->getUnit();

}

static bool has_training_assignment(df::unit* unit) {

return binsearch_index(df::global::plotinfo->equipment.training_assignments,

&df::training_assignment::animal_id, unit->id) > -1;

}

const uint32_t whole;

BadFlags() : whole(get_bad_flags()) { }

uint32_t get_bad_flags() {

df::item_flags flags;

#define F(x) flags.bits.x = true;

F(forbid); F(garbage_collect); F(hostile); F(on_fire);

F(rotten); F(trader); F(in_building); F(construction);

F(artifact); F(spider_web); F(owned); F(in_job);

#undef F

return flags.whole;

}

DEBUG(cycle,out).print("scan_item [%s] item_id=%d\n", processor.name.c_str(), item->id);

if (DBG_NAME(cycle).isEnabled(DebugCategory::LTRACE)) {

string name = "";

item->getItemDescription(&name, 0);

TRACE(cycle,out).print("item: %s\n", name.c_str());

}

if (item->flags.whole & bad_flags.whole) {

TRACE(cycle,out).print("rejected flag check\n");

return;

}

if (processor.is_designated(out, item)) {

TRACE(cycle,out).print("already designated\n");

++processor.stats.designated_counts[processor.stockpile_number];

return;

}

if (!processor.can_designate(out, item)) {

TRACE(cycle,out).print("cannot designate\n");

return;

}

if (!processor.enabled) {

++processor.stats.can_designate_counts[processor.stockpile_number];

return;

}

processor.designate(out, item);

++processor.stats.newly_designated;

++processor.stats.designated_counts[processor.stockpile_number];

MeltStockProcessor &melt_stock_processor,

TradeStockProcessor &trade_stock_processor,

DumpStockProcessor &dump_stock_processor,

TrainStockProcessor &train_stock_processor) {

auto id = bld->id;

Buildings::StockpileIterator items;

for (items.begin(bld); !items.done(); ++items) {

df::item *item = *items;

scan_item(out, item, trade_stock_processor);

if (0 == (item->flags.whole & bad_flags.whole) &&

item->isAssignedToThisStockpile(id)) {

TRACE(cycle,out).print("assignedToStockpile\n");

vector<df::item *> contents;

Items::getContainedItems(item, &contents);

for (df::item *contained_item : contents) {

scan_item(out, contained_item, melt_stock_processor);

scan_item(out, contained_item, dump_stock_processor);

}

continue;

}

scan_item(out, item, melt_stock_processor);

scan_item(out, item, dump_stock_processor);

scan_item(out, item, train_stock_processor);

}

DEBUG(cycle,out).print("running %s cycle\n", plugin_name);

cycle_timestamp = world->frame_counter;

ProcessorStats melt_stats, trade_stats, dump_stats, train_stats;

unordered_map<df::building_stockpilest *, PersistentDataItem> cache;

validate_stockpile_configs(out, cache);

for (auto &entry : cache) {

df::building_stockpilest *bld = entry.first;

PersistentDataItem &c = entry.second;

int32_t stockpile_number = bld->stockpile_number;

bool melt = get_config_bool(c, STOCKPILE_CONFIG_MELT);

bool trade = get_config_bool(c, STOCKPILE_CONFIG_TRADE);

bool dump = get_config_bool(c, STOCKPILE_CONFIG_DUMP);

bool train = get_config_bool(c, STOCKPILE_CONFIG_TRAIN);

MeltStockProcessor melt_stock_processor(stockpile_number, melt, melt_stats);

TradeStockProcessor trade_stock_processor(stockpile_number, trade, trade_stats);

DumpStockProcessor dump_stock_processor(stockpile_number, dump, dump_stats);

TrainStockProcessor train_stock_processor(stockpile_number, train, train_stats);

scan_stockpile(out, bld, melt_stock_processor,

trade_stock_processor, dump_stock_processor, train_stock_processor);

}

melt_count = melt_stats.newly_designated;

trade_count = trade_stats.newly_designated;

dump_count = dump_stats.newly_designated;

TRACE(cycle,out).print("exit %s do_cycle\n", plugin_name);

color_ostream *out = Lua::GetOutput(L);

if (!out)

out = &Core::getInstance().getConsole();

DEBUG(status,*out).print("entering logistics_getStockpileData\n");

unordered_map<df::building_stockpilest *, PersistentDataItem> cache;

validate_stockpile_configs(*out, cache);

ProcessorStats melt_stats, trade_stats, dump_stats, train_stats;

for (auto bld : df::global::world->buildings.other.STOCKPILE) {

int32_t stockpile_number = bld->stockpile_number;

MeltStockProcessor melt_stock_processor(stockpile_number, false, melt_stats);

TradeStockProcessor trade_stock_processor(stockpile_number, false, trade_stats);

DumpStockProcessor dump_stock_processor(stockpile_number, false, dump_stats);

TrainStockProcessor train_stock_processor(stockpile_number, false, train_stats);

scan_stockpile(*out, bld, melt_stock_processor,

trade_stock_processor, dump_stock_processor, train_stock_processor);

}

unordered_map<string, StatMap> stats;

stats.emplace("melt_designated", melt_stats.designated_counts);

stats.emplace("melt_can_designate", melt_stats.can_designate_counts);

stats.emplace("trade_designated", trade_stats.designated_counts);

stats.emplace("trade_can_designate", trade_stats.can_designate_counts);

stats.emplace("dump_designated", dump_stats.designated_counts);

stats.emplace("dump_can_designate", dump_stats.can_designate_counts);

stats.emplace("train_designated", train_stats.designated_counts);

stats.emplace("train_can_designate", train_stats.can_designate_counts);

Lua::Push(L, stats);

unordered_map<int32_t, unordered_map<string, string>> configs;

for (auto &entry : cache) {

df::building_stockpilest *bld = entry.first;

PersistentDataItem &c = entry.second;

bool melt = get_config_bool(c, STOCKPILE_CONFIG_MELT);

bool trade = get_config_bool(c, STOCKPILE_CONFIG_TRADE);

bool dump = get_config_bool(c, STOCKPILE_CONFIG_DUMP);

bool train = get_config_bool(c, STOCKPILE_CONFIG_TRAIN);

unordered_map<string, string> config;

config.emplace("melt", melt ? "true" : "false");

config.emplace("trade", trade ? "true" : "false");

config.emplace("dump", dump ? "true" : "false");

config.emplace("train", train ? "true" : "false");

configs.emplace(bld->stockpile_number, config);

}

Lua::Push(L, configs);

TRACE(cycle, *out).print("exit logistics_getStockpileData\n");

return 2;

DEBUG(status, out).print("entering logistics_cycle\n");

int32_t melt_count = 0, trade_count = 0, dump_count = 0, train_count = 0;

do_cycle(out, melt_count, trade_count, dump_count, train_count);

out.print("logistics: marked %d item(s) for melting\n", melt_count);

out.print("logistics: marked %d item(s) for trading\n", trade_count);

out.print("logistics: marked %d item(s) for dumping\n", dump_count);

out.print("logistics: marked %d animal(s) for train\n", train_count);

vector<df::building_stockpilest*> &sps) {

if (lua_isnumber(L, idx)) {

sps.emplace_back(find_stockpile(lua_tointeger(L, -1)));

return;

}

const char * pname = lua_tostring(L, -1);

if (!pname || !*pname)

return;

string name(pname);

for (auto sp : world->buildings.other.STOCKPILE) {

if (name == sp->name)

sps.emplace_back(sp);

}

unordered_map<string, int> stockpile_config;

stockpile_config.emplace("stockpile_number", stockpile_number);

if (watched_stockpiles.count(stockpile_number)) {

PersistentDataItem &c = watched_stockpiles[stockpile_number];

stockpile_config.emplace("melt", get_config_bool(c, STOCKPILE_CONFIG_MELT));

stockpile_config.emplace("trade", get_config_bool(c, STOCKPILE_CONFIG_TRADE));

stockpile_config.emplace("dump", get_config_bool(c, STOCKPILE_CONFIG_DUMP));

stockpile_config.emplace("train", get_config_bool(c, STOCKPILE_CONFIG_TRAIN));

} else {

stockpile_config.emplace("melt", false);

stockpile_config.emplace("trade", false);

stockpile_config.emplace("dump", false);

stockpile_config.emplace("train", false);

}

return stockpile_config;

color_ostream *out = Lua::GetOutput(L);

if (!out)

out = &Core::getInstance().getConsole();

DEBUG(status, *out).print("entering logistics_getStockpileConfigs\n");

unordered_map<df::building_stockpilest*, PersistentDataItem> cache;

validate_stockpile_configs(*out, cache);

vector<df::building_stockpilest*> sps;

find_stockpiles(L, -1, sps);

if (sps.empty())

return 0;

vector<unordered_map<string, int>> configs;

for (auto sp : sps)

configs.emplace_back(get_stockpile_config(sp->stockpile_number));

Lua::PushVector(L, configs);

return 1;

DEBUG(status, out).print("entering logistics_setStockpileConfig stockpile_number=%d, melt=%d, trade=%d, dump=%d, train=%d\n",

stockpile_number, melt, trade, dump, train);

if (!find_stockpile(stockpile_number)) {

out.printerr("invalid stockpile number: %d\n", stockpile_number);

return;

}

auto &c = ensure_stockpile_config(out, stockpile_number);

set_config_bool(c, STOCKPILE_CONFIG_MELT, melt);

set_config_bool(c, STOCKPILE_CONFIG_TRADE, trade);

set_config_bool(c, STOCKPILE_CONFIG_DUMP, dump);

set_config_bool(c, STOCKPILE_CONFIG_TRAIN, train);

color_ostream *out = Lua::GetOutput(L);

if (!out)

out = &Core::getInstance().getConsole();

DEBUG(status, *out).print("entering logistics_clearStockpileConfig\n");

vector<df::building_stockpilest*> sps;

find_stockpiles(L, -1, sps);

if (sps.empty())

return 0;

for (auto sp : sps)

remove_stockpile_config(*out, sp->stockpile_number);

return 0;

DEBUG(status, out).print("entering logistics_clearAllStockpileConfigs\n");

for (auto &entry : watched_stockpiles)

World::DeletePersistentData(entry.second);

watched_stockpiles.clear();

color_ostream *out = Lua::GetOutput(L);

if (!out)

out = &Core::getInstance().getConsole();

DEBUG(status,*out).print("entering logistics_getGlobalCounts\n");

size_t num_melt = df::global::world->items.other.ANY_MELT_DESIGNATED.size();

size_t num_trade = 0;

for (auto link = world->jobs.list.next; link; link = link->next) {

df::job *job = link->item;

if (job->job_type == df::job_type::BringItemToDepot)

++num_trade;

}

size_t num_dump = 0;

for (auto item : world->items.other.IN_PLAY) {

if (item->flags.bits.dump)

++num_dump;

}

size_t num_train = 0;

// TODO

unordered_map<string, size_t> results;

results.emplace("total_melt", num_melt);

results.emplace("total_trade", num_trade);

results.emplace("total_dump", num_dump);

results.emplace("total_train", num_train);

Lua::Push(L, results);

TRACE(cycle, *out).print("exit logistics_getGlobalCounts\n");

return 1;