Canaan CQRS

gistfile1.txt

# You need to clone the project and run it 
# For the CQRS and domains create everything under a file called CQRS.js 
# For handling the flow create a file called services.js

Check the utils file to get all the needed functionality
You will need to use two domains ( projects, and user ) and should be named like this
The project app will be like this

{
  balance: 0,
  projects: [],
  selected: {},
  entries:[],
}

So when creating commands or queries the paths will be selectedProject, balance,entries[], and projects[] mind the brackets and check the documentation if you haven't already
The query doesn't require [] so you can directly define the path as entries for example

{
  balance: 0,
  projects: [],
}

For the user it will be

{
info:{}
}

so the path will info

Import this file to https://www.json-rule-editor.com/#/home and initialise the rules engine

{
	"name": "Demo",
	"attributes": [
		{
			"name": "data",
			"type": "object"
		},
		{
			"name": "context",
			"type": "object"
		},
		{
			"name": "user.data.info.subscriptionType",
			"type": "string"
		},
		{
			"name": "type",
			"type": "string"
		},
		{
			"name": "CanaanApp.data.commandCounter.projects-addEntry.count",
			"type": "number"
		}
	],
	"decisions": [
		{
			"conditions": {
				"all": [
					{
						"fact": "data",
						"operator": "equal",
						"value": "Free",
						"path": ".user.data.info.subscriptionType"
					},
					{
						"fact": "context",
						"operator": "equal",
						"value": "addEntry",
						"path": ".type"
					},
					{
						"fact": "data",
						"operator": "greaterThanInclusive",
						"value": "3",
						"path": ".CanaanApp.data.commandCounter.projects-addEntry.count"
					}
				]
			},
			"event": {
				"type": "FreeSubscriptionLimitExceeded",
				"params": {
					"message": "You are on a free plan You can't add on more than 3 logs per visit, Upgrade your plan to add more"
				}
			}
		}
	]
}

To use the subscribe with React use

const [some,setSome] = useState(); 
useEffect(()=>{
domain.subscribe(query,setSome);
},[]);