New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More
Socket
Sign inDemoInstall
Socket

@moirae/node-plugin

Package Overview
Dependencies
Maintainers
3
Versions
4
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@moirae/node-plugin

NodeJS port of Moirae Core module to enable usage in non-NestJS environments. Note this is not the ideal configuration and should only be used in edge cases.

  • 0.6.0
  • latest
  • Source
  • npm
  • Socket score

Version published
Maintainers
3
Created
Source

@moirae/node-plugin

NodeJS port of Moirae Core module to enable usage in non-NestJS environments. Note this is not the ideal configuration and should only be used in edge cases.

Supported Features

  • AggregateFactory
  • Command Execution
  • Command Listening
  • Event Listening
  • Event Persistence
  • Event PubSub
  • Query Execution
  • Query Listening

Setup

Moirae requires more advanced configuration when operating in this mode. As an example with RabbitMQ:

const {ObservableFactory} = require('@moirae/core');
const {MoiraePlugin} = require('@moirae/node-plugin');
const {RabbitMQConnection, RabbitMQPublisher} = require('@moirae/rabbitmq');

// Define the parameters of the connection and initialize it
const rabbitMQConfig = {/* config contents */};
const connection = new RabbitMQConnection(rabbitMQConfig);

const moirae = new MoiraePlugin({
    domains: ["myApp"],
    // Provide a way to instantiate new Publisher instances
    getCommandPublisher: () =>
        new RabbitMQPublisher(new ObservableFactory(), rabbitMQConfig, rmqConnection),
    getEventPublisher: () =>
        new RabbitMQPublisher(new ObservableFactory(), rabbitMQConfig, rmqConnection),
    getQueryPublisher: () =>
        new RabbitMQPublisher(new ObservableFactory(), rabbitMQConfig, rmqConnection)
});

// Add Query/Command handlers
moirae.injectCommandHandler(...);
moirae.injectQueryHandler(...);

// Initialize
await rmqConnection.onModuleInit();
await moirae.init();

// ... App logic ...

// Teardown
await rmqConnection.onApplicationShutdown();
await moirae.tearDown();

When operating in a non-NestJS environment, the plugin must compensate for the lack of a Dependency Injection container and therefore creates one itself. However the user must provide some key elements: namely the publisher and event store as they must be created independently of Moirae.

Additionally the lifecycle methods of NestJS may need to be managed independently. In the above example, the connection lifecycle methods of onModuleInit and onApplicationShutdown are not called for the RabbitMQConnection automatically. These methods are handled for all elements gotten from the MoiraePlugin, including the Publishers generated on startup.

Commands, Events, Queries

Commands, Events, and Queries must be duplicated across all systems as the DTOs are key for the usage of Moirae.

FAQs

Package last updated on 21 Nov 2022

Did you know?

Socket

Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.

Install

Related posts

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc