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)
275MessageMethod method,
Plugins\IConnection.cs (1)
76MessageMethod method,
Plugins\IMessageDispatcher.cs (3)
35Message CreateMessage(MessageType type, MessageMethod method); 45Message CreateMessage<TPayload>(MessageType type, MessageMethod method, TPayload payload) 86MessageMethod 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)
26MessageMethod method, 37bool TryAdd(MessageMethod method, IRequestHandler handler); 45bool TryGet(MessageMethod method, out IRequestHandler handler); 52bool 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)
142public Message CreateMessage(MessageType type, MessageMethod method) 158public Message CreateMessage<TPayload>(MessageType type, MessageMethod method, TPayload payload) 280MessageMethod method, 426message = new Message(requestId, MessageType.Fault, MessageMethod.None, fault); 462MessageMethod method, 643private IRequestHandler GetInboundRequestHandler(MessageMethod method) 717private static bool GetIsKeepAlive(MessageType type, MessageMethod method) 719if (type == MessageType.Request && method == MessageMethod.Handshake) 727private static TimeSpan GetRequestTimeout(IConnection connection, MessageType type, MessageMethod method) 729if (type == MessageType.Request && method == MessageMethod.Handshake)
Plugins\Messages\Message.cs (5)
35public MessageMethod Method { get; } 60/// is an undefined <see cref="MessageMethod" /> value.</exception> 62public Message(string requestId, MessageType type, MessageMethod method, JObject payload = null) 67internal Message(string requestId, MessageType type, MessageMethod method, object payload = null) 84if (!Enum.IsDefined(typeof(MessageMethod), method))
Plugins\MessageUtilities.cs (2)
28MessageMethod method) 53MessageMethod method,
Plugins\PluginFactory.cs (6)
238var processingHandler = new InboundRequestProcessingHandler(new HashSet<MessageMethod> { MessageMethod.Handshake, MessageMethod.Log }); 358requestHandlers.TryAdd(MessageMethod.Close, new CloseRequestHandler(plugin)); 359requestHandlers.TryAdd(MessageMethod.MonitorNuGetProcessExit, new MonitorNuGetProcessExitRequestHandler(plugin)); 447MessageMethod.Close);
Plugins\PluginManager.cs (5)
285MessageMethod.MonitorNuGetProcessExit.ToString(), 287MessageMethod.MonitorNuGetProcessExit, 293MessageMethod.Initialize.ToString(), 339MessageMethod.GetOperationClaims, 417MessageMethod.Initialize,
Plugins\PluginPackageDownloader.cs (1)
203MessageMethod.GetPackageHash,
Plugins\PluginPackageReader.cs (7)
287MessageMethod.CopyFilesInPackage, 303MessageMethod.CopyFilesInPackage, 935MessageMethod.CopyNupkgFile, 1034MessageMethod.CopyFilesInPackage, 1050MessageMethod.CopyFilesInPackage, 1073MessageMethod.GetFilesInPackage, 1089MessageMethod.GetFilesInPackage,
Plugins\RequestHandlers.cs (6)
16private readonly ConcurrentDictionary<MessageMethod, IRequestHandler> _handlers; 23_handlers = new ConcurrentDictionary<MessageMethod, IRequestHandler>(); 37MessageMethod method, 61public bool TryAdd(MessageMethod method, IRequestHandler handler) 77public bool TryGet(MessageMethod method, out IRequestHandler handler) 87public bool TryRemove(MessageMethod method)
Plugins\RequestHandlers\SymmetricHandshake.cs (3)
84if (!_connection.MessageDispatcher.RequestHandlers.TryAdd(MessageMethod.Handshake, this)) 100_connection.MessageDispatcher.RequestHandlers.TryRemove(MessageMethod.Handshake); 123MessageMethod.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,