Add MQTTService

Akari.Provider.WaveshareUART.csproj

@@ -93,6 +93,7 @@
     </Reference>
   </ItemGroup>
   <ItemGroup>
+    <Compile Include="MQTTService.cs" />
     <Compile Include="Views\DataDisplay.cs" />
     <Compile Include="Views\EditUserDisplay.cs" />
     <Compile Include="Views\EntryDialog.cs" />

MQTTService.cs

@@ -0,0 +1,88 @@
+using Akari.Provider.WaveshareUART.Users;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+using WaveshareUARTFingerprintSensor;
+
+namespace Akari.Provider.WaveshareUART
+{
+    public class MQTTService
+    {
+        public FingerprintSensor FingerprintSensor => WaveshareUARTProvider.Instance.FingerprintSensor;
+        public UsersManager UsersManager => WaveshareUARTProvider.Instance.UsersManager;
+
+        public MQTTService()
+        {
+
+        }
+
+        public void Start()
+        {
+            Console.WriteLine("Starting MQTT service...");
+
+            InitMQTT();
+
+            Console.WriteLine($"There is {UsersManager.Count} users registered");
+
+            FingerprintSensor.Waked += FingerprintSensor_Waked;
+
+            FingerprintSensor.Sleep();
+
+            Console.WriteLine("Waiting for fingerprints...");
+
+            Thread.Sleep(-1);
+
+            FingerprintSensor.Waked -= FingerprintSensor_Waked;
+        }
+
+        private void InitMQTT()
+        {
+            // TODO
+        }
+
+        private void SendAuth(User user)
+        {
+            // TODO
+        }
+
+        private void FingerprintSensor_Waked(FingerprintSensor sender)
+        {
+            FingerprintSensor.Wake();
+
+            if (FingerprintSensor.TryComparison1N(out var userInfo))
+            {
+                if (TryFindUser(userInfo.userID, out var user))
+                {
+                    Console.WriteLine($"{user.Name} fingerprint recognized");
+
+                    SendAuth(user);
+                }
+                else
+                {
+                    Console.WriteLine($"Found unknown fingerprint with id {userInfo.userID}");
+                }
+            }
+
+            FingerprintSensor.Sleep();
+        }
+
+        private bool TryFindUser(ushort userID, out User user)
+        {
+            ushort id = (ushort)((userID / UsersManager.RangeLength) * UsersManager.RangeLength + UsersManager.RangeStart);
+
+            if (UsersManager[id] is User u)
+            {
+                user = u;
+
+                return true;
+            }
+
+            user = default;
+
+            return false;
+        }
+    }
+}

Program.cs

@@ -8,9 +8,6 @@ namespace Akari.Provider.WaveshareUART
     {
         static void Main(string[] args)
         {
-            // TODO
-            args = new[] { "-c" };
-
             if (args.Length > 0)
             {
                 switch (args[0])

WaveshareUARTProvider.cs

@@ -31,9 +31,11 @@ namespace Akari.Provider.WaveshareUART
             FingerprintSensor.Start();
         }
 
-        internal void FingerprintLoop()
+        public void FingerprintLoop()
         {
+            InitSensor();
 
+            new MQTTService().Start();
         }
     }
 }