Browse Source

Sucess alert fixed

pull/100/head
Sebastian Stehle 9 years ago
parent
commit
f090340753
  1. 4
      src/Squidex.Infrastructure/CQRS/Events/EventReceiver.cs
  2. 2
      src/Squidex/app/theme/_bootstrap.scss
  3. 20
      tests/Squidex.Domain.Apps.Read.Tests/Apps/CachingAppProviderTests.cs

4
src/Squidex.Infrastructure/CQRS/Events/EventReceiver.cs

@ -142,7 +142,7 @@ namespace Squidex.Infrastructure.CQRS.Events
await subscription.SubscribeAsync(async storedEvent => await subscription.SubscribeAsync(async storedEvent =>
{ {
await DispatchConsumer(ParseEvent(storedEvent), eventConsumer, eventConsumer.Name); await DispatchConsumerAsync(ParseEvent(storedEvent), eventConsumer, eventConsumer.Name);
await eventConsumerInfoRepository.SetPositionAsync(eventConsumer.Name, storedEvent.EventPosition, false); await eventConsumerInfoRepository.SetPositionAsync(eventConsumer.Name, storedEvent.EventPosition, false);
}, async exception => }, async exception =>
@ -187,7 +187,7 @@ namespace Squidex.Infrastructure.CQRS.Events
} }
} }
private async Task DispatchConsumer(Envelope<IEvent> @event, IEventConsumer eventConsumer, string consumerName) private async Task DispatchConsumerAsync(Envelope<IEvent> @event, IEventConsumer eventConsumer, string consumerName)
{ {
var eventId = @event.Headers.EventId().ToString(); var eventId = @event.Headers.EventId().ToString();
var eventType = @event.Payload.GetType().Name; var eventType = @event.Payload.GetType().Name;

2
src/Squidex/app/theme/_bootstrap.scss

@ -41,7 +41,7 @@
// //
// Alert overrides. // Alert overrides.
// //
.alert-info, .alert-success,
.alert-warning, .alert-warning,
.alert-info, .alert-info,
.alert-danger { .alert-danger {

20
tests/Squidex.Domain.Apps.Read.Tests/Apps/CachingAppProviderTests.cs

@ -67,8 +67,8 @@ namespace Squidex.Domain.Apps.Read.Apps
A.CallTo(() => repository.FindAppAsync(appId.Id)) A.CallTo(() => repository.FindAppAsync(appId.Id))
.Returns(Task.FromResult(appV1)); .Returns(Task.FromResult(appV1));
await ProvideAppById(appV1); await ProvideAppByIdAsync(appV1);
await ProvideAppByName(appV1); await ProvideAppByNameAsync(appV1);
A.CallTo(() => repository.FindAppAsync(appId.Id)).MustHaveHappened(); A.CallTo(() => repository.FindAppAsync(appId.Id)).MustHaveHappened();
A.CallTo(() => repository.FindAppAsync(appId.Name)).MustNotHaveHappened(); A.CallTo(() => repository.FindAppAsync(appId.Name)).MustNotHaveHappened();
@ -80,8 +80,8 @@ namespace Squidex.Domain.Apps.Read.Apps
A.CallTo(() => repository.FindAppAsync(appId.Name)) A.CallTo(() => repository.FindAppAsync(appId.Name))
.Returns(Task.FromResult(appV1)); .Returns(Task.FromResult(appV1));
await ProvideAppByName(appV1); await ProvideAppByNameAsync(appV1);
await ProvideAppById(appV1); await ProvideAppByIdAsync(appV1);
A.CallTo(() => repository.FindAppAsync(appId.Id)).MustNotHaveHappened(); A.CallTo(() => repository.FindAppAsync(appId.Id)).MustNotHaveHappened();
A.CallTo(() => repository.FindAppAsync(appId.Name)).MustHaveHappened(); A.CallTo(() => repository.FindAppAsync(appId.Name)).MustHaveHappened();
@ -95,11 +95,11 @@ namespace Squidex.Domain.Apps.Read.Apps
A.CallTo(() => repository.FindAppAsync(appId.Id)) A.CallTo(() => repository.FindAppAsync(appId.Id))
.Returns(appV1).Once(); .Returns(appV1).Once();
await ProvideAppById(appV1); await ProvideAppByIdAsync(appV1);
sut.On(Envelope.Create(new AppLanguageAdded {AppId = appId }).To<IEvent>()).Wait(); sut.On(Envelope.Create(new AppLanguageAdded {AppId = appId }).To<IEvent>()).Wait();
await ProvideAppById(appV2); await ProvideAppByIdAsync(appV2);
A.CallTo(() => repository.FindAppAsync(appId.Id)).MustHaveHappened(Repeated.Exactly.Times(2)); A.CallTo(() => repository.FindAppAsync(appId.Id)).MustHaveHappened(Repeated.Exactly.Times(2));
} }
@ -112,21 +112,21 @@ namespace Squidex.Domain.Apps.Read.Apps
A.CallTo(() => repository.FindAppAsync(appId.Name)) A.CallTo(() => repository.FindAppAsync(appId.Name))
.Returns(appV1).Once(); .Returns(appV1).Once();
await ProvideAppByName(appV1); await ProvideAppByNameAsync(appV1);
sut.On(Envelope.Create(new AppLanguageAdded { AppId = appId }).To<IEvent>()).Wait(); sut.On(Envelope.Create(new AppLanguageAdded { AppId = appId }).To<IEvent>()).Wait();
await ProvideAppByName(appV2); await ProvideAppByNameAsync(appV2);
A.CallTo(() => repository.FindAppAsync(appId.Name)).MustHaveHappened(Repeated.Exactly.Times(2)); A.CallTo(() => repository.FindAppAsync(appId.Name)).MustHaveHappened(Repeated.Exactly.Times(2));
} }
private async Task ProvideAppById(IAppEntity app) private async Task ProvideAppByIdAsync(IAppEntity app)
{ {
Assert.Equal(app, await sut.FindAppByIdAsync(appId.Id)); Assert.Equal(app, await sut.FindAppByIdAsync(appId.Id));
} }
private async Task ProvideAppByName(IAppEntity app) private async Task ProvideAppByNameAsync(IAppEntity app)
{ {
Assert.Equal(app, await sut.FindAppByNameAsync(appId.Name)); Assert.Equal(app, await sut.FindAppByNameAsync(appId.Name));
} }

Loading…
Cancel
Save