![\"GitHub](\"https://github.com/actions/setup-node/workflows/Main%20workflow/badge.svg\"){kind=icon}
\n\n \n
\n ![\"Nest](\"https://nestjs.com/img/logo_text.svg\"){kind=logo}
\n
![\"NPM](\"https://img.shields.io/npm/v/@nestjs/core.svg\")
\n![\"Package](\"https://img.shields.io/npm/l/@nestjs/core.svg\")
\n![\"NPM](\"https://img.shields.io/npm/dm/@nestjs/core.svg\")
\n\n## Description\nInjects eventstore connector modules, components, bus and eventstore config into a nestjs application. An example is provided in the examples folder.\n\n### Installation\n`npm i --save nestjs-eventstore`\n\n### Usage\n\n#### Using the EventStoreCqrsModule\n\n`EventStoreCqrsModule` uses `@nestjs/cqrs` module under the hood. It overrides the default eventbus of `@nestjs/cqrs` and pushes the event to the eventstore rather than the internal eventBus.\nTherefore the `eventBus.publish(event, streamName)` method takes [two arguments instead of one](https://github.com/daypaio/nestjs-eventstore/blob/2e09dd435c60a1a881b9b012d6c83f810b3c85da/src/event-store/eventstore-cqrs/event-store.bus.ts#L115). The first one is the event itself, and the second one is the stream name. \n\nOnce the event is pushed to the eventStore all the subscriptions listening to that event are pushed that event from the event store. Event handlers can then be triggered to cater for those events.\n\n**app.module.ts**\n\n```typescript\nimport {\n EventStoreBusConfig,\n EventStoreSubscriptionType,\n} from 'nestjs-eventstore';\n\n//linking of events from EventStore to local events\nconst EventInstantiators = [\n SomeEvent: (_id: any, data: any, loggedInUserId: any) => new SomeEvent(_id, data, loggedInUserId);\n];\n\nexport const eventStoreBusConfig: EventStoreBusConfig = {\n subscriptions: [\n { // persistanct subscription\n type: EventStoreSubscriptionType.Persistent,\n stream: '$ce-persons',\n persistentSubscriptionName: 'contacts',\n },\n { // Catchup subscription\n type: EventStoreSubscriptionType.CatchUp,\n stream: '$ce-users',\n },\n ],\n eventInstantiators: {\n ...EventInstantiators\n },\n};\n\n@Module({\n imports: [\n ConfigModule.load(path.resolve(__dirname, 'config', '**/!(*.d).{ts,js}')),\n EventStoreCqrsModule.forRootAsync(\n {\n useFactory: async (config: ConfigService) => {\n return {\n connectionSettings: config.get('eventstore.connectionSettings'),\n endpoint: config.get('eventstore.tcpEndpoint'),\n };\n },\n inject: [ConfigService],\n },\n eventStoreBusConfig,\n ),\n ],\n})\nexport class AppModule {}\n\n```\n\n**custom.command.handler.ts**\n\nThis following is a way to use the command handlers that push to the custom eventBus to the eventstore using aggregate root.\n\n```typescript\nimport { ICommandHandler, CommandHandler } from '@nestjs/cqrs';\nimport { SomeCommand } from '../impl/some.command';\nimport { EventPublisher } from 'nestjs-eventstore'; //this is necessary as it overrides the default publisher\nimport { ObjectAggregate } from '../../models/object.aggregate';\n\n@CommandHandler(SomeCommand)\nexport class SomeCommandHandler\n implements ICommandHandler