index : minetest.git	gpcf lifo-fixes release
	modified minetest for gpcfs purposes	gpcf

aboutsummaryrefslogtreecommitdiff

log msg author committer range

path: root/CMakeLists.txt

	Commit message (Expand)	Author	Age
*	Set version to 0.4	Perttu Ahola	2011-11-29
*	Update changelog and call this 0.3.1	Perttu Ahola	2011-11-09
*	Call this 0.3.dev-20111108	Perttu Ahola	2011-11-08
*	Call this version 0.3.dev-20111104	Perttu Ahola	2011-11-04
*	Update /README.txt, remove duplicate /doc/README.txt and update CMakeLists.tx...	Perttu Ahola	2011-11-03
*	Set version to 0.3.0 and update changelog	Perttu Ahola	2011-11-01
*	0.3.dev-20111021	Perttu Ahola	2011-10-21
*	Update version number to 0.3.dev-20111016	Perttu Ahola	2011-10-16
*	strict_protocol_version_checking setting; PROTOCOL_VERSION in clientserver.h;...	Perttu Ahola	2011-10-15
*	Set a better version number	Perttu Ahola	2011-10-15
*	In CMake scripts: New version number, fix MSVC stuff	Perttu Ahola	2011-10-14
*	Make client report a newer version number to the server than 2011-07-31 does ...	Perttu Ahola	2011-09-22
*	Oh well, let's call it just 0.2.20110922	Perttu Ahola	2011-09-22
*	Update changelog and version to 0.2.20110922_rc1	Perttu Ahola	2011-09-22
*	Update version number to something more proper for this stage of development ...	Perttu Ahola	2011-09-06
*	updated version in CMakeLists	Perttu Ahola	2011-07-31
*	updated version	Perttu Ahola	2011-07-31
*	Added MaterialItem conversion from old content type namespace to new	Perttu Ahola	2011-07-31
*	Updated CMakeLists, changelog and example config for release	Perttu Ahola	2011-07-31
*	updated CMakeList.txts a bit	Perttu Ahola	2011-07-31
*	updated version to rc2, rolling out new windows test binary	Perttu Ahola	2011-07-30
*	Removed remaining -delta references	Perttu Ahola	2011-07-30
*	removed -delta namings	Perttu Ahola	2011-07-23
*	Tweak makefiles to add -delta suffix.	Weedy	2011-07-21
*	Merge branch 'upstream/master'	Nils Dagsson Moskopp	2011-07-14
|\
| *	Updated version and changelog	Perttu Ahola	2011-07-04
* |	Merge branch 'master' of https://github.com/erlehmann/minetest-delta.git into...	Sebastian Rühl	2011-06-26
|\ \ | |/ |/|
| *	MacOSX build support	MrLoom	2011-06-01
* |	Reorganizing stuff (import from temporary git repo)	Perttu Ahola	2011-06-25
* |	Changed MapBlockObjects to be never written anymore. Incremented version number.	Perttu Ahola	2011-06-18
* |	merged Mac OSX build fix from minetest-delta	Perttu Ahola	2011-06-18
* |	In a globally installed build, debug.txt is now placed in userdata directory....	Perttu Ahola	2011-06-02
* |	0.2.20110602_0	Perttu Ahola	2011-06-02
* |	updated version	Perttu Ahola	2011-05-31
* |	20110529_2	Perttu Ahola	2011-05-29
* |	version	Perttu Ahola	2011-05-29
* |	changed version number to 0.2.20110529_0	Perttu Ahola	2011-05-29
|/
*	Optimized smooth lighting calculation code	Perttu Ahola	2011-04-24
*	updated menu a bit, and some other small fixes	Perttu Ahola	2011-04-24
*	removed /usr prefix from install paths	Perttu Ahola	2011-04-24
*	changed version for making a test binary	Perttu Ahola	2011-04-23
*	updated changelog and version	Perttu Ahola	2011-04-10
*	still modified version!	Perttu Ahola	2011-04-06
*	Fixed wrong version number	Perttu Ahola	2011-04-06
*	Changed version number according to a new versioning scheme.	Perttu Ahola	2011-04-06
*	Incremented version to 0.0.2.	Perttu Ahola	2011-04-05
*	small fixes: crack texture, server build on windows, configuration file examp...	Perttu Ahola	2011-02-16
*	might work good on cmake+msvc now	Perttu Ahola	2011-02-15
*	oops... blew. now?	Perttu Ahola	2011-01-18
*	Tried to fix install directory problem on linux... Let's hope this doesn't bl...	Perttu Ahola	2011-01-18

• [next]

generated by cgit v1.2.3 (git 2.39.1) at 2024-11-13 03:29:33 +0000

/*
Minetest
Copyright (C) 2013 celeron55, Perttu Ahola <celeron55@gmail.com>

This program is free software; you can redistribute it and/or modify
it under the terms of the GNU Lesser General Public License as published by
the Free Software Foundation; either version 2.1 of the License, or
(at your option) any later version.

This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU Lesser General Public License for more details.

You should have received a copy of the GNU Lesser General Public License along
with this program; if not, write to the Free Software Foundation, Inc.,
51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
*/

#include "rollback.h"
#include <fstream>
#include <list>
#include <sstream>
#include "log.h"
#include "mapnode.h"
#include "gamedef.h"
#include "nodedef.h"
#include "util/serialize.h"
#include "util/string.h"
#include "util/numeric.h"
#include "inventorymanager.h" // deserializing InventoryLocations
#include "sqlite3.h"
#include "filesys.h"

#define POINTS_PER_NODE (16.0)

#define SQLRES(f, good) \
	if ((f) != (good)) {\
		throw FileNotGoodException(std::string("RollbackManager: " \
			"SQLite3 error (" __FILE__ ":" TOSTRING(__LINE__) \
			"): ") + sqlite3_errmsg(db)); \
	}
#define SQLOK(f) SQLRES(f, SQLITE_OK)

#define SQLOK_ERRSTREAM(s, m)                             \
	if ((s) != SQLITE_OK) {                               \
		errorstream << "RollbackManager: " << (m) << ": " \
			<< sqlite3_errmsg(db) << std::endl;           \
	}

#define FINALIZE_STATEMENT(statement) \
	SQLOK_ERRSTREAM(sqlite3_finalize(statement), "Failed to finalize " #statement)

class ItemStackRow : public ItemStack {
public:
	ItemStackRow & operator = (const ItemStack & other)
	{
		*static_cast<ItemStack *>(this) = other;
		return *this;
	}

	int id;
};

struct ActionRow {
	int          id;
	int          actor;
	time_t       timestamp;
	int          type;
	std::string  location, list;
	int          index, add;
	ItemStackRow stack;
	int          nodeMeta;
	int          x, y, z;
	int          oldNode;
	int          oldParam1, oldParam2;
	std::string  oldMeta;
	int          newNode;
	int          newParam1, newParam2;
	std::string  newMeta;
	int          guessed;
};


struct Entity {
	int         id;
	std::string name;
};



RollbackManager::RollbackManager(const std::string & world_path,
		IGameDef * gamedef_) :
	gamedef(gamedef_)
{
	verbosestream << "RollbackManager::RollbackManager(" << world_path
		<< ")" << std::endl;

	std::string txt_filename = world_path + DIR_DELIM "rollback.txt";
	std::string migrating_flag = txt_filename + ".migrating";
	database_path = world_path + DIR_DELIM "rollback.sqlite";

	bool created = initDatabase();

	if (fs::PathExists(txt_filename) && (created ||
			fs::PathExists(migrating_flag))) {
		std::ofstream of(migrating_flag.c_str());
		of.close();
		migrate(txt_filename);
		fs::DeleteSingleFileOrEmptyDirectory(migrating_flag);
	}
}


RollbackManager::~RollbackManager()
{
	flush();

	FINALIZE_STATEMENT(stmt_insert);
	FINALIZE_STATEMENT(stmt_replace);
	FINALIZE_STATEMENT(stmt_select);
	FINALIZE_STATEMENT(stmt_select_range);
	FINALIZE_STATEMENT(stmt_select_withActor);
	FINALIZE_STATEMENT(stmt_knownActor_select);
	FINALIZE_STATEMENT(stmt_knownActor_insert);
	FINALIZE_STATEMENT(stmt_knownNode_select);
	FINALIZE_STATEMENT(stmt_knownNode_insert);

	SQLOK_ERRSTREAM(sqlite3_close(db), "Could not close db");
}


void RollbackManager::registerNewActor(const int id, const std::string &name)
{
	Entity actor = {id, name};
	knownActors.push_back(actor);
}


void RollbackManager::registerNewNode(const int id, const std::string &name)
{
	Entity node = {id, name};
	knownNodes.push_back(node);
}


int RollbackManager::getActorId(const std::string &name)
{
	for (std::vector<Entity>::const_iterator iter = knownActors.begin();
			iter != knownActors.end(); ++iter) {
		if (iter->name == name) {
			return iter->id;
		}
	}

	SQLOK(sqlite3_bind_text(stmt_knownActor_insert, 1, name.c_str(), name.size(), NULL));
	SQLRES(sqlite3_step(stmt_knownActor_insert), SQLITE_DONE);
	SQLOK(sqlite3_reset(stmt_knownActor_insert));

	int id = sqlite3_last_insert_rowid(db);
	registerNewActor(id, name);

	return id;
}


int RollbackManager::getNodeId(const std::string &name)
{
	for (std::vector<Entity>::const_iterator iter = knownNodes.begin();
			iter != knownNodes.end(); ++iter) {
		if (iter->name == name) {
			return iter->id;
		}
	}

	SQLOK(sqlite3_bind_text(stmt_knownNode_insert, 1, name.c_str(), name.size(), NULL));
	SQLRES(sqlite3_step(stmt_knownNode_insert), SQLITE_DONE);
	SQLOK(sqlite3_reset(stmt_knownNode_insert));

	int id = sqlite3_last_insert_rowid(db);
	registerNewNode(id, name);

	return id;
}


const char * RollbackManager::getActorName(const int id)
{
	for (std::vector<Entity>::const_iterator iter = knownActors.begin();
			iter != knownActors.end(); ++iter) {
		if (iter->id == id) {
			return iter->name.c_str();
		}
	}

	return "";
}


const char * RollbackManager::getNodeName(const int id)
{
	for (std::vector<Entity>::const_iterator iter = knownNodes.begin();
			iter != knownNodes.end(); ++iter) {
		if (iter->id == id) {
			return iter->name.c_str();
		}
	}

	return "";
}


bool RollbackManager::createTables()
{
	SQLOK(sqlite3_exec(db,
		"CREATE TABLE IF NOT EXISTS `actor` (\n"
		"	`id` INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL,\n"
		"	`name` TEXT NOT NULL\n"
		");\n"
		"CREATE TABLE IF NOT EXISTS `node` (\n"
		"	`id` INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL,\n"
		"	`name` TEXT NOT NULL\n"
		");\n"
		"CREATE TABLE IF NOT EXISTS `action` (\n"
		"	`id` INTEGER PRIMARY KEY AUTOINCREMENT,\n"
		"	`actor` INTEGER NOT NULL,\n"
		"	`timestamp` TIMESTAMP NOT NULL,\n"
		"	`type` INTEGER NOT NULL,\n"
		"	`list` TEXT,\n"
		"	`index` INTEGER,\n"
		"	`add` INTEGER,\n"
		"	`stackNode` INTEGER,\n"
		"	`stackQuantity` INTEGER,\n"
		"	`nodeMeta` INTEGER,\n"
		"	`x` INT,\n"
		"	`y` INT,\n"
		"	`z` INT,\n"
		"	`oldNode` INTEGER,\n"
		"	`oldParam1` INTEGER,\n"
		"	`oldParam2` INTEGER,\n"
		"	`oldMeta` TEXT,\n"
		"	`newNode` INTEGER,\n"
		"	`newParam1` INTEGER,\n"
		"	`newParam2` INTEGER,\n"
		"	`newMeta` TEXT,\n"
		"	`guessedActor` INTEGER,\n"
		"	FOREIGN KEY (`actor`) REFERENCES `actor`(`id`),\n"
		"	FOREIGN KEY (`stackNode`) REFERENCES `node`(`id`),\n"
		"	FOREIGN KEY (`oldNode`)   REFERENCES `node`(`id`),\n"
		"	FOREIGN KEY (`newNode`)   REFERENCES `node`(`id`)\n"
		");\n"
		"CREATE INDEX IF NOT EXISTS `actionIndex` ON `action`(`x`,`y`,`z`,`timestamp`,`actor`);\n",
		NULL, NULL, NULL));
	verbosestream << "SQL Rollback: SQLite3 database structure was created" << std::endl;

	return true;
}


bool RollbackManager::initDatabase()
{
	verbosestream << "RollbackManager: Database connection setup" << std::endl;

	bool needs_create = !fs::PathExists(database_path);
	SQLOK(sqlite3_open_v2(database_path.c_str(), &db,
			SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE, NULL));

	if (needs_create) {
		createTables();
	}

	SQLOK(sqlite3_prepare_v2(db,
		"INSERT INTO `action` (\n"
		"	`actor`, `timestamp`, `type`,\n"
		"	`list`, `index`, `add`, `stackNode`, `stackQuantity`, `nodeMeta`,\n"
		"	`x`, `y`, `z`,\n"
		"	`oldNode`, `oldParam1`, `oldParam2`, `oldMeta`,\n"
		"	`newNode`, `newParam1`, `newParam2`, `newMeta`,\n"
		"	`guessedActor`\n"
		") VALUES (\n"
		"	?, ?, ?,\n"
		"	?, ?, ?, ?, ?, ?,\n"
		"	?, ?, ?,\n"
		"	?, ?, ?, ?,\n"