121 references to MessageMethod
NuGet.Credentials (6)
SecurePluginCredentialProvider.cs (6)
130MessageMethod.GetAuthenticationCredentials, 157MessageMethod.SetLogLevel.ToString(), 159MessageMethod.SetLogLevel, 168MessageMethod.Log, 182var key = $"{MessageMethod.SetCredentials}.{Id}"; 195MessageMethod.SetCredentials,
NuGet.Protocol (115)
Plugins\Connection.cs (1)
273MessageMethod method,
Plugins\IConnection.cs (1)
74MessageMethod method,
Plugins\IMessageDispatcher.cs (3)
33Message CreateMessage(MessageType type, MessageMethod method); 43Message CreateMessage<TPayload>(MessageType type, MessageMethod method, TPayload payload) 84MessageMethod method,
Plugins\InboundRequestProcessingHandler.cs (5)
14private readonly ISet<MessageMethod> _fastProccessingMethods; 19: this(Enumerable.Empty<MessageMethod>()) 27public InboundRequestProcessingHandler(IEnumerable<MessageMethod> fastProcessingMethods) 33_fastProccessingMethods = new HashSet<MessageMethod>(fastProcessingMethods); 50internal void Handle(MessageMethod messageMethod, Func<Task> task, CancellationToken cancellationToken)
Plugins\IRequestHandlers.cs (4)
25MessageMethod method, 36bool TryAdd(MessageMethod method, IRequestHandler handler); 44bool TryGet(MessageMethod method, [NotNullWhen(true)] out IRequestHandler? handler); 51bool TryRemove(MessageMethod method);
Plugins\Logging\CommunicationLogMessage.cs (2)
11private readonly MessageMethod _method; 16internal CommunicationLogMessage(DateTimeOffset now, string requestId, MessageMethod method, MessageType type, MessageState state)
Plugins\Logging\TaskLogMessage.cs (2)
13private readonly MessageMethod _method; 18internal TaskLogMessage(DateTimeOffset now, string requestId, MessageMethod method, MessageType type, TaskState state)
Plugins\MessageConverter.cs (36)
14private static readonly Dictionary<(MessageMethod, MessageType), Func<JsonElement, object?>> _read = new() 16[(MessageMethod.Handshake, MessageType.Request)] = e => e.Deserialize(PluginJsonContext.Default.HandshakeRequest), 17[(MessageMethod.Handshake, MessageType.Response)] = e => e.Deserialize(PluginJsonContext.Default.HandshakeResponse), 19[(MessageMethod.Initialize, MessageType.Request)] = e => e.Deserialize(PluginJsonContext.Default.InitializeRequest), 20[(MessageMethod.Initialize, MessageType.Response)] = e => e.Deserialize(PluginJsonContext.Default.InitializeResponse), 22[(MessageMethod.GetOperationClaims, MessageType.Request)] = e => e.Deserialize(PluginJsonContext.Default.GetOperationClaimsRequest), 23[(MessageMethod.GetOperationClaims, MessageType.Response)] = e => e.Deserialize(PluginJsonContext.Default.GetOperationClaimsResponse), 25[(MessageMethod.GetServiceIndex, MessageType.Request)] = e => e.Deserialize(PluginJsonContext.Default.GetServiceIndexRequest), 26[(MessageMethod.GetServiceIndex, MessageType.Response)] = e => e.Deserialize(PluginJsonContext.Default.GetServiceIndexResponse), 28[(MessageMethod.GetAuthenticationCredentials, MessageType.Request)] = e => e.Deserialize(PluginJsonContext.Default.GetAuthenticationCredentialsRequest), 29[(MessageMethod.GetAuthenticationCredentials, MessageType.Response)] = e => e.Deserialize(PluginJsonContext.Default.GetAuthenticationCredentialsResponse), 31[(MessageMethod.GetCredentials, MessageType.Request)] = e => e.Deserialize(PluginJsonContext.Default.GetCredentialsRequest), 32[(MessageMethod.GetCredentials, MessageType.Response)] = e => e.Deserialize(PluginJsonContext.Default.GetCredentialsResponse), 34[(MessageMethod.Log, MessageType.Request)] = e => e.Deserialize(PluginJsonContext.Default.LogRequest), 35[(MessageMethod.Log, MessageType.Response)] = e => e.Deserialize(PluginJsonContext.Default.LogResponse), 37[(MessageMethod.SetLogLevel, MessageType.Request)] = e => e.Deserialize(PluginJsonContext.Default.SetLogLevelRequest), 38[(MessageMethod.SetLogLevel, MessageType.Response)] = e => e.Deserialize(PluginJsonContext.Default.SetLogLevelResponse), 40[(MessageMethod.SetCredentials, MessageType.Request)] = e => e.Deserialize(PluginJsonContext.Default.SetCredentialsRequest), 41[(MessageMethod.SetCredentials, MessageType.Response)] = e => e.Deserialize(PluginJsonContext.Default.SetCredentialsResponse), 43[(MessageMethod.MonitorNuGetProcessExit, MessageType.Request)] = e => e.Deserialize(PluginJsonContext.Default.MonitorNuGetProcessExitRequest), 44[(MessageMethod.MonitorNuGetProcessExit, MessageType.Response)] = e => e.Deserialize(PluginJsonContext.Default.MonitorNuGetProcessExitResponse), 46[(MessageMethod.CopyFilesInPackage, MessageType.Request)] = e => e.Deserialize(PluginJsonContext.Default.CopyFilesInPackageRequest), 47[(MessageMethod.CopyFilesInPackage, MessageType.Response)] = e => e.Deserialize(PluginJsonContext.Default.CopyFilesInPackageResponse), 49[(MessageMethod.CopyNupkgFile, MessageType.Request)] = e => e.Deserialize(PluginJsonContext.Default.CopyNupkgFileRequest), 50[(MessageMethod.CopyNupkgFile, MessageType.Response)] = e => e.Deserialize(PluginJsonContext.Default.CopyNupkgFileResponse), 52[(MessageMethod.GetFilesInPackage, MessageType.Request)] = e => e.Deserialize(PluginJsonContext.Default.GetFilesInPackageRequest), 53[(MessageMethod.GetFilesInPackage, MessageType.Response)] = e => e.Deserialize(PluginJsonContext.Default.GetFilesInPackageResponse), 55[(MessageMethod.GetPackageHash, MessageType.Request)] = e => e.Deserialize(PluginJsonContext.Default.GetPackageHashRequest), 56[(MessageMethod.GetPackageHash, MessageType.Response)] = e => e.Deserialize(PluginJsonContext.Default.GetPackageHashResponse), 58[(MessageMethod.GetPackageVersions, MessageType.Request)] = e => e.Deserialize(PluginJsonContext.Default.GetPackageVersionsRequest), 59[(MessageMethod.GetPackageVersions, MessageType.Response)] = e => e.Deserialize(PluginJsonContext.Default.GetPackageVersionsResponse), 61[(MessageMethod.PrefetchPackage, MessageType.Request)] = e => e.Deserialize(PluginJsonContext.Default.PrefetchPackageRequest), 62[(MessageMethod.PrefetchPackage, MessageType.Response)] = e => e.Deserialize(PluginJsonContext.Default.PrefetchPackageResponse), 136if (!Enum.TryParse<MessageMethod>(methodStr, out var messageMethod) || !Enum.IsDefined(typeof(MessageMethod), messageMethod))
Plugins\MessageDispatcher.cs (10)
143public Message CreateMessage(MessageType type, MessageMethod method) 159public Message CreateMessage<TPayload>(MessageType type, MessageMethod method, TPayload payload) 281MessageMethod method, 425message = new Message(requestId, MessageType.Fault, MessageMethod.None, fault); 461MessageMethod method, 642private IRequestHandler GetInboundRequestHandler(MessageMethod method) 708private static bool GetIsKeepAlive(MessageType type, MessageMethod method) 710if (type == MessageType.Request && method == MessageMethod.Handshake) 718private static TimeSpan GetRequestTimeout(IConnection connection, MessageType type, MessageMethod method) 720if (type == MessageType.Request && method == MessageMethod.Handshake)
Plugins\Messages\Message.cs (5)
33public MessageMethod Method { get; } 58/// is an undefined <see cref="MessageMethod" /> value.</exception> 60public Message(string requestId, MessageType type, MessageMethod method, JObject? payload = null) 66internal Message(string requestId, MessageType type, MessageMethod method, object? payload = null) 83if (!Enum.IsDefined(typeof(MessageMethod), method))
Plugins\MessageUtilities.cs (2)
30MessageMethod method) 55MessageMethod method,
Plugins\PluginFactory.cs (6)
243var processingHandler = new InboundRequestProcessingHandler(new HashSet<MessageMethod> { MessageMethod.Handshake, MessageMethod.Log }); 363requestHandlers.TryAdd(MessageMethod.Close, new CloseRequestHandler(plugin)); 364requestHandlers.TryAdd(MessageMethod.MonitorNuGetProcessExit, new MonitorNuGetProcessExitRequestHandler(plugin)); 450MessageMethod.Close);
Plugins\PluginManager.cs (5)
284MessageMethod.MonitorNuGetProcessExit.ToString(), 286MessageMethod.MonitorNuGetProcessExit, 292MessageMethod.Initialize.ToString(), 345MessageMethod.GetOperationClaims, 423MessageMethod.Initialize,
Plugins\PluginPackageDownloader.cs (1)
201MessageMethod.GetPackageHash,
Plugins\PluginPackageReader.cs (7)
285MessageMethod.CopyFilesInPackage, 301MessageMethod.CopyFilesInPackage, 933MessageMethod.CopyNupkgFile, 1032MessageMethod.CopyFilesInPackage, 1048MessageMethod.CopyFilesInPackage, 1071MessageMethod.GetFilesInPackage, 1087MessageMethod.GetFilesInPackage,
Plugins\RequestHandlers.cs (6)
15private readonly ConcurrentDictionary<MessageMethod, IRequestHandler> _handlers; 22_handlers = new ConcurrentDictionary<MessageMethod, IRequestHandler>(); 36MessageMethod method, 60public bool TryAdd(MessageMethod method, IRequestHandler handler) 76public bool TryGet(MessageMethod method, [NotNullWhen(true)] out IRequestHandler? handler) 86public bool TryRemove(MessageMethod method)
Plugins\RequestHandlers\SymmetricHandshake.cs (3)
85if (!_connection.MessageDispatcher.RequestHandlers.TryAdd(MessageMethod.Handshake, this)) 101_connection.MessageDispatcher.RequestHandlers.TryRemove(MessageMethod.Handshake); 124MessageMethod.Handshake,
Providers\DownloadResourcePluginProvider.cs (2)
85MessageMethod.GetCredentials, 103MessageMethod.GetServiceIndex,
RemoteRepositories\PluginFindPackageByIdResource.cs (6)
201MessageMethod.SetLogLevel.ToString(), 279MessageMethod.SetLogLevel.ToString(), 284MessageMethod.PrefetchPackage, 417MessageMethod.GetPackageVersions, 491MessageMethod.Log, 506MessageMethod.SetLogLevel,
RemoteRepositories\PluginFindPackageByIdResourceProvider.cs (2)
85MessageMethod.GetCredentials, 103MessageMethod.GetServiceIndex,
Resources\DownloadResourcePlugin.cs (4)
113MessageMethod.SetLogLevel.ToString(), 118MessageMethod.PrefetchPackage, 157MessageMethod.Log, 172MessageMethod.SetLogLevel,
Resources\PluginResource.cs (2)
80var key = $"{MessageMethod.SetCredentials}.{_packageSource.SourceUri}"; 99MessageMethod.SetCredentials,