openrw/rwgame/RWGame.cpp

#include "RWGame.hpp"
#include "State.hpp"
#include "states/LoadingState.hpp"
#include "states/IngameState.hpp"
#include "states/MenuState.hpp"
#include "states/BenchmarkState.hpp"
#include "DrawUI.hpp"

#include <core/Profiler.hpp>

#include <objects/GameObject.hpp>
#include <engine/GameState.hpp>
#include <engine/SaveGame.hpp>
#include <engine/GameWorld.hpp>
#include <render/GameRenderer.hpp>
#include <render/DebugDraw.hpp>

#include <script/ScriptMachine.hpp>
#include <script/modules/GTA3Module.hpp>

#include <data/CutsceneData.hpp>
#include <ai/PlayerController.hpp>
#include <objects/CharacterObject.hpp>
#include <objects/VehicleObject.hpp>

#include <boost/algorithm/string/predicate.hpp>

#include "GitSHA1.h"

// Use first 8 chars of git hash as the build string
const std::string kBuildStr(kGitSHA1Hash, 8);
const std::string kWindowTitle = "RWGame";

#define MOUSE_SENSITIVITY_SCALE 2.5f

DebugDraw* debug = nullptr;

StdOutReciever logPrinter;

RWGame::RWGame(int argc, char* argv[])
{
	if (!config.isValid())
	{
		throw std::runtime_error("Invalid configuration file at: " + config.getConfigFile());
	}

	size_t w = GAME_WINDOW_WIDTH, h = GAME_WINDOW_HEIGHT;
	bool fullscreen = false;
	bool newgame = false;
	bool test = false;
    std::string startSave;
	std::string benchFile;

	for( int i = 1; i < argc; ++i )
	{
		if( boost::iequals( "-w", argv[i] ) && i+1 < argc )
		{
			w = std::atoi(argv[i+1]);
		}
		if( boost::iequals( "-h", argv[i] ) && i+1 < argc )
		{
			h = std::atoi(argv[i+1]);
		}
		if( boost::iequals( "-f", argv[i] ))
		{
			fullscreen = true;
		}
		if( strcmp( "--newgame", argv[i] ) == 0 )
		{
			newgame = true;
		}
		if( strcmp( "--test", argv[i] ) == 0 )
		{
			test = true;
		}
        if( strcmp( "--load", argv[i] ) == 0 && i+1 < argc )
        {
            startSave = argv[i+1];
        }
		if( strcmp( "--benchmark", argv[i]) == 0 && i+1 < argc )
		{
			benchFile = argv[i+1];
		}
	}

	if (SDL_Init(SDL_INIT_VIDEO) < 0)
		throw std::runtime_error("Failed to initialize SDL2!");

	window = new GameWindow();
	window->create(kWindowTitle + " [" + kBuildStr + "]", w, h, fullscreen);

	work = new WorkContext();

	log.addReciever(&logPrinter);
	log.info("Game", "Game directory: " + config.getGameDataPath());
	log.info("Game", "Build: " + kBuildStr);
	
	if(! GameData::isValidGameDirectory(config.getGameDataPath()) )
	{
		throw std::runtime_error("Invalid game directory path: " + config.getGameDataPath());
	}

	data = new GameData(&log, work, config.getGameDataPath());

	// Initalize all the archives.
	data->loadIMG("/models/gta3");
	//engine->data.loadIMG("/models/txd");
	data->loadIMG("/anim/cuts");
	
	data->load();
	
	// Initialize renderer
	renderer = new GameRenderer(&log, data);
	
	// Set up text renderer
	renderer->text.setFontTexture(0, "pager");
	renderer->text.setFontTexture(1, "font1");
	renderer->text.setFontTexture(2, "font2");

	debug = new DebugDraw;
	debug->setDebugMode(btIDebugDraw::DBG_DrawWireframe | btIDebugDraw::DBG_DrawConstraints | btIDebugDraw::DBG_DrawConstraintLimits);
	debug->setShaderProgram(renderer->worldProg);

	data->loadDynamicObjects(config.getGameDataPath() + "/data/object.dat");

	data->loadGXT(config.getGameLanguage() + ".gxt");
	
	getRenderer()->water.setWaterTable(data->waterHeights, 48, data->realWater, 128*128);
	
	for(int m = 0; m < MAP_BLOCK_SIZE; ++m)
	{
		std::string num = (m < 10 ? "0" : "");
		std::string name = "radar" + num +  std::to_string(m);
		data->loadTXD(name + ".txd");
	}

	auto loading = new LoadingState(this);
	if (! benchFile.empty())
	{
		loading->setNextState(new BenchmarkState(this, benchFile));
	}
	else if( newgame )
	{
		if( test )
		{
			loading->setNextState(new IngameState(this,true, "test"));
		}
		else
		{
			loading->setNextState(new IngameState(this,true));
		}
	}
    else if( ! startSave.empty() )
    {
        loading->setNextState(new IngameState(this,true, startSave));
    }
	else
	{
		loading->setNextState(new MenuState(this));
	}
	
	StateManager::get().enter(loading);

	log.info("Game", "Started");
}

RWGame::~RWGame()
{
	log.info("Game", "Beginning cleanup");

	log.info("Game", "Stopping work queue");
	work->stop();

	log.info("Game", "Cleaning up scripts");
	delete script;

	log.info("Game", "Cleaning up renderer");
	delete renderer;

	log.info("Game", "Cleaning up world");
	delete world;
	
	log.info("Game", "Cleaning up state");
	delete state;

	log.info("Game", "Cleaning up window");
	delete window;

	log.info("Game", "Cleaning up work queue");
	delete work;

	log.info("Game", "Done cleaning up");
}

void RWGame::newGame()
{
	if( state != nullptr )
	{
		log.error("Game", "Cannot start a new game: game is already running.");
		return;
	}

	state = new GameState();
	world = new GameWorld(&log, work, data);
	world->dynamicsWorld->setDebugDrawer(debug);

	// Associate the new world with the new state and vice versa
	state->world = world;
	world->state = state;

	for(std::map<std::string, std::string>::iterator it = world->data->iplLocations.begin();
		it != world->data->iplLocations.end();
		++it) {
		world->data->loadZone(it->second);
		world->placeItems(it->second);
	}
	
}

void RWGame::saveGame(const std::string& savename)
{
	RW_UNUSED(savename);
}

void RWGame::loadGame(const std::string& savename)
{
	delete state->world;
	delete state->script;
	state = nullptr;

    log.info("Game", "Loading game " + savename);

	newGame();

	startScript("main.scm");

	if(! SaveGame::loadGame(*state, savename) )
	{
		log.error("Game", "Failed to load game");
	}
}

void RWGame::startScript(const std::string& name)
{
	SCMFile* f = world->data->loadSCM(name);
	if( f ) {
		if( script ) delete script;

		SCMOpcodes* opcodes = new SCMOpcodes;
		opcodes->modules.push_back(new GTA3Module);

		script = new ScriptMachine(state, f, opcodes);
		
		state->script = script;
	}
	else {
		log.error("Game", "Failed to load SCM: " + name);
	}
}

PlayerController *RWGame::getPlayer()
{
	auto object = world->pedestrianPool.find(state->playerObject);
	if( object )
	{
		auto controller = static_cast<CharacterObject*>(object)->controller;
		return static_cast<PlayerController*>(controller);
	}
	return nullptr;
}

int RWGame::run()
{
	last_clock_time = clock.now();

	// Loop until we run out of states.
	while (StateManager::get().states.size()) {
		State* state = StateManager::get().states.back();

		RW_PROFILE_FRAME_BOUNDARY();
		
		RW_PROFILE_BEGIN("Input");
		SDL_Event event;
		while (SDL_PollEvent(&event)) {
			switch (event.type) {
			case SDL_QUIT:
				StateManager::get().clear();
				break;

			case SDL_WINDOWEVENT:
				switch (event.window.event) {
				case SDL_WINDOWEVENT_FOCUS_GAINED:
					inFocus = true;
					break;

				case SDL_WINDOWEVENT_FOCUS_LOST:
					inFocus = false;
					break;
				}
				break;

			case SDL_KEYDOWN:
				globalKeyEvent(event);
				break;

			case SDL_MOUSEMOTION:
				event.motion.xrel *= MOUSE_SENSITIVITY_SCALE;
				event.motion.yrel *= MOUSE_SENSITIVITY_SCALE;
				break;
			}

			RW_PROFILE_BEGIN("State");
			state->handleEvent(event);
			RW_PROFILE_END()
		}
		RW_PROFILE_END();

		auto now = clock.now();
		float timer = std::chrono::duration<float>(now - last_clock_time).count();
		last_clock_time = now;
		accum += timer * timescale;

		RW_PROFILE_BEGIN("Update");
		if ( accum >= GAME_TIMESTEP ) {
			if (StateManager::get().states.size() == 0) {
				break;
			}

			RW_PROFILE_BEGIN("state");
			StateManager::get().tick(GAME_TIMESTEP);
			RW_PROFILE_END();

			RW_PROFILE_BEGIN("engine");
			tick(GAME_TIMESTEP);
			RW_PROFILE_END();
			
			accum -= GAME_TIMESTEP;
			
			// Throw away time if the accumulator reaches too high.
			if ( accum > GAME_TIMESTEP * 5.f )
			{
				accum = 0.f;
			}
		}
		RW_PROFILE_END();

		float alpha = fmod(accum, GAME_TIMESTEP) / GAME_TIMESTEP;
		if( ! state->shouldWorldUpdate() )
		{
			alpha = 1.f;
		}

		RW_PROFILE_BEGIN("Render");
		RW_PROFILE_BEGIN("engine");
		render(alpha, timer);
		RW_PROFILE_END();

		RW_PROFILE_BEGIN("state");
		if (StateManager::get().states.size() > 0) {
			StateManager::get().draw(renderer);
		}
		RW_PROFILE_END();
		RW_PROFILE_END();

		renderProfile();

		window->swap();
	}

	return 0;
}

void RWGame::tick(float dt)
{
	// Process the Engine's background work.
	world->_work->update();
	
	State* currState = StateManager::get().states.back();

	world->chase.update(dt);
	
	static float clockAccumulator = 0.f;
	if ( currState->shouldWorldUpdate() ) {
		// Clear out any per-tick state.
		world->clearTickData();

		state->gameTime += dt;

		clockAccumulator += dt;
		while( clockAccumulator >= 1.f ) {
			world->state->basic.gameMinute ++;
			while( state->basic.gameMinute >= 60 ) {
				state->basic.gameMinute = 0;
				state->basic.gameHour ++;
				while( state->basic.gameHour >= 24 ) {
					state->basic.gameHour = 0;
				}
			}
			clockAccumulator -= 1.f;
		}
		
		// Clean up old VisualFX
		for( int i = 0; i < static_cast<int>(world->effects.size()); ++i )
		{
			VisualFX* effect = world->effects[i];
			if( effect->getType() == VisualFX::Particle )
			{
				auto& part = effect->particle;
				if( part.lifetime < 0.f ) continue;
				if( world->getGameTime() >= part.starttime + part.lifetime )
				{
					world->destroyEffect( effect );
					--i;
				}
			}
		}

		for( auto& object : world->allObjects ) {
			object->_updateLastTransform();
			object->tick(dt);
		}
		
		world->destroyQueuedObjects();

		state->text.tick(dt);

		world->dynamicsWorld->stepSimulation(dt, 2, dt);
		
		if( script ) {
			try {
				script->execute(dt);
			}
			catch( SCMException& ex ) {
				std::cerr << ex.what() << std::endl;
				log.error( "Script", ex.what() );
				throw;
			}
		}

		/// @todo this doesn't make sense as the condition
		if ( state->playerObject ) {
			nextCam.frustum.update(nextCam.frustum.projection() * nextCam.getView());
			// Use the current camera position to spawn pedestrians.
			world->cleanupTraffic(nextCam);
			world->createTraffic(nextCam);
		}
	}
	
	// render() needs two cameras to smoothly interpolate between ticks.
	lastCam = nextCam;
	nextCam = currState->getCamera();
}

void RWGame::render(float alpha, float time)
{
	lastDraws = getRenderer()->getRenderer()->getDrawCount();
	
	getRenderer()->getRenderer()->swap();

	glm::ivec2 windowSize = window->getSize();
	renderer->setViewport(windowSize.x, windowSize.y);

	ViewCamera viewCam;
	viewCam.frustum.fov = glm::radians(90.f);
	if( state->currentCutscene != nullptr && state->cutsceneStartTime >= 0.f )
	{
		auto cutscene = state->currentCutscene;
		float cutsceneTime = std::min(world->getGameTime() - state->cutsceneStartTime,
									  cutscene->tracks.duration);
		cutsceneTime += GAME_TIMESTEP * alpha;
		glm::vec3 cameraPos = cutscene->tracks.getPositionAt(cutsceneTime),
				targetPos = cutscene->tracks.getTargetAt(cutsceneTime);
		float zoom = cutscene->tracks.getZoomAt(cutsceneTime);
		viewCam.frustum.fov = glm::radians(zoom);
		float tilt = cutscene->tracks.getRotationAt(cutsceneTime);

		auto direction = glm::normalize(targetPos - cameraPos);
		auto right = glm::normalize(glm::cross(glm::vec3(0.f, 0.f, 1.f), direction));
		auto up = glm::normalize(glm::cross(direction, right));

		glm::mat3 m;
		m[0][0] = direction.x;
		m[0][1] = right.x;
		m[0][2] = up.x;

		m[1][0] = direction.y;
		m[1][1] = right.y;
		m[1][2] = up.y;

		m[2][0] = direction.z;
		m[2][1] = right.z;
		m[2][2] = up.z;

		auto qtilt = glm::angleAxis(glm::radians(tilt), direction);

		cameraPos += cutscene->meta.sceneOffset;
		targetPos += cutscene->meta.sceneOffset;

		viewCam.position = cameraPos;
		viewCam.rotation = glm::inverse(glm::quat_cast(m)) * qtilt;
	}
	else if( state->cameraFixed )
	{
		viewCam.position = state->cameraPosition;
		viewCam.rotation = state->cameraRotation;
	}
	else
	{
		// There's no cutscene playing - use the camera returned by the State.
		viewCam.position = glm::mix(lastCam.position, nextCam.position, alpha);
		viewCam.rotation = glm::slerp(lastCam.rotation, nextCam.rotation, alpha);
	}

	viewCam.frustum.aspectRatio = windowSize.x / static_cast<float>(windowSize.y);

	if ( state->isCinematic )
	{
		viewCam.frustum.fov *= viewCam.frustum.aspectRatio;
	}

	glEnable(GL_DEPTH_TEST);
	glClear(GL_DEPTH_BUFFER_BIT|GL_COLOR_BUFFER_BIT);

	renderer->getRenderer()->pushDebugGroup("World");

	RW_PROFILE_BEGIN("world");
	renderer->renderWorld(world, viewCam, alpha);
	RW_PROFILE_END();


	auto rendertime = renderer->getRenderer()->popDebugGroup();

	RW_PROFILE_BEGIN("debug");
	if( showDebugPaths )
	{
		renderDebugPaths(time);
	}

	if ( showDebugStats )
	{
		renderDebugStats(time, rendertime);
	}

	if( showDebugPhysics )
	{
		if( world )
		{
			world->dynamicsWorld->debugDrawWorld();
			debug->flush(renderer);
		}
	}
	RW_PROFILE_END();
	
	drawOnScreenText(world, renderer);
}

void RWGame::renderDebugStats(float time, Renderer::ProfileInfo& worldRenderTime)
{
	// Turn time into milliseconds
	float time_ms = time * 1000.f;
	constexpr size_t average_every_frame = 15;
	static float times[average_every_frame];
	static size_t times_index = 0;
	static float time_average = 0;
	times[times_index++] = time_ms;
	if (times_index >= average_every_frame) {
		times_index = 0;
		time_average = 0;

		for (size_t i = 0; i < average_every_frame; ++i) {
			time_average += times[i];
		}
		time_average /= average_every_frame;
	}

	std::map<std::string, Renderer::ProfileInfo*> profGroups {
		{"Objects", &renderer->profObjects},
		{"Effects", &renderer->profEffects},
		{"Sky", &renderer->profSky},
		{"Water", &renderer->profWater},
	};

	std::stringstream ss;
	ss << "Frametime: " << time_ms << " (FPS " << (1.f/time) << ")\n";
	ss << "Average (per " << average_every_frame << " frames); Frametime: " << time_average << " (FPS " << (1000.f/time_average) << ")\n";
	ss << "Draws: " << lastDraws << " (" << renderer->culled << " Culls)\n";
	ss << " Texture binds: " << renderer->getRenderer()->getTextureCount() << "\n";
	ss << " Buffer binds: " << renderer->getRenderer()->getBufferCount() << "\n";
	ss << " World time: " << (worldRenderTime.duration/1000000) << "ms\n";
	for(auto& perf : profGroups)
	{
		ss << "  " << perf.first << ": "
		<< perf.second->draws << " draws " << perf.second->primitives << " prims "
		<< (perf.second->duration/1000000) << "ms\n";
	}
	
	// Count the number of interesting objects.
	int peds = 0, cars = 0;
	for( auto& object : world->allObjects )
	{
		switch ( object->type() )
		{
			case GameObject::Character: peds++; break;
			case GameObject::Vehicle: cars++; break;
			default: break;
		}
	}
	
	ss << "P " << peds << " V " << cars << "\n";
	
	if( state->playerObject ) {
		ss << "Player (" << state->playerObject << ")\n";
		auto object = world->pedestrianPool.find(state->playerObject);
		auto player = static_cast<CharacterObject*>(object)->controller;
		ss << "Player Activity: ";
		if( player->getCurrentActivity() ) {
			ss << player->getCurrentActivity()->name();
		}
		else {
			ss << "Idle";
		}
		ss << std::endl;
	}
	
	TextRenderer::TextInfo ti;
	ti.text = GameStringUtil::fromString(ss.str());
	ti.font = 2;
	ti.screenPosition = glm::vec2( 10.f, 10.f );
	ti.size = 15.f;
	ti.baseColour = glm::u8vec3(255);
	renderer->text.renderText(ti);

	/*while( engine->log.size() > 0 && engine->log.front().time + 10.f < engine->gameTime ) {
		engine->log.pop_front();
	}

	ti.screenPosition = glm::vec2( 10.f, 500.f );
	ti.size = 15.f;
	for(auto it = engine->log.begin(); it != engine->log.end(); ++it) {
		ti.text = it->message;
		switch(it->type) {
		case GameWorld::LogEntry::Error:
			ti.baseColour = glm::vec3(1.f, 0.f, 0.f);
			break;
		case GameWorld::LogEntry::Warning:
			ti.baseColour = glm::vec3(1.f, 1.f, 0.f);
			break;
		default:
			ti.baseColour = glm::vec3(1.f, 1.f, 1.f);
			break;
		}

		// Interpolate the color
		// c.a = (engine->gameTime - it->time > 5.f) ? 255 - (((engine->gameTime - it->time) - 5.f)/5.f) * 255 : 255;
		// text.setColor(c);

		engine->renderer.text.renderText(ti);
		ti.screenPosition.y -= ti.size;
	}*/
}

void RWGame::renderDebugPaths(float time)
{
	RW_UNUSED(time);

	btVector3 roadColour(1.f, 0.f, 0.f);
	btVector3 pedColour(0.f, 0.f, 1.f);
	
	for( AIGraphNode* n : world->aigraph.nodes )
	{
		btVector3 p( n->position.x, n->position.y, n->position.z );
		auto& col = n->type == AIGraphNode::Pedestrian ? pedColour : roadColour;
		debug->drawLine( p - btVector3(0.f, 0.f, 1.f), p + btVector3(0.f, 0.f, 1.f), col);
		debug->drawLine( p - btVector3(1.f, 0.f, 0.f), p + btVector3(1.f, 0.f, 0.f), col);
		debug->drawLine( p - btVector3(0.f, 1.f, 0.f), p + btVector3(0.f, 1.f, 0.f), col);

		for( AIGraphNode* c : n->connections )
		{
			btVector3 f( c->position.x, c->position.y, c->position.z );
			debug->drawLine( p, f, col);
		}
	}

	// Draw Garage bounds
	for(size_t g = 0; g < state->garages.size(); ++g) {
		auto& garage = state->garages[g];
		btVector3 minColor(1.f, 0.f, 0.f);
		btVector3 maxColor(0.f, 1.f, 0.f);
		btVector3 min(garage.min.x,garage.min.y,garage.min.z);
		btVector3 max(garage.max.x,garage.max.y,garage.max.z);
		debug->drawLine(min, min + btVector3(0.5f, 0.f, 0.f), minColor);
		debug->drawLine(min, min + btVector3(0.f, 0.5f, 0.f), minColor);
		debug->drawLine(min, min + btVector3(0.f, 0.f, 0.5f), minColor);
		
		debug->drawLine(max, max - btVector3(0.5f, 0.f, 0.f), maxColor);
		debug->drawLine(max, max - btVector3(0.f, 0.5f, 0.f), maxColor);
		debug->drawLine(max, max - btVector3(0.f, 0.f, 0.5f), maxColor);
	}

	// Draw vehicle generators
	for(size_t v = 0; v < state->vehicleGenerators.size(); ++v) {
		auto& generator = state->vehicleGenerators[v];
		btVector3 color(1.f, 0.f, 0.f);
		btVector3 position(generator.position.x,generator.position.y,generator.position.z);
		float heading = glm::radians(generator.heading);
		auto back  = btVector3(0.f,-1.f, 0.f).rotate(btVector3(0.f, 0.f, 1.f), heading);
		auto right = btVector3(0.15f, -0.15f, 0.f).rotate(btVector3(0.f, 0.f, 1.f), heading);
		auto left  = btVector3(-0.15f,-0.15f, 0.f).rotate(btVector3(0.f, 0.f, 1.f), heading);
		debug->drawLine(position, position+back, color);
		debug->drawLine(position, position+right, color);
		debug->drawLine(position, position+left, color);
	}

	debug->flush(renderer);
}

void RWGame::renderProfile()
{
#if RW_PROFILER
	auto& frame = perf::Profiler::get().getFrame();
	constexpr float upperlimit = 30000.f;
	constexpr float lineHeight = 15.f;
	static std::vector<glm::vec4> perf_colours;
	if (perf_colours.size() == 0) {
		float c = 8.f;
		for (int r = 0; r < c; ++r) {
			for (int g = 0; g < c; ++g) {
				for (int b = 0; b < c; ++b) {
					perf_colours.push_back({
											   r / c, g / c, b / c, 1.f
										   });
				}
			}
		}
	}


	float xscale = renderer->getRenderer()->getViewport().x / upperlimit;
	TextRenderer::TextInfo ti;
	ti.align = TextRenderer::TextInfo::Left;
	ti.font = 2;
	ti.size = lineHeight - 2.f;
	ti.baseColour = glm::u8vec3(255);
	std::function<void(const perf::ProfileEntry&,int)> renderEntry = [&](const perf::ProfileEntry& entry, int depth)
	{
		int g = 0;
		for(auto& event : entry.childProfiles)
		{
			auto duration = event.end - event.start;
			float y = 60.f + (depth * (lineHeight + 5.f));
			renderer->drawColour(perf_colours[(std::hash<std::string>()(entry.label) * (g++))%perf_colours.size()],
			{
				xscale * event.start,
				y,
				xscale * duration,
				lineHeight
			});
			ti.screenPosition.x = xscale * (event.start);
			ti.screenPosition.y = y + 2.f;
			ti.text = event.label + " " + std::to_string(duration) + " us ";
			renderer->text.renderText(ti);
			renderEntry(event, depth+1);
		}
	};
	renderEntry(frame, 0);
	ti.screenPosition = glm::vec2( xscale * (16000), 40.f);
	ti.text = ".16 ms";
	renderer->text.renderText(ti);
#endif
}

void RWGame::globalKeyEvent(const SDL_Event& event)
{
	switch (event.key.keysym.sym) {
	case SDLK_LEFTBRACKET:
		world->offsetGameTime(-30);
		break;
	case SDLK_RIGHTBRACKET:
		world->offsetGameTime(30);
		break;
	case SDLK_9:
		timescale *= 0.5f;
		break;
	case SDLK_0:
		timescale *= 2.0f;
		break;
	case SDLK_F1:
		showDebugStats = ! showDebugStats;
		break;
	case SDLK_F2:
		showDebugPaths = ! showDebugPaths;
		break;
	case SDLK_F3:
		showDebugPhysics = ! showDebugPhysics;
		break;
	default: break;
	}
}