using System; using System.Collections.Generic; using System.Text; using RH_Engine; using System.Net.Sockets; namespace ClientApp.Utils { public delegate void HandleSerial(string message); public delegate void HandleNoTunnelId(); public delegate void OnSuccessfullConnection(); public sealed class EngineConnection { private static EngineConnection instance = null; private static readonly object padlock = new object(); public HandleNoTunnelId OnNoTunnelId; public OnSuccessfullConnection OnSuccessFullConnection; private static PC[] PCs = { //new PC("DESKTOP-M2CIH87", "Fabian"), //new PC("T470S", "Shinichi"), //new PC("DESKTOP-DHS478C", "semme"), new PC("HP-ZBOOK-SEM", "Sem") //new PC("DESKTOP-TV73FKO", "Wouter"), //new PC("DESKTOP-SINMKT1", "Ralf van Aert"), //new PC("NA", "Bart") }; private static ServerResponseReader serverResponseReader; private static string sessionId = string.Empty; private static string tunnelId = string.Empty; private static string cameraId = string.Empty; private static string routeId = string.Empty; private static string panelId = string.Empty; private static string bikeId = string.Empty; private static string headId = string.Empty; public float BikeSpeed { get; set; } public float BikePower { get; set; } public float BikeBPM { get; set; } public float BikeResistance { get; set; } public bool FollowingRoute = false; private static NetworkStream stream; private static Dictionary serialResponses = new Dictionary(); private Command mainCommand; public bool Connected = false; EngineConnection() { BikeSpeed = 0; BikePower = 0; BikeBPM = 0; BikeResistance = 50; } /// /// Singleton constructor /// public static EngineConnection INSTANCE { get { lock (padlock) { if (instance == null) { instance = new EngineConnection(); } } return instance; } } /// /// connects to the vr engine and initalizes the serverResponseReader /// public void Connect() { TcpClient client = new TcpClient("145.48.6.10", 6666); stream = client.GetStream(); initReader(); CreateConnection(); } /// /// initializes and starts the reading of the responses from the vr server /// /// the networkstream private void initReader() { serverResponseReader = new ServerResponseReader(stream); serverResponseReader.callback = HandleResponse; serverResponseReader.StartRead(); } #region VR Message traffic /// /// connects to the server and creates the tunnel /// /// the network stream to use public void CreateConnection() { WriteTextMessage("{\r\n\"id\" : \"session/list\",\r\n\"serial\" : \"list\"\r\n}"); // wait until we have got a sessionId while (sessionId == string.Empty) { } string tunnelCreate = "{\"id\" : \"tunnel/create\", \"data\" : {\"session\" : \"" + sessionId + "\"}}"; WriteTextMessage(tunnelCreate); } /// /// callback method that handles responses from the server /// /// the response message from the server public void HandleResponse(string message) { string id = JSONParser.GetID(message); // because the first messages don't have a serial, we need to check on the id if (id == "session/list") { sessionId = JSONParser.GetSessionID(message, PCs); } else if (id == "tunnel/create") { tunnelId = JSONParser.GetTunnelID(message); Console.WriteLine("set tunnel id to " + tunnelId); if (tunnelId == null) { Write("could not find a valid tunnel id!"); OnNoTunnelId?.Invoke(); Connected = false; FollowingRoute = false; return; } else { Write("got tunnel id! " + tunnelId); Connected = true; OnSuccessFullConnection?.Invoke(); } } if (message.Contains("serial")) { //Console.WriteLine("GOT MESSAGE WITH SERIAL: " + message + "\n\n\n"); string serial = JSONParser.GetSerial(message); //Console.WriteLine("Got serial " + serial); if (serialResponses.ContainsKey(serial)) serialResponses[serial].Invoke(message); } } public void initScene() { Write("initializing scene..."); mainCommand = new Command(tunnelId); // reset the scene WriteTextMessage(mainCommand.ResetScene()); //Get sceneinfo and set the id's SendMessageAndOnResponse(mainCommand.GetSceneInfoCommand("sceneinfo"), "sceneinfo", (message) => { //Console.WriteLine("\r\n\r\n\r\nscene info" + message); cameraId = JSONParser.GetIdSceneInfoChild(message, "Camera"); string headId = JSONParser.GetIdSceneInfoChild(message, "Head"); string handLeftId = JSONParser.GetIdSceneInfoChild(message, "LeftHand"); string handRightId = JSONParser.GetIdSceneInfoChild(message, "RightHand"); //Force(stream, mainCommand.DeleteNode(handLeftId, "deleteHandL"), "deleteHandL", (message) => Console.WriteLine("Left hand deleted")); //Force(stream, mainCommand.DeleteNode(handRightId, "deleteHandR"), "deleteHandR", (message) => Console.WriteLine("Right hand deleted")); }); // add the route and set the route id SendMessageAndOnResponse(mainCommand.RouteCommand("routeID"), "routeID", (message) => routeId = JSONParser.GetResponseUuid(message)); } internal void StartRouteFollow() { Write("Starting route follow..."); FollowingRoute = true; SendMessageAndOnResponse(mainCommand.AddBikeModel("bikeID"), "bikeID", (message) => { bikeId = JSONParser.GetResponseUuid(message); SendMessageAndOnResponse(mainCommand.addPanel("panelAdd", bikeId), "panelAdd", (message) => { panelId = JSONParser.getPanelID(message); WriteTextMessage(mainCommand.ColorPanel(panelId)); UpdateInfoPanel(); while (cameraId == string.Empty) { } SetFollowSpeed(5.0f); }); }); } public void UpdateInfoPanel() { ShowPanel(BikeSpeed, (int)BikeBPM, (int)BikePower, (int)BikeResistance); WriteTextMessage(mainCommand.RouteSpeed(BikeSpeed, bikeId)); WriteTextMessage(mainCommand.RouteSpeed(BikeSpeed, cameraId)); } public void ShowPanel(double bikeSpeed, int bpm, int power, int resistance) { WriteTextMessage(mainCommand.ClearPanel(panelId)); SendMessageAndOnResponse(mainCommand.showBikespeed(panelId, "bikeSpeed", bikeSpeed), "bikeSpeed", (message) => { // TODO check if is drawn }); SendMessageAndOnResponse(mainCommand.showHeartrate(panelId, "bpm", bpm), "bpm", (message) => { // TODO check if is drawn }); SendMessageAndOnResponse(mainCommand.showPower(panelId, "power", power), "power", (message) => { // TODO check if is drawn }); SendMessageAndOnResponse(mainCommand.showResistance(panelId, "resistance", resistance), "resistance", (message) => { // TODO check if is drawn }); // Check if every text is drawn! WriteTextMessage(mainCommand.SwapPanel(panelId)); } private void SetFollowSpeed(float speed) { WriteTextMessage(mainCommand.RouteFollow(routeId, bikeId, speed, new float[] { 0, -(float)Math.PI / 2f, 0 }, new float[] { 0, 0, 0 })); WriteTextMessage(mainCommand.RouteFollow(routeId, cameraId, speed)); } #endregion #region message send/receive /// /// method that sends the speciefied message with the specified serial, and executes the given action upon receivind a reply from the server with this serial. /// /// the networkstream to use /// the message to send /// the serial to check for /// the code to be executed upon reveiving a reply from the server with the specified serial public void SendMessageAndOnResponse(string message, string serial, HandleSerial action) { if (serialResponses.ContainsKey(serial)) { serialResponses[serial] = action; } else { serialResponses.Add(serial, action); } WriteTextMessage(message); } /// /// writes a message to the server /// /// the network stream to use /// the message to send public void WriteTextMessage(string message) { byte[] msg = Encoding.ASCII.GetBytes(message); byte[] res = new byte[msg.Length + 4]; Array.Copy(BitConverter.GetBytes(msg.Length), 0, res, 0, 4); Array.Copy(msg, 0, res, 4, msg.Length); stream.Write(res); //Write("sent message " + message); } #endregion public void Stop() { serverResponseReader.Stop(); } public void Write(string msg) { Console.WriteLine("[ENGINECONNECT] " + msg); } } }