cqrs-swissknife/domain/loader.js

'use strict';

const fs = require('fs');
const path = require('path');

const loadAggregate = (filePath, { commands = {}, events = {} }) => {
	const aggregate = {
		commands: {},
		events: {},
		path: filePath,
	};

	// commands
	Object.entries(commands).forEach(([commandName]) => {
		aggregate.commands[commandName] = {};
	});

	// events
	Object.entries(events).forEach(([eventName]) => {
		aggregate.events[eventName] = {};
	});

	return aggregate;
};

const loadContext = (contextDirectory) => {
	const context = {};

	fs.readdirSync(contextDirectory).forEach((aggregateName) => {
		const aggregateFile = path.join(contextDirectory, aggregateName);


		if (!fs.statSync(aggregateFile).isFile())
			return;

		if (path.extname(aggregateFile) !== '.js') return;

		context[path.basename(aggregateName, '.js')] = loadAggregate(aggregateFile, require(aggregateFile)); // eslint-disable-line
	});

	return context;
};

const loadDomain = (writeModelDirectory, options) => {
	const contexts = {};

	fs.readdirSync(writeModelDirectory).forEach((contextName) => {
		const contextDirectory = path.join(writeModelDirectory, contextName);

		if (!fs.statSync(contextDirectory).isDirectory())
			return;

		contexts[contextName] = loadContext(contextDirectory, options);
	});

	return contexts;
};

module.exports = (directory, options) => loadDomain(directory, options);