Session.h

/***************************************************************************
# Copyright (c) 2015, NVIDIA CORPORATION. All rights reserved.
#
# Redistribution and use in source and binary forms, with or without
# modification, are permitted provided that the following conditions
# are met:
#  * Redistributions of source code must retain the above copyright
#    notice, this list of conditions and the following disclaimer.
#  * Redistributions in binary form must reproduce the above copyright
#    notice, this list of conditions and the following disclaimer in the
#    documentation and/or other materials provided with the distribution.
#  * Neither the name of NVIDIA CORPORATION nor the names of its
#    contributors may be used to endorse or promote products derived
#    from this software without specific prior written permission.
#
# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS ``AS IS'' AND ANY
# EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
# IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
# PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE COPYRIGHT OWNER OR
# CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
# EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
# PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
# PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY
# OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
***************************************************************************/
#pragma once

#include <G3D/G3D.h>
#include "FpsConfig.h"
#include <ctime>

class FPSciApp;
class PlayerEntity;
class TargetEntity;
class FPSciLogger;
class Weapon;
enum PresentationState;

// Simple timer for measuring time offsets
class Timer
{
public:
	std::chrono::steady_clock::time_point startTime;
	void startTimer() { startTime = std::chrono::steady_clock::now(); };
	float getTime()
	{
		auto now = std::chrono::steady_clock::now();
		int t = std::chrono::duration_cast<std::chrono::duration<int, std::milli>>(now - startTime).count();
		return ((float)t) / 1000.0f;
	};
};

 struct FrameInfo {
	FILETIME time;
	//float idt = 0.0f;
	float sdt = 0.0f;
	uint32 network_RTT = 0;
	uint32 local_frame = 0;
	uint32 remote_frame = 0;
	String guid = "";

	FrameInfo() {};

	FrameInfo(FILETIME t, float simDeltaTime) {
		time = t;
		sdt = simDeltaTime;
	}

	FrameInfo(FILETIME t, float simDeltaTime, uint32 rtt, uint32 localFrameNum, uint32 remoteFrameNum, GUniqueID clientGUID) {
		time = t;
		sdt = simDeltaTime;
		network_RTT = rtt;
		local_frame = localFrameNum;
		remote_frame = remoteFrameNum;
		guid = clientGUID.toString16();
	}
};

struct TargetLocation {
	FILETIME time;
	String name = "";
	PresentationState state;
	Point3 position = Point3::zero();

	TargetLocation() {};

	TargetLocation(FILETIME t, String targetName, PresentationState trialState, Point3 targetPosition) {
		time = t;
		name = targetName;
		state = trialState;
		position = targetPosition;
	}

	inline bool noChangeFrom(const TargetLocation& other) const {
		return state == other.state && position == other.position;
	}
};

enum PlayerActionType{
	None,
	Aim,
	FireCooldown,
	Miss,
	Hit,
	Destroy,
	Move
};

struct PlayerAction {
	FILETIME			time;
	Point2				viewDirection = Point2::zero();
	Point3				position = Point3::zero();
	PresentationState	state;
	PlayerActionType	action = PlayerActionType::None;
	String				targetName = "";

	PlayerAction() {};

	PlayerAction(FILETIME t, Point2 playerViewDirection, Point3 playerPosition, PresentationState trialState, PlayerActionType playerAction, String name) {
		time = t;
		viewDirection = playerViewDirection;
		position = playerPosition;
		action = playerAction;
		state = trialState;
		targetName = name;
	}

	inline bool noChangeFrom(const PlayerAction& other) const {
		return viewDirection == other.viewDirection && position == other.position && action == other.action && state == other.state && targetName == other.targetName;
	}
};

/** Trial count class (optional for alternate TargetConfig/count table lookup) */
class TrialCount {
public:
	Array<String>	ids;			///< Trial ID list
	int				count = 1;		///< Count of trials to be performed
	static int		defaultCount;	///< Default count to use

	TrialCount() {};
	TrialCount(const Array<String>& trialIds, int trialCount) : ids(trialIds), count(trialCount) {};
	TrialCount(const Any& any);

	Any toAny(const bool forceAll = true) const;
};

/** Configuration for a session worth of trials */
class SessionConfig : public FpsConfig {
public:
	String				id;								///< Session ID
	String				description = "Session";		///< String indicating whether session is training or real
	int					blockCount = 1;					///< Default to just 1 block per session
	Array<TrialCount>	trials;							///< Array of trials (and their counts) to be performed
	bool				closeOnComplete = false;		///< Close application on session completed?
	bool*				isNetworked = nullptr;			///< Checks if its a networked session or not
	int					clientScore = 0;				///< Keeps track of clients score
	int					hitsToKill = 1;
	int					networkLatency = 0;				///< Amount of latenecy to add to all network packets
	int					numberOfRoundsPlayed = 0;		///< Tracks the number of rounds played by the clients
	float				networkedSessionProgress = 0;	///< Keeps track of the progress of a networked session


	SessionConfig() : FpsConfig(defaultConfig()) {}
	SessionConfig(const Any& any);

	// Use a static method to bypass order of declaration for static members (specific to Sampler s_freeList in GLSamplerObect)
	// Trick from: https://www.cs.technion.ac.il/users/yechiel/c++-faq/static-init-order-on-first-use.html
	static FpsConfig& defaultConfig() {
		static FpsConfig def;				// This is NOT freed ever (in our code)
		return def;
	}

	static shared_ptr<SessionConfig> create() { return createShared<SessionConfig>(); }
	Any toAny(const bool forceAll = false) const;
	float getTrialsPerBlock(void) const;			// Get the total number of trials in this session
	Array<String> getUniqueTargetIds() const;

	void respawnPlayer() { player.respawnToPos = true; }
	void propagatePlayerControlsToAllFromGUI() { propagatePlayerControlsToClient(true, false); }
	void propagatePlayerControlsToSelectedClientFromFile() { propagatePlayerControlsToClient(false, true); }
	void propagatePlayerControlsToSelectedClientFromGUI() { propagatePlayerControlsToClient(false, false); }
	void propagatePlayerControlsToClient(bool sendToAll, bool sendFromFile){ 
		player.propagatePlayerConfigsToSelectedClient = !sendToAll; 
		player.readFromFile = sendFromFile; 
		player.propagatePlayerConfigsToAll = sendToAll;
	}
};

class Session : public ReferenceCountedObject {
protected:
	FPSciApp* m_app = nullptr;							///< Pointer to the app
	Scene* m_scene = nullptr;							///< Pointer to the scene
	
	shared_ptr<SessionConfig> m_config;					///< The session this experiment will run
	
	String m_dbFilename;								///< Filename for output logging (less the .db extension)

	shared_ptr<PlayerEntity> m_player;					///< Player entity
	shared_ptr<Weapon> m_weapon;						///< Weapon
	shared_ptr<Camera> m_camera;						///< Camera entity

	// Experiment management					
	int m_destroyedTargets = 0;							///< Number of destroyed target
	int m_hitCount = 0;									///< Count of total hits in this trial
	bool m_hasSession;									///< Flag indicating whether psych helper has loaded a valid session
	int	m_currBlock = 1;								///< Index to the current block of trials
	Array<Array<shared_ptr<TargetConfig>>> m_trials;	///< Storage for trials (to repeat over blocks)
	String m_feedbackMessage;							///< Message to show when trial complete

	// Target management
	Table<String, Array<shared_ptr<ArticulatedModel>>>* m_targetModels;
	int m_lastUniqueID = 0;									///< Counter for creating unique names for various entities
	
	Array<shared_ptr<TargetEntity>> m_targetArray;			///< Array of drawn targets
	Array<shared_ptr<TargetEntity>> m_hittableTargets;		///< Array of targets that can be hit
	Array<shared_ptr<TargetEntity>> m_unhittableTargets;	///< Array of targets that can't be hit

	Table<String, TargetLocation> m_lastLogTargetLoc;		///< Last logged target location (used for logOnChange)
	Point3 m_lastRefTargetPos;								///< Last reference target location (used for aim invalidation)

	int m_frameTimeIdx = 0;									///< Frame time index
	int m_currTrialIdx;										///< Current trial
	int m_currQuestionIdx = -1;								///< Current question index
	Array<int> m_remainingTrials;							///< Completed flags
	Array<int> m_completedTrials;								///< Count of completed trials
	Array<Array<shared_ptr<TargetConfig>>> m_targetConfigs;	///< Target configurations by trial

	// Time-based parameters
	float m_pretrialDuration;							///< (Possibly) randomized pretrial duration
	RealTime m_taskExecutionTime;						///< Task completion time for the most recent trial
	String m_taskStartTime;								///< Recorded task start timestamp							
	String m_taskEndTime;								///< Recorded task end timestamp
	RealTime m_totalRemainingTime = 0;					///< Time remaining in the trial
	Timer m_timer;										///< Timer used for timing tasks	
	// Could move timer above to stopwatch in future
	//Stopwatch stopwatch;			

	Array<HANDLE> m_sessProcesses;						///< Handles for session-level processes
	Array<HANDLE> m_trialProcesses;						///< Handles for trial-level processes

	// Target parameters
	const float m_targetDistance = 1.0f;				///< Actual distance to target
	
	Session(FPSciApp* app, shared_ptr<SessionConfig> config);
	Session(FPSciApp* app);

	~Session(){
		clearTargets();					// Clear the targets when the session is done
		// For now leave "orphaned" processes to allow (session) end commands to run until completion
		//closeTrialProcesses();		// Close any trial processes affiliated with this session
		//closeSessionProcesses();		// Close any processes affiliated with this session
	}

	inline void runTrialCommands(String evt) {
		evt = toLower(evt);
		auto cmds = (evt == "start") ? m_config->commands.trialStartCmds : m_config->commands.trialEndCmds;
		for (auto cmd : cmds) { 
			m_trialProcesses.append(runCommand(cmd, evt + " of trial")); 
		}
	}

	inline void closeTrialProcesses() {
		for (auto handle : m_trialProcesses) { 
			TerminateProcess(handle, 0); 
		}
		m_trialProcesses.clear();
	}

	inline void runSessionCommands(String evt) {
		evt = toLower(evt);
		auto cmds = (evt == "start") ? m_config->commands.sessionStartCmds : m_config->commands.sessionEndCmds;
		for (auto cmd : cmds) { 
			m_sessProcesses.append(runCommand(cmd, evt + " of session")); 
		}
	}

	inline void closeSessionProcesses() {
		for (auto handle : m_sessProcesses) { 
			TerminateProcess(handle, 0); 
		}
		m_sessProcesses.clear();
	}

	String formatFeedback(const String& input);
	String formatCommand(const String& input);

	/** Insert a target into the target array/scene */
	inline void insertTarget(shared_ptr<TargetEntity> target);

	/** Get the total target count for the current trial */
	int totalTrialTargets() const {
		int totalTargets = 0;
		for (shared_ptr<TargetConfig> target : m_targetConfigs[m_currTrialIdx]) {
			if (target->respawnCount == -1) {
				totalTargets = -1;		// Ininite spawn case
				break;
			}
			else {
				totalTargets += (target->respawnCount + 1);
			}
		}
		return totalTargets;
	}

	shared_ptr<TargetEntity> spawnDestTarget(
		shared_ptr<TargetConfig> config,
		const Point3& offset,
		const Color3& color,
		const int paramIdx,
		const String& name = "");

	shared_ptr<FlyingEntity> spawnReferenceTarget(
		const Point3& position,
		const Point3& orbitCenter,
		const float size,
		const Color3& color
	);

	shared_ptr<FlyingEntity> spawnFlyingTarget(
		shared_ptr<TargetConfig> config,
		const Point3& position,
		const Point3& orbitCenter,
		const Color3& color,
		const int paramIdx,
		const String& name = ""
	);

	shared_ptr<JumpingEntity> spawnJumpingTarget(
		shared_ptr<TargetConfig> config,
		const Point3& position,
		const Point3& orbitCenter,
		const Color3& color,
		const float targetDistance,
		const int paramIdx,
		const String& name = ""
	);

	inline float drawTruncatedExp(float lambda, float min, float max) {
		const float p = Random::common().uniform();
		const float R = max - min;
		if (lambda == 0.f) return min + p * R;
		if (lambda < -88.f) return max;				// This prevents against numerical errors in the expression below
		return -log(1 - p * (1 - exp(-lambda * R))) / lambda + min;
	}

	inline Point2 getViewDirection()
	{   // returns (azimuth, elevation), where azimuth is 0 deg when straightahead and + for right, - for left.
		Point3 view_cartesian = m_camera->frame().lookVector();
		float az = atan2(view_cartesian.x, -view_cartesian.z) * 180 / pif();
		float el = atan2(view_cartesian.y, sqrtf(view_cartesian.x * view_cartesian.x + view_cartesian.z * view_cartesian.z)) * 180 / pif();
		return Point2(az, el);
	}

	inline Point3 getPlayerLocation()
	{
		return m_camera->frame().translation;
	}

	HANDLE runCommand(CommandSpec cmd, String evt) {
		STARTUPINFO si;
		PROCESS_INFORMATION pi;
		ZeroMemory(&si, sizeof(si));
		si.cb = sizeof(si);
		ZeroMemory(&pi, sizeof(pi));

		// Run the (formatted command)
		LPSTR command = LPSTR(formatCommand(cmd.cmdStr).c_str());
		bool success;
		if (cmd.foreground) {	// Run process in the foreground
			success = CreateProcess(NULL, command, NULL, NULL, FALSE, CREATE_NEW_CONSOLE, NULL, NULL, &si, &pi);
		}
		else {				// Run process silently in the background
			success = CreateProcess(NULL, command, NULL, NULL, TRUE, CREATE_NO_WINDOW, NULL, NULL, &si, &pi);
		}

		if (!success) {
			logPrintf("Failed to run %s command: \"%s\". %s\n", evt, cmd, GetLastErrorString());
		}

		if (cmd.blocking) {	// Optional blocking behavior
			WaitForSingleObject(pi.hProcess, INFINITE);
		}

		return pi.hProcess;
	}

	String GetLastErrorString() {
		DWORD error = GetLastError();
		if (error) {
			LPVOID lpMsgBuf;
			DWORD bufLen = FormatMessage(FORMAT_MESSAGE_ALLOCATE_BUFFER | FORMAT_MESSAGE_FROM_SYSTEM | FORMAT_MESSAGE_IGNORE_INSERTS, NULL, error, MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT), (LPTSTR)&lpMsgBuf, 0, NULL);
			if (bufLen) {
				LPCSTR lpMsgStr = (LPCSTR)lpMsgBuf;
				std::string result(lpMsgStr, lpMsgStr + bufLen);
				LocalFree(lpMsgBuf);
				return String(result);
			}
		}
		return String();
	}

public:
	float initialHeadingRadians = 0.0f;
	shared_ptr<FPSciLogger> logger;					///< Output results logger

	static shared_ptr<Session> create(FPSciApp* app) {
		return createShared<Session>(app);
	}
	static shared_ptr<Session> create(FPSciApp* app, shared_ptr<SessionConfig> config) {
		return createShared<Session>(app, config);
	}

	void randomizePosition(const shared_ptr<TargetEntity>& target) const;
	void initTargetAnimation();
	void spawnTrialTargets(Point3 initialSpawnPos, bool previewMode = false);

	bool blockComplete() const;
	bool nextCondition();
	bool hasNextCondition() const;

	const RealTime targetFrameTime();

	void endLogging();

	/** randomly returns either +1 or -1 **/	
	static float randSign() {
		if (Random::common().uniform() > 0.5) {
			return 1;
		} else {
			return -1;
		}
	}
	
	void updatePresentationState();
	virtual void onInit(String filename, String description);
	virtual void onSimulation(RealTime rdt, SimTime sdt, SimTime idt);
	void processResponse();
	void recordTrialResponse(int destroyedTargets, int totalTargets);
	void accumulateTrajectories();
	virtual void accumulateFrameInfo(RealTime rdt, float sdt, float idt);

	void countDestroy() {
		m_destroyedTargets++;
	}

	/** Destroy a target from the targets array */
	void destroyTarget(shared_ptr<TargetEntity> target);

	/** clear all targets (used when clearing remaining targets at the end of a trial) */
	void clearTargets();

	bool inTask();
	float getElapsedTrialTime();
	float getRemainingTrialTime();
	float getProgress();
	double getScore();
	String getFeedbackMessage();

	/** queues action with given name to insert into database when trial completes
	@param action - one of "aim" "hit" "miss" or "invalid (shots limited by fire rate)" */
	void accumulatePlayerAction(PlayerActionType action, String target="");
	
	bool updateBlock(bool init = false);

	bool moveOn = false;								///< Flag indicating session is complete
	PresentationState currentState;						///< Current presentation state

	const Array<shared_ptr<TargetEntity>>& targetArray() const {
		return m_targetArray;
	}

	/** dynamically allocates a new array of pointers to the hittable targets in the session */
	const Array<shared_ptr<TargetEntity>>& hittableTargets() const {
		return m_hittableTargets;
	}

	/** dynamically allocates a new array of pointers to the unhittable (visible but inactive) targets in the session */
	const Array<shared_ptr<TargetEntity>>& unhittableTargets() const {
		return m_unhittableTargets;
	}
};