ApexSystem.cs

Go to the documentation of this file.

using System;
using System.Collections.Generic;
using System.Net.Http;
using System.Text.RegularExpressions;
using System.Threading.Tasks;
using Newtonsoft.Json;
using PixoVR.Apex.Events;
using PixoVR.Apex.Utils;
using PixoVR.Apex.XAPI;
using TinCan;
using UnityEngine;
using UnityEngine.XR;
 
#if MANAGE_XR
using MXR.SDK;
#endif
 
namespace PixoVR.Apex
{
    public delegate void PlatformResponse(ResponseType type, bool wasSuccessful, object responseData);
 
    [DefaultExecutionOrder(-50)]
    public class ApexSystem : ApexSingleton<ApexSystem>
    {
        private enum VersionParts : int
        {
            Major = 0,
            Minor,
            Patch,
        }
 
        public static string ServerIP
        {
            get { return Instance.serverIP; }
            set { }
        }
 
        public static int ModuleID
        {
            get { return Instance.moduleID; }
            set { Instance.moduleID = value; }
        }
 
        public static string ModuleName
        {
            get { return Instance.moduleName; }
            set { Instance.moduleName = value; }
        }
 
        public static string ModuleVersion
        {
            get { return Instance.moduleVersion; }
            set { Instance.moduleVersion = value; }
        }
 
        public static string ScenarioID
        {
            get { return Instance.scenarioID; }
            set { Instance.scenarioID = value; }
        }
 
        public static LoginResponseContent CurrentActiveLogin
        {
            get { return Instance.currentActiveLogin; }
            set { }
        }
 
        public static bool RunSetupOnAwake
        {
            get { return Instance.runSetupOnAwake; }
            set { Instance.runSetupOnAwake = value; }
        }
 
        public static bool LoginCheckModuleAccess
        {
            get { return Instance.loginCheckModuleAccess; }
            set { }
        }
 
        public static string DeviceSerialNumber
        {
            get { return Instance.deviceSerialNumber; }
            set { }
        }
 
        public static string PassedLoginToken
        {
            get { return Instance.loginToken; }
            set { }
        }
 
        public static string OptionalData
        {
            get { return Instance.optionalParameter; }
            set { Instance.optionalParameter = value; }
        }
 
        public static string ReturnTarget
        {
            get { return Instance.returnTargetParameter; }
            set
            {
                if (value != null)
                {
                    Instance.returnTargetParameter = value;
                }
                else
                {
                    Instance.returnTargetParameter = "";
                }
 
                if (Instance.returnTargetParameter.Contains("://"))
                {
                    TargetType = "url";
                }
                else
                {
                    TargetType = "app";
                }
            }
        }
 
        public static string TargetType
        {
            get { return Instance.targetTypeParameter; }
            private set { Instance.targetTypeParameter = value; }
        }
 
        [SerializeField, EndpointDisplay]
        protected PlatformServer PlatformTargetServer;
 
        [SerializeField]
        protected string serverIP = "";
 
        [SerializeField]
        protected int moduleID = 0;
 
        [SerializeField]
        protected string moduleName = "Generic";
 
        [SerializeField]
        protected string moduleVersion = "0.00.00";
 
        [SerializeField]
        protected string scenarioID = "Generic";
 
        [SerializeField]
        public bool runSetupOnAwake = true;
 
        [SerializeField]
        public bool loginCheckModuleAccess = true;
 
        [SerializeField]
        protected float heartbeatTime = 5.0f;
 
        protected string webSocketUrl;
        protected string deviceID;
        protected string deviceModel;
        protected string platform;
        protected string clientIP;
        protected Guid currentSessionID;
        protected int heartbeatSessionID;
        protected float heartbeatTimer;
        protected bool sessionInProgress;
        protected bool userAccessVerified = false;
        protected string deviceSerialNumber = "";
 
        protected string loginToken = "";
        protected string optionalParameter = "";
        protected string returnTargetParameter = "";
        protected string targetTypeParameter = "";
 
        protected LoginResponseContent currentActiveLogin = null;
        protected APIHandler apexAPIHandler;
        protected ApexWebsocket webSocket;
        protected Task<bool> socketConnectTask;
        protected Task socketDisconnectTask;
 
        public OnHttpResponseEvent OnPingSuccess = new OnHttpResponseEvent();
        public OnHttpResponseEvent OnPingFailed = new OnHttpResponseEvent();
 
        public OnModuleAccessSuccessEvent OnModuleAccessSuccess = new OnModuleAccessSuccessEvent();
        public OnApexFailureEvent OnModuleAccessFailed = new OnApexFailureEvent();
 
        public OnLoginSuccessEvent OnLoginSuccess = new OnLoginSuccessEvent();
        public OnApexFailureEvent OnLoginFailed = new OnApexFailureEvent();
 
        public OnGetUserSuccessEvent OnGetUserSuccess = new OnGetUserSuccessEvent();
        public OnApexFailureEvent OnGetUserFailed = new OnApexFailureEvent();
 
        public OnGetUserModulesSuccessEvent OnGetUserModulesSuccess = new OnGetUserModulesSuccessEvent();
        public OnApexFailureEvent OnGetUserModulesFailed = new OnApexFailureEvent();
 
        public OnHttpResponseEvent OnJoinSessionSuccess = new OnHttpResponseEvent();
        public OnApexFailureEvent OnJoinSessionFailed = new OnApexFailureEvent();
 
        public OnHttpResponseEvent OnCompleteSessionSuccess = new OnHttpResponseEvent();
        public OnApexFailureEvent OnCompleteSessionFailed = new OnApexFailureEvent();
 
        public OnHttpResponseEvent OnSendEventSuccess = new OnHttpResponseEvent();
        public OnApexFailureEvent OnSendEventFailed = new OnApexFailureEvent();
 
        public OnGetOrgModulesSuccessEvent OnGetOrganizationModulesSuccess = new OnGetOrgModulesSuccessEvent();
        public OnApexFailureEvent OnGetOrganizationModulesFailed = new OnApexFailureEvent();
 
        public PlatformResponse OnPlatformResponse = null;
 
        public OnAuthCodeReceived OnAuthorizationCodeReceived = new OnAuthCodeReceived();
 
        public OnGeneratedAssistedLoginSuccessEvent OnGeneratedAssistedLoginSuccess = new();
        public OnApexFailureEvent OnGeneratedAssistedLoginFailed = new();
 
        void Awake()
        {
            SetupPlatformConfiguration();
 
#if UNITY_IOS || UNITY_EDITOR_OSX || UNITY_STANDALONE_OSX
            SetupDeepLinking();
#endif
            if (runSetupOnAwake)
            {
                Debug.Log("[ApexSystem] Running on awake!");
                SetupAPI();
            }
 
            DontDestroyOnLoad(gameObject);
#if MANAGE_XR
            InitMXRSDK();
#endif
        }
 
#if MANAGE_XR
        async void InitMXRSDK()
        {
            await MXRManager.InitAsync();
            MXRManager.System.OnDeviceStatusChange += OnDeviceStatusChanged;
            deviceSerialNumber = MXRManager.System.DeviceStatus.serial;
        }
 
        void OnDeviceStatusChanged(DeviceStatus newDeviceStatus)
        {
            deviceSerialNumber = newDeviceStatus.serial;
        }
#endif
        void SetupDeepLinking()
        {
            Application.deepLinkActivated += OnDeepLinkActivated;
            if (!string.IsNullOrEmpty(Application.absoluteURL))
            {
                // Cold start and Application.absoluteURL not null so process Deep Link.
                OnDeepLinkActivated(Application.absoluteURL);
            }
        }
 
 
        void OnDeepLinkActivated(string url)
        {
            // Update DeepLink Manager global variable, so URL can be accessed from anywhere.
            var urlArguments = PixoPlatformUtilities.ParseURLArguments(url);
            _ParsePassedData(urlArguments);
        }
 
        void SetupPlatformConfiguration()
        {
            Debug.Log("SetupPlatformConfiguration");
 
#if UNITY_ANDROID
            if (PixoAndroidUtils.DoesFileExistInSharedLocation("pixoconfig.cnf"))
            {
                Debug.Log("Found pixoconfig.cnf");
 
                string configContent = PixoAndroidUtils.ReadFileFromSharedStorage("pixoconfig.cnf");
 
                if (configContent.Length > 0)
                {
                    Debug.Log("Configuration is not empty.");
                    ConfigurationTypes configData = JsonConvert.DeserializeObject<ConfigurationTypes>(configContent);
                    if (configData == null)
                    {
                        Debug.Log("Failed to deserialize the config.");
                        return;
                    }
 
                    // Parse out the platform target to utilize the unity built in config values
                    if (configData.Platform.Contains("NA", StringComparison.CurrentCultureIgnoreCase))
                    {
                        if (configData.Platform.Contains("Production", StringComparison.CurrentCultureIgnoreCase))
                        {
                            Debug.Log("NA Production platform target.");
                            PlatformTargetServer = PlatformServer.NA_PRODUCTION;
                        }
 
                        if (configData.Platform.Contains("Dev", StringComparison.CurrentCultureIgnoreCase))
                        {
                            Debug.Log("NA Dev platform target.");
                            PlatformTargetServer = PlatformServer.NA_DEV;
                        }
 
                        if (configData.Platform.Contains("Stage", StringComparison.CurrentCultureIgnoreCase))
                        {
                            Debug.Log("NA Stage platform target.");
                            PlatformTargetServer = PlatformServer.NA_STAGE;
                        }
                    }
                    else if (configData.Platform.Contains("SA", StringComparison.CurrentCultureIgnoreCase))
                    {
                        Debug.Log("SA Production platform target.");
                        PlatformTargetServer = PlatformServer.SA_PRODUCTION;
                    }
 
                    // TODO (MGruber): Add a custom value, but this requires multiple configuration values to be saved.
                    // Need to save the normal headset api endpoint, web api endpoint and platform api endpoint. 3 VALUES! D:
                }
            }
#endif
        }
 
        void SetupAPI()
        {
            Debug.Log("Mac Address: " + ApexUtils.GetMacAddress());
            if (serverIP.Length == 0)
            {
                serverIP = GetEndpointFromTarget(PlatformTargetServer);
            }
 
            apexAPIHandler = new APIHandler(serverIP);
 
            if (apexAPIHandler != null)
            {
                Debug.Log("[ApexSystem] Apex API Handler is not null!");
            }
 
            // TODO: Move to new plugin
            apexAPIHandler.SetWebEndpoint(GetWebEndpointFromPlatformTarget(PlatformTargetServer));
            apexAPIHandler.SetPlatformEndpoint(GetPlatformEndpointFromPlatformTarget(PlatformTargetServer));
            apexAPIHandler.OnAPIResponse += OnAPIResponse;
 
            if (webSocket != null)
            {
                if (webSocket.IsConnected())
                {
                    DisconnectWebsocket();
                }
            }
 
            webSocket = new ApexWebsocket();
            webSocket.OnConnectSuccess.AddListener(() => OnWebSocketConnected());
            webSocket.OnConnectFailed.AddListener((reason) => OnWebSocketConnectFailed(reason));
            webSocket.OnReceive.AddListener((data) => OnWebSocketReceive(data));
            webSocket.OnClosed.AddListener((reason) => OnWebSocketClosed(reason));
 
            PopulateWebSocketURL();
 
            var applicationArugments = PixoPlatformUtilities.ParseApplicationArguments();
            _ParsePassedData(applicationArugments);
            if(!string.IsNullOrEmpty(loginToken))
            {
                Debug.Log($"[ApexSystem] Login Token: {loginToken}");
            }
        }
 
        // TODO: Rename the entered 'returnTarget' and the passed returnTargetParameter.
        void _ExitApplication(string returnTarget)
        {
            if (returnTarget == null)
            {
                returnTarget = "";
            }
 
            string returnTargetType = "app";
 
            if (returnTarget.Contains("://"))
            {
                returnTargetType = "url";
            }
 
            Debug.Log("[ApexSystem] " + returnTarget + " " + returnTargetType);
 
            string parameters = "";
 
            Debug.Log("[ApexSystem] Building parameters for url.");
 
            if (CurrentActiveLogin != null)
            {
                parameters += "pixotoken=" + CurrentActiveLogin.Token;
            }
 
            if (optionalParameter != null)
            {
                if (optionalParameter.Length > 0)
                {
                    if (parameters.Length > 0)
                        parameters += "&";
                    parameters += "optional=" + optionalParameter;
                }
            }
 
            if (returnTarget.Length > 0)
            {
                if (parameters.Length > 0)
                    parameters += "&";
                parameters += "returntarget=" + returnTarget;
            }
 
            if (returnTargetType.Length > 0)
            {
                if (parameters.Length > 0)
                    parameters += "&";
                parameters += "targettype=" + returnTargetType;
            }
 
            Debug.Log("[ApexSystem] Checking the return target parameter.");
 
            if (returnTargetParameter != null)
            {
                if (returnTargetParameter.Length > 0)
                {
                    Debug.Log("[ApexSystem] Had a valid return target parameter.");
                    if (targetTypeParameter.Equals("url", StringComparison.OrdinalIgnoreCase))
                    {
                        Debug.Log("[ApexSystem] Return Target is a URL.");
 
                        string returnURL = returnTargetParameter;
                        if (parameters.Length > 0)
                        {
                            if (!returnURL.Contains('?'))
                                returnURL += "?";
                            else
                                returnURL += "&";
 
                            returnURL += parameters;
                        }
                        Debug.Log("Custom Target: " + returnURL);
                        PixoPlatformUtilities.OpenURL(returnURL);
                        return;
                    }
                    else
                    {
                        Debug.Log("[ApexSystem] Return Target is a package name.");
 
                        List<string> keys = new List<string>(),
                            values = new List<string>();
 
                        Debug.Log("[ApexSystem] Adding pixo token.");
 
                        if (CurrentActiveLogin != null)
                        {
                            keys.Add("pixotoken");
                            values.Add(CurrentActiveLogin.Token);
                        }
 
                        Debug.Log("[ApexSystem] Adding optional.");
 
                        if (optionalParameter.Length > 0)
                        {
                            keys.Add("optional");
                            values.Add(optionalParameter);
                        }
 
                        Debug.Log("[ApexSystem] Adding return target.");
 
                        if (returnTarget.Length > 0)
                        {
                            keys.Add("returntarget");
                            values.Add(returnTarget);
                        }
 
                        Debug.Log("[ApexSystem] Adding return target type.");
 
                        if (returnTargetType.Length > 0)
                        {
                            keys.Add("targettype");
                            values.Add(returnTargetType);
                        }
 
                        PixoPlatformUtilities.OpenApplication(returnTargetParameter, keys.ToArray(), values.ToArray());
                        return;
                    }
                }
            }
 
            PixoAndroidUtils.Quit();
        }
 
        string GetEndpointFromTarget(PlatformServer target)
        {
            return target.ToUrlString();
        }
 
        string GetWebEndpointFromPlatformTarget(PlatformServer target)
        {
            int targetValue = (int)target;
            WebPlatformServer webTarget = (WebPlatformServer)targetValue;
 
            return webTarget.ToUrlString();
        }
 
        string GetPlatformEndpointFromPlatformTarget(PlatformServer target)
        {
            int targetValue = (int)target;
            APIPlatformServer apiTarget = (APIPlatformServer)targetValue;
 
            return apiTarget.ToUrlString();
        }
 
        void PopulateWebSocketURL()
        {
            webSocketUrl = serverIP;
 
            if (webSocketUrl.Contains("://"))
            {
                webSocketUrl = webSocketUrl.Split(new string[] { "://" }, 2, StringSplitOptions.RemoveEmptyEntries)[1];
            }
 
            if (webSocketUrl.Contains("/"))
            {
                webSocketUrl = webSocketUrl.Split(new string[] { "/" }, 2, StringSplitOptions.RemoveEmptyEntries)[0];
            }
 
            webSocketUrl = "wss://" + webSocketUrl + "/ws";
        }
 
        void Start()
        {
            if (!IsModuleVersionValid())
            {
                Debug.LogWarning($"{moduleVersion} is an invalid module version.");
            }
            deviceID = SystemInfo.deviceUniqueIdentifier;
            deviceModel = SystemInfo.deviceModel;
            platform =
                XRSettings.loadedDeviceName.Length > 0 ? XRSettings.loadedDeviceName : Application.platform.ToString();
            clientIP = Utils.ApexUtils.GetLocalIP();
        }
 
        private void FixedUpdate()
        {
            if (webSocket != null)
            {
                webSocket.Update();
            }
 
            if (sessionInProgress)
            {
                heartbeatTimer -= Time.fixedDeltaTime;
 
                if (heartbeatTimer <= 0.0f)
                {
                    _SendHeartbeat();
                    heartbeatTimer += heartbeatTime;
                }
            }
        }
 
        void ConnectWebsocket()
        {
            socketConnectTask = Task.Run(() => webSocket.Connect(new Uri(webSocketUrl)));
        }
 
        void DisconnectWebsocket()
        {
            socketDisconnectTask = Task.Run(() => webSocket.CloseSocket());
        }
 
        void OnWebSocketConnected()
        {
            Debug.Log("Websocket connected successfully.");
        }
 
        void OnWebSocketConnectFailed(string reason)
        {
            Debug.LogError("Websocket failed to connect with error: " + reason);
        }
 
        void OnWebSocketReceive(string data)
        {
            Debug.Log("Websocket received: " + data);
            try
            {
                if (data.Contains("auth_code"))
                {
                    var authCode = JsonConvert.DeserializeObject<AuthorizationCode>(data);
                    OnAuthorizationCodeReceived.Invoke(authCode.Code);
                }
 
                if (data.Contains("Token", StringComparison.OrdinalIgnoreCase))
                {
                    object loginResponse = JsonConvert.DeserializeObject<LoginResponseContent>(data);
                    HandleLogin(true, loginResponse);
                }
            }
            catch (Exception ex)
            {
                Debug.Log(ex.Message);
            }
        }
 
        void OnWebSocketClosed(System.Net.WebSockets.WebSocketCloseStatus reason)
        {
            Debug.Log("Websocket closed with reason: " + reason);
        }
 
        bool IsModuleVersionValid()
        {
            if (IsModuleVersionOnlyNumerical() == false)
                return false;
 
            string[] moduleVersionParts = moduleVersion.Split('.');
 
            if (moduleVersionParts.Length != 3)
                return false;
 
            if (!IsModuleMajorVersionPartValid(moduleVersionParts[(int)VersionParts.Major]))
                return false;
 
            if (!IsModuleNonMajorVersionPartValid(moduleVersionParts[(int)VersionParts.Minor]))
                return false;
 
            if (!IsModuleNonMajorVersionPartValid(moduleVersionParts[(int)VersionParts.Patch]))
                return false;
 
            return true;
        }
 
        static readonly Regex VersionValidator = new Regex(@"^[0123456789.]+$");
 
        bool IsModuleVersionOnlyNumerical()
        {
            return VersionValidator.IsMatch(moduleVersion);
        }
 
        bool IsModuleNonMajorVersionPartValid(string modulePart)
        {
            if (modulePart.Length <= 0)
                return false;
 
            if (modulePart.Length > 2)
                return false;
 
            return true;
        }
 
        bool IsModuleMajorVersionPartValid(string modulePart)
        {
            if (modulePart.Length <= 0)
                return false;
 
            if (modulePart.StartsWith("0"))
                return false;
 
            return true;
        }
 
        [Obsolete("ReturnToHub has been deprecated, please use ExitApplication.", true)]
        public static void ReturnToHub()
        {
            Instance._ReturnToHub();
        }
 
        public static void ExitApplication(string returnTarget = "")
        {
            Instance._ExitApplication(returnTarget);
        }
 
        public static bool RequestAuthorizationCode()
        {
            return Instance._RequestAuthorizationCode();
        }
 
        public static void ChangePlatformServer(PlatformServer newServer)
        {
            Instance._ChangePlatformServer(newServer);
        }
 
        public static void Ping()
        {
            Instance._Ping();
        }
 
        public static bool LoginWithToken()
        {
            return LoginWithToken(Instance.loginToken);
        }
 
        public static bool LoginWithToken(string token)
        {
            return Instance._LoginWithToken(token);
        }
 
        public static bool Login(LoginData login)
        {
            return Instance._Login(login);
        }
 
        public static bool Login(string username, string password)
        {
            return Instance._Login(username, password);
        }
 
        public static bool CheckModuleAccess(int targetModuleID = -1)
        {
            return Instance._CheckModuleAccess(targetModuleID);
        }
 
        public static bool JoinSession(string scenarioID = null, Extension contextExtension = null)
        {
            return Instance._JoinSession(scenarioID, contextExtension);
        }
 
        public static bool CompleteSession(
            SessionData currentSessionData,
            Extension contextExtension = null,
            Extension resultExtension = null
        )
        {
            return Instance._CompleteSession(currentSessionData, contextExtension, resultExtension);
        }
 
        public static bool SendSimpleSessionEvent(string action, string targetObject, Extension contextExtension)
        {
            return Instance._SendSimpleSessionEvent(action, targetObject, contextExtension);
        }
 
        public static bool SendSessionEvent(Statement eventStatement)
        {
            return Instance._SendSessionEvent(eventStatement);
        }
 
        public static bool GetCurrentUser()
        {
            return GetUser();
        }
 
        public static bool GetUser(int userId = -1)
        {
            return Instance._GetUser(userId);
        }
 
        public static bool GetCurrentUserModules()
        {
            return GetUserModules();
        }
 
        public static bool GetUserModules(int userId = -1)
        {
            return Instance._GetUserModules(userId);
        }
 
        public static bool GetModulesList(string platformName)
        {
            return Instance._GetModuleList(platformName);
        }
 
        protected void _ChangePlatformServer(PlatformServer newServer)
        {
            PlatformTargetServer = newServer;
 
            SetupAPI();
        }
 
        protected void _Ping()
        {
            apexAPIHandler.Ping();
        }
 
        public bool _LoginWithToken(string token)
        {
            if (token.Length <= 0)
            {
                return false;
            }
 
            Debug.Log($"[ApexSystem] Logging in with token: {token}");
            apexAPIHandler.LoginWithToken(token);
 
            return true;
        }
 
        protected bool _Login(LoginData login)
        {
            Debug.Log("[ApexSystem] _Login called.");
            if (apexAPIHandler == null)
            {
                Debug.Log("[ApexSystem] API Handler is null.");
                OnLoginFailed.Invoke(
                    GenerateFailureResponse(
                        "There was an error reaching the platform, please contact your administrator."
                    )
                );
                return false;
            }
 
            if (login.Login.Length <= 0)
            {
                Debug.Log("[Login] No user name.");
                OnLoginFailed.Invoke(GenerateFailureResponse("No username or email entered."));
                return false;
            }
 
            if (login.Password.Length <= 0)
            {
                Debug.Log("[Login] No password.");
                login.Password = "<empty>";
            }
 
            apexAPIHandler.Login(login);
 
            Debug.Log("[ApexSystem] Login called.");
 
            return true;
        }
 
        protected bool _Login(string username, string password)
        {
            return _Login(new LoginData(username, password));
        }
 
        protected FailureResponse GenerateFailureResponse(string message)
        {
            FailureResponse failureResponse = new FailureResponse();
            failureResponse.Error = "true";
            failureResponse.HttpCode = "400";
            failureResponse.Message = message;
 
            return failureResponse;
        }
 
        protected void _ParsePassedData(Dictionary<string, string> arguments)
        {
            if (arguments == null)
            {
                Debug.Log("No arguments found for the application.");
                return;
            }
 
            if (arguments.ContainsKey("optional"))
                optionalParameter = arguments["optional"];
 
            if (arguments.ContainsKey("returntarget"))
                returnTargetParameter = arguments["returntarget"];
 
            if (arguments.ContainsKey("targettype"))
                targetTypeParameter = arguments["targettype"];
 
            if (arguments.ContainsKey("pixotoken"))
                loginToken = arguments["pixotoken"];
        }
 
 
 
        public bool _CheckModuleAccess(int targetModuleID = -1)
        {
            Debug.Log("[ApexSystem] _CheckModuleAccess called.");
 
            if (currentActiveLogin == null)
            {
                Debug.LogError("[ApexSystem] Cannot check user's module access with no active login.");
                return false;
            }
 
            if (targetModuleID <= -1)
            {
                targetModuleID = moduleID;
            }
 
            apexAPIHandler.GetModuleAccess(targetModuleID, currentActiveLogin.ID, deviceSerialNumber);
 
            return true;
        }
 
        protected bool _JoinSession(string newScenarioID = null, Extension contextExtension = null)
        {
            if (currentActiveLogin == null)
            {
                Debug.LogError("[ApexSystem] Cannot join session with no active login.");
                return false;
            }
 
            if (userAccessVerified == false)
            {
                return false;
            }
 
            if (newScenarioID != null)
            {
                scenarioID = newScenarioID;
            }
 
            if (sessionInProgress == true)
            {
                Debug.LogError(
                    "[ApexSystem] Session is already in progress."
                        + " The previous session didn't complete or a new session was started during an active session."
                );
            }
 
            currentSessionID = Guid.NewGuid();
 
            Statement sessionStatement = new Statement();
            Agent sessionActor = new Agent();
            sessionActor.mbox = currentActiveLogin.Email;
 
            Verb sessionVerb = new Verb();
            sessionVerb.id = ApexVerbs.JOINED_SESSION;
            sessionVerb.display = new LanguageMap();
            sessionVerb.display.Add("en", "Joined Session");
 
            Activity sessionActivity = new Activity();
            sessionActivity.id = string.Format("https://pixovr.com/xapi/objects/{0}/{1}", moduleID, scenarioID);
 
            Context sessionContext = new Context();
            sessionContext.registration = currentSessionID;
            sessionContext.revision = moduleVersion;
            sessionContext.platform = platform;
 
            sessionContext.extensions = AppendStandardContextExtension(contextExtension);
 
            sessionStatement.actor = sessionActor;
            sessionStatement.verb = sessionVerb;
            sessionStatement.target = sessionActivity;
            sessionStatement.context = sessionContext;
 
            JoinSessionData sessionData = new JoinSessionData();
            sessionData.DeviceId = deviceID;
            sessionData.IpAddress = clientIP;
            sessionData.ModuleId = moduleID;
            sessionData.Uuid = currentSessionID.ToString();
            sessionData.EventType = ApexEventTypes.PIXOVR_SESSION_JOINED;
            sessionData.JsonData = sessionStatement;
 
            apexAPIHandler.JoinSession(currentActiveLogin.Token, sessionData);
 
            return true;
        }
 
        protected bool _SendSimpleSessionEvent(string verbName, string targetObject, Extension contextExtension)
        {
            if (userAccessVerified == false)
                return false;
 
            if (verbName == null)
                return false;
 
            if (verbName.Length == 0)
                return false;
 
            Statement sessionStatement = new Statement();
            Agent sessionActor = new Agent();
            sessionActor.mbox = currentActiveLogin.Email;
 
            Verb sessionVerb = new Verb();
            sessionVerb.id = new Uri("https://pixovr.com/xapi/verbs/" + verbName.Replace(' ', '_').ToLower());
            sessionVerb.display = new LanguageMap();
            sessionVerb.display.Add("en", verbName);
 
            Activity sessionActivity = new Activity();
            sessionActivity.id = string.Format(
                "https://pixovr.com/xapi/objects/{0}/{1}/{2}",
                moduleID,
                scenarioID,
                targetObject.Replace(' ', '_').ToLower()
            );
 
            Context sessionContext = new Context();
            sessionContext.registration = currentSessionID;
            sessionContext.revision = moduleVersion;
            sessionContext.platform = platform;
 
            sessionContext.extensions = AppendStandardContextExtension(contextExtension);
 
            sessionStatement.actor = sessionActor;
            sessionStatement.verb = sessionVerb;
            sessionStatement.target = sessionActivity;
            sessionStatement.context = sessionContext;
 
            SessionEventData sessionEvent = new SessionEventData();
            sessionEvent.DeviceId = deviceID;
            sessionEvent.ModuleId = ModuleID;
            sessionEvent.Uuid = currentSessionID.ToString();
            sessionEvent.EventType = ApexEventTypes.PIXOVR_SESSION_EVENT;
            sessionEvent.JsonData = sessionStatement;
 
            apexAPIHandler.SendSessionEvent(currentActiveLogin.Token, sessionEvent);
 
            return true;
        }
 
        protected bool _SendSessionEvent(Statement eventStatement)
        {
            if (userAccessVerified == false)
            {
                return false;
            }
 
            if (currentActiveLogin == null)
            {
                Debug.LogError("[ApexSystem] Cannot send a session event with no active login.");
                return false;
            }
 
            if (sessionInProgress == false)
            {
                Debug.LogError("[ApexSystem] No session in progress to send event for.");
                return false;
            }
 
            if (eventStatement == null)
            {
                Debug.LogError("[ApexSystem] No event data to send.");
                return false;
            }
 
            if (eventStatement.actor != null)
            {
                Debug.LogWarning("[ApexSystem] Actor data should not be filled out.");
            }
 
            if (eventStatement.verb == null)
            {
                Debug.LogError("[ApexSystem] Verb missing from eventStatement.");
                return false;
            }
 
            if (eventStatement.verb.id == null)
            {
                Debug.LogError("[ApexSystem] verb.id missing from eventStatement.");
                return false;
            }
 
            if (eventStatement.target == null)
            {
                Debug.LogError("[ApexSystem] Object (target) missing from eventStatement.");
                return false;
            }
 
            eventStatement.actor = new Agent();
            eventStatement.actor.mbox = currentActiveLogin.Email;
 
            if (eventStatement.context == null)
            {
                eventStatement.context = new Context();
            }
 
            eventStatement.context.registration = currentSessionID;
            eventStatement.context.revision = ModuleVersion;
            eventStatement.context.platform = platform;
 
            eventStatement.context.extensions = AppendStandardContextExtension(eventStatement.context.extensions);
 
            SessionEventData sessionEvent = new SessionEventData();
            sessionEvent.DeviceId = deviceID;
            sessionEvent.ModuleId = ModuleID;
            sessionEvent.Uuid = currentSessionID.ToString();
            sessionEvent.EventType = ApexEventTypes.PIXOVR_SESSION_EVENT;
            sessionEvent.JsonData = eventStatement;
 
            apexAPIHandler.SendSessionEvent(currentActiveLogin.Token, sessionEvent);
 
            return true;
        }
 
        protected bool _CompleteSession(
            SessionData currentSessionData,
            Extension contextExtension,
            Extension resultExtension
        )
        {
            if (userAccessVerified == false)
            {
                return false;
            }
 
            if (currentActiveLogin == null)
            {
                Debug.LogError("[ApexSystem] Cannot complete session with no active login.");
                return false;
            }
 
            if (sessionInProgress == false)
            {
                Debug.LogError("[ApexSystem] No session in progress to complete.");
                return false;
            }
 
            // Create our actor
            Agent sessionActor = new Agent();
            sessionActor.mbox = currentActiveLogin.Email;
 
            // Create our verb
            Verb sessionVerb = new Verb();
            sessionVerb.id = ApexVerbs.COMPLETED_SESSION;
            sessionVerb.display = new LanguageMap();
            sessionVerb.display.Add("en", "Completed Session");
 
            // Create the session activity
            Activity sessionActivity = new Activity();
            sessionActivity.id = string.Format("https://pixovr.com/xapi/objects/{0}/{1}", moduleID, scenarioID);
 
            // Create our context
            Context sessionContext = new Context();
            sessionContext.registration = currentSessionID;
            sessionContext.revision = moduleVersion;
            sessionContext.platform = platform;
 
            sessionContext.extensions = AppendStandardContextExtension(contextExtension);
 
            // Create our results
            Result sessionResult = new Result();
            sessionResult.completion = currentSessionData.Complete;
            sessionResult.success = currentSessionData.Success;
            // Add score to the results
            sessionResult.score = new Score();
            sessionResult.score.min = currentSessionData.MinimumScore;
            sessionResult.score.max = currentSessionData.MaximumScore;
            sessionResult.score.raw = currentSessionData.Score;
            sessionResult.score.scaled = DetermineScaledScore(
                currentSessionData.ScaledScore,
                currentSessionData.Score,
                currentSessionData.MaximumScore
            );
            sessionResult.duration = TimeSpan.FromSeconds(currentSessionData.Duration);
            if (resultExtension != null)
            {
                sessionResult.extensions = new Extensions(resultExtension.ToJObject());
            }
 
            // Create our statement and add the pieces
            Statement sessionStatement = new Statement();
            sessionStatement.actor = sessionActor;
            sessionStatement.verb = sessionVerb;
            sessionStatement.target = sessionActivity;
            sessionStatement.context = sessionContext;
            sessionStatement.result = sessionResult;
 
            CompleteSessionData sessionData = new CompleteSessionData();
            sessionData.DeviceId = deviceID;
            sessionData.ModuleId = moduleID;
            sessionData.Uuid = currentSessionID.ToString();
            sessionData.EventType = ApexEventTypes.PIXOVR_SESSION_COMPLETE;
            sessionData.JsonData = sessionStatement;
            sessionData.SessionDuration = currentSessionData.Duration;
            sessionData.Score = currentSessionData.Score;
            sessionData.ScoreMin = currentSessionData.MinimumScore;
            sessionData.ScoreMax = currentSessionData.MaximumScore;
            sessionData.ScoreScaled = DetermineScaledScore(
                currentSessionData.ScaledScore,
                currentSessionData.Score,
                currentSessionData.MaximumScore
            );
 
            apexAPIHandler.CompleteSession(currentActiveLogin.Token, sessionData);
 
            return true;
        }
 
        protected bool _SendHeartbeat()
        {
            Debug.Log("Sending heartbeat...");
            if (!sessionInProgress)
                return false;
 
            if (currentActiveLogin == null)
                return false;
 
            apexAPIHandler.SendHeartbeat(currentActiveLogin.Token, heartbeatSessionID);
 
            return true;
        }
 
        protected bool _GetUser(int userId = -1)
        {
            if (currentActiveLogin == null)
                return false;
 
            if (userId < 0)
            {
                userId = currentActiveLogin.ID;
            }
 
            apexAPIHandler.GetUserData(currentActiveLogin.Token, userId);
            return true;
        }
 
        protected bool _GetUserModules(int userId = -1)
        {
            if (currentActiveLogin == null)
                return false;
 
            if (userId < 0)
            {
                userId = currentActiveLogin.ID;
            }
 
            apexAPIHandler.GetUserModules(currentActiveLogin.Token, userId);
            return true;
        }
 
        protected bool _GetModuleList(string platformName)
        {
            if (currentActiveLogin == null)
                return false;
 
            apexAPIHandler.GetModuleList(currentActiveLogin.Token, platformName);
            return true;
        }
 
        private float DetermineScaledScore(float scaledScore, float score, float maxScore)
        {
            float determinedScaledScore = scaledScore;
 
            if (scaledScore < Mathf.Epsilon && score >= Mathf.Epsilon)
            {
                determinedScaledScore = (score / maxScore) * 100f;
            }
 
            return determinedScaledScore;
        }
 
        private Extensions AppendStandardContextExtension(Extensions currentContextExtensions)
        {
            return AppendStandardContextExtension(new Extension(currentContextExtensions.ToJObject()));
        }
 
        private Extensions AppendStandardContextExtension(Extension currentContextExtension)
        {
            Extension contextExtension;
            if (currentContextExtension != null)
            {
                contextExtension = currentContextExtension;
            }
            else
            {
                contextExtension = new Extension();
            }
 
            contextExtension.Add(ApexExtensionStrings.MODULE_ID, moduleID.ToString());
            contextExtension.AddSimple("device_id", deviceID);
            contextExtension.AddSimple("device_model", deviceModel);
            contextExtension.AddSimple("sdk_version", "unity-" + ApexUtils.SDKVersion);
 
            return new Extensions(contextExtension.ToJObject());
        }
 
        protected void OnAPIResponse(ResponseType response, HttpResponseMessage message, object responseData)
        {
            Debug.Log("[ApexSystem] On API Response");
            bool success = message.IsSuccessStatusCode;
            if (responseData is FailureResponse)
            {
                success = success && (responseData is IFailure) && (!(responseData as FailureResponse).HasErrored());
            }
 
            switch (response)
            {
                case ResponseType.RT_PING:
                {
                    if (success)
                    {
                        Debug.Log("[ApexSystem] Ping successful.");
                        OnPingSuccess.Invoke(message);
                    }
                    else
                    {
                        Debug.Log("[ApexSystem] Ping failed.");
                        OnPingFailed.Invoke(message);
                    }
                    break;
                }
                case ResponseType.RT_LOGIN:
                {
                    Debug.Log("[ApexSystem] Calling to handle login.");
                    HandleLogin(success, responseData);
                    break;
                }
                case ResponseType.RT_GET_USER:
                {
                    if (success)
                    {
                        OnGetUserSuccess.Invoke(responseData as GetUserResponseContent);
                    }
                    else
                    {
                        FailureResponse failureData = responseData as FailureResponse;
                        Debug.Log(string.Format("[ApexSystem] Failed to get user.\nError: {0}", failureData.Message));
                        OnGetUserFailed.Invoke(responseData as FailureResponse);
                    }
                    break;
                }
                case ResponseType.RT_GET_USER_MODULES:
                {
                    if (success)
                    {
                        OnGetUserModulesSuccess.Invoke(responseData as GetUserModulesResponse);
                    }
                    else
                    {
                        FailureResponse failureData = responseData as FailureResponse;
                        Debug.Log(string.Format("[ApexSystem] Failed to get user.\nError: {0}", failureData.Message));
                        OnGetUserFailed.Invoke(responseData as FailureResponse);
                    }
                    break;
                }
                case ResponseType.RT_SESSION_JOINED:
                {
                    if (success)
                    {
                        JoinSessionResponse joinSessionResponse = responseData as JoinSessionResponse;
                        Debug.Log(string.Format("[ApexSystem] Session Id is {0}.", joinSessionResponse.SessionId));
                        heartbeatSessionID = joinSessionResponse.SessionId;
                        sessionInProgress = true;
                        OnJoinSessionSuccess.Invoke(message);
                    }
                    else
                    {
                        FailureResponse failureData = responseData as FailureResponse;
                        Debug.Log(
                            string.Format("[ApexSystem] Failed to join session.\nError: {0}", failureData.Message)
                        );
                        currentSessionID = Guid.Empty;
                        sessionInProgress = false;
                        OnJoinSessionFailed.Invoke(responseData as FailureResponse);
                    }
                    break;
                }
                case ResponseType.RT_SESSION_COMPLETE:
                {
                    if (success)
                    {
                        sessionInProgress = false;
                        currentSessionID = Guid.Empty;
                        OnCompleteSessionSuccess.Invoke(message);
                    }
                    else
                    {
                        FailureResponse failureData = responseData as FailureResponse;
                        Debug.Log(
                            string.Format("[ApexSystem] Failed to complete session.\nError: {0}", failureData.Message)
                        );
                        OnCompleteSessionFailed.Invoke(responseData as FailureResponse);
                    }
                    break;
                }
                case ResponseType.RT_SESSION_EVENT:
                {
                    if (success)
                    {
                        Debug.Log("[ApexSystem] Session event sent.");
                        OnSendEventSuccess.Invoke(message);
                    }
                    else
                    {
                        FailureResponse failureData = responseData as FailureResponse;
                        Debug.Log(
                            string.Format("[ApexSystem] Failed to send session event.\nError: {0}", failureData.Message)
                        );
                        OnSendEventFailed.Invoke(responseData as FailureResponse);
                    }
                    break;
                }
                case ResponseType.RT_GET_USER_ACCESS:
                {
                    if (success)
                    {
                        var userAccessResponseContent = responseData as UserAccessResponseContent;
                        if (userAccessResponseContent.Access)
                        {
                            if (userAccessResponseContent.PassingScore.HasValue)
                            {
                                currentActiveLogin.MinimumPassingScore = userAccessResponseContent.PassingScore.Value;
                            }
 
                            userAccessVerified = true;
                            OnModuleAccessSuccess.Invoke(currentActiveLogin);
                        }
                        else
                        {
                            currentActiveLogin = null;
                            userAccessVerified = false;
                            OnModuleAccessFailed.Invoke(
                                new FailureResponse()
                                {
                                    Error = "True",
                                    HttpCode = "401",
                                    Message = "User does not have access to module",
                                }
                            );
                        }
                    }
                    else
                    {
                        FailureResponse failureData = responseData as FailureResponse;
                        Debug.Log(
                            string.Format(
                                "[ApexSystem] Failed to get users module access data.\nError: {0}",
                                failureData.Message
                            )
                        );
 
                        OnModuleAccessFailed.Invoke(responseData as FailureResponse);
                    }
                    break;
                }
                case ResponseType.RT_GET_MODULES_LIST:
                {
                    if (success)
                    {
                        OnGetOrganizationModulesSuccess.Invoke(responseData as List<OrgModule>);
                    }
                    else
                    {
                        FailureResponse failureData = responseData as FailureResponse;
                        Debug.Log(
                            string.Format("[ApexSystem] Failed to get org modules.\nError: {0}", failureData.Message)
                        );
 
                        OnGetOrganizationModulesFailed.Invoke(responseData as FailureResponse);
                    }
 
                    break;
                }
                case ResponseType.RT_GEN_AUTH_LOGIN:
                {
                    if (success)
                    {
                        OnGeneratedAssistedLoginSuccess.Invoke(responseData as GeneratedAssistedLogin);
                    }
                    else
                    {
                        FailureResponse failureData = responseData as FailureResponse;
                        Debug.Log(string.Format("[ApexSystem] Failed to get module.\nError: {0}", failureData.Message));
                        OnGeneratedAssistedLoginFailed.Invoke(responseData as FailureResponse);
                    }
                    break;
                }
                default:
                {
                    break;
                }
            }
 
            if (OnPlatformResponse != null)
            {
                OnPlatformResponse.Invoke(response, success, responseData);
            }
        }
 
        protected void HandleLogin(bool successful, object responseData)
        {
            Debug.Log("[ApexSystem] Handling Login");
            userAccessVerified = false;
 
            if (successful)
            {
                currentActiveLogin = responseData as LoginResponseContent;
 
                OnLoginSuccess.Invoke();
 
                if (loginCheckModuleAccess)
                {
                    apexAPIHandler.GetModuleAccess(moduleID, currentActiveLogin.ID, deviceSerialNumber);
                }
            }
            else
            {
                FailureResponse failureData = responseData as FailureResponse;
                Debug.Log(string.Format("[ApexSystem] Failed to log in.\nError: {0}", failureData.Message));
                OnLoginFailed.Invoke(responseData as FailureResponse);
            }
        }
 
        void _ReturnToHub()
        {
            var token = currentActiveLogin.Token;
 
            if (
                serverIP.Contains("apexsa.", StringComparison.CurrentCultureIgnoreCase)
                || serverIP.Contains("saudi.", StringComparison.CurrentCultureIgnoreCase)
            )
            {
                Debug.Log($"pixovr://com.PixoVR.SA_TrainingAcademy?pixotoken={token}");
                Application.OpenURL($"pixovr://com.PixoVR.SA_TrainingAcademy?pixotoken={token}");
            }
            else
            {
                Debug.Log($"pixovr://com.PixoVR.PixoHub?pixotoken={token}");
                Application.OpenURL($"pixovr://com.PixoVR.PixoHub?pixotoken={token}");
            }
        }
 
        bool _RequestAuthorizationCode()
        {
            if (!webSocket.IsConnected())
            {
                ConnectWebsocket();
            }
            return webSocket.RequestAuthorizationCode();
        }
 
        public static bool GenerateOneTimeLoginForCurrentUser()
        {
            if (Instance.currentActiveLogin == null)
                return false;
 
            return Instance._GenerateOneTimeLoginForUser();
        }
 
        bool _GenerateOneTimeLoginForCurrentUser()
        {
            if (currentActiveLogin == null)
            {
                Debug.LogError("[ApexSystem] No current user logged in.");
                return false;
            }
 
            return _GenerateOneTimeLoginForUser();
        }
 
        bool _GenerateOneTimeLoginForUser()
        {
            if (currentActiveLogin == null)
            {
                Debug.LogError("[ApexSystem] No user logged in to generate code.");
                return false;
            }
 
            apexAPIHandler.GenerateAssistedLogin(currentActiveLogin.Token);
            return true;
        }
    }
}