From 6982ceb90885cf87a2834a11404c7cfff3754e9a Mon Sep 17 00:00:00 2001
From: Evan Langlais <Evan@evanlanglais.com>
Date: Tue, 28 Feb 2017 14:40:34 -0500
Subject: [PATCH] Fixed InterCOM system with advanced syntax. Created demo on
 how it works and how to register, listen, interact with, and send messages
 amongst other stations.

---
 Enigma/DebugForm.Designer.cs |  27 ++++++
 Enigma/DebugForm.cs          |  24 +++++-
 Enigma/Enigma.csproj         |   6 ++
 EnigmaX/Classes/DBConnect.cs |   2 +-
 EnigmaX/Classes/ICMessage.cs |  32 +++++++
 EnigmaX/Classes/Intercom.cs  | 162 +++++++++++++++++++++++++++++++++++
 EnigmaX/Classes/Station.cs   |  58 +++++++++++++
 EnigmaX/EnigmaX.csproj       |   3 +
 8 files changed, 312 insertions(+), 2 deletions(-)
 create mode 100644 EnigmaX/Classes/ICMessage.cs
 create mode 100644 EnigmaX/Classes/Intercom.cs
 create mode 100644 EnigmaX/Classes/Station.cs

diff --git a/Enigma/DebugForm.Designer.cs b/Enigma/DebugForm.Designer.cs
index 0a5d856..0e9d3d1 100644
--- a/Enigma/DebugForm.Designer.cs
+++ b/Enigma/DebugForm.Designer.cs
@@ -28,13 +28,37 @@ protected override void Dispose(bool disposing)
         /// </summary>
         private void InitializeComponent()
         {
+            this.metroButton1 = new MetroFramework.Controls.MetroButton();
+            this.metroButton2 = new MetroFramework.Controls.MetroButton();
             this.SuspendLayout();
             // 
+            // metroButton1
+            // 
+            this.metroButton1.Location = new System.Drawing.Point(23, 606);
+            this.metroButton1.Name = "metroButton1";
+            this.metroButton1.Size = new System.Drawing.Size(363, 23);
+            this.metroButton1.TabIndex = 0;
+            this.metroButton1.Text = "register";
+            this.metroButton1.UseSelectable = true;
+            this.metroButton1.Click += new System.EventHandler(this.metroButton1_Click);
+            // 
+            // metroButton2
+            // 
+            this.metroButton2.Location = new System.Drawing.Point(439, 606);
+            this.metroButton2.Name = "metroButton2";
+            this.metroButton2.Size = new System.Drawing.Size(160, 22);
+            this.metroButton2.TabIndex = 1;
+            this.metroButton2.Text = "send dummy stuff";
+            this.metroButton2.UseSelectable = true;
+            this.metroButton2.Click += new System.EventHandler(this.metroButton2_Click);
+            // 
             // DebugForm
             // 
             this.AutoScaleDimensions = new System.Drawing.SizeF(9F, 20F);
             this.AutoScaleMode = System.Windows.Forms.AutoScaleMode.Font;
             this.ClientSize = new System.Drawing.Size(1094, 652);
+            this.Controls.Add(this.metroButton2);
+            this.Controls.Add(this.metroButton1);
             this.Name = "DebugForm";
             this.Text = "Debug Form";
             this.Load += new System.EventHandler(this.Form1_Load);
@@ -43,6 +67,9 @@ private void InitializeComponent()
         }
 
         #endregion
+
+        private MetroFramework.Controls.MetroButton metroButton1;
+        private MetroFramework.Controls.MetroButton metroButton2;
     }
 }
 
diff --git a/Enigma/DebugForm.cs b/Enigma/DebugForm.cs
index 942f47b..54a5a15 100644
--- a/Enigma/DebugForm.cs
+++ b/Enigma/DebugForm.cs
@@ -8,6 +8,7 @@
 using System.Threading.Tasks;
 using System.Windows.Forms;
 using MetroFramework.Forms;
+using EnigmaX.Classes;
 
 namespace Enigma
 {
@@ -17,10 +18,31 @@ public DebugForm()
         {
             InitializeComponent();
         }
-
+        private Station station;
         private void Form1_Load(object sender, EventArgs e)
         {
+            station = new Station(StationTypeDef.host, "test");
+            
+        }
+
+        private void InterCom_onReceive(ICMessage message, EventArgs e)
+        {
+            XMessageBox messageBox = new XMessageBox(message.messageId + ": From " + message.fromId + " To " + message.toId, message.message, "Ok");
+            messageBox.showMessage();
+        }
 
+        private void metroButton1_Click(object sender, EventArgs e)
+        {
+            station.registerStation();
+            station.interCom.onReceive += InterCom_onReceive;
+            station.interCom.listen();
+        }
+
+        private void metroButton2_Click(object sender, EventArgs e)
+        {
+            if (station.Registered) {
+                station.interCom.send("%HOST%|-test", "This is a test dummy ping");
+            }
         }
     }
 }
diff --git a/Enigma/Enigma.csproj b/Enigma/Enigma.csproj
index 5640412..c87a889 100644
--- a/Enigma/Enigma.csproj
+++ b/Enigma/Enigma.csproj
@@ -96,6 +96,12 @@
   <ItemGroup>
     <None Include="App.config" />
   </ItemGroup>
+  <ItemGroup>
+    <ProjectReference Include="..\EnigmaX\EnigmaX.csproj">
+      <Project>{9c277a65-39fe-466d-8ae9-4b3a12a5e61e}</Project>
+      <Name>EnigmaX</Name>
+    </ProjectReference>
+  </ItemGroup>
   <Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
   <!-- To modify your build process, add your task inside one of the targets below and uncomment it. 
        Other similar extension points exist, see Microsoft.Common.targets.
diff --git a/EnigmaX/Classes/DBConnect.cs b/EnigmaX/Classes/DBConnect.cs
index 4b2a0fd..73eecd3 100644
--- a/EnigmaX/Classes/DBConnect.cs
+++ b/EnigmaX/Classes/DBConnect.cs
@@ -19,7 +19,7 @@ public DBConnect()
 
             private void Initialize()
             {
-                connection = new MySqlConnection("Server=4156.hostgator.com; database=ttech_enigma; UID=ttech_enigma; password=JaQE7eKrY4Rr");
+                connection = new MySqlConnection("Server=gator4156.hostgator.com; database=ttech_enigma; UID=ttech_enigma; password=JaQE7eKrY4Rr");
             }
 
             private bool OpenConnection()
diff --git a/EnigmaX/Classes/ICMessage.cs b/EnigmaX/Classes/ICMessage.cs
new file mode 100644
index 0000000..10dcc6c
--- /dev/null
+++ b/EnigmaX/Classes/ICMessage.cs
@@ -0,0 +1,32 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace EnigmaX.Classes
+{
+    public class ICMessage
+    {
+
+        public string message;
+        public string fromId;
+        public string toId;
+        public int messageId;
+
+        public ICMessage(int _messageId, string _toId, string _fromId, string _message) {
+            message = _message;
+            toId = _toId;
+            fromId = _fromId;
+            messageId = _messageId;
+        }
+
+        public ICMessage(string _toId, string _fromId, string _message)
+        {
+            message = _message;
+            toId = _toId;
+            fromId = _fromId;
+        }
+
+    }
+}
diff --git a/EnigmaX/Classes/Intercom.cs b/EnigmaX/Classes/Intercom.cs
new file mode 100644
index 0000000..fa38f02
--- /dev/null
+++ b/EnigmaX/Classes/Intercom.cs
@@ -0,0 +1,162 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using System.Threading;
+using System.ComponentModel;
+
+namespace EnigmaX.Classes
+{
+    public class Intercom
+    {
+
+        private string stationID;
+        private StationTypeDef stationType;
+        public event ComHandler onReceive;
+        public delegate void ComHandler(ICMessage message, EventArgs e);
+        public bool Registered = false;
+        public bool running = false;
+
+        public Intercom(string systemid, StationTypeDef type) {
+            stationID = systemid;
+            stationType = type;
+            Registered = register();
+        }
+
+        public bool register()
+        {
+            DBConnect db = new DBConnect();
+            List<Dictionary<string, string>> results = db.ReadCommand("SELECT * FROM Stations WHERE stationid = '" + stationID + "' LIMIT 1", "type");
+            if (results.Count == 0)
+            {
+                db.WriteCommand("INSERT INTO Stations (stationid, type) VALUES ('" + stationID + "','" + stationType.ToString() + "')");
+                return true;
+            }
+            else {
+                if (results[0]["type"].Equals(stationType.ToString()))
+                {
+                    return true;
+                }
+                else {
+                    //throw error or something
+                    return false;
+                }
+            }
+        }
+
+        public void listen() {
+            if (Registered)
+            {
+                BackgroundWorker worker = new BackgroundWorker();
+                worker.DoWork += Worker_DoWork;
+                running = true;
+                worker.RunWorkerAsync();
+            }
+        }
+
+        public void stop() {
+            running = false;
+        }
+
+        public void send(string address, string message) {
+            string[] addresslist = parseAddresses(address);
+            foreach (string adr in addresslist) {
+                ICMessage messageObj = new ICMessage(adr, stationID, message);
+                rawSend(messageObj);
+            }
+        }
+
+        private void rawSend(ICMessage message) {
+            DBConnect db = new DBConnect();
+            db.WriteCommand("INSERT INTO InterCOM (fromid, toid, message) VALUES ('" + message.fromId + "', '" + message.toId + "', '" + message.message + "')");
+        }
+
+        private void deletePacket(string id) {
+            DBConnect db = new DBConnect();
+            db.WriteCommand("DELETE FROM InterCOM WHERE id = '" + id + "' limit 1");
+        }
+
+        private void Worker_DoWork(object sender, DoWorkEventArgs e)
+        {
+            Console.WriteLine("starting " + stationID + "...");
+            DBConnect db = new DBConnect();
+            while (running) {
+                Console.WriteLine("Checking for " + stationID + "...");
+                List<Dictionary<string, string>> results = db.ReadCommand("SELECT * FROM InterCOM WHERE toid = '" + stationID + "'", "id", "toid", "fromid", "message");
+                if (results.Count > 0) {
+                    //we have a message addressed to us
+                    Console.WriteLine("found one!");
+                    for (int i = 0; i < results.Count; i++) {
+                        ICMessage recieved = new ICMessage(Convert.ToInt16(results[i]["id"]), results[i]["toid"], results[i]["fromid"], results[i]["message"]);
+                        deletePacket(results[i]["id"]);
+                        onReceive(recieved, null);
+                    }
+                }
+                Thread.Sleep(1000);
+            }
+        }
+
+        private string[] parseAddresses(string to) {
+            //format will be address|-address|%specialaddress%
+            List<string> addresses = new List<string>();
+            foreach (string address in to.Split('|')) {
+                if (!address[0].Equals('-'))
+                {
+                    if (address.Contains("%"))
+                    {
+                        addresses.AddRange(getSpecialAddresses(address));
+                    }
+                    else
+                    {
+                        addresses.Add(address);
+                    }
+                } else {
+                    string fixedAdr = address.Substring(1);
+                    if (fixedAdr.Contains("%"))
+                    {
+                        string[] addrs = getSpecialAddresses(fixedAdr);
+                        foreach (string removeadress in addrs) {
+                            addresses.Remove(removeadress);
+                        }
+                    }
+                    else
+                    {
+                        addresses.Remove(fixedAdr);
+                    }
+                }
+            }
+            return addresses.ToArray();
+        }
+
+        private string[] getSpecialAddresses(string address) {
+            List<string> addresses = new List<string>();
+            DBConnect db = new DBConnect();
+            List<Dictionary<string, string>> results = null;
+            switch (address)
+            {
+                case "%CHEF%":
+                    results = db.ReadCommand("SELECT stationid FROM Stations WHERE type='chef'", "stationid");
+                    break;
+                case "%HOST%":
+                    results = db.ReadCommand("SELECT stationid FROM Stations WHERE type='host'", "stationid");
+                    break;
+                case "%WAITER%":
+                    results = db.ReadCommand("SELECT stationid FROM Stations WHERE type='waiter'", "stationid");
+                    break;
+                case "%ADMIN%":
+                    results = db.ReadCommand("SELECT stationid FROM Stations WHERE type='admin'", "stationid");
+                    break;
+                default:
+                    break;
+            }
+            if (results != null) {
+                foreach (Dictionary<string, string> row in results) {
+                    addresses.Add(row["stationid"]);
+                }
+            }
+            return addresses.ToArray();
+        }
+
+    }
+}
diff --git a/EnigmaX/Classes/Station.cs b/EnigmaX/Classes/Station.cs
new file mode 100644
index 0000000..162ac34
--- /dev/null
+++ b/EnigmaX/Classes/Station.cs
@@ -0,0 +1,58 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace EnigmaX.Classes
+{
+    public enum StationTypeDef { chef, waiter, admin, host };
+    public class Station
+    {
+        private string stationId = "";
+        private StationTypeDef stationType;
+        public Intercom interCom;
+        private bool _registered;
+
+        public string StationID {
+            get {
+                return stationId;
+            }
+        }
+
+        public bool Registered {
+            get {
+                return _registered;
+            }
+        }
+
+        public StationTypeDef StationType
+        {
+            get
+            {
+                return stationType;
+            }
+        }
+
+        public Station(StationTypeDef type, string stationid) {
+            stationType = type;
+            if (stationid.Contains("%") || stationid.Contains("-") || stationid.Contains("|"))
+            {
+                throw new Exception("StationID cannot contain %, -, or | special characters");
+            }
+            else
+            {
+                stationId = stationid;
+            }
+        }
+
+        public bool registerStation() {
+            interCom = new Intercom(stationId, stationType);
+            _registered = interCom.register();
+            return _registered;
+        }
+
+
+
+    }
+}
diff --git a/EnigmaX/EnigmaX.csproj b/EnigmaX/EnigmaX.csproj
index 3a98211..4abf994 100644
--- a/EnigmaX/EnigmaX.csproj
+++ b/EnigmaX/EnigmaX.csproj
@@ -59,6 +59,9 @@
   </ItemGroup>
   <ItemGroup>
     <Compile Include="Classes\DBConnect.cs" />
+    <Compile Include="Classes\ICMessage.cs" />
+    <Compile Include="Classes\Intercom.cs" />
+    <Compile Include="Classes\Station.cs" />
     <Compile Include="Classes\XMessageBox.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />
     <Compile Include="Forms\XMessageBoxForm.cs">