chinchilla-software-com / cqrs Goto Github PK

A lightweight enterprise Function as a Service (FaaS) framework to write function based serverless and micro-service applications in hybrid multi-datacentre, on-premise and Azure environments.

License: GNU Lesser General Public License v2.1

C# 100.00%

cqrs azure event-sourcing akkadotnet servicebus eda microservices webjobs webapi serverless

cqrs's People

Contributors

Stargazers

Watchers

Forkers

snuffykl robin-- jdiss carldai0106 blinds52 gmfx apkalexei rioka mvanhelmont cesarpr01 crazyants zarmsen aleenabhat12 logikonline kksanjeev fengweijp kiwipiet williamthiago eliteappdev greyoy 403016605 darkdaskin gromag eaba thenephalim liaoxianfei edweller pjjwpc ddd-cqrs-es jenniferlawl jango2015 kouweizhong irongoose arturribeiro heianxing jcimafranca aarym lulzzz cronologi aliakbarrashidi tuga1975 csuffyy anhzin jangocheng awesomedotnetcore matafonoff muratgundes aaditya0777 qingw laniatech mallickhruday dystudio codercouple zhangzhouzhe carlha itd3v matrixdekoder cqrs-es-archive-01 suprcodr ykankaya quanliang2000 mbukata aluevano 5l1v3r1 krystal-my miguelangelvega lanicon atikhan bubdm ethananro gitmelyk ingted djun vuyosoci derkodex laball 0xdo opencxx cjvandyk

cqrs's Issues

Azure Servicebus subscription filters aren't always applied

Azure Servicebus subscription filters aren't always applied.

Add a WCF example

Possibly an extension of the Northwind example.

Document new security features

The Azure document db package not able to build the aggregate root (fetch events)

Issue with the change in e25ca98
line 52
string collectionName = string.Format("{0}::{1}", AzureDocumentDbEventStoreConnectionStringFactory.GetEventStoreConnectionCollectionName(), aggregateRootType.FullName);

was changed to:
string collectionName = string.Format("{0}", AzureDocumentDbEventStoreConnectionStringFactory.GetEventStoreConnectionCollectionName());

where as in PersitEvent method the methods are saved to the collection with the name in format as mentioned in the first line of code.

Built-in support for Snapshots

SQL
MongoDB
Cosmos DB (DocumentDB)
Azure Blob Storage
Azure Table Storage

Where is example to use EventStore or Azure database

Hi,

I am really interesting in this project, where can I find example or code that implement the EventStore database or Azure database/

Thanks
Thomas.

Create a very simple HelloWorld example

Create a very simple HelloWorld example.
Document the process and add to the wiki as well.

Add WebJob Host

No AggregateRoot for a services means no IAuthenticationTokenHelper, ICorrelationIdHelper and ILogger are not in the service

[EventHub] Authentication/Message signing for Command receiving

HashAlgorithm doesn't seem to be thread safe

Replace with a factory pattern.

Akka Saga event handler uses the wrong resolver

The Akka saga event handler in the tests uses the aggregate root resolver, which won't find the saga. It also doesn't provide the ID to locate the correct saga.

Don't see any indication of .NET Core 2 Standard support

Just wondering what the take is here on usage in a .NET Core 2 environment. Thanks.

[EventBus] Authentication/Message signing for Command receiving

[EventHub] Authentication/Message signing for Event receiving

All SendAndWait/PublishAndWait methods never return

They are all incorrectly execute
(TEvent)events.SingleOrDefault(@event => @events is TEvent)
instead of
(TEvent)events.SingleOrDefault(@event => @event is TEvent)
NOTE the lack of a s in the correct method body

Sample event reply tooling

Race condition when applying Serivce Bus subscription filters

CQRS/Framework/Azure/Cqrs.Azure.ServiceBus/AzureEventBusReceiver.cs

Lines 106 to 115 in 3d79e23

    
           			Task.Factory.StartNewSafely 
        
           			(() => 
        
           			{ 
        
           				// Because refreshing the rule can take a while, we only want to do this when the value changes 
        
           				string filter; 
        
           				if (!ConfigurationManager.TryGetSetting(FilterKeyConfigurationKey, out filter)) 
        
           					return; 
        
           				if (FilterKey == filter) 
        
           					return; 
        
           				FilterKey = filter;

This core is run twice - once for public and private topics respectively. Due to a race condition sometimes only one topic gets its subscription filter applied.

Cqrs.Domain.AggregateRoot.ApplyChange stores Changes in the wrong order

The current execution is
Changes = new ReadOnlyCollection<IEvent<TAuthenticationToken>>(new []{@event}.Concat(Changes).ToList());
and it should probably be
Changes = new ReadOnlyCollection<IEvent<TAuthenticationToken>>(Changes.Concat(new[] { @event }).ToList());
this way the order events are applied is retained as that determines the order of event storing.

Cqrs.Domain.AggregateRepository.Save will also apply the same version number to all events applied which will be problematic.

SqlDataStoreExtension.Truncate raises a sql error

  $exception	{"Incorrect syntax near '@p0'."}	System.Exception {System.Data.SqlClient.SqlException}

VS solution file is very old.

Isn't there a newer version of the sln file available?
Latest sln file is for Visual Studio 2012.

UnitOfWork doesn't properly support snapshots

The UnitOfWork (UOW) doesn't support snapshot usage when calling commit.

.NET Core support

Is .NET Core support on the roadmap? As of the moment, I cannot install Cqrs.net nuget packages in a .net core 2.2 project.

Update samples for new version 2.2 packages

Concurrency issue while hosting in a cluster

AggregateRoot are applying changes with the same version number. Suspect root cause is due to us hosting in a service fabric and thus the ReaderWriterLockSlim is not shared among the clusters. Might need to use a distributed lock if that's the case?

.Net6 Support

Since the next LTS is .NET 6 and this is based on the full framework it should be brought up to standard or marked as unmaintained.

Non Akka Sagas cannot differentiate.

The Pull Request #11 added Saga support. The tests around the Akka version appear to be well enough built that the event handlers locate which instance of the saga to pass the event to, the standard saga appears to send it to a random (or all) sagas.

The standard saga tests need to be redesigned to show how to properly use sagas.

Create a very simple, updated Northwind example

Replace the current Northwind example with something that doesn't use the visual platform.

[EventBus] Authentication/Message signing for Event publishing

[EventBus] Authentication/Message signing for Command publishing

Snapshot support in the Akka implementation is incomplete

Make the implementation at least as good as the Azure Servicebus implementation

Update simplified SQL event store to support multiple writes and separate reads

Update the WebApi packages to allow an out-of-the-box simple implementation

Add what ever is needed to create as simple to implement as possible a HelloWorld example.

[EventHub] Authentication/Message signing for Event publishing

Version check issue

While checking the expected version, condition x.Version >= fromVersion is incorrect and should be x.Version > fromVersion

This is causing the valid version numbers to fail. This condition is correct for other event sources but wrong for AzureDocumentDB.

https://github.com/Chinchilla-Software-Com/CQRS/blob/master/Framework/Azure/Cqrs.Azure.DocumentDb/Events/AzureDocumentDbEventStore.cs
Line 63

Kinds Regards!

multiple write connection strings and
a separate read connection string

Yes, but why "RSN"?

What does the abbreviation itself mean? Why these three letters?

Please update doc:
https://github.com/Chinchilla-Software-Com/CQRS/wiki/Rsn

	Task.Factory.StartNewSafely
	(() =>
	{
	// Because refreshing the rule can take a while, we only want to do this when the value changes
	string filter;
	if (!ConfigurationManager.TryGetSetting(FilterKeyConfigurationKey, out filter))
	return;
	if (FilterKey == filter)
	return;
	FilterKey = filter;