移除无用的项目。

BlobDownload/BlobDownload.csproj

@@ -1,14 +0,0 @@
-<Project Sdk="Microsoft.NET.Sdk">
-
-  <PropertyGroup>
-    <OutputType>Exe</OutputType>
-    <TargetFramework>net5.0</TargetFramework>
-  </PropertyGroup>
-
-  <ItemGroup>
-    <PackageReference Include="Aspose.Slides.NET" Version="21.8.0" />
-    <PackageReference Include="Azure.Storage.Blobs.Batch" Version="12.6.0" />
-    <PackageReference Include="System.Drawing.Common" Version="5.0.2" />
-  </ItemGroup>
-
-</Project>

BlobDownload/Program.cs

@@ -1,105 +0,0 @@
-using Azure.Storage.Blobs;
-using Azure.Storage.Blobs.Models;
-using Azure.Storage.Blobs.Specialized;
-using System;
-using System.Collections.Generic;
-using System.Drawing;
-using System.IO;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-
-namespace BlobDownload
-{
-   public class Program
-    {
-        static bool IsNumeric(string str)
-        {
-            System.Text.RegularExpressions.Regex reg1 = new System.Text.RegularExpressions.Regex(@"^[-]?\d+[.]?\d*$");
-            return reg1.IsMatch(str);
-        }
-        static async Task Main(string[] args)
-        {
-            var prs = new Aspose.Slides.Presentation(@"C:\Users\CrazyIter\Desktop\6.2.3平面图形的认识与测量（三）(3).pptx");
-            prs.Save(@"C:\Users\CrazyIter\Desktop\output.Gif", Aspose.Slides.Export.SaveFormat.Gif);
-            string reg1 = "123aewe";
-            string reg2 = "858";
-            string reg3 = "858=";
-            string reg4 = "aa858=";
-            string reg5 = "83edd58=";
-            Console.WriteLine(IsNumeric(reg1));
-            Console.WriteLine(IsNumeric(reg2));
-            Console.WriteLine(IsNumeric(reg3));
-            Console.WriteLine(IsNumeric(reg4));
-            Console.WriteLine(IsNumeric(reg5));
-
-
-
-            string base64 = "/base64.txt";
-            StreamReader sr = new StreamReader(base64, Encoding.Default);
-            StringBuilder content = new StringBuilder();
-            string line;
-            while ((line = sr.ReadLine()) != null)
-            {
-                content.Append(line);
-            }
-            byte[] bytes = Convert.FromBase64String(content.ToString());
-            Stream stream = new MemoryStream(bytes);
-
-            // MemoryStream memoryStream = new MemoryStream();
-            System.Drawing.Bitmap inFile = new System.Drawing.Bitmap(stream);
-            Graphics graphics = Graphics.FromImage(inFile);
-            graphics.Save();
-            graphics.Dispose();
-            inFile.Save("test.png", System.Drawing.Imaging.ImageFormat.Png);
-            //byte[] arr = new byte[memoryStream.Length];
-            //memoryStream.Position = 0;
-            //memoryStream.Read(arr, 0, (int)memoryStream.Length);
-            //memoryStream.Close();
-            //memoryStream.Dispose();
-            /*
-            string StorageAccountConnectionString = "DefaultEndpointsProtocol=https;AccountName=teammodelstorage;AccountKey=Yq7D4dE6cFuer2d2UZIccTA/i0c3sJ/6ITc8tNOyW+K5f+/lWw9GCos3Mxhj47PyWQgDL8YbVD63B9XcGtrMxQ==;EndpointSuffix=core.chinacloudapi.cn";
-            BlobServiceClient blobServiceClient = new BlobServiceClient(StorageAccountConnectionString);
-            BlobContainerClient blobContainerClient = new BlobContainerClient(StorageAccountConnectionString, "hbcn");
-            //BlobClient blob = blobContainerClient.GetBlobClient("res/PRD-20191015001/index.json");
-            //await blob.DownloadToAsync(@"D:\VisualStudioProjects\TEAMModelOS\BlobDownload\download\index.json");
-            string downloadpath = "F:/download";
-            HashSet<string> pathset = new HashSet<string>();
-            List<string> items = new List<string>();
-            int count = 0;
-            await  foreach (BlobItem item in blobContainerClient.GetBlobsAsync(BlobTraits.None, BlobStates.None, "res/PRD-20191015002"))
-            {
-                string path = Path.Combine(downloadpath, item.Name);
-                var paths= path.Split("/");
-                StringBuilder stringBuilder = new StringBuilder();
-                for (int i = 0; i < paths.Length-1; i++) {
-                    stringBuilder.Append($"{paths[i]}/");
-
-                }
-                pathset.Add(stringBuilder.ToString());
-                count++;
-                items.Add(item.Name);
-            }
-
-            foreach (var path in pathset) {
-                if (!Directory.Exists(path)) {
-                    Directory.CreateDirectory(path);
-                }
-            }
-            List<Task> tasks = new List<Task>();
-            long  start= DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
-            foreach (var item in items)
-            {
-                BlobClient blob = blobContainerClient.GetBlobClient(item);
-
-                string path = Path.Combine(downloadpath, item);
-               
-                tasks.Add(blob.DownloadToAsync(path));
-            }
-            await Task.WhenAll(tasks);
-            long end = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
-            Console.WriteLine($"文件个数：{count}；下载时间：{end-start}毫秒");
-            */
-        }
-    }
-}

Client/Client.csproj

@@ -1,16 +0,0 @@
-<Project Sdk="Microsoft.NET.Sdk">
-
-  <PropertyGroup>
-    <OutputType>Exe</OutputType>
-    <TargetFramework>netcoreapp3.1</TargetFramework>
-  </PropertyGroup>
-
-  <ItemGroup>
-    <PackageReference Include="Microsoft.AspNetCore.SignalR.Client" Version="5.0.3" />
-    <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="5.0.1" />
-    <PackageReference Include="Microsoft.Extensions.Logging" Version="5.0.0" />
-    <PackageReference Include="Microsoft.Extensions.Logging.Console" Version="5.0.0" />
-    <PackageReference Include="Twilio" Version="5.55.0" />
-  </ItemGroup>
-
-</Project>

Client/Program.cs

@@ -1,68 +0,0 @@
-using Client.SSE;
-using System;
-using System.Collections.Generic;
-using System.IO;
-using System.Net.Http;
-using System.Security.Policy;
-using System.Text;
-using System.Text.Json;
-using System.Text.Json.Serialization;
-using System.Threading;
-using System.Threading.Tasks;
-
-
-namespace Client
-{
-    class Program
-    {    
-        static void Main(string[] args)
-        {
-            //SSE
-            try
-            {
-                Console.WriteLine("12536".PadLeft(7, '0'));
-                var cts = new CancellationTokenSource();
-                var header = new Dictionary<string, string>() { { "X-Auth-Name", "IES5" } };
-               //var sse = new EventSource(new Uri("https://localhost:5001/service/sse"), header, 5000);
-                var sse = new EventSource(new Uri("https://teammodelos-test.chinacloudsites.cn/service/sse"), header, 5000);
-
-                sse.StateChanged += Sse_StateChanged;
-                sse.EventReceived += Sse_EventReceived;
-                sse.Start(cts.Token);
-
-                //cts?.Cancel(); 中斷SSE Client連線
-            }
-            catch (TaskCanceledException ex)
-            {
-                Console.WriteLine(ex.Message);
-            }
-            catch (AggregateException ex)
-            {
-                Console.WriteLine(ex.Message);
-            }
-            catch (Exception ex)
-            {
-                Console.WriteLine(ex.Message);
-            }
-            Console.ReadLine();
-        }
-
-        private static void Sse_EventReceived(object sender, ServerSentEventReceivedEventArgs e)
-        {
-            var mm = e.Message;
-            Console.WriteLine(mm.Data);
-        }
-
-
-        private static void Sse_StateChanged(object sender, StateChangedEventArgs e)
-        {
-            //CONNECTING 0 連線中
-            //OPEN 1 開啟
-            //CLOSED 2 關閉
-            var aa = e.State;
-
-            Console.WriteLine(aa.ToString());
-        }
-
-    }
-}

Client/SSE/ConnectedState.cs

@@ -1,143 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Net;
-using System.IO;
-using System.Threading.Tasks;
-using System.Threading;
-using System.Diagnostics;
-
-namespace Client.SSE
-{
-    public class ConnectedState : IConnectionState
-    {    
-
-        private IWebRequesterFactory mWebRequesterFactory;
-        private ServerSentEvent mSse = null;
-        private string mRemainingText = string.Empty;   // the text that is not ended with a lineending char is saved for next call.
-        private IServerResponse mResponse;
-        private Dictionary<string, string> headers;
-
-        public EventSourceState State { get { return EventSourceState.OPEN; } }
-
-        public ConnectedState(IServerResponse response, IWebRequesterFactory webRequesterFactory, Dictionary<string, string> headers)
-        {
-            mResponse = response;
-            mWebRequesterFactory = webRequesterFactory;
-            this.headers = headers;
-        }
-
-        public Task<IConnectionState> Run(Action<ServerSentEvent> msgReceived, CancellationToken cancelToken, Dictionary<string, string> headers)
-        {   
-            Task<IConnectionState> t = new Task<IConnectionState>(() =>
-            {
-                //using (mResponse)
-                {
-                    //using (var stream = mResponse.GetResponseStream())
-                    var stream = mResponse.GetResponseStream();
-                    {
-                        byte[] buffer = new byte[1024 * 8];
-                        var taskRead = stream.ReadAsync(buffer, 0, buffer.Length, cancelToken);
-
-                        try
-                        {
-                            taskRead.Wait(cancelToken);
-                        }
-                        catch (Exception ex)
-                        {
-                            Trace.WriteLine(ex, "ConnectedState.Run");
-                        }
-                        if (!cancelToken.IsCancellationRequested)
-                        {
-                            int bytesRead = taskRead.Result;
-                            if (bytesRead > 0) // stream has not reached the end yet
-                            {
-                                //Console.WriteLine("ReadCallback {0} bytesRead", bytesRead);
-                                string text = Encoding.UTF8.GetString(buffer, 0, bytesRead);
-                                text = mRemainingText + text;
-                                string[] lines = StringSplitter.SplitIntoLines(text, out mRemainingText);
-                                foreach (string line in lines)
-                                {
-                                    if (cancelToken.IsCancellationRequested) break;
-
-                                    // Dispatch message if empty lne
-                                    if (string.IsNullOrEmpty(line.Trim()) && mSse != null)
-                                    {
-                                        Trace.WriteLine("SSE Message received");
-                                        msgReceived(mSse);
-                                        mSse = null;
-                                    }
-                                    else if (line.StartsWith(":"))
-                                    {
-                                        // This a comment, just log it.
-                                        Trace.WriteLine("SSE A comment was received: " + line);
-                                    }
-                                    else
-                                    {
-                                        string fieldName = String.Empty;
-                                        string fieldValue = String.Empty;
-                                        if (line.Contains(':'))
-                                        {
-                                            int index = line.IndexOf(':');
-                                            fieldName = line.Substring(0, index);
-                                            fieldValue = line.Substring(index + 1).TrimStart();
-                                        }
-                                        else
-                                            fieldName = line;
-
-                                        if (String.Compare(fieldName, "event", true) == 0)
-                                        {
-                                            mSse = mSse ?? new ServerSentEvent();
-                                            mSse.EventType = fieldValue;
-                                        }
-                                        else if (String.Compare(fieldName, "data", true) == 0)
-                                        {
-                                            mSse = mSse ?? new ServerSentEvent();
-                                            mSse.Data = fieldValue + '\n';
-                                        }
-                                        else if (String.Compare(fieldName, "id", true) == 0)
-                                        {
-                                            mSse = mSse ?? new ServerSentEvent();
-                                            mSse.LastEventId = fieldValue;
-                                        }
-                                        else if (String.Compare(fieldName, "retry", true) == 0)
-                                        {
-                                            int parsedRetry;
-                                            if (int.TryParse(fieldValue, out parsedRetry))
-                                            {
-                                                mSse = mSse ?? new ServerSentEvent();
-                                                mSse.Retry = parsedRetry;
-                                            }
-                                        }
-                                        else
-                                        {
-                                            // Ignore this, just log it
-                                            Trace.WriteLine("SSE A unknown line was received: " + line);
-                                        }
-                                    }
-                                }
-
-                                if (!cancelToken.IsCancellationRequested)
-                                    return this;
-                            }
-                            else // end of the stream reached
-                            {
-                                Trace.WriteLine("SSE No bytes read. End of stream.");
-                            }
-                        }
-
-                        //stream.Dispose()
-                        //stream.Close();
-                        //mResponse.Close();
-                        //mResponse.Dispose();
-                        return new DisconnectedState(mResponse.ResponseUri, mWebRequesterFactory, headers);
-                    }
-                }
-            });
-
-            t.Start();
-            return t;
-        }
-    }
-}

Client/SSE/ConnectingState.cs

@@ -1,55 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-using System.Net;
-using System.IO;
-using System.Threading;
-using System.Diagnostics;
-
-namespace Client.SSE
-{
-    public class ConnectingState : IConnectionState
-    {      
-
-        private Uri mUrl;
-        private IWebRequesterFactory mWebRequesterFactory;
-        private Dictionary<string, string> headers;
-
-        public EventSourceState State { get { return EventSourceState.CONNECTING; } }
-
-        public ConnectingState(Uri url, IWebRequesterFactory webRequesterFactory, Dictionary<string, string> headers)
-        {
-            if (url == null) throw new ArgumentNullException("Url cant be null");
-            if (webRequesterFactory == null) throw new ArgumentNullException("Factory cant be null");
-            mUrl = url;
-            mWebRequesterFactory = webRequesterFactory;
-            this.headers = headers;
-        }
-
-        public Task<IConnectionState> Run(Action<ServerSentEvent> donothing, CancellationToken cancelToken, Dictionary<string, string> headers)
-        {
-            IWebRequester requester = mWebRequesterFactory.Create();
-            var taskResp = requester.Get(mUrl, headers);
-
-            return taskResp.ContinueWith<IConnectionState>(tsk => 
-            {
-                if (tsk.Status == TaskStatus.RanToCompletion && !cancelToken.IsCancellationRequested)
-                {
-                    IServerResponse response = tsk.Result;
-                    if (response.StatusCode == HttpStatusCode.OK)
-                    {
-                        return new ConnectedState(response, mWebRequesterFactory, headers);
-                    }
-                    else
-                    {
-                        Trace.WriteLine("Failed to connect to: " + mUrl.ToString() + response ?? (" Http statuscode: " + response.StatusCode));
-                    }
-                }
-
-                return new DisconnectedState(mUrl, mWebRequesterFactory, headers);
-            });
-        }
-    }
-}

Client/SSE/DisconnectedState.cs

@@ -1,37 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading;
-using System.Threading.Tasks;
-
-namespace Client.SSE
-{
-    public class DisconnectedState : IConnectionState 
-    {
-        private Uri mUrl;
-        private IWebRequesterFactory mWebRequesterFactory;
-        private Dictionary<string, string> headers;
-
-        public EventSourceState State
-        {
-            get { return EventSourceState.CLOSED; }
-        }
-
-        public DisconnectedState(Uri url, IWebRequesterFactory webRequesterFactory, Dictionary<string, string> headers)
-        {
-            if (url == null) throw new ArgumentNullException("Url cant be null");
-            mUrl = url;
-            mWebRequesterFactory = webRequesterFactory;
-            this.headers = headers;
-        }
-
-        public Task<IConnectionState> Run(Action<ServerSentEvent> donothing, CancellationToken cancelToken, Dictionary<string, string> headers)
-        {
-            if(cancelToken.IsCancellationRequested)
-                return Task.Factory.StartNew<IConnectionState>(() => { return new DisconnectedState(mUrl, mWebRequesterFactory, headers); });
-            else
-                return Task.Factory.StartNew<IConnectionState>(() => { return new ConnectingState(mUrl, mWebRequesterFactory, headers); });
-        }
-    }
-}

Client/SSE/EventSource.cs

@@ -1,116 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Diagnostics;
-using System.Text;
-using System.Threading;
-
-namespace Client.SSE
-{
-    public class EventSource
-    {   
-        public event EventHandler<StateChangedEventArgs> StateChanged;
-        public event EventHandler<ServerSentEventReceivedEventArgs> EventReceived;
-
-        public CancellationTokenSource CancellationToken { get; set; }
-
-        private IWebRequesterFactory _webRequesterFactory = new WebRequesterFactory();
-        private int _timeout = 0;
-        public Uri Url { get; private set; }
-        public EventSourceState State { get { return CurrentState.State; } }
-        public string LastEventId { get; private set; }
-        private IConnectionState mCurrentState = null;
-        private CancellationToken mStopToken;
-        private CancellationTokenSource mTokenSource = new CancellationTokenSource();
-        private Dictionary<string, string> _headers;
-
-        private IConnectionState CurrentState
-        {
-            get { return mCurrentState; }
-            set
-            {
-                if (!value.Equals(mCurrentState))
-                {
-                    StringBuilder sb = new StringBuilder("State changed from ");
-                    sb.Append(mCurrentState == null ? "Unknown" : mCurrentState.State.ToString());
-                    sb.Append(" to ");
-                    sb.Append(value == null ? "Unknown" : value.State.ToString());
-                    Trace.WriteLine(sb.ToString());
-                    mCurrentState = value;
-                    OnStateChanged(mCurrentState.State);
-                }
-            }
-        }
-
-        public EventSource(Uri url, int timeout)
-        {
-            Initialize(url, timeout);
-        }
-
-        public EventSource(Uri url, Dictionary<string, string> headers, int timeout)
-        {
-            _headers = headers;
-            Initialize(url, timeout);
-        }
-
-        /// <summary>
-        /// Constructor for testing purposes
-        /// </summary>
-        /// <param name="factory">The factory that generates the WebRequester to use.</param>
-        public EventSource(Uri url, IWebRequesterFactory factory)
-        {
-            _webRequesterFactory = factory;
-            Initialize(url, 0);
-        }
-
-        private void Initialize(Uri url, int timeout)
-        {
-            _timeout = timeout;
-            Url = url;
-            CurrentState = new DisconnectedState(Url, _webRequesterFactory, _headers);
-            Trace.WriteLine("SSE EventSource created for " + url.ToString());
-        }
-
-
-        /// <summary>
-        /// Start the EventSource. 
-        /// </summary>
-        /// <param name="stopToken">Cancel this token to stop the EventSource.</param>
-        public void Start(CancellationToken stopToken)
-        {
-            if (State == EventSourceState.CLOSED)
-            {
-                mStopToken = stopToken;
-                mTokenSource = CancellationTokenSource.CreateLinkedTokenSource(stopToken);
-                Run();
-            }
-        }
-
-        protected void Run()
-        {
-            if (mTokenSource.IsCancellationRequested && CurrentState.State == EventSourceState.CLOSED)
-                return;
-
-            mCurrentState.Run(this.OnEventReceived, mTokenSource.Token, _headers).ContinueWith(cs =>
-            {
-                CurrentState = cs.Result;
-                Run();
-            });
-        }
-
-        protected void OnEventReceived(ServerSentEvent sse)
-        {
-            if (EventReceived != null)
-            {
-                EventReceived(this, new ServerSentEventReceivedEventArgs(sse));
-            }
-        }
-
-        protected void OnStateChanged(EventSourceState newState)
-        {
-            if (StateChanged != null)
-            {
-                StateChanged(this, new StateChangedEventArgs(newState));
-            }
-        }
-    }
-}

Client/SSE/EventSourceState.cs

@@ -1,14 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-
-namespace Client.SSE
-{
-    public enum EventSourceState
-    {
-        CONNECTING,
-        OPEN,
-        CLOSED 
-    }
-}

Client/SSE/IConnectionState.cs

@@ -1,15 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading;
-using System.Threading.Tasks;
-
-namespace Client.SSE
-{
-    public interface IConnectionState
-    {
-        EventSourceState State { get; }
-        Task<IConnectionState> Run(Action<ServerSentEvent> MsgReceivedCallback, CancellationToken cancelToken, Dictionary<string, string> headers);
-    }
-}

Client/SSE/IServerResponse.cs

@@ -1,17 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Net;
-using System.Text;
-
-namespace Client.SSE
-{
-    public interface IServerResponse
-    {
-        HttpStatusCode StatusCode { get; }
-
-        System.IO.Stream GetResponseStream();
-
-        Uri ResponseUri { get; }
-    }
-}

Client/SSE/IWebRequester.cs

@@ -1,15 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Net;
-using System.Text;
-using System.Threading.Tasks;
-
-namespace Client.SSE
-{
-    public interface IWebRequester
-    {
-        Task<IServerResponse> Get(Uri url, Dictionary<string, string> headers = null);
-
-    }
-}

Client/SSE/IWebRequesterFactory.cs

@@ -1,12 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-
-namespace Client.SSE
-{
-    public interface IWebRequesterFactory
-    {
-        IWebRequester Create();
-    }
-}

Client/SSE/ServerResponse.cs

@@ -1,39 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Net;
-using System.Text;
-
-namespace Client.SSE
-{
-    public class ServerResponse : IServerResponse
-    {
-        private System.Net.HttpWebResponse mHttpResponse;
-
-        public ServerResponse(System.Net.WebResponse webResponse)
-        {
-            this.mHttpResponse = webResponse as HttpWebResponse;
-        }
-
-        public HttpStatusCode StatusCode
-        {
-            get
-            {
-                return mHttpResponse.StatusCode;
-            }
-        }
-
-        public System.IO.Stream GetResponseStream()
-        {
-            return mHttpResponse.GetResponseStream();
-        }
-
-        public Uri ResponseUri
-        {
-            get
-            {
-                return mHttpResponse.ResponseUri;
-            }
-        }
-    }
-}

Client/SSE/ServerSentEvent.cs

@@ -1,26 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-
-namespace Client.SSE
-{
-    public class ServerSentEvent
-    {
-        public string LastEventId { get; set; }
-        public string EventType { get; set; }
-        public string Data { get; set; }
-        public int? Retry { get; set; }
-
-        public override string ToString()
-        {
-            StringBuilder sb = new StringBuilder();
-            sb.Append("EventType: ").Append(EventType).AppendLine();
-            sb.Append("Data: ").Append(Data).AppendLine();
-            sb.Append("LastEventId: ").Append(LastEventId).AppendLine();
-            if(Retry.HasValue)
-                sb.Append("Retry: ").Append(Retry.Value).AppendLine();
-            return sb.ToString();
-        }
-    }
-}

Client/SSE/ServerSentEventReceivedEventArgs.cs

@@ -1,17 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-
-namespace Client.SSE
-{
-    public class ServerSentEventReceivedEventArgs : EventArgs
-    {
-        public ServerSentEvent Message { get; private set; }
-        public ServerSentEventReceivedEventArgs(ServerSentEvent message)
-        {
-            Message = message;
-        }
-
-    }
-}

Client/SSE/StateChangedEventArgs.cs

@@ -1,16 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-
-namespace Client.SSE
-{
-    public class StateChangedEventArgs : EventArgs
-    {
-        public EventSourceState State { get; private set; }
-        public StateChangedEventArgs(EventSourceState state)
-        {
-            State = state;
-        }
-    }
-}

Client/SSE/StringSplitter.cs

@@ -1,47 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-
-namespace Client.SSE
-{
-    public class StringSplitter
-    {
-        public static string[] SplitIntoLines(string text, out string remainingText)
-        {
-            List<string> lines = new List<string>();
-
-            //bool endFound = false;
-            //bool searchingForFirstChar = true;
-            int lineLength = 0;
-            char previous = char.MinValue;
-            for (int i = 0; i < text.Length; i++)
-            {
-                char c = text[i];
-                if (c == '\n' || c == '\r')
-                {
-                    bool isCRLFPair = previous=='\r' && c == '\n';
-
-                    if (!isCRLFPair)
-                    {
-                        string line = text.Substring(i - lineLength, lineLength);
-                        lines.Add(line);
-                    }
-
-                    lineLength = 0;
-                }
-                else
-                {
-                    lineLength++;
-                }
-                previous = c;
-            }
-
-            // Save the last chars that is not followed by a lineending.
-            remainingText = text.Substring(text.Length - lineLength);
-
-            return lines.ToArray();
-        }
-    }
-}

Client/SSE/WatchDog.cs

@@ -1,38 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading;
-using System.Threading.Tasks;
-
-namespace Client.SSE
-{
-    public class Watchdog
-    {
-        private long _timeout;
-        private Timer _timer;
-        public event EventHandler TimerExpired;
-
-        public void Start()
-        {
-            _timer = new Timer(new TimerCallback(OnTimerExpired), null, 0, _timeout);
-        }
-
-        public void Reset()
-        {
-            _timer.Change(0, _timeout);
-        }
-
-        private void OnTimerExpired(object State)
-        {
-            _timer.Change(Timeout.Infinite, Timeout.Infinite);
-            if (TimerExpired != null)
-                TimerExpired(this, new EventArgs());
-        }
-
-        public Watchdog(long timeout)
-        {
-            if (timeout < 1) throw new ArgumentOutOfRangeException("timeout", "timeout muste be greater than zero.");
-        }
-    }
-}

Client/SSE/WebRequester.cs

@@ -1,30 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Net;
-using System.Threading.Tasks;
-
-namespace Client.SSE
-{
-    public class WebRequester : IWebRequester
-    {
-        public Task<IServerResponse> Get(Uri url, Dictionary<string, string> headers = null)
-        {
-            var wreq = (HttpWebRequest)WebRequest.Create(url);
-            wreq.Method = "GET";
-            wreq.Proxy = null;
-
-            if (headers != null)
-            {
-                foreach (var header in headers)
-                {
-                    wreq.Headers.Add(header.Key, header.Value);
-                }
-            }
-
-            var taskResp = Task.Factory.FromAsync<WebResponse>(wreq.BeginGetResponse,
-                wreq.EndGetResponse, null).ContinueWith<IServerResponse>(t => new ServerResponse(t.Result));
-            return taskResp;
-
-        }
-    }
-}

Client/SSE/WebRequesterFactory.cs

@@ -1,16 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-
-namespace Client.SSE
-{
-    public class WebRequesterFactory : IWebRequesterFactory
-    {
-        public IWebRequester Create()
-        {
-            return new WebRequester();
-        }
-    }
-}

TEAMModelOS.sln

@@ -13,10 +13,6 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "TEAMModelFunction", "TEAMMo
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "TEAMModelAPI", "TEAMModelAPI\TEAMModelAPI.csproj", "{2146FEEC-7178-4141-A8C7-CBEBAEE404A6}"
 EndProject
-Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Client", "Client\Client.csproj", "{E1A7F6EA-319E-4582-A800-A04DEB8284D9}"
-EndProject
-Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "BlobDownload", "BlobDownload\BlobDownload.csproj", "{4869FD86-3A59-49D4-B2C9-01D370F10F32}"
-EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "TEAMModeBI", "TEAMModeBI\TEAMModeBI.csproj", "{13572BD5-5F97-419A-A3A3-12E0358192E4}"
 EndProject
 Global
@@ -45,14 +41,6 @@ Global
 		{2146FEEC-7178-4141-A8C7-CBEBAEE404A6}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{2146FEEC-7178-4141-A8C7-CBEBAEE404A6}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{2146FEEC-7178-4141-A8C7-CBEBAEE404A6}.Release|Any CPU.Build.0 = Release|Any CPU
-		{E1A7F6EA-319E-4582-A800-A04DEB8284D9}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{E1A7F6EA-319E-4582-A800-A04DEB8284D9}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{E1A7F6EA-319E-4582-A800-A04DEB8284D9}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{E1A7F6EA-319E-4582-A800-A04DEB8284D9}.Release|Any CPU.Build.0 = Release|Any CPU
-		{4869FD86-3A59-49D4-B2C9-01D370F10F32}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{4869FD86-3A59-49D4-B2C9-01D370F10F32}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{4869FD86-3A59-49D4-B2C9-01D370F10F32}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{4869FD86-3A59-49D4-B2C9-01D370F10F32}.Release|Any CPU.Build.0 = Release|Any CPU
 		{13572BD5-5F97-419A-A3A3-12E0358192E4}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
 		{13572BD5-5F97-419A-A3A3-12E0358192E4}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{13572BD5-5F97-419A-A3A3-12E0358192E4}.Release|Any CPU.ActiveCfg = Release|Any CPU