Browse Source

Small fixes.

pull/204/head
Sebastian Stehle 9 years ago
parent
commit
38c3825a29
  1. 3
      src/Squidex.Domain.Apps.Read/State/Grains/AppStateGrain.cs
  2. 11
      src/Squidex.Domain.Apps.Read/State/Grains/AppUserGrain.cs
  3. 2
      src/Squidex.Infrastructure/EventSourcing/Grains/EventConsumerGrain.cs
  4. 2
      src/Squidex.Infrastructure/States/Persistence.cs
  5. 10
      src/Squidex/Config/Domain/InfrastructureServices.cs

3
src/Squidex.Domain.Apps.Read/State/Grains/AppStateGrain.cs

@ -46,7 +46,10 @@ namespace Squidex.Domain.Apps.Read.State.Grains
catch (Exception ex)
{
exception = ex;
}
if (state == null)
{
state = new AppStateGrainState();
}

11
src/Squidex.Domain.Apps.Read/State/Grains/AppUserGrain.cs

@ -17,22 +17,15 @@ namespace Squidex.Domain.Apps.Read.State.Grains
public sealed class AppUserGrain : IStatefulObject
{
private IPersistence<AppUserGrainState> persistence;
private AppUserGrainState state;
private AppUserGrainState state = new AppUserGrainState();
public Task ActivateAsync(string key, IStore store)
{
persistence = store.WithSnapshots<AppUserGrain, AppUserGrainState>(key, ApplySnapShot);
persistence = store.WithSnapshots<AppUserGrain, AppUserGrainState>(key, s => state = s);
return persistence.ReadAsync();
}
public Task ApplySnapShot(AppUserGrainState state)
{
this.state = state;
return TaskHelper.Done;
}
public Task AddAppAsync(string appName)
{
state = state.AddApp(appName);

2
src/Squidex.Infrastructure/EventSourcing/Grains/EventConsumerGrain.cs

@ -24,7 +24,7 @@ namespace Squidex.Infrastructure.EventSourcing.Grains
private IEventSubscription currentSubscription;
private IEventConsumer eventConsumer;
private IPersistence<EventConsumerState> persistence;
private EventConsumerState state;
private EventConsumerState state = new EventConsumerState();
public EventConsumerGrain(
IEventStore eventStore,

2
src/Squidex.Infrastructure/States/Persistence.cs

@ -59,7 +59,7 @@ namespace Squidex.Infrastructure.States
positionSnapshot = position;
positionEvent = position;
if (applyState != null)
if (applyState != null && position >= 0)
{
await applyState(state);
}

10
src/Squidex/Config/Domain/InfrastructureServices.cs

@ -19,6 +19,7 @@ using Squidex.Infrastructure.Assets.ImageSharp;
using Squidex.Infrastructure.Commands;
using Squidex.Infrastructure.EventSourcing;
using Squidex.Infrastructure.Log;
using Squidex.Infrastructure.States;
using Squidex.Infrastructure.UsageTracking;
using Squidex.Pipeline;
@ -76,12 +77,6 @@ namespace Squidex.Config.Domain
services.AddSingletonAs<ActionContextAccessor>()
.As<IActionContextAccessor>();
services.AddSingletonAs<DefaultDomainObjectRepository>()
.As<IDomainObjectRepository>();
services.AddSingletonAs<DefaultDomainObjectFactory>()
.As<IDomainObjectFactory>();
services.AddSingletonAs<AggregateHandler>()
.As<IAggregateHandler>();
@ -94,7 +89,8 @@ namespace Squidex.Config.Domain
services.AddSingletonAs<ImageSharpAssetThumbnailGenerator>()
.As<IAssetThumbnailGenerator>();
services.AddSingletonAs<EventDataFormatter>();
services.AddSingletonAs<JsonEventDataFormatter>()
.As<IEventDataFormatter>();
}
}
}

Loading…
Cancel
Save