feat(nestjs-mikro-orm-request-context): init

packages/nestjs-mikro-orm-request-context/package.json

@@ -0,0 +1,45 @@
+{
+  "name": "@atls/nestjs-mikro-orm-request-context",
+  "version": "0.0.0",
+  "license": "BSD-3-Clause",
+  "type": "module",
+  "exports": {
+    "./package.json": "./package.json",
+    ".": "./src/index.ts"
+  },
+  "main": "src/index.ts",
+  "files": [
+    "dist"
+  ],
+  "scripts": {
+    "build": "yarn library build",
+    "prepack": "yarn run build",
+    "postpack": "rm -rf dist"
+  },
+  "devDependencies": {
+    "@mikro-orm/core": "5.7.12",
+    "@nestjs/common": "10.0.5",
+    "@nestjs/core": "10.0.5",
+    "reflect-metadata": "0.2.2",
+    "rxjs": "7.8.1"
+  },
+  "peerDependencies": {
+    "@mikro-orm/core": "^5",
+    "@nestjs/common": "^10",
+    "@nestjs/core": "^10",
+    "reflect-metadata": "^0.2",
+    "rxjs": "^7"
+  },
+  "publishConfig": {
+    "exports": {
+      "./package.json": "./package.json",
+      ".": {
+        "import": "./dist/index.js",
+        "types": "./dist/index.d.ts",
+        "default": "./dist/index.js"
+      }
+    },
+    "main": "dist/index.js",
+    "typings": "dist/index.d.ts"
+  }
+}

packages/nestjs-mikro-orm-request-context/src/index.ts

@@ -0,0 +1,2 @@
+export * from './interceptors/index.js'
+export * from './module/index.js'

packages/nestjs-mikro-orm-request-context/src/interceptors/index.ts

@@ -0,0 +1 @@
+export * from './mikro-orm-request-context.interceptor.js'

packages/nestjs-mikro-orm-request-context/src/interceptors/mikro-orm-request-context.interceptor.ts

@@ -0,0 +1,35 @@
+import type { NestInterceptor }  from '@nestjs/common'
+import type { ExecutionContext } from '@nestjs/common'
+import type { CallHandler }      from '@nestjs/common'
+
+import { RequestContext }        from '@mikro-orm/core'
+import { MikroORM }              from '@mikro-orm/core'
+import { Injectable }            from '@nestjs/common'
+import { Observable }            from 'rxjs'
+
+@Injectable()
+export class MikroORMRequestContextInterceptor implements NestInterceptor {
+  constructor(private readonly orm: MikroORM) {}
+
+  intercept(_: ExecutionContext, next: CallHandler): Observable<any> {
+    return new Observable((subscriber) => {
+      RequestContext.createAsync(
+        this.orm.em,
+        async () =>
+          new Promise<void>((resolve) => {
+            next.handle().subscribe(
+              (result) => {
+                subscriber.next(result)
+                subscriber.complete()
+                resolve()
+              },
+              (error) => {
+                subscriber.error(error)
+                resolve()
+              }
+            )
+          })
+      )
+    })
+  }
+}

packages/nestjs-mikro-orm-request-context/src/module/index.ts

@@ -0,0 +1 @@
+export * from './mikro-orm-request-context.module.js'

packages/nestjs-mikro-orm-request-context/src/module/mikro-orm-request-context.module.ts

@@ -0,0 +1,24 @@
+import type { DynamicModule }                from '@nestjs/common'
+
+import { MikroORM }                          from '@mikro-orm/core'
+import { Module }                            from '@nestjs/common'
+import { APP_INTERCEPTOR }                   from '@nestjs/core'
+
+import { MikroORMRequestContextInterceptor } from '../interceptors/index.js'
+
+@Module({})
+export class MikroORMRequestContextModule {
+  static forInterceptor(options = {}): DynamicModule {
+    return {
+      ...options,
+      module: MikroORMRequestContextModule,
+      providers: [
+        {
+          provide: APP_INTERCEPTOR,
+          useFactory: (orm: MikroORM) => new MikroORMRequestContextInterceptor(orm),
+          inject: [MikroORM],
+        },
+      ],
+    }
+  }
+}

yarn.lock

@@ -873,6 +873,24 @@ __metadata:
   languageName: unknown
   linkType: soft
 
+"@atls/nestjs-mikro-orm-request-context@workspace:packages/nestjs-mikro-orm-request-context":
+  version: 0.0.0-use.local
+  resolution: "@atls/nestjs-mikro-orm-request-context@workspace:packages/nestjs-mikro-orm-request-context"
+  dependencies:
+    "@mikro-orm/core": "npm:5.7.12"
+    "@nestjs/common": "npm:10.0.5"
+    "@nestjs/core": "npm:10.0.5"
+    reflect-metadata: "npm:0.2.2"
+    rxjs: "npm:7.8.1"
+  peerDependencies:
+    "@mikro-orm/core": ^5
+    "@nestjs/common": ^10
+    "@nestjs/core": ^10
+    reflect-metadata: ^0.2
+    rxjs: ^7
+  languageName: unknown
+  linkType: soft
+
 "@atls/nestjs-proto-types@workspace:*, @atls/nestjs-proto-types@workspace:packages/nestjs-proto-types":
   version: 0.0.0-use.local
   resolution: "@atls/nestjs-proto-types@workspace:packages/nestjs-proto-types"