32 lines
835 B
C#
32 lines
835 B
C#
using System;
|
|
using System.Net;
|
|
using System.Net.Sockets;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
using Newtonsoft.Json;
|
|
using NadekoBot.Core.Services;
|
|
|
|
namespace NadekoBot.Common.ShardCom
|
|
{
|
|
public class ShardComServer
|
|
{
|
|
private readonly IDataCache _cache;
|
|
|
|
public ShardComServer(IDataCache cache)
|
|
{
|
|
_cache = cache;
|
|
}
|
|
|
|
public void Start()
|
|
{
|
|
var sub = _cache.Redis.GetSubscriber();
|
|
sub.SubscribeAsync("shardcoord_send", (ch, data) =>
|
|
{
|
|
var _ = OnDataReceived(JsonConvert.DeserializeObject<ShardComMessage>(data));
|
|
}, StackExchange.Redis.CommandFlags.FireAndForget);
|
|
}
|
|
|
|
public event Func<ShardComMessage, Task> OnDataReceived = delegate { return Task.CompletedTask; };
|
|
}
|
|
}
|