feat(medusa): Bulk emit events (#3407)

.changeset/serious-avocados-rush.md

@@ -0,0 +1,7 @@
+---
+"@medusajs/inventory": patch
+"medusa-test-utils": patch
+"@medusajs/medusa": patch
+---
+
+feat(medusa): Bulk emit events

integration-tests/plugins/__tests__/inventory/service.js

@@ -3,7 +3,7 @@ const path = require("path")
 const { bootstrapApp } = require("../../../helpers/bootstrap-app")
 const { initDb, useDb } = require("../../../helpers/use-db")
 
-jest.setTimeout(30000)
+jest.setTimeout(50000)
 
 describe("Inventory Module", () => {
  let appContainer

packages/inventory/src/services/reservation-item.ts

@@ -1,17 +1,16 @@
 import { EntityManager } from "typeorm"
 import { isDefined, MedusaError } from "medusa-core-utils"
 import {
- FindConfig,
  buildQuery,
- IEventBusService,
- FilterableReservationItemProps,
  CreateReservationItemInput,
+ FilterableReservationItemProps,
+ FindConfig,
+ IEventBusService,
  TransactionBaseService,
  UpdateReservationItemInput,
 } from "@medusajs/medusa"
 
 import { ReservationItem } from "../models"
-import { CONNECTION_NAME } from "../config"
 import { InventoryLevelService } from "."
 
 type InjectedDependencies = {
@@ -278,10 +277,12 @@ export default class ReservationItemService extends TransactionBaseService {
  item.quantity * -1
  ),
  ])
- })
 
- await this.eventBusService_.emit(ReservationItemService.Events.DELETED, {
- id: reservationItemId,
+ await this.eventBusService_
+ .withTransaction(manager)
+ .emit(ReservationItemService.Events.DELETED, {
+ id: reservationItemId,
+ })
  })
  }
 }

packages/medusa-test-utils/src/mock-repository.js

@@ -12,6 +12,8 @@ class MockRepo {
  save,
  findAndCount,
  del,
+ count,
+ insertBulk
  }) {
  this.create_ = create;
  this.update_ = update;
@@ -25,12 +27,19 @@ class MockRepo {
  this.save_ = save;
  this.findAndCount_ = findAndCount;
  this.findOneWithRelations_ = findOneWithRelations;
+ this.insertBulk_ = insertBulk;
  }
 
  setFindOne(fn) {
  this.findOne_ = fn;
  }
 
+ insertBulk = jest.fn().mockImplementation((...args) => {
+ if (this.insertBulk_) {
+ return this.insertBulk_(...args)
+ }
+ return {}
+ })
  create = jest.fn().mockImplementation((...args) => {
  if (this.create_) {
  return this.create_(...args);

packages/medusa/src/repositories/staged-job.ts

@@ -1,5 +1,28 @@
 import { EntityRepository, Repository } from "typeorm"
-import { StagedJob } from "../models/staged-job"
+import { QueryDeepPartialEntity } from "typeorm/query-builder/QueryPartialEntity"
+import { StagedJob } from "../models"
+import { rowSqlResultsToEntityTransformer } from "../utils"
 
 @EntityRepository(StagedJob)
-export class StagedJobRepository extends Repository<StagedJob> {}
+export class StagedJobRepository extends Repository<StagedJob> {
+ async insertBulk(jobToCreates: QueryDeepPartialEntity<StagedJob>[]) {
+ const queryBuilder = this.createQueryBuilder()
+ .insert()
+ .into(StagedJob)
+ .values(jobToCreates)
+
+ // TODO: remove if statement once this issue is resolved https:/typeorm/typeorm/issues/9850
+ if (!queryBuilder.connection.driver.isReturningSqlSupported("insert")) {
+ const rawStagedJobs = await queryBuilder.execute()
+ return rawStagedJobs.generatedMaps
+ }
+
+ const rawStagedJobs = await queryBuilder.returning("*").execute()
+
+ return rowSqlResultsToEntityTransformer(
+ rawStagedJobs.raw,
+ queryBuilder,
+ this.queryRunner!
+ )
+ }
+}