Rename controls

2018-03-17 20:37:48 +01:00
parent 954c34b6e0
commit 2ce6891569
6 changed files with 16 additions and 14 deletions
--- a/VAR.Focus.Web/Controls/HndChat.cs
+++ b/VAR.Focus.Web/Controls/HndChat.cs
@@ -0,0 +1,126 @@
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Web;
+using VAR.Focus.BusinessLogic;
+using VAR.Focus.BusinessLogic.Entities;
+using VAR.Focus.BusinessLogic.Persistence;
+using VAR.Focus.Web.Code;
+
+namespace VAR.Focus.Web.Controls
+{
+    public class HndChat : IHttpHandler
+    {
+        #region Declarations
+
+        private static object _monitor = new object();
+        private static Dictionary<string, MessageBoard> _chatBoards = new Dictionary<string, MessageBoard>();
+
+        #endregion Declarations
+
+        #region IHttpHandler
+
+        public bool IsReusable
+        {
+            get { return false; }
+        }
+
+        public void ProcessRequest(HttpContext context)
+        {
+            try
+            {
+                if (context.Request.RequestType == "GET")
+                {
+                    ProcessReciver(context);
+                }
+                if (context.Request.RequestType == "POST")
+                {
+                    ProcessSender(context);
+                }
+            }
+            catch (Exception ex)
+            {
+                context.ResponseObject(new OperationStatus { IsOK = false, Message = ex.Message, });
+            }
+        }
+
+        #endregion IHttpHandler
+
+        #region Private methods
+
+        private void ProcessReciver(HttpContext context)
+        {
+            string idMessageBoard = context.GetRequestParm("IDMessageBoard");
+            int idMessage = Convert.ToInt32(context.GetRequestParm("IDMessage"));
+            string strTimePoolData = context.GetRequestParm("TimePoolData");
+            int timePoolData = Convert.ToInt32(string.IsNullOrEmpty(strTimePoolData) ? "0" : strTimePoolData);
+
+            MessageBoard messageBoard;
+            bool mustWait = (timePoolData > 0);
+            do
+            {
+                if (_chatBoards.ContainsKey(idMessageBoard) == false)
+                {
+                    lock (_chatBoards)
+                    {
+                        if (_chatBoards.ContainsKey(idMessageBoard) == false)
+                        {
+                            messageBoard = new MessageBoard(idMessageBoard, new JsonFilePersistence());
+                            _chatBoards[idMessageBoard] = messageBoard;
+                        }
+                    }
+                }
+
+                if (_chatBoards.ContainsKey(idMessageBoard))
+                {
+                    messageBoard = _chatBoards[idMessageBoard];
+                    List<Message> listMessages = messageBoard.Messages_GetList(idMessage);
+                    if (listMessages.Count > 0)
+                    {
+                        mustWait = false;
+                        context.ResponseObject(listMessages);
+                        return;
+                    }
+                }
+                if (mustWait)
+                {
+                    lock (_monitor) { Monitor.Wait(_monitor, timePoolData); }
+                }
+            } while (mustWait);
+            context.ResponseObject(new List<Message>());
+        }
+
+        private void ProcessSender(HttpContext context)
+        {
+            string text = Convert.ToString(context.GetRequestParm("Text"));
+            string idMessageBoard = context.GetRequestParm("IDMessageBoard");
+            if (string.IsNullOrEmpty(idMessageBoard)) { idMessageBoard = "root"; }
+            string userName = Convert.ToString(context.GetRequestParm("UserName"));
+            Session session = WebSessions.Current.Session_GetCurrent(context);
+            if (session.UserName.ToLower() != userName.ToLower())
+            {
+                context.ResponseObject(new OperationStatus { IsOK = false, Message = "User mismatch" });
+                return;
+            }
+
+            lock (_chatBoards)
+            {
+                MessageBoard messageBoard;
+                if (_chatBoards.ContainsKey(idMessageBoard))
+                {
+                    messageBoard = _chatBoards[idMessageBoard];
+                }
+                else
+                {
+                    messageBoard = new MessageBoard(idMessageBoard, new JsonFilePersistence());
+                    _chatBoards[idMessageBoard] = messageBoard;
+                }
+                messageBoard.Message_Add(userName, text);
+                lock (_monitor) { Monitor.PulseAll(_monitor); }
+            }
+            context.ResponseObject(new OperationStatus { IsOK = true, Message = "Message sent" });
+        }
+
+        #endregion Private methods
+    }
+}