public list fertig gestellt

2023-08-01 14:20:27 +02:00
parent f4a0af33b0
commit 2f2524a5c4
7 changed files with 145 additions and 55 deletions
--- a/ConsoleApp3/CheckSevDeskPublicList.cs
+++ b/ConsoleApp3/CheckSevDeskPublicList.cs
@@ -0,0 +1,118 @@
+using ConsoleApp3.Contracts;
+using OpenQA.Selenium.DevTools;
+using OpenQA.Selenium.Support.UI;
+using System;
+using System.Collections.Generic;
+using System.Diagnostics;
+using System.Linq;
+using System.Net.Sockets;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace CardMarketBot
+{
+    internal class CheckSevDeskPublicList : ICheckSevDesk
+    {
+        private static readonly object _lock = new object();
+        private static bool _closed;
+
+        enum EResult
+        {
+            FAILED,
+            AVAIBLE,
+            OK,
+            WRITTEN
+        }
+        private static void Write(TcpClient client, string str)
+        {
+            try
+            {
+                SocketShutdown reason = SocketShutdown.Send;
+                lock (_lock)
+                {
+                    BinaryWriter writer = new BinaryWriter(client.GetStream());
+                    writer.Write(str);
+                    if (_closed)
+                    {
+                        reason = SocketShutdown.Both;
+                    }
+                }
+                //client.Client.Shutdown(reason);
+            }
+            catch (IOException e)
+            {
+                Console.WriteLine($"IOException writing to socket: {e.Message}");
+            }
+        }
+
+        private static EResult Read(TcpClient client)
+        {
+            try
+            {
+                //while(true)
+                //{
+                try
+                {
+                    if (!client.Connected)
+                    {
+                        lock (_lock)
+                        {
+                            _closed = true;
+                            //break;
+                        }
+                    }
+                    BinaryReader reader = new BinaryReader(client.GetStream());
+                    string res = reader.ReadString();
+                    if (res.Contains("OK"))
+                        return EResult.OK;
+                    return EResult.FAILED;
+                }
+                catch (EndOfStreamException)
+                {
+                    lock (_lock)
+                    {
+                        _closed = true;
+                    }
+                    return EResult.FAILED;
+                }
+                //client.Client.Shutdown(SocketShutdown.Receive);
+                //}
+            }
+            catch (IOException e)
+            {
+                Console.WriteLine(e.Message);
+                return EResult.FAILED;
+            }
+        }
+
+
+        public bool AlreadyKnown(string verkaufsnummer)
+        {
+            try
+            {
+                TcpClient client = new TcpClient("nas.cosysda.de", 4000);
+                Write(client, string.Format("#TEST#{0}", verkaufsnummer));
+                EResult result = Read(client);
+
+                client.Client.Shutdown(SocketShutdown.Both);
+                client.Close();
+
+                return result == EResult.OK;
+            }
+            catch(SocketException e)
+            {
+                throw new SocketException();
+            }
+        }
+
+        public bool Write(string verkaufsnummer)
+        {
+            TcpClient client = new TcpClient("nas.cosysda.de", 4000);
+            Write(client, string.Format("#WRITE#{0}", verkaufsnummer));
+            EResult result = Read(client);
+            client.Client.Shutdown(SocketShutdown.Both);
+            client.Close();
+            return result == EResult.OK;
+        }
+    }
+}