Initial commit. Work to do: Identify and update protocols for handling repsonses. Add interface to send notifications / request. Implement mapping between lsp protocols and such

Author: david-driscoll

.editorconfig

@@ -0,0 +1,55 @@
+[*]
+end_of_line = crlf
+charset = utf-8
+indent_style = space
+indent_size = 4
+trim_trailing_whitespace = true
+insert_final_newline = true
+
+[*.xml]
+indent_style = space
+
+[*.{cs,vb}]
+# Sort using and Import directives with System.* appearing first
+dotnet_sort_system_directives_first = true
+# Avoid "this." and "Me." if not necessary
+dotnet_style_qualification_for_event = false:warning
+dotnet_style_qualification_for_field = false:warning
+dotnet_style_qualification_for_method = false:warning
+dotnet_style_qualification_for_property = false:warning
+# Use language keywords instead of framework type names for type references
+dotnet_style_predefined_type_for_locals_parameters_members = true:error
+dotnet_style_predefined_type_for_member_access = true:error
+# Suggest more modern language features when available
+dotnet_style_coalesce_expression = true:error
+dotnet_style_collection_initializer = true:suggestion
+dotnet_style_explicit_tuple_names = true:error
+dotnet_style_null_propagation = true:warning
+dotnet_style_object_initializer = true:warning
+
+# Naming Conventions:
+# Pascal Casing
+#dotnet_naming_symbols.method_and_property_symbols.applicable_kinds= method,property,enum
+#dotnet_naming_symbols.method_and_property_symbols.applicable_accessibilities = *
+#dotnet_naming_style.pascal_case_style.capitalization = pascal_case
+
+[*.cs]
+csharp_style_conditional_delegate_call = true:suggestion
+csharp_style_expression_bodied_accessors = true:suggestion
+csharp_style_expression_bodied_constructors = true:none
+csharp_style_expression_bodied_indexers = true:none
+csharp_style_expression_bodied_methods = true:none
+csharp_style_expression_bodied_operators = true:none
+csharp_style_expression_bodied_properties = true:suggestion
+csharp_style_inlined_variable_declaration = true:error
+csharp_style_pattern_matching_over_as_with_null_check = true:error
+csharp_style_pattern_matching_over_is_with_cast_check = true:error
+csharp_style_throw_expression = true:suggestion
+csharp_style_var_elsewhere = true:warning
+csharp_style_var_for_built_in_types = true:warning
+csharp_style_var_when_type_is_apparent = true:error
+csharp_new_line_before_catch = true
+csharp_new_line_before_else = true
+csharp_new_line_before_finally = true
+csharp_new_line_before_members_in_anonymous_types = true
+csharp_new_line_before_open_brace = types,methods,properties,indexers,events,event_accessors,control_blocks,anonymous_types,object_collections,array_initializers,local_functions

.gitattributes

@@ -0,0 +1,51 @@
+*.doc  diff=astextplain
+*.DOC	diff=astextplain
+*.docx	diff=astextplain
+*.DOCX	diff=astextplain
+*.dot	diff=astextplain
+*.DOT	diff=astextplain
+*.pdf	diff=astextplain
+*.PDF	diff=astextplain
+*.rtf	diff=astextplain
+*.RTF	diff=astextplain
+
+*.jpg  	binary
+*.png 	binary
+*.gif 	binary
+
+*.cs text=auto diff=csharp 
+*.vb text=auto
+*.resx text=auto
+*.c text=auto
+*.cpp text=auto
+*.cxx text=auto
+*.h text=auto
+*.hxx text=auto
+*.py text=auto
+*.rb text=auto
+*.java text=auto
+*.html text=auto
+*.htm text=auto
+*.css text=auto
+*.scss text=auto
+*.sass text=auto
+*.less text=auto
+*.js text=auto
+*.lisp text=auto
+*.clj text=auto
+*.sql text=auto
+*.php text=auto
+*.lua text=auto
+*.m text=auto
+*.asm text=auto
+*.erl text=auto
+*.fs text=auto
+*.fsx text=auto
+*.hs text=auto
+
+*.csproj text=auto
+*.vbproj text=auto
+*.fsproj text=auto
+*.dbproj text=auto
+*.xproj text=auto
+*.sln text=auto eol=crlf

.gitignore

@@ -0,0 +1,45 @@
+[Oo]bj/
+[Bb]in/
+TestResults/
+.nuget/
+*.sln.ide/
+_ReSharper.*/
+packages/**/
+artifacts/
+PublishProfiles/
+*.user
+*.suo
+*.cache
+*.docstates
+_ReSharper.*
+nuget.exe
+*net45.csproj
+*net451.csproj
+*k10.csproj
+*.psess
+*.vsp
+*.pidb
+*.userprefs
+*DS_Store
+*.ncrunchsolution
+*.*sdf
+*.ipch
+*.sln.ide
+debugSettings.json
+buildlog
+/.vs
+*.lock.json
+/omnisharp*.tar.gz
+scripts/Omnisharp*
+.msbuild-*/
+
+# NuGet
+*.nuget.targets
+
+# Build folder
+.tools/
+.dotnet/
+
+# VS Code
+/.vscode/settings.json
+/.vscode/launch.json

LSP.sln

@@ -0,0 +1,55 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio 15
+VisualStudioVersion = 15.0.26228.4
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "src", "src", "{D764E024-3D3F-4112-B932-2DB722A1BACC}"
+EndProject
+Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "test", "test", "{2F323ED5-EBF8-45E1-B9D3-C014561B3DDA}"
+EndProject
+Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = ".config", ".config", "{AE4D7807-6F78-428C-A0D9-914BA583A104}"
+	ProjectSection(SolutionItems) = preProject
+		.editorconfig = .editorconfig
+	EndProjectSection
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "JsonRpc", "src\JsonRpc\JsonRpc.csproj", "{EE777A17-24B6-499B-8E80-4F6D2750B4E4}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Lsp", "src\Lsp\Lsp.csproj", "{FDCFF5B0-D3BF-4E3C-B146-98CEE61DF55D}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "JsonRpc.Tests", "test\JsonRpc.Tests\JsonRpc.Tests.csproj", "{2E3DF5C2-8A38-4A03-86D7-8D463C917E47}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Lsp.Tests", "test\Lsp.Tests\Lsp.Tests.csproj", "{54CDF265-B534-4493-BA8B-38AA8374A579}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{EE777A17-24B6-499B-8E80-4F6D2750B4E4}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{EE777A17-24B6-499B-8E80-4F6D2750B4E4}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{EE777A17-24B6-499B-8E80-4F6D2750B4E4}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{EE777A17-24B6-499B-8E80-4F6D2750B4E4}.Release|Any CPU.Build.0 = Release|Any CPU
+		{FDCFF5B0-D3BF-4E3C-B146-98CEE61DF55D}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{FDCFF5B0-D3BF-4E3C-B146-98CEE61DF55D}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{FDCFF5B0-D3BF-4E3C-B146-98CEE61DF55D}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{FDCFF5B0-D3BF-4E3C-B146-98CEE61DF55D}.Release|Any CPU.Build.0 = Release|Any CPU
+		{2E3DF5C2-8A38-4A03-86D7-8D463C917E47}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{2E3DF5C2-8A38-4A03-86D7-8D463C917E47}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{2E3DF5C2-8A38-4A03-86D7-8D463C917E47}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{2E3DF5C2-8A38-4A03-86D7-8D463C917E47}.Release|Any CPU.Build.0 = Release|Any CPU
+		{54CDF265-B534-4493-BA8B-38AA8374A579}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{54CDF265-B534-4493-BA8B-38AA8374A579}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{54CDF265-B534-4493-BA8B-38AA8374A579}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{54CDF265-B534-4493-BA8B-38AA8374A579}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(NestedProjects) = preSolution
+		{EE777A17-24B6-499B-8E80-4F6D2750B4E4} = {D764E024-3D3F-4112-B932-2DB722A1BACC}
+		{FDCFF5B0-D3BF-4E3C-B146-98CEE61DF55D} = {D764E024-3D3F-4112-B932-2DB722A1BACC}
+		{2E3DF5C2-8A38-4A03-86D7-8D463C917E47} = {2F323ED5-EBF8-45E1-B9D3-C014561B3DDA}
+		{54CDF265-B534-4493-BA8B-38AA8374A579} = {2F323ED5-EBF8-45E1-B9D3-C014561B3DDA}
+	EndGlobalSection
+EndGlobal

src/JsonRpc/Client/Request.cs

@@ -0,0 +1,18 @@
+using Newtonsoft.Json;
+using Newtonsoft.Json.Linq;
+using Newtonsoft.Json.Serialization;
+
+namespace JsonRPC.Client
+{
+    [JsonObject(NamingStrategyType = typeof(CamelCaseNamingStrategy))]
+    public class Request
+    {
+        public object Id { get; set; }
+
+        public string ProtocolVersion { get; set; } = "2.0";
+
+        public string Method { get; set; }
+
+        public object Params { get; set; }
+    }
+}

src/JsonRpc/Connection.cs

@@ -0,0 +1,53 @@
+using System;
+using System.IO;
+using System.Linq;
+using System.Threading.Tasks;
+using JsonRPC.Server;
+using Newtonsoft.Json;
+using Newtonsoft.Json.Linq;
+
+namespace JsonRPC
+{
+    public class Connection : IDisposable
+    {
+        private readonly TextReader _input;
+
+        private readonly TextWriter _output;
+
+        private readonly Reciever _reciever;
+        private readonly Responder _responder;
+        private InputHandler _inputHandler;
+        private Mediater _mediater;
+
+        public Connection(TextReader input, TextWriter output)
+        {
+            _input = input;
+            _output = output;
+            _reciever = new Reciever();
+            _responder = new Responder();
+            _mediater = new Mediater();
+        }
+
+        private async Task HandleRequest(JToken payload)
+        {
+            if (!_reciever.IsValid(payload))
+            {
+                _responder.Respond(new InvalidRequest());
+                return;
+            }
+
+            var requests = _reciever.GetRequests(payload);
+            await _mediater.RespondTo(requests);
+        }
+
+        public void Open()
+        {
+            _inputHandler = new InputHandler(_input, async (payload) => await HandleRequest(payload));
+        }
+
+        public void Dispose()
+        {
+            _inputHandler?.Dispose();
+        }
+    }
+}

src/JsonRpc/INotificationHandler.cs

@@ -0,0 +1,9 @@
+using System.Threading.Tasks;
+
+namespace JsonRPC
+{
+    public interface INotificationHandler<TNotification>
+    {
+        Task Handle(TNotification notification);
+    }
+}

src/JsonRpc/IRequestHandler.cs

@@ -0,0 +1,9 @@
+using System.Threading.Tasks;
+
+namespace JsonRPC
+{
+    public interface IRequestHandler<TRequest, TResponse>
+    {
+        Task<TResponse> Handle(TRequest request);
+    }
+}

src/JsonRpc/InputHandler.cs

@@ -0,0 +1,74 @@
+using System;
+using System.IO;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+using Newtonsoft.Json.Linq;
+
+namespace JsonRPC
+{
+    public class InputHandler : IDisposable
+    {
+        public const char CR = '\r';
+        public const char LF = '\n';
+        public static char[] CRLF = { CR, LF };
+        public static char[] HeaderKeys = { CR, LF, ':' };
+        public const short MinBuffer = 21; // Minimum size of the buffer "Content-Length: X\r\n\r\n"
+
+        private readonly TextReader _input;
+        private readonly Action<JToken> _inputHandler;
+        private readonly Thread _thread;
+
+        public InputHandler(TextReader input, Action<JToken> inputHandler)
+        {
+            _input = input;
+            _inputHandler = inputHandler;
+
+            _thread = new Thread(async () => await Loop()) {
+                IsBackground = true,
+                Priority = ThreadPriority.AboveNormal
+            };
+            _thread.Start();
+        }
+
+        private async Task Loop()
+        {
+            while (true)
+            {
+                var buffer = new char[200];
+                var current = await _input.ReadBlockAsync(buffer, 0, MinBuffer);
+                while (current < MinBuffer || buffer[current - 4] != CR || buffer[current - 3] != LF ||
+                       buffer[current - 2] != CR || buffer[current - 1] != LF)
+                {
+                    current += await _input.ReadBlockAsync(buffer, 0, 1);
+                }
+
+                var headersContent = Encoding.ASCII.GetString(Encoding.ASCII.GetBytes(buffer, 0, current));
+                var headers = headersContent.Split(HeaderKeys, StringSplitOptions.RemoveEmptyEntries);
+                long length = 0;
+                for (var i = 0; i < headers.Length; i += 2)
+                {
+                    var header = headers[0];
+                    var value = headers[i + 1].Trim();
+                    if (header.Equals("Content-Length", StringComparison.OrdinalIgnoreCase))
+                    {
+                        length = long.Parse(value);
+                    }
+                }
+
+                var requestBuffer = new char[length];
+
+                await _input.ReadBlockAsync(requestBuffer, 0, requestBuffer.Length);
+
+                var request = Encoding.ASCII.GetString(Encoding.ASCII.GetBytes(requestBuffer));
+                var payload = JToken.Parse(request);
+                _inputHandler(payload);
+            }
+        }
+
+        public void Dispose()
+        {
+            _thread.Abort();
+        }
+    }
+}