123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164 |
- #include "Game.h"
- #include <Logging.h>
- #include "AsynchronCall.h"
- #include "Chat.h"
- #include "Dimension.h"
- #include "Entity.h"
- #include "ItemEntity.h"
- #include "JsonUtils.h"
- #include "MultiblockTree.h"
- #include "NetworkMessage.h"
- #include "NoBlock.h"
- #include "Player.h"
- #include "PlayerHand.h"
- #include "PlayerRegister.h"
- #include "Quest.h"
- #include "RecipieLoader.h"
- #include "Server.h"
- #include "TickOrganizer.h"
- #include "UIController.h"
- #include "WorldGenerator.h"
- #include "WorldLoader.h"
- #include "Zeit.h"
- using namespace Framework;
- Framework::ConsoleHandler* Game::consoleHandler = 0;
- Framework::InputLine* Game::consoleInput = 0;
- Game::Game(Framework::Text name, Framework::Text worldsDir)
- : Thread(),
- name(name),
- typeRegistry(new TypeRegistry()),
- dimensions(new RCArray<Dimension>()),
- clients(new RCArray<GameClient>()),
- questManager(new QuestManager()),
- ticker(new TickOrganizer()),
- path((const char*)(worldsDir + "/" + name)),
- stop(0),
- tickId(0),
- nextEntityId(0),
- generator(0),
- loader(0),
- recipies(new RecipieLoader()),
- chat(0),
- playerRegister(new PlayerRegister(path)),
- uiController(new UIController()),
- totalTickTime(0),
- tickCounter(0),
- averageTickTime(0),
- ticksPerSecond(0),
- totalTime(0),
- blockTypes(0),
- blockTypeCount(0),
- itemTypes(0),
- itemTypeCount(0),
- entityTypes(0),
- entityTypeCount(0),
- multiblockStructureTypes(0),
- multiblockStructureTypeCount(0)
- {
- if (!DateiExistiert(path)) DateiPfadErstellen(path + "/");
- Datei d;
- d.setDatei(path + "/eid");
- if (d.existiert())
- {
- d.open(Datei::Style::lesen);
- d.lese((char*)&nextEntityId, 4);
- d.close();
- }
- start();
- }
- Game::~Game()
- {
- dimensions->release();
- clients->release();
- generator->release();
- loader->release();
- chat->release();
- playerRegister->release();
- typeRegistry->release();
- uiController->release();
- recipies->release();
- for (int i = 0; i < blockTypeCount; i++)
- {
- if (blockTypes[i]) blockTypes[i]->release();
- }
- delete[] blockTypes;
- for (int i = 0; i < itemTypeCount; i++)
- {
- if (itemTypes[i]) itemTypes[i]->release();
- }
- delete[] itemTypes;
- for (int i = 0; i < entityTypeCount; i++)
- {
- if (entityTypes[i]) entityTypes[i]->release();
- }
- delete[] entityTypes;
- for (int i = 0; i < multiblockStructureTypeCount; i++)
- {
- if (multiblockStructureTypes[i]) multiblockStructureTypes[i]->release();
- }
- delete[] multiblockStructureTypes;
- }
- void Game::initialize()
- {
- // TODO load mods libraries
- // load block types
- Framework::Logging::info() << "Loading block types";
- Framework::Array<BlockType*> blockTypeArray;
- Framework::JSON::Validator::JSONValidator* validator
- = Framework::JSON::Validator::JSONValidator::buildForArray()
- ->addAcceptedTypeInArray(typeRegistry->getValidator<BlockType>())
- ->removeInvalidEntries()
- ->finishArray();
- loadAllJsonsFromDirectory("data/blocks",
- [this, &blockTypeArray, validator](
- Framework::JSON::JSONValue* zValue, Framework::Text path) {
- Framework::RCArray<Framework::JSON::Validator::JSONValidationResult>
- validationResults;
- Framework::JSON::JSONValue* validParts
- = validator->getValidParts(zValue, &validationResults);
- for (Framework::JSON::Validator::JSONValidationResult* result :
- validationResults)
- {
- Framework::Logging::error() << result->getInvalidInfo();
- }
- if (validParts)
- {
- for (Framework::JSON::JSONValue* value : *validParts->asArray())
- {
- BlockType* blockType
- = typeRegistry->fromJson<BlockType>(value);
- if (blockType)
- {
- blockTypeArray.add(blockType);
- }
- }
- validParts->release();
- }
- });
- validator->release();
- Framework::Logging::info() << "Loaded " << blockTypeArray.getEintragAnzahl()
- << " block types from data/blocks";
- blockTypes = new BlockType*[2 + blockTypeArray.getEintragAnzahl()];
- blockTypes[0]
- = new NoBlockBlockType(&NoBlock::INSTANCE, "__not_yet_generated");
- blockTypes[1] = new NoBlockBlockType(&AirBlock::INSTANCE, "Air");
- blockTypeCount = 2;
- for (BlockType* blockType : blockTypeArray)
- {
- blockTypes[blockTypeCount++] = blockType;
- }
- for (int i = 0; i < blockTypeCount; i++)
- {
- blockTypes[i]->setTypeId(i);
- }
- Framework::Logging::info() << "Loading item types";
- Framework::Array<ItemType*> itemTypeArray;
- validator
- = Framework::JSON::Validator::JSONValidator::buildForArray()
- ->addAcceptedTypeInArray(typeRegistry->getValidator<ItemType>())
- ->removeInvalidEntries()
- ->finishArray();
- loadAllJsonsFromDirectory("data/items",
- [this, &itemTypeArray, validator](
- Framework::JSON::JSONValue* zValue, Framework::Text path) {
- Framework::RCArray<Framework::JSON::Validator::JSONValidationResult>
- validationResults;
- Framework::JSON::JSONValue* validParts
- = validator->getValidParts(zValue, &validationResults);
- for (Framework::JSON::Validator::JSONValidationResult* result :
- validationResults)
- {
- Framework::Logging::error() << result->getInvalidInfo();
- }
- if (validParts)
- {
- for (Framework::JSON::JSONValue* value : *validParts->asArray())
- {
- ItemType* itemType
- = typeRegistry->fromJson<ItemType>(value);
- if (itemType)
- {
- itemTypeArray.add(itemType);
- }
- }
- validParts->release();
- }
- });
- validator->release();
- Framework::Logging::info() << "Loaded " << itemTypeArray.getEintragAnzahl()
- << " item types from data/items";
- itemTypes
- = new ItemType*[blockTypeCount + itemTypeArray.getEintragAnzahl()];
- itemTypes[0] = new PlayerHandItemType();
- itemTypeCount = 1;
- for (int i = 0; i < blockTypeCount; i++)
- {
- ItemType* itemType = blockTypes[i]->createItemType();
- if (itemType)
- {
- itemTypes[itemTypeCount++] = itemType;
- }
- }
- for (ItemType* itemType : itemTypeArray)
- {
- itemTypes[itemTypeCount++] = itemType;
- }
- for (int i = 0; i < itemTypeCount; i++)
- {
- itemTypes[i]->setTypeId(i);
- }
- Framework::Logging::info() << "Loading entity types";
- Framework::Array<EntityType*> entityTypeArray;
- /* validator
- = Framework::JSON::Validator::JSONValidator::buildForArray()
- ->addAcceptedTypeInArray(typeRegistry->getValidator<EntityType>())
- ->removeInvalidEntries()
- ->finishArray();
- loadAllJsonsFromDirectory("data/entities",
- [this, &entityTypeArray, validator](
- Framework::JSON::JSONValue* zValue, Framework::Text path) {
- Framework::RCArray<Framework::JSON::Validator::JSONValidationResult>
- validationResults;
- Framework::JSON::JSONValue* validParts
- = validator->getValidParts(zValue, &validationResults);
- for (Framework::JSON::Validator::JSONValidationResult* result :
- validationResults)
- {
- result->printInvalidInfo();
- }
- if (validParts)
- {
- for (Framework::JSON::JSONValue* value : *validParts->asArray())
- {
- EntityType* entityType
- = typeRegistry->fromJson<EntityType>(value);
- if (entityType)
- {
- entityTypeArray.add(entityType);
- }
- }
- validParts->release();
- }
- });
- validator->release();*/
- Framework::Logging::info()
- << "Loaded " << entityTypeArray.getEintragAnzahl()
- << " entity types from data/entities";
- entityTypes = new EntityType*[2 + entityTypeArray.getEintragAnzahl()];
- entityTypes[0] = new PlayerEntityType();
- entityTypes[1] = new ItemEntityType();
- entityTypeCount = 2;
- for (EntityType* entityType : entityTypeArray)
- {
- entityTypes[entityTypeCount++] = entityType;
- }
- for (int i = 0; i < entityTypeCount; i++)
- {
- entityTypes[i]->setTypeId(i);
- }
- // initialize loaded types
- bool allInitialized = false;
- while (!allInitialized)
- {
- allInitialized = true;
- for (int i = 0; i < blockTypeCount; i++)
- {
- if (blockTypes[i] && !blockTypes[i]->initialize(this))
- {
- Framework::Logging::error()
- << "Could not initialize Block Type '"
- << blockTypes[i]->getName() << "'.";
- blockTypes[i]->release();
- blockTypes[i] = 0;
- allInitialized = false;
- }
- }
- }
- allInitialized = false;
- while (!allInitialized)
- {
- allInitialized = true;
- for (int i = 0; i < itemTypeCount; i++)
- {
- if (itemTypes[i] && !itemTypes[i]->initialize(this))
- {
- Framework::Logging::error()
- << "Could not initialize Item Type '"
- << itemTypes[i]->getName() << "'.";
- itemTypes[i]->release();
- itemTypes[i] = 0;
- allInitialized = false;
- }
- }
- }
- allInitialized = false;
- while (!allInitialized)
- {
- allInitialized = true;
- for (int i = 0; i < entityTypeCount; i++)
- {
- if (entityTypes[i] && !entityTypes[i]->initialize(this))
- {
- Framework::Logging::error()
- << "Could not initialize Entity Type '"
- << entityTypes[i]->getName() << "'.";
- entityTypes[i]->release();
- entityTypes[i] = 0;
- allInitialized = false;
- }
- }
- }
- for (int i = 0; i < blockTypeCount; i++)
- {
- if (blockTypes[i])
- {
- blockTypes[i]->initializeDefault();
- }
- }
- multiblockStructureTypes = new MultiblockStructureType*[1];
- multiblockStructureTypes[0] = new MultiblockTreeStructureType();
- multiblockStructureTypeCount = 1;
- // save syntax info
- Framework::DateiRemove("data/syntax");
- typeRegistry->writeSyntaxInfo("data/syntax");
- // initialize world generator and world loader
- int seed = 0;
- int index = 0;
- for (const char* n = name; *n; n++)
- seed += (int)pow((float)*n * 31, (float)++index);
- generator = new WorldGenerator(seed);
- loader = new WorldLoader();
- // load recipies
- recipies->loadRecipies("data/recipies");
- // initialize chat
- chat = new Chat();
- // load quests
- questManager->loadQuests();
- }
- void Game::thread()
- {
- ZeitMesser waitForLock;
- ZeitMesser removeOldClients;
- ZeitMesser tickEntities;
- ZeitMesser worldUpdates;
- ZeitMesser clientReply;
- ZeitMesser removeOldChunks;
- ZeitMesser m;
- ZeitMesser total;
- total.messungStart();
- double tickTime = 0;
- double sleepTime = 0;
- int nextTimeSync = MAX_TICKS_PER_SECOND;
- while (!stop)
- {
- m.messungStart();
- ticker->nextTick();
- actionsCs.lock();
- while (actions.getEintragAnzahl() > 0)
- {
- actions.get(0)();
- actions.remove(0);
- }
- actionsCs.unlock();
- Array<int> removed;
- double waitTotal = 0;
- waitForLock.messungStart();
- cs.lock();
- waitForLock.messungEnde();
- waitTotal += waitForLock.getSekunden();
- removeOldClients.messungStart();
- int index = 0;
- nextTimeSync--;
- for (auto player : *clients)
- {
- if (!player->isOnline())
- {
- uiController->removePlayerDialogs(player->zEntity()->getId());
- chat->removeObserver(player->zEntity()->getId());
- chat->broadcastMessage(
- Framework::Text(player->zEntity()->getName())
- + " left the game.",
- Chat::CHANNEL_INFO);
- Datei pFile;
- pFile.setDatei(path + "/player/"
- + getPlayerId(player->zEntity()->getName()));
- pFile.erstellen();
- if (pFile.open(Datei::Style::schreiben))
- zEntityType(EntityTypeEnum::PLAYER)
- ->saveEntity(player->zEntity(), &pFile);
- pFile.close();
- removed.add(index, 0);
- Dimension* dim
- = zDimension(player->zEntity()->getDimensionId());
- dim->removeSubscriptions(player->zEntity());
- Chunk* chunk = dim->zChunk(
- getChunkCenter((int)player->zEntity()->getLocation().x,
- (int)player->zEntity()->getLocation().y));
- if (chunk)
- {
- chunk->onEntityLeaves(player->zEntity(), 0);
- }
- dim->removeEntity(player->zEntity()->getId());
- }
- else
- {
- if (nextTimeSync <= 0 && player->zEntity())
- {
- Dimension* zDim
- = zDimension(player->zEntity()->getDimensionId());
- if (zDim)
- {
- NetworkMessage* msg = new NetworkMessage();
- msg->syncTime(zDim->getCurrentDayTime(),
- zDim->getNightDuration(),
- zDim->getNightTransitionDuration(),
- zDim->getDayDuration());
- player->sendResponse(msg);
- }
- }
- }
- index++;
- }
- if (nextTimeSync <= 0)
- {
- nextTimeSync = MAX_TICKS_PER_SECOND;
- }
- for (auto i : removed)
- clients->remove(i);
- removeOldClients.messungEnde();
- cs.unlock();
- tickEntities.messungStart();
- for (auto dim : *dimensions)
- dim->tickEntities();
- tickEntities.messungEnde();
- waitForLock.messungStart();
- cs.lock();
- waitForLock.messungEnde();
- waitTotal += waitForLock.getSekunden();
- worldUpdates.messungStart();
- worldUpdates.messungEnde();
- cs.unlock();
- clientReply.messungStart();
- for (auto client : *clients)
- client->reply();
- clientReply.messungEnde();
- waitForLock.messungStart();
- cs.lock();
- waitForLock.messungEnde();
- waitTotal += waitForLock.getSekunden();
- removeOldChunks.messungStart();
- for (auto dim : *dimensions)
- dim->removeOldChunks();
- removeOldChunks.messungEnde();
- cs.unlock();
- m.messungEnde();
- double sec = m.getSekunden();
- tickCounter++;
- totalTickTime += sec;
- sleepTime += 1.0 / MAX_TICKS_PER_SECOND - tickTime;
- if (sleepTime > 0)
- {
- Sleep((int)(sleepTime * 1000));
- }
- total.messungEnde();
- total.messungStart();
- tickTime = total.getSekunden();
- totalTime += tickTime;
- if (totalTime >= 1)
- {
- averageTickTime = totalTickTime / tickCounter;
- ticksPerSecond = tickCounter;
- totalTickTime = 0;
- tickCounter = 0;
- totalTime = 0;
- }
- else if (sec > 1)
- {
- Framework::Logging::warning()
- << "tick needed " << sec
- << " seconds. The game will run sower then normal.\n";
- Framework::Logging::trace()
- << "waiting: " << waitTotal
- << "\nremoveOldClients: " << removeOldClients.getSekunden()
- << "\ntickEntities:" << tickEntities.getSekunden()
- << "\nworldUpdates: " << worldUpdates.getSekunden()
- << "\nclientReply: " << clientReply.getSekunden()
- << "\nremoveOldChunks:" << removeOldChunks.getSekunden();
- }
- }
- save();
- generator->exitAndWait();
- loader->exitAndWait();
- ticker->exitAndWait();
- for (Dimension* dim : *dimensions)
- dim->requestStopAndWait();
- Framework::Logging::info() << "Game thread exited";
- }
- void Game::api(Framework::InMemoryBuffer* zRequest, GameClient* zOrigin)
- {
- char type;
- zRequest->lese(&type, 1);
- NetworkMessage* response = new NetworkMessage();
- switch (type)
- {
- case 1: // world
- {
- Dimension* dim = zDimension(zOrigin->zEntity()->getDimensionId());
- if (!dim)
- {
- dim = generator->createDimension(
- zOrigin->zEntity()->getDimensionId());
- if (!dim)
- {
- Framework::Logging::error()
- << "could not create dimension "
- << zOrigin->zEntity()->getDimensionId()
- << ". No Factory was provided.";
- return;
- }
- addDimension(dim);
- }
- dim->api(zRequest, response, zOrigin->zEntity());
- break;
- }
- case 2: // player
- zOrigin->zEntity()->playerApi(zRequest, response);
- break;
- case 3: // entity
- {
- int id;
- zRequest->lese((char*)&id, 4);
- for (Dimension* dim : *dimensions)
- {
- Entity* entity = dim->zEntity(id);
- if (entity)
- {
- entity->api(zRequest, response, zOrigin->zEntity());
- break;
- }
- }
- break;
- }
- case 4:
- { // inventory
- bool isEntity;
- zRequest->lese((char*)&isEntity, 1);
- Inventory* target;
- if (isEntity)
- {
- int id;
- zRequest->lese((char*)&id, 4);
- target = zEntity(id);
- }
- else
- {
- int dim;
- Vec3<int> pos;
- zRequest->lese((char*)&dim, 4);
- zRequest->lese((char*)&pos.x, 4);
- zRequest->lese((char*)&pos.y, 4);
- zRequest->lese((char*)&pos.z, 4);
- target = zBlockAt(pos, dim, 0);
- }
- if (target)
- target->inventoryApi(zRequest, response, zOrigin->zEntity());
- break;
- }
- case 5:
- { // crafting uiml request
- int id;
- zRequest->lese((char*)&id, 4);
- Text uiml = recipies->getCrafingUIML(id);
- Text dialogId = "crafting_";
- dialogId += id;
- uiController->addDialog(new UIDialog(dialogId,
- zOrigin->zEntity()->getId(),
- new Framework::XML::Element(uiml)));
- break;
- }
- case 6:
- { // chat message
- chat->chatApi(zRequest, zOrigin->zEntity(), response);
- break;
- }
- case 7: // other dimension
- {
- int dimensionId;
- zRequest->lese((char*)&dimensionId, 4);
- Dimension* dim = zDimension(dimensionId);
- if (dim)
- {
- dim->api(zRequest, response, zOrigin->zEntity());
- }
- break;
- }
- case 8: // ui message
- {
- uiController->api(zRequest, response, zOrigin->zEntity());
- break;
- }
- default:
- Framework::Logging::warning()
- << "received unknown api request in game with type " << (int)type;
- }
- if (!response->isEmpty())
- {
- if (response->isBroadcast())
- broadcastMessage(response);
- else
- zOrigin->sendResponse(response);
- }
- else
- {
- response->release();
- }
- }
- void Game::updateLightning(int dimensionId, Vec3<int> location)
- {
- Dimension* zDim = zDimension(dimensionId);
- if (zDim) zDim->updateLightning(location);
- }
- void Game::updateLightningWithoutWait(int dimensionId, Vec3<int> location)
- {
- Dimension* zDim = zDimension(dimensionId);
- if (zDim) zDim->updateLightningWithoutWait(location);
- }
- void Game::broadcastMessage(NetworkMessage* response)
- {
- for (auto client : *clients)
- client->sendResponse(
- dynamic_cast<NetworkMessage*>(response->getThis()));
- response->release();
- }
- void Game::sendMessage(NetworkMessage* response, Entity* zTargetPlayer)
- {
- for (auto client : *clients)
- {
- if (client->zEntity()->getId() == zTargetPlayer->getId())
- {
- client->sendResponse(response);
- return;
- }
- }
- response->release();
- }
- bool Game::checkPlayer(Framework::Text name, Framework::Text secret)
- {
- if (playerRegister->checkSecret(name, secret))
- return 1;
- else
- {
- Framework::Logging::warning()
- << "player " << name.getText()
- << " tryed to connect with an invalid secret.";
- return 0;
- }
- }
- bool Game::existsPlayer(Framework::Text name)
- {
- return playerRegister->hasPlayer(name);
- }
- Framework::Text Game::createPlayer(Framework::Text name)
- {
- return playerRegister->addPlayer(name);
- }
- GameClient* Game::addPlayer(FCKlient* client, Framework::Text name)
- {
- cs.lock();
- int id = playerRegister->getPlayerId(name);
- Datei pFile;
- pFile.setDatei(path + "/player/" + id);
- Player* player;
- bool isNew = 0;
- if (!pFile.existiert() || !pFile.open(Datei::Style::lesen))
- {
- player = (Player*)zEntityType(EntityTypeEnum::PLAYER)
- ->createEntityAt(
- Vec3<float>(0.5, 0.5, 0), DimensionEnum::OVERWORLD);
- player->setName(name);
- isNew = 1;
- }
- else
- {
- player
- = (Player*)zEntityType(EntityTypeEnum::PLAYER)->loadEntity(&pFile);
- pFile.close();
- }
- if (player->getId() >= nextEntityId)
- {
- nextEntityId = player->getId() + 1;
- }
- GameClient* gameClient = new GameClient(player, client);
- gameClient->sendTypes();
- clients->add(gameClient);
- if (!zDimension(player->getDimensionId()))
- {
- Dimension* dim = generator->createDimension(player->getDimensionId());
- if (!dim)
- {
- Framework::Logging::error() << "could not create dimension "
- << (int)player->getDimensionId()
- << ". No Factory was provided.";
- return 0;
- }
- NetworkMessage* msg = new NetworkMessage();
- msg->syncTime(dim->getCurrentDayTime(),
- dim->getNightDuration(),
- dim->getNightTransitionDuration(),
- dim->getDayDuration());
- gameClient->sendResponse(msg);
- this->addDimension(dim);
- }
- // subscribe the new player as an observer of the new chunk
- Dimension* dim = zDimension(player->getDimensionId());
- InMemoryBuffer* buffer = new InMemoryBuffer();
- buffer->schreibe("\0", 1);
- Punkt center = getChunkCenter(
- (int)player->getPosition().x, (int)player->getPosition().y);
- buffer->schreibe((char*)¢er.x, 4);
- buffer->schreibe((char*)¢er.y, 4);
- buffer->schreibe("\0", 1);
- dim->api(buffer, 0, player);
- buffer->release();
- while (isNew
- && !dim->zChunk(getChunkCenter(
- (int)player->getPosition().x, (int)player->getPosition().y)))
- {
- cs.unlock();
- Sleep(1000);
- cs.lock();
- }
- if (isNew)
- {
- Either<Block*, int> b = BlockTypeEnum::AIR;
- int h = WORLD_HEIGHT;
- while (((b.isA() && (!(Block*)b || ((Block*)b)->isPassable()))
- || (b.isB() && zBlockType(b)->zDefault()->isPassable()))
- && h > 0)
- b = zBlockAt({(int)player->getPosition().x,
- (int)player->getPosition().y,
- --h},
- player->getDimensionId(),
- 0);
- player->setPosition(
- {player->getPosition().x, player->getPosition().y, (float)h + 2.f});
- }
- Dimension* zDim = zDimension(player->getDimensionId());
- if (zDim)
- {
- zDim->addEntity(player);
- }
- else
- {
- Framework::Logging::error()
- << "could not add player to dimension "
- << (int)player->getDimensionId() << ". Dimension not loaded.";
- player->release();
- }
- chat->addObserver(gameClient->zEntity()->getId());
- chat->broadcastMessage(name + " joined the game.", Chat::CHANNEL_INFO);
- cs.unlock();
- return dynamic_cast<GameClient*>(gameClient->getThis());
- }
- bool Game::isChunkLoaded(int x, int y, int dimension) const
- {
- Dimension* dim = zDimension(dimension);
- return (dim && dim->hasChunck(x, y));
- }
- bool Game::doesChunkExist(int x, int y, int dimension)
- {
- cs.lock();
- bool result = isChunkLoaded(x, y, dimension)
- || loader->existsChunk(x, y, dimension);
- cs.unlock();
- return result;
- }
- void Game::blockTargetChanged(Block* zBlock)
- {
- for (GameClient* client : *this->clients)
- {
- if (client->zEntity()->zTarget()
- && client->zEntity()->zTarget()->isBlock(
- zBlock->getPos(), NO_DIRECTION))
- {
- client->zEntity()->onTargetChange();
- }
- }
- }
- void Game::entityTargetChanged(Entity* zEntity)
- {
- for (GameClient* client : *this->clients)
- {
- if (client->zEntity()->zTarget()
- && client->zEntity()->zTarget()->isEntity(zEntity->getId()))
- {
- client->zEntity()->onTargetChange();
- }
- }
- }
- void Game::spawnItem(
- Framework::Vec3<float> location, int dimensionId, Item* stack)
- {
- spawnItem(location, dimensionId, new ItemStack(stack, 1));
- }
- void Game::spawnItem(
- Framework::Vec3<float> location, int dimensionId, ItemStack* stack)
- {
- ItemEntity* itemEntity
- = (ItemEntity*)zEntityType(EntityTypeEnum::ITEM)
- ->createEntity(
- location, dimensionId, Game::INSTANCE->getNextEntityId());
- itemEntity->unsaveAddItem(stack, NO_DIRECTION, 0);
- stack->release();
- Dimension* dim = zDimension(dimensionId);
- if (dim)
- {
- dim->addEntity(itemEntity);
- }
- else
- {
- Framework::Logging::error()
- << "could not spawn item entity in dimension " << dimensionId
- << ". Dimension not loaded.";
- itemEntity->release();
- return;
- }
- }
- Framework::Either<Block*, int> Game::zBlockAt(
- Framework::Vec3<int> location, int dimension, OUT Chunk** zChunk) const
- {
- Dimension* dim = zDimension(dimension);
- if (dim) return dim->zBlock(location, zChunk);
- return 0;
- }
- Block* Game::zRealBlockInstance(Framework::Vec3<int> location, int dimension)
- {
- Dimension* dim = zDimension(dimension);
- if (dim) return dim->zRealBlockInstance(location);
- return 0;
- }
- int Game::getBlockType(Framework::Vec3<int> location, int dimension)
- {
- Dimension* dim = zDimension(dimension);
- if (dim) return dim->getBlockType(location);
- return 0;
- }
- Dimension* Game::zDimension(int id) const
- {
- for (auto dim : *dimensions)
- {
- if (dim->getDimensionId() == id) return dim;
- }
- return 0;
- }
- Framework::Punkt Game::getChunkCenter(int x, int y)
- {
- return Punkt(((x < 0 ? x + 1 : x) / CHUNK_SIZE) * CHUNK_SIZE
- + (x < 0 ? -CHUNK_SIZE : CHUNK_SIZE) / 2,
- ((y < 0 ? y + 1 : y) / CHUNK_SIZE) * CHUNK_SIZE
- + (y < 0 ? -CHUNK_SIZE : CHUNK_SIZE) / 2);
- }
- Area Game::getChunckArea(Punkt center) const
- {
- return {center.x - CHUNK_SIZE / 2,
- center.y - CHUNK_SIZE / 2,
- center.x + CHUNK_SIZE / 2 - 1,
- center.y + CHUNK_SIZE / 2 - 1,
- 0};
- }
- Framework::Text Game::getWorldDirectory() const
- {
- return path;
- }
- void Game::requestArea(Area area)
- {
- generator->requestGeneration(area);
- loader->requestLoading(area);
- }
- void Game::save() const
- {
- questManager->saveQuests();
- Datei d;
- d.setDatei(path + "/eid");
- d.open(Datei::Style::schreiben);
- d.schreibe((char*)&nextEntityId, 4);
- d.close();
- playerRegister->save();
- for (auto dim : *dimensions)
- dim->save(path);
- chat->save();
- Framework::Logging::info() << "Game was saved";
- }
- void Game::requestStop()
- {
- stop = 1;
- warteAufThread(1000000);
- }
- void Game::addDimension(Dimension* d)
- {
- dimensions->add(d);
- }
- int Game::getNextEntityId()
- {
- cs.lock();
- int result = nextEntityId++;
- cs.unlock();
- return result;
- }
- WorldGenerator* Game::zGenerator() const
- {
- return generator;
- }
- Game* Game::INSTANCE = 0;
- void Game::initialize(Framework::Text name, Framework::Text worldsDir)
- {
- if (!Game::INSTANCE)
- {
- Game::INSTANCE = new Game(name, worldsDir);
- Game::INSTANCE->initialize();
- }
- }
- Entity* Game::zEntity(int id, int dimensionId) const
- {
- Dimension* d = zDimension(dimensionId);
- if (d) return d->zEntity(id);
- return 0;
- }
- Entity* Game::zEntity(int id) const
- {
- for (Dimension* d : *dimensions)
- {
- Entity* e = d->zEntity(id);
- if (e) return e;
- }
- // for new players that are currently loading
- for (GameClient* client : *clients)
- {
- if (client->zEntity()->getId() == id)
- {
- return client->zEntity();
- }
- }
- return 0;
- }
- Entity* Game::zNearestEntity(int dimensionId,
- Framework::Vec3<float> pos,
- std::function<bool(Entity*)> filter)
- {
- Dimension* d = zDimension(dimensionId);
- if (!d) return 0;
- return d->zNearestEntity(pos, filter);
- }
- RecipieLoader* Game::zRecipies() const
- {
- return recipies;
- }
- void Game::doLater(std::function<void()> action)
- {
- actionsCs.lock();
- actions.add(action);
- actionsCs.unlock();
- }
- TickOrganizer* Game::zTickOrganizer() const
- {
- return ticker;
- }
- Chat* Game::zChat() const
- {
- return chat;
- }
- Player* Game::zPlayerByName(const char* name) const
- {
- for (GameClient* client : *clients)
- {
- if (strcmp(client->zEntity()->getName(), name) == 0)
- {
- return client->zEntity();
- }
- }
- return 0;
- }
- void Game::listPlayerNames(Framework::RCArray<Framework::Text>& names)
- {
- for (GameClient* client : *clients)
- {
- names.add(new Framework::Text(client->zEntity()->getName()));
- }
- }
- TypeRegistry* Game::zTypeRegistry() const
- {
- return typeRegistry;
- }
- int Game::getPlayerId(const char* name) const
- {
- return playerRegister->getPlayerId(name);
- }
- QuestManager* Game::zQuestManager() const
- {
- return questManager;
- }
- UIController* Game::zUIController() const
- {
- return uiController;
- }
- double Game::getAverageTickTime() const
- {
- return averageTickTime;
- }
- int Game::getTicksPerSecond() const
- {
- return ticksPerSecond;
- }
- int Game::getPlayerCount() const
- {
- return clients->getEintragAnzahl();
- }
- int Game::getChunkCount() const
- {
- int result = 0;
- for (Dimension* dim : *dimensions)
- {
- result += dim->getChunkCount();
- }
- return result;
- }
- const BlockType* Game::zBlockType(int id) const
- {
- return blockTypes[id];
- }
- const ItemType* Game::zItemType(int id) const
- {
- return itemTypes[id];
- }
- const EntityType* Game::zEntityType(int id) const
- {
- return entityTypes[id];
- }
- int Game::getEntityTypeId(const char* name) const
- {
- for (int i = 0; i < entityTypeCount; i++)
- {
- if (entityTypes[i]
- && Framework::Text(entityTypes[i]->getName()).istGleich(name))
- {
- return i;
- }
- }
- Framework::Logging::warning()
- << "no entity type with name '" << name << "' found.";
- return -1;
- }
- int Game::getBlockTypeId(const char* name) const
- {
- for (int i = 0; i < blockTypeCount; i++)
- {
- if (blockTypes[i]
- && Framework::Text(blockTypes[i]->getName()).istGleich(name))
- {
- return i;
- }
- }
- Framework::Logging::warning()
- << "no block type with name '" << name << "' found.";
- return -1;
- }
- int Game::getItemTypeId(const char* name) const
- {
- for (int i = 0; i < itemTypeCount; i++)
- {
- if (itemTypes[i]
- && Framework::Text(itemTypes[i]->getName()).istGleich(name))
- {
- return i;
- }
- }
- Framework::Logging::warning()
- << "no item type with name '" << name << "' found.";
- return -1;
- }
- int Game::getBlockTypeCount() const
- {
- return blockTypeCount;
- }
- int Game::getItemTypeCount() const
- {
- return itemTypeCount;
- }
- int Game::getEntityTypeCount() const
- {
- return entityTypeCount;
- }
- const MultiblockStructureType* Game::zMultiblockStructureType(int id) const
- {
- return multiblockStructureTypes[id];
- }
- int Game::getMultiblockStructureTypeCount() const
- {
- return multiblockStructureTypeCount;
- }
|