Function NODE_METHOD

src/objects/backup.cpp:39–87

}

NODE_METHOD(Backup::JS_new) {
	UseAddon;
	if (!addon->privileged_info) return ThrowTypeError(info.Env(), "Disabled constructor");
	assert(info.IsConstructCall());
	const Napi::CallbackInfo& pinfo = *addon->privileged_info;
	UNWRAP_OR_RETURN(Database, db, pinfo.This());
	REQUIRE_DATABASE_OPEN(db->GetState());
	REQUIRE_DATABASE_NOT_BUSY(db->GetState());

	Napi::Object database = pinfo[0].As<Napi::Object>();
	Napi::String attachedName = pinfo[1].As<Napi::String>();
	Napi::String destFile = pinfo[2].As<Napi::String>();
	bool unlink = pinfo[3].As<Napi::Boolean>().Value();

	UseIsolate;
	sqlite3* dest_handle;
	std::string dest_file = destFile.Utf8Value();
	std::string attached_name = attachedName.Utf8Value();
	int mask = (SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE);

	if (sqlite3_open_v2(dest_file.c_str(), &dest_handle, mask, NULL) != SQLITE_OK) {
		Database::ThrowSqliteError(env, addon, dest_handle);
		int status = sqlite3_close(dest_handle);
		assert(status == SQLITE_OK); ((void)status);
		return env.Undefined();
	}

	sqlite3_extended_result_codes(dest_handle, 1);
	sqlite3_limit(dest_handle, SQLITE_LIMIT_LENGTH, INT_MAX);
	sqlite3_backup* backup_handle = sqlite3_backup_init(dest_handle, "main", db->GetHandle(), attached_name.c_str());
	if (backup_handle == NULL) {
		Database::ThrowSqliteError(env, addon, dest_handle);
		int status = sqlite3_close(dest_handle);
		assert(status == SQLITE_OK); ((void)status);
		return env.Undefined();
	}

	this->db = db;
	this->dest_handle = dest_handle;
	this->backup_handle = backup_handle;
	this->id = addon->NextId();
	this->unlink = unlink;
	this->alive = true;
	db->AddBackup(this);

	SetFrozen(env, info.This().As<Napi::Object>(), addon->cs.database, database);

	return info.This();
}

NODE_METHOD(Backup::JS_transfer) {
	UNWRAP_OR_RETURN(Backup, backup, info.This());