-
Notifications
You must be signed in to change notification settings - Fork 105
/
Copy pathICompletionHandler.cs
77 lines (66 loc) · 4 KB
/
ICompletionHandler.cs
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
using System;
using System.Threading;
using System.Threading.Tasks;
using OmniSharp.Extensions.JsonRpc;
using OmniSharp.Extensions.LanguageServer.Protocol.Client.Capabilities;
using OmniSharp.Extensions.LanguageServer.Protocol.Models;
// ReSharper disable CheckNamespace
namespace OmniSharp.Extensions.LanguageServer.Protocol.Server
{
[Parallel, Method(DocumentNames.Completion)]
public interface ICompletionHandler : IJsonRpcRequestHandler<CompletionParams, CompletionList>, IRegistration<CompletionRegistrationOptions>, ICapability<CompletionCapability> { }
[Serial, Method(DocumentNames.CompletionResolve)]
public interface ICompletionResolveHandler : ICanBeResolvedHandler<CompletionItem> { }
public abstract class CompletionHandler : ICompletionHandler, ICompletionResolveHandler
{
protected readonly CompletionRegistrationOptions _options;
public CompletionHandler(CompletionRegistrationOptions registrationOptions)
{
_options = registrationOptions;
}
public CompletionRegistrationOptions GetRegistrationOptions() => _options;
public abstract Task<CompletionList> Handle(CompletionParams request, CancellationToken cancellationToken);
public abstract Task<CompletionItem> Handle(CompletionItem request, CancellationToken cancellationToken);
public abstract bool CanResolve(CompletionItem value);
public virtual void SetCapability(CompletionCapability capability) => Capability = capability;
protected CompletionCapability Capability { get; private set; }
}
public static class CompletionHandlerExtensions
{
public static IDisposable OnCompletion(
this ILanguageServerRegistry registry,
Func<CompletionParams, CancellationToken, Task<CompletionList>> handler,
Func<CompletionItem, CancellationToken, Task<CompletionItem>> resolveHandler = null,
Func<CompletionItem, bool> canResolve = null,
CompletionRegistrationOptions registrationOptions = null,
Action<CompletionCapability> setCapability = null)
{
registrationOptions = registrationOptions ?? new CompletionRegistrationOptions();
registrationOptions.ResolveProvider = canResolve != null && resolveHandler != null;
return registry.AddHandlers(new DelegatingHandler(handler, resolveHandler, canResolve, setCapability, registrationOptions));
}
class DelegatingHandler : CompletionHandler
{
private readonly Func<CompletionParams, CancellationToken, Task<CompletionList>> _handler;
private readonly Func<CompletionItem, CancellationToken, Task<CompletionItem>> _resolveHandler;
private readonly Func<CompletionItem, bool> _canResolve;
private readonly Action<CompletionCapability> _setCapability;
public DelegatingHandler(
Func<CompletionParams, CancellationToken, Task<CompletionList>> handler,
Func<CompletionItem, CancellationToken, Task<CompletionItem>> resolveHandler,
Func<CompletionItem, bool> canResolve,
Action<CompletionCapability> setCapability,
CompletionRegistrationOptions registrationOptions) : base(registrationOptions)
{
_handler = handler;
_resolveHandler = resolveHandler;
_canResolve = canResolve;
_setCapability = setCapability;
}
public override Task<CompletionList> Handle(CompletionParams request, CancellationToken cancellationToken) => _handler.Invoke(request, cancellationToken);
public override Task<CompletionItem> Handle(CompletionItem request, CancellationToken cancellationToken) => _resolveHandler.Invoke(request, cancellationToken);
public override bool CanResolve(CompletionItem value) => _canResolve.Invoke(value);
public override void SetCapability(CompletionCapability capability) => _setCapability?.Invoke(capability);
}
}
}