83 references to MessageType
NuGet.Protocol (83)
Plugins\AutomaticProgressReporter.cs (1)
179MessageType.Progress,
Plugins\IMessageDispatcher.cs (2)
35Message CreateMessage(MessageType type, MessageMethod method); 45Message CreateMessage<TPayload>(MessageType type, MessageMethod method, TPayload payload)
Plugins\InboundRequestContext.cs (2)
120var response = MessageUtilities.Create(request.RequestId, MessageType.Cancel, request.Method); 187MessageType.Fault,
Plugins\Logging\CommunicationLogMessage.cs (2)
14private readonly MessageType _type; 16internal CommunicationLogMessage(DateTimeOffset now, string requestId, MessageMethod method, MessageType type, MessageState state)
Plugins\Logging\TaskLogMessage.cs (2)
16private readonly MessageType _type; 18internal TaskLogMessage(DateTimeOffset now, string requestId, MessageMethod method, MessageType type, TaskState state)
Plugins\MessageConverter.cs (38)
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), 125if (!Enum.TryParse<MessageType>(typeStr, out var messageType) || !Enum.IsDefined(typeof(MessageType), messageType)) 149if (messageType is MessageType.Fault) 153else if (messageType is MessageType.Progress)
Plugins\MessageDispatcher.cs (24)
142public Message CreateMessage(MessageType type, MessageMethod method) 158public Message CreateMessage<TPayload>(MessageType type, MessageMethod method, TPayload payload) 298MessageType.Request, 342return DispatchAsync(connection, MessageType.Response, request, responsePayload, cancellationToken); 379MessageType type, 409var message = MessageUtilities.Create(request.RequestId, MessageType.Cancel, request.Method); 426message = new Message(requestId, MessageType.Fault, MessageMethod.None, fault); 432message = new Message(request.RequestId, MessageType.Fault, request.Method, fault); 444var message = MessageUtilities.Create(request.RequestId, MessageType.Progress, request.Method, progress); 461MessageType type, 481case MessageType.Request: 482case MessageType.Response: 483case MessageType.Fault: 541case MessageType.Response: 545case MessageType.Progress: 549case MessageType.Fault: 553case MessageType.Cancel: 570case MessageType.Cancel: 574case MessageType.Request: 578case MessageType.Fault: 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)
29public MessageType Type { get; } 58/// is an undefined <see cref="MessageType" /> value.</exception> 62public Message(string requestId, MessageType type, MessageMethod method, JObject payload = null) 67internal Message(string requestId, MessageType type, MessageMethod method, object payload = null) 74if (!Enum.IsDefined(typeof(MessageType), type))
Plugins\MessageUtilities.cs (2)
27MessageType type, 52MessageType type,
Plugins\OutboundRequestContext`1.cs (4)
141MessageType.Cancel)); 259_logger.Write(new TaskLogMessage(_logger.Now, _request.RequestId, _request.Method, MessageType.Cancel, TaskState.Queued)); 269_logger.Write(new TaskLogMessage(_logger.Now, _request.RequestId, _request.Method, MessageType.Cancel, TaskState.Executing)); 281_logger.Write(new TaskLogMessage(_logger.Now, _request.RequestId, _request.Method, MessageType.Cancel, TaskState.Completed));
Plugins\PluginFactory.cs (1)
446MessageType.Request,