83 references to MessageType
NuGet.Protocol (83)
Plugins\AutomaticProgressReporter.cs (1)
177MessageType.Progress,
Plugins\IMessageDispatcher.cs (2)
33Message CreateMessage(MessageType type, MessageMethod method); 43Message CreateMessage<TPayload>(MessageType type, MessageMethod method, TPayload payload)
Plugins\InboundRequestContext.cs (2)
118var response = MessageUtilities.Create(request.RequestId, MessageType.Cancel, request.Method); 185MessageType.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)
143public Message CreateMessage(MessageType type, MessageMethod method) 159public Message CreateMessage<TPayload>(MessageType type, MessageMethod method, TPayload payload) 299MessageType.Request, 343return DispatchAsync(connection, MessageType.Response, request, responsePayload, cancellationToken); 380MessageType type, 408var message = MessageUtilities.Create(request.RequestId, MessageType.Cancel, request.Method); 425message = new Message(requestId, MessageType.Fault, MessageMethod.None, fault); 431message = new Message(request.RequestId, MessageType.Fault, request.Method, fault); 443var message = MessageUtilities.Create(request.RequestId, MessageType.Progress, request.Method, progress); 460MessageType type, 480case MessageType.Request: 481case MessageType.Response: 482case MessageType.Fault: 538case MessageType.Response: 542case MessageType.Progress: 546case MessageType.Fault: 550case MessageType.Cancel: 567case MessageType.Cancel: 571case MessageType.Request: 575case MessageType.Fault: 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)
27public MessageType Type { get; } 56/// is an undefined <see cref="MessageType" /> value.</exception> 60public Message(string requestId, MessageType type, MessageMethod method, JObject? payload = null) 66internal Message(string requestId, MessageType type, MessageMethod method, object? payload = null) 73if (!Enum.IsDefined(typeof(MessageType), type))
Plugins\MessageUtilities.cs (2)
29MessageType type, 54MessageType type,
Plugins\OutboundRequestContext`1.cs (4)
142MessageType.Cancel)); 273_logger.Write(new TaskLogMessage(_logger.Now, _request.RequestId, _request.Method, MessageType.Cancel, TaskState.Queued)); 283_logger.Write(new TaskLogMessage(_logger.Now, _request.RequestId, _request.Method, MessageType.Cancel, TaskState.Executing)); 295_logger.Write(new TaskLogMessage(_logger.Now, _request.RequestId, _request.Method, MessageType.Cancel, TaskState.Completed));
Plugins\PluginFactory.cs (1)
449MessageType.Request,