mirror of https://github.com/Squidex/squidex.git
Sebastian Stehle
8 years ago
11 changed files with 244 additions and 167 deletions
@ -0,0 +1,36 @@ |
|||
// ==========================================================================
|
|||
// Squidex Headless CMS
|
|||
// ==========================================================================
|
|||
// Copyright (c) Squidex UG (haftungsbeschränkt)
|
|||
// All rights reserved. Licensed under the MIT license.
|
|||
// ==========================================================================
|
|||
|
|||
using System.Collections.Generic; |
|||
using System.Linq; |
|||
using System.Threading.Tasks; |
|||
using Squidex.Infrastructure.Migrations; |
|||
|
|||
namespace Migrate_01 |
|||
{ |
|||
public class Migration03_SplitContentCollections : IMigration |
|||
{ |
|||
private readonly Rebuilder rebuilder; |
|||
|
|||
public int FromVersion { get; } = 2; |
|||
|
|||
public int ToVersion { get; } = 3; |
|||
|
|||
public Migration03_SplitContentCollections(Rebuilder rebuilder) |
|||
{ |
|||
this.rebuilder = rebuilder; |
|||
} |
|||
|
|||
public async Task UpdateAsync(IEnumerable<IMigration> previousMigrations) |
|||
{ |
|||
if (!previousMigrations.Any(x => x is Migration01_FromCqrs)) |
|||
{ |
|||
await rebuilder.RebuildContentAsync(); |
|||
} |
|||
} |
|||
} |
|||
} |
|||
@ -0,0 +1,157 @@ |
|||
// ==========================================================================
|
|||
// Squidex Headless CMS
|
|||
// ==========================================================================
|
|||
// Copyright (c) Squidex UG (haftungsbeschränkt)
|
|||
// All rights reserved. Licensed under the MIT license.
|
|||
// ==========================================================================
|
|||
|
|||
using System; |
|||
using System.Collections.Generic; |
|||
using System.Threading; |
|||
using System.Threading.Tasks; |
|||
using Squidex.Domain.Apps.Core.Schemas; |
|||
using Squidex.Domain.Apps.Entities.Apps; |
|||
using Squidex.Domain.Apps.Entities.Assets; |
|||
using Squidex.Domain.Apps.Entities.Contents.State; |
|||
using Squidex.Domain.Apps.Entities.Rules; |
|||
using Squidex.Domain.Apps.Entities.Schemas; |
|||
using Squidex.Domain.Apps.Events; |
|||
using Squidex.Domain.Apps.Events.Assets; |
|||
using Squidex.Domain.Apps.Events.Contents; |
|||
using Squidex.Domain.Apps.Events.Rules; |
|||
using Squidex.Infrastructure; |
|||
using Squidex.Infrastructure.EventSourcing; |
|||
using Squidex.Infrastructure.States; |
|||
|
|||
namespace Migrate_01 |
|||
{ |
|||
public sealed class Rebuilder |
|||
{ |
|||
private readonly FieldRegistry fieldRegistry; |
|||
private readonly IEventStore eventStore; |
|||
private readonly IEventDataFormatter eventDataFormatter; |
|||
private readonly ISnapshotStore<ContentState, Guid> snapshotContentStore; |
|||
private readonly IStateFactory stateFactory; |
|||
|
|||
public Rebuilder( |
|||
FieldRegistry fieldRegistry, |
|||
IEventDataFormatter eventDataFormatter, |
|||
IEventStore eventStore, |
|||
ISnapshotStore<ContentState, Guid> snapshotContentStore, |
|||
IStateFactory stateFactory) |
|||
{ |
|||
this.fieldRegistry = fieldRegistry; |
|||
this.eventDataFormatter = eventDataFormatter; |
|||
this.eventStore = eventStore; |
|||
this.snapshotContentStore = snapshotContentStore; |
|||
this.stateFactory = stateFactory; |
|||
} |
|||
|
|||
public Task RebuildAssetsAsync() |
|||
{ |
|||
const string filter = "^asset\\-"; |
|||
|
|||
var handledIds = new HashSet<Guid>(); |
|||
|
|||
return eventStore.GetEventsAsync(async storedEvent => |
|||
{ |
|||
var @event = ParseKnownEvent(storedEvent); |
|||
|
|||
if (@event != null) |
|||
{ |
|||
if (@event.Payload is AssetEvent assetEvent && handledIds.Add(assetEvent.AssetId)) |
|||
{ |
|||
var asset = await stateFactory.CreateAsync<AssetDomainObject>(assetEvent.AssetId); |
|||
|
|||
asset.ApplySnapshot(asset.Snapshot.Apply(@event)); |
|||
|
|||
await asset.WriteSnapshotAsync(); |
|||
} |
|||
} |
|||
}, CancellationToken.None, filter); |
|||
} |
|||
|
|||
public Task RebuildConfigAsync() |
|||
{ |
|||
const string filter = "^((app\\-)|(schema\\-)|(rule\\-))"; |
|||
|
|||
var handledIds = new HashSet<Guid>(); |
|||
|
|||
return eventStore.GetEventsAsync(async storedEvent => |
|||
{ |
|||
var @event = ParseKnownEvent(storedEvent); |
|||
|
|||
if (@event != null) |
|||
{ |
|||
if (@event.Payload is SchemaEvent schemaEvent && handledIds.Add(schemaEvent.SchemaId.Id)) |
|||
{ |
|||
var schema = await stateFactory.GetSingleAsync<SchemaDomainObject>(schemaEvent.SchemaId.Id); |
|||
|
|||
await schema.WriteSnapshotAsync(); |
|||
} |
|||
else if (@event.Payload is RuleEvent ruleEvent && handledIds.Add(ruleEvent.RuleId)) |
|||
{ |
|||
var rule = await stateFactory.GetSingleAsync<RuleDomainObject>(ruleEvent.RuleId); |
|||
|
|||
await rule.WriteSnapshotAsync(); |
|||
} |
|||
else if (@event.Payload is AppEvent appEvent && handledIds.Add(appEvent.AppId.Id)) |
|||
{ |
|||
var app = await stateFactory.GetSingleAsync<AppDomainObject>(appEvent.AppId.Id); |
|||
|
|||
await app.WriteSnapshotAsync(); |
|||
} |
|||
} |
|||
}, CancellationToken.None, filter); |
|||
} |
|||
|
|||
public async Task RebuildContentAsync() |
|||
{ |
|||
const string filter = "^((content\\-))"; |
|||
|
|||
var handledIds = new HashSet<Guid>(); |
|||
|
|||
await snapshotContentStore.ClearAsync(); |
|||
|
|||
await eventStore.GetEventsAsync(async storedEvent => |
|||
{ |
|||
var @event = ParseKnownEvent(storedEvent); |
|||
|
|||
if (@event.Payload is ContentEvent contentEvent) |
|||
{ |
|||
try |
|||
{ |
|||
var (content, version) = await snapshotContentStore.ReadAsync(contentEvent.ContentId); |
|||
|
|||
if (content == null) |
|||
{ |
|||
version = EtagVersion.Empty; |
|||
|
|||
content = new ContentState(); |
|||
} |
|||
|
|||
content = content.Apply(@event); |
|||
|
|||
await snapshotContentStore.WriteAsync(contentEvent.ContentId, content, version, version + 1); |
|||
} |
|||
catch (DomainObjectNotFoundException) |
|||
{ |
|||
// Schema has been deleted.
|
|||
} |
|||
} |
|||
}, CancellationToken.None, filter); |
|||
} |
|||
|
|||
private Envelope<IEvent> ParseKnownEvent(StoredEvent storedEvent) |
|||
{ |
|||
try |
|||
{ |
|||
return eventDataFormatter.Parse(storedEvent.Data); |
|||
} |
|||
catch (TypeNameNotFoundException) |
|||
{ |
|||
return null; |
|||
} |
|||
} |
|||
} |
|||
} |
|||
Loading…
Reference in new issue