aboutsummaryrefslogtreecommitdiffstats
path: root/Software/Visual_Studio/Web/Tango.MachineService/Web.Release.config
blob: 28a4d5fcc327efda9352a8a0995eb323d7010c41 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
<?xml version="1.0"?>

<!-- For more information on using Web.config transformation visit https://go.microsoft.com/fwlink/?LinkId=301874 -->

<configuration xmlns:xdt="http://schemas.microsoft.com/XML-Document-Transform">
  <!--
    In the example below, the "SetAttributes" transform will change the value of
    "connectionString" to use "ReleaseSQLServer" only when the "Match" locator
    finds an attribute "name" that has a value of "MyDB".

    <connectionStrings>
      <add name="MyDB"
        connectionString="Data Source=ReleaseSQLServer;Initial Catalog=MyReleaseDB;Integrated Security=True"
        xdt:Transform="SetAttributes" xdt:Locator="Match(name)"/>
    </connectionStrings>
  -->
  <system.web>
    <compilation xdt:Transform="RemoveAttributes(debug)" />
    <!--
      In the example below, the "Replace" transform will replace the entire
      <customErrors> section of your Web.config file.
      Note that because there is only one customErrors section under the
      <system.web> node, there is no need to use the "xdt:Locator" attribute.

      <customErrors defaultRedirect="GenericError.htm"
        mode="RemoteOnly" xdt:Transform="Replace">
        <error statusCode="500" redirect="InternalError.htm"/>
      </customErrors>
    -->
  </system.web>
</configuration>
rd.Constant */ .highlight .kd { color: #008800; font-weight: bold } /* Keyword.Declaration */ .highlight .kn { color: #008800; font-weight: bold } /* Keyword.Namespace */ .highlight .kp { color: #008800 } /* Keyword.Pseudo */ .highlight .kr { color: #008800; font-weight: bold } /* Keyword.Reserved */ .highlight .kt { color: #888888; font-weight: bold } /* Keyword.Type */ .highlight .m { color: #0000DD; font-weight: bold } /* Literal.Number */ .highlight .s { color: #dd2200; background-color: #fff0f0 } /* Literal.String */ .highlight .na { color: #336699 } /* Name.Attribute */ .highlight .nb { color: #003388 } /* Name.Builtin */ .highlight .nc { color: #bb0066; font-weight: bold } /* Name.Class */ .highlight .no { color: #003366; font-weight: bold } /* Name.Constant */ .highlight .nd { color: #555555 } /* Name.Decorator */ .highlight .ne { color: #bb0066; font-weight: bold } /* Name.Exception */ .highlight .nf { color: #0066bb; font-weight: bold } /* Name.Function */ .highlight .nl { color: #336699; font-style: italic } /* Name.Label */ .highlight .nn { color: #bb0066; font-weight: bold } /* Name.Namespace */ .highlight .py { color: #336699; font-weight: bold } /* Name.Property */ .highlight .nt { color: #bb0066; font-weight: bold } /* Name.Tag */ .highlight .nv { color: #336699 } /* Name.Variable */ .highlight .ow { color: #008800 } /* Operator.Word */ .highlight .w { color: #bbbbbb } /* Text.Whitespace */ .highlight .mb { color: #0000DD; font-weight: bold } /* Literal.Number.Bin */ .highlight .mf { color: #0000DD; font-weight: bold } /* Literal.Number.Float */ .highlight .mh { color: #0000DD; font-weight: bold } /* Literal.Number.Hex */ .highlight .mi { color: #0000DD; font-weight: bold } /* Literal.Number.Integer */ .highlight .mo { color: #0000DD; font-weight: bold } /* Literal.Number.Oct */ .highlight .sa { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Affix */ .highlight .sb { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Backtick */ .highlight .sc { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Char */ .highlight .dl { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Delimiter */ .highlight .sd { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Doc */ .highlight .s2 { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Double */ .highlight .se { color: #0044dd; background-color: #fff0f0 } /* Literal.String.Escape */ .highlight .sh { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Heredoc */ .highlight .si { color: #3333bb; background-color: #fff0f0 } /* Literal.String.Interpol */ .highlight .sx { color: #22bb22; background-color: #f0fff0 } /* Literal.String.Other */ .highlight .sr { color: #008800; background-color: #fff0ff } /* Literal.String.Regex */ .highlight .s1 { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Single */ .highlight .ss { color: #aa6600; background-color: #fff0f0 } /* Literal.String.Symbol */ .highlight .bp { color: #003388 } /* Name.Builtin.Pseudo */ .highlight .fm { color: #0066bb; font-weight: bold } /* Name.Function.Magic */ .highlight .vc { color: #336699 } /* Name.Variable.Class */ .highlight .vg { color: #dd7700 } /* Name.Variable.Global */ .highlight .vi { color: #3333bb } /* Name.Variable.Instance */ .highlight .vm { color: #336699 } /* Name.Variable.Magic */ .highlight .il { color: #0000DD; font-weight: bold } /* Literal.Number.Integer.Long */
using Microsoft.AspNet.SignalR;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using System.Web;
using Tango.Integration.ExternalBridge.Web;

namespace Tango.MachineService.Hubs
{
    public class ExternalBridgeHub : Hub
    {
        private static List<ExternalBridgeInfo> _externalBridges;
        private static List<MachineSession> _sessions;

        public class ExternalBridgeInfo
        {
            public String ConnectionID { get; set; }
            public MachineInfo MachineInfo { get; set; }
        }

        public class MachineSession
        {
            public String SessionID { get; set; }
            public String ReceiverConnectionID { get; set; }
            public String ControllerConnectionID { get; set; }
            public ExternalBridgeInfo ExternalBridge { get; set; }

            public MachineSession()
            {
                SessionID = Guid.NewGuid().ToString();
            }
        }

        static ExternalBridgeHub()
        {
            _externalBridges = new List<ExternalBridgeInfo>();
            _sessions = new List<MachineSession>();
        }

        public void RegisterMachine(MachineInfo machineInfo)
        {
            _externalBridges.RemoveAll(x => x.MachineInfo.SerialNumber == machineInfo.SerialNumber);
            _sessions.RemoveAll(x => x.ExternalBridge.ConnectionID == Context.ConnectionId);

            machineInfo.IPAddress = GetIpAddress();

            _externalBridges.Add(new ExternalBridgeInfo()
            {
                MachineInfo = machineInfo,
                ConnectionID = Context.ConnectionId,
            });
        }

        public void UnregisterMachine()
        {
            _externalBridges.RemoveAll(x => x.ConnectionID == Context.ConnectionId);
            _sessions.RemoveAll(x => x.ExternalBridge.ConnectionID == Context.ConnectionId);
        }

        public String Ping()
        {
            return "Ping";
        }

        public List<MachineInfo> GetAvailableMachines()
        {
            return _externalBridges.Select(x => x.MachineInfo).ToList();
        }

        public String CreateSession(String serialNumber)
        {
            var externalBridge = _externalBridges.SingleOrDefault(x => x.MachineInfo.SerialNumber == serialNumber);

            if (externalBridge != null)
            {
                var existingSession = GetSession();

                if (existingSession != null)
                {
                    _sessions.Remove(existingSession);
                }

                MachineSession session = new MachineSession();
                session.ControllerConnectionID = Context.ConnectionId;
                session.ExternalBridge = externalBridge;
                _sessions.Add(session);
                Clients.Client(externalBridge.ConnectionID).OnSessionCreated(session.SessionID);
                return session.SessionID;
            }

            return null;
        }

        public void JoinSession(String sessionID)
        {
            var session = _sessions.SingleOrDefault(x => x.SessionID == sessionID);

            if (session != null)
            {
                session.ReceiverConnectionID = Context.ConnectionId;
                Clients.Client(session.ControllerConnectionID).SessionCreated();
            }
        }

        public void Write(List<byte[]> dataCollection)
        {
            var connectionID = GetOtherSideConnectionID();

            if (connectionID != null)
            {
                Clients.Client(connectionID).DataAvailable(dataCollection);
            }
        }

        public void LeaveSession()
        {
            var connectionID = GetOtherSideConnectionID();
            ClearSession();
            Clients.Client(connectionID).OnSessionClosed();
        }

        public override Task OnDisconnected(bool stopCalled)
        {
            _externalBridges.RemoveAll(x => x.ConnectionID == Context.ConnectionId);
            _sessions.RemoveAll(x => x.ControllerConnectionID == Context.ConnectionId || x.ReceiverConnectionID == Context.ConnectionId || x.ExternalBridge.ConnectionID == Context.ConnectionId);
            return base.OnDisconnected(stopCalled);
        }

        private void ClearSession()
        {
            _sessions.RemoveAll(x => x.ControllerConnectionID == Context.ConnectionId || x.ReceiverConnectionID == Context.ConnectionId);
        }

        private MachineSession GetSession()
        {
            return _sessions.SingleOrDefault(x => x.ReceiverConnectionID == Context.ConnectionId || x.ControllerConnectionID == Context.ConnectionId);
        }

        private String GetOtherSideConnectionID()
        {
            var session = GetSession();

            if (session != null)
            {
                String connectionID = String.Empty;

                if (session.ReceiverConnectionID == Context.ConnectionId)
                {
                    connectionID = session.ControllerConnectionID;
                }
                else
                {
                    connectionID = session.ReceiverConnectionID;
                }

                return connectionID;
            }

            return null;
        }

        protected string GetIpAddress()
        {
            try
            {
                string ipAddress;
                object tempObject;

                Context.Request.Environment.TryGetValue("server.RemoteIpAddress", out tempObject);

                if (tempObject != null)
                {
                    ipAddress = (string)tempObject;
                }
                else
                {
                    ipAddress = "";
                }

                return ipAddress;
            }
            catch
            {
                return String.Empty;
            }
        }
    }
}