56 lines
2.1 KiB
C#
56 lines
2.1 KiB
C#
using Microsoft.Extensions.Configuration;
|
|
using Microsoft.Extensions.Logging;
|
|
using PushShared.Push.Data;
|
|
using RabbitMQ.Client;
|
|
using System.Text;
|
|
using System.Text.Json;
|
|
|
|
namespace PushShared
|
|
{
|
|
public class RabbitPushService : IPushService
|
|
{
|
|
private readonly ILogger<RabbitPushService> _logger;
|
|
private readonly IConfiguration _configuration;
|
|
private readonly ConnectionFactory _connectionFactory;
|
|
private readonly IConnection _connection;
|
|
private readonly IModel _channel;
|
|
|
|
public RabbitPushService(ILogger<RabbitPushService> logger, IConfiguration configuration)
|
|
{
|
|
_logger = logger;
|
|
_configuration = configuration;
|
|
_connectionFactory = new() { Uri = new(_configuration.GetConnectionString("RabbitMQ")!) };
|
|
_connection = _connectionFactory.CreateConnection();
|
|
_channel = _connection.CreateModel();
|
|
_channel.QueueDeclare(queue: "push-queue",
|
|
durable: false,
|
|
exclusive: false,
|
|
autoDelete: false);
|
|
}
|
|
|
|
public void SendPush(PushNotification push)
|
|
{
|
|
_logger.LogInformation("Serializing push notification...");
|
|
var body = Encoding.UTF8.GetBytes(JsonSerializer.Serialize(push));
|
|
_logger.LogInformation("Publishing push notification to queue");
|
|
_channel.BasicPublish(exchange: "",
|
|
routingKey: "push-queue",
|
|
body: body);
|
|
_logger.LogInformation("Publish successful");
|
|
}
|
|
|
|
public PushNotification? ReceivePush()
|
|
{
|
|
var result = _channel.BasicGet("push-queue", true);
|
|
if (result is null)
|
|
{
|
|
return null;
|
|
}
|
|
_logger.LogInformation("Push notification found, deserializing...");
|
|
var body = result.Body.ToArray();
|
|
var push = JsonSerializer.Deserialize<PushNotification>(Encoding.UTF8.GetString(body));
|
|
_logger.LogInformation("Get successful, returning push notification");
|
|
return push;
|
|
}
|
|
}
|
|
}
|