messengerapi.Client/code/MessengerApi.Client/Client.cs

using MessengerApi.Model;
using MessengerApi.Model.Messages;
using portaloggy;
using System.Text;
using System.Text.Json;
using System.Text.Json.Nodes;

namespace MessengerApi
{
    /// <summary>
    /// Exists for mocking reason. This is implemented by <see cref="Client"/>.
    /// </summary>
    public interface IClient
    {
        /// <summary>
        /// Receives pending messages from the messenger API.
        /// </summary>
        /// <param name="credentials">Credentials to the API.</param>
        IEnumerable<InboxMessage> GetMessages();

        /// <summary>
        /// Acknowledges message reception to the server.
        /// </summary>
        void AckMessage(InboxMessage message);

        /// <summary>
        /// Acknowledges message reception to the server.
        /// </summary>
        /// <param name="messageId"></param>
        void AckMessage(Guid messageId);

        /// <summary>
        /// Sends a message.
        /// </summary>
        /// <param name="credentials">Credentials to the API.</param>
        Guid SendMessage(OutboxMessage outboxMessage);

        /// <summary>
        /// Returns user ids for allowed message recipients.
        /// </summary>
        Contact[] GetYellowPages();

        /// <summary>
        /// Returns number of pending messages, waiting for delivery.
        /// </summary>
        int Peek();

        /// <summary>
        /// Gets delivery state of a message.
        /// </summary>
        State Verify(Guid messageId);
    }

    public class Client : IClient
    {
        private readonly HttpClient _httpClient;
        private readonly ILogger _logger;

        private Credentials _credentials;

        public Client(Credentials credentials, HttpClient httpClient = null, ILogger logger = null)
        {
            _credentials = credentials;
            _httpClient = httpClient ?? new HttpClient();
            _logger = logger ?? new ConsoleLogger();
        }

        public IEnumerable<InboxMessage> GetMessages()
        {
            var url = $"{_credentials.ApiUrl}/receive";
            var request = new HttpRequestMessage(HttpMethod.Get, url);
            request.Headers.Authorization = new System.Net.Http.Headers.AuthenticationHeaderValue("Bearer", _credentials.ApiKey);
            
            _logger.Debug($"Sending query to {url} with content {request.ToString()} to obtain messages.");

            var response = _httpClient.Send(request);

            if (!response.IsSuccessStatusCode)
            {
                _logger.Error(response.ReasonPhrase);
                throw new HttpRequestException("Can't receive.", null, response.StatusCode);
            }

            var responseContent = response.Content
                .ReadAsStringAsync()
                .GetAwaiter()
                .GetResult();

            if (!string.IsNullOrWhiteSpace(responseContent))
            {
                _logger.Debug($"Received response of {responseContent}.");
            }

            if (string.IsNullOrWhiteSpace(responseContent))
            {
                return Enumerable.Empty<InboxMessage>().ToArray();
            }

            var json = JsonNode.Parse(responseContent);
            var messages = new List<InboxMessage>();

            foreach (var item in json["messages"].AsArray())
            {
                messages.Add(new InboxMessage
                {
                    Id = item["id"].GetValue<Guid>(),
                    Payload = item["payload"].ToJsonString(),
                    PayloadType = item["payloadType"].ToJsonString(),
                    Sender = item["sender"].GetValue<Guid>(),
                });
            }

            _logger.Debug($"Received {messages.Count} messages.");

            return messages.ToArray();
        }

        public Guid SendMessage(OutboxMessage outboxMessage)
        {
            var body = new JsonObject();

            if(outboxMessage.ToUserId.HasValue)
            {
                body.Add("toUserId", JsonValue.Create<Guid>(outboxMessage.ToUserId.Value));
            }

            if(outboxMessage.Payload != null)
            {
                body.Add("payload", JsonValue.Create<string>(outboxMessage.Payload));
            }

            if(outboxMessage.PayloadType != null)
            {
                body.Add("payloadType", JsonValue.Create<string>(outboxMessage.PayloadType));
            }

            if(outboxMessage.LifespanInSeconds != null)
            {
                body.Add("lifespanInSeconds", JsonValue.Create<int>(outboxMessage.LifespanInSeconds.Value));
            }

            var content = new StringContent(body.ToString(), Encoding.UTF8, "application/json");

            var url = $"{_credentials.ApiUrl}/send";
            var request = new HttpRequestMessage(HttpMethod.Post, url);
            request.Content = content;
            request.Headers.Authorization = new System.Net.Http.Headers.AuthenticationHeaderValue("Bearer", _credentials.ApiKey);

            _logger.Debug($"Sending query to {url} with content {body.ToString()} to obtain messages.");

            var response = _httpClient.Send(request);
            
            if (!response.IsSuccessStatusCode)
            {
                _logger.Error(response.ReasonPhrase);
                throw new HttpRequestException("Can't send.", null, response.StatusCode);
            }

            var responseString = response.Content.ReadAsStringAsync().GetAwaiter().GetResult();
            var guid = JsonSerializer.Deserialize<Guid>(responseString);
            return guid;
        }

        public Contact[] GetYellowPages()
        {
            var url = $"{_credentials.ApiUrl}/yellowpages";
            var request = new HttpRequestMessage(HttpMethod.Get, url);
            request.Headers.Authorization = new System.Net.Http.Headers.AuthenticationHeaderValue("Bearer", _credentials.ApiKey);

            _logger.Debug($"Sending query to {url} with content {request.ToString()}.");

            var response = _httpClient.Send(request);

            if (!response.IsSuccessStatusCode)
            {
                _logger.Error(response.ReasonPhrase);
                throw new HttpRequestException("Can't receive.", null, response.StatusCode);
            }

            var responseContent = response.Content
                .ReadAsStringAsync()
                .GetAwaiter()
                .GetResult();

            var json = JsonNode.Parse(responseContent);

            var contacts = json["users"].AsArray().Select(x => new Contact
            {
                Id = x["id"].GetValue<Guid>(),
                Name = x["name"].GetValue<string>()
            }).ToArray();

            return contacts;
        }

        public void AckMessage(InboxMessage message)
        {
            this.AckMessage(message.Id);
        }

        public void AckMessage(Guid messageId)
        {
            var body = new JsonObject
            {
                { "messageId", JsonValue.Create<Guid>(messageId) }
            };

            var content = new StringContent(body.ToString(), Encoding.UTF8, "application/json");

            var url = $"{_credentials.ApiUrl}/ack";
            var request = new HttpRequestMessage(HttpMethod.Post, url);
            request.Headers.Authorization = new System.Net.Http.Headers.AuthenticationHeaderValue("Bearer", _credentials.ApiKey);

            _logger.Debug($"Sending query to {url} with content {body.ToString()} to obtain messages.");

            var response = _httpClient.Send(request);

            if (!response.IsSuccessStatusCode)
            {
                _logger.Error(response.ReasonPhrase);
                throw new HttpRequestException("Can't send.", null, response.StatusCode);
            }
        }

        public int Peek()
        {
            var url = $"{_credentials.ApiUrl}/peek";
            var request = new HttpRequestMessage(HttpMethod.Get, url);
            request.Headers.Authorization = new System.Net.Http.Headers.AuthenticationHeaderValue("Bearer", _credentials.ApiKey);

            _logger.Debug($"Sending query to {url} with content {request.ToString()} to obtain messages.");

            var response = _httpClient.Send(request);

            if (!response.IsSuccessStatusCode)
            {
                _logger.Error(response.ReasonPhrase);
                throw new HttpRequestException("Can't receive.", null, response.StatusCode);
            }

            var responseContent = response.Content
                .ReadAsStringAsync()
                .GetAwaiter()
                .GetResult();

            if (!string.IsNullOrWhiteSpace(responseContent))
            {
                _logger.Debug($"Received response of {responseContent}.");
                return int.Parse(responseContent);
            }

            throw new InvalidOperationException("Unreadable response.");
        }

        public State Verify(Guid messageId)
        {
            var url = $"{_credentials.ApiUrl}/verify?messageId={messageId}";
            var request = new HttpRequestMessage(HttpMethod.Get, url);
            request.Headers.Authorization = new System.Net.Http.Headers.AuthenticationHeaderValue("Bearer", _credentials.ApiKey);

            _logger.Debug($"Sending query to {url} to get message state.");

            var response = _httpClient.Send(request);

            if (!response.IsSuccessStatusCode)
            {
                _logger.Error(response.ReasonPhrase);
                throw new HttpRequestException("Can't receive.", null, response.StatusCode);
            }

            var responseContent = response.Content
                .ReadAsStringAsync()
                .GetAwaiter()
                .GetResult();
            
            if (!string.IsNullOrWhiteSpace(responseContent))
            {
                return JsonSerializer.Deserialize<State>(responseContent);
            }

            throw new InvalidOperationException("Unreadable response.");
        }
    }
}