Browse Source

Correct handling of old events.

pull/118/head
Sebastian Stehle 8 years ago
parent
commit
29648c0bce
  1. 7
      src/Squidex.Domain.Apps.Events/Schemas/Old/WebhookAdded.cs
  2. 7
      src/Squidex.Domain.Apps.Events/Schemas/Old/WebhookDeleted.cs
  3. 13
      src/Squidex.Domain.Apps.Read.MongoDb/Schemas/MongoSchemaRepository_EventHandling.cs

7
src/Squidex.Domain.Apps.Events/Schemas/Old/WebhookAdded.cs

@ -13,17 +13,12 @@ namespace Squidex.Domain.Apps.Events.Schemas.Old
{ {
[EventType(nameof(WebhookAdded))] [EventType(nameof(WebhookAdded))]
[Obsolete] [Obsolete]
public sealed class WebhookAdded : SchemaEvent, IMigratedEvent public sealed class WebhookAdded : SchemaEvent
{ {
public Guid Id { get; set; } public Guid Id { get; set; }
public Uri Url { get; set; } public Uri Url { get; set; }
public string SharedSecret { get; set; } public string SharedSecret { get; set; }
public IEvent Migrate()
{
return new NoopEvent();
}
} }
} }

7
src/Squidex.Domain.Apps.Events/Schemas/Old/WebhookDeleted.cs

@ -13,13 +13,8 @@ namespace Squidex.Domain.Apps.Events.Schemas.Old
{ {
[EventType(nameof(WebhookDeleted))] [EventType(nameof(WebhookDeleted))]
[Obsolete] [Obsolete]
public sealed class WebhookDeleted : SchemaEvent, IMigratedEvent public sealed class WebhookDeleted : SchemaEvent
{ {
public Guid Id { get; set; } public Guid Id { get; set; }
public IEvent Migrate()
{
return new NoopEvent();
}
} }
} }

13
src/Squidex.Domain.Apps.Read.MongoDb/Schemas/MongoSchemaRepository_EventHandling.cs

@ -16,6 +16,7 @@ using Squidex.Domain.Apps.Read.MongoDb.Utils;
using Squidex.Infrastructure.CQRS.Events; using Squidex.Infrastructure.CQRS.Events;
using Squidex.Infrastructure.Dispatching; using Squidex.Infrastructure.Dispatching;
using Squidex.Infrastructure.Reflection; using Squidex.Infrastructure.Reflection;
using Squidex.Domain.Apps.Events.Schemas.Old;
namespace Squidex.Domain.Apps.Read.MongoDb.Schemas namespace Squidex.Domain.Apps.Read.MongoDb.Schemas
{ {
@ -127,5 +128,17 @@ namespace Squidex.Domain.Apps.Read.MongoDb.Schemas
{ {
entity.SerializeSchema(schema, serializer); entity.SerializeSchema(schema, serializer);
} }
#pragma warning disable CS0612 // Type or member is obsolete
protected Task On(WebhookAdded @event, EnvelopeHeaders headers)
{
return Collection.UpdateAsync(@event, headers, e => { });
}
protected Task On(WebhookDeleted @event, EnvelopeHeaders headers)
{
return Collection.UpdateAsync(@event, headers, e => { });
}
#pragma warning restore CS0612 // Type or member is obsolete
} }
} }

Loading…
Cancel
Save