diff --git a/src/Squidex.Infrastructure.Redis/EventStore/RedisEventStore.cs b/src/Squidex.Infrastructure.Redis/EventStore/RedisEventStore.cs deleted file mode 100644 index 55abc9170..000000000 --- a/src/Squidex.Infrastructure.Redis/EventStore/RedisEventStore.cs +++ /dev/null @@ -1,55 +0,0 @@ -using System; -using System.Collections.Generic; -using System.Text; -using System.Threading.Tasks; -using Squidex.Infrastructure.CQRS.Events; -using StackExchange.Redis; - -namespace Squidex.Infrastructure.Redis.EventStore -{ - public class RedisEventStore : IEventStore, IExternalSystem - { - private readonly Lazy redisClient; - - public RedisEventStore(Lazy redis) - { - this.redisClient = redis; - } - - public Task> GetEventsAsync(string streamName) - { - var db = redisClient.Value.GetDatabase(); - - - throw new NotImplementedException(); - } - - public Task AppendEventsAsync(Guid commitId, string streamName, int expectedVersion, ICollection events) - { - throw new NotImplementedException(); - } - - public IEventSubscription CreateSubscription(string streamFilter = null, string position = null) - { - throw new NotImplementedException(); - } - - public void Connect() - { - try - { - redisClient.Value.GetStatus(); - - var db = redisClient.Value.GetDatabase(); - if (!db.HashExists("SquidexEventStore", 0)) - { - db.HashSet("SquidexEventStore", new[] { new HashEntry(0, "{event data}") }); - } - } - catch (Exception ex) - { - throw new ConfigurationException($"Redis connection failed to connect to database {redisClient.Value.Configuration}", ex); - } - } - } -}