src/MassTransit.Abstractions/Clients/ResponseExtensions.cs - develop - vshmidt/masstransit

src/MassTransit.Abstractions/Clients/ResponseExtensions.cs

45 строк2 KB

Chris Patterson

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

22 янв 2022, 18:24

22 янв 2022, 18:24b5b4f50

namespace MassTransit
{
    using System;
    using System.Collections.Generic;
    using System.Linq;


    public static class ResponseExtensions
    {
        /// <summary>
        /// Used for pattern matching via (response,message)
        /// </summary>
        /// <param name="response"></param>
        /// <param name="context"></param>
        /// <param name="message"></param>
        public static void Deconstruct(this Response response, out Response context, out object message)
        {
            context = response;
            message = response.Message;
        }

        /// <summary>
        /// Returns true if the response type is explicitly accepted, or if the accept response header is
        /// not present (downlevel client).
        /// </summary>
        /// <param name="context">The consumed message context</param>
        /// <param name="defaultIfHeaderNotFound">Value to return if header was not present</param>
        /// <typeparam name="T">The response type</typeparam>
        /// <returns>True if explicitly support or header is missing, otherwise false</returns>
        public static bool IsResponseAccepted<T>(this ConsumeContext context, bool defaultIfHeaderNotFound = true)
            where T : class
        {
            if (context.ResponseAddress == null)
                return false;

            var acceptTypes = context.GetHeader<IList<string>>(MessageHeaders.Request.Accept);
            if (acceptTypes == null || acceptTypes.Count <= 0)
                return defaultIfHeaderNotFound;

            var matchingTypeNames = MessageTypeCache<T>.MessageTypeNames;

            return acceptTypes.Any(accept => matchingTypeNames.Any(x => x.Equals(accept, StringComparison.OrdinalIgnoreCase)));
        }
    }
}