feat: add seller events and store the active sellers in Algolia

packages/framework/src/types/algolia/algolia-seller.ts

@@ -0,0 +1,11 @@
+import { z } from 'zod'
+
+export type AlgoliaSeller = z.infer<typeof AlgoliaSellerValidator>
+export const AlgoliaSellerValidator = z.object({
+  id:  z.string(),
+  store_status: z.string(),
+  name: z.string(),
+  handle: z.string(),
+  description: z.string().nullable(),
+  photo: z.string().nullable()
+})

packages/framework/src/types/algolia/events.ts

@@ -1,7 +1,8 @@
 export enum AlgoliaEvents {
   PRODUCTS_CHANGED = 'algolia.products.changed',
   PRODUCTS_DELETED = 'algolia.products.deleted',
-  REVIEW_CHANGED = 'algolia.reviews.changed'
+  REVIEW_CHANGED = 'algolia.reviews.changed',
+  SELLERS_CHANGED = 'algolia.sellers.changed'
 }
 
 export enum IntermediateEvents {

packages/framework/src/types/algolia/index-types.ts

@@ -1,4 +1,5 @@
 export enum IndexType {
   PRODUCT = 'products',
-  REVIEW = 'reviews'
+  REVIEW = 'reviews',
+  SELLER = 'sellers'
 }

packages/framework/src/types/algolia/index.ts

@@ -2,4 +2,5 @@ export * from './index-types'
 export * from './algolia-entity'
 export * from './algolia-product'
 export * from './algolia-review'
+export * from './algolia-seller'
 export * from './events'

packages/framework/src/types/seller/events.ts

@@ -1,3 +1,5 @@
 export enum SellerEvents {
-  STORE_STATUS_CHANGED = 'seller.store_status_changed'
+  STORE_STATUS_CHANGED = 'seller.store_status_changed',
+  SELLER_CREATED = 'seller.created',
+  SELLER_UPDATED = 'seller.updated'
 }

packages/modules/algolia/src/api/admin/algolia/route.ts

@@ -77,5 +77,6 @@ export const GET = async (req: MedusaRequest, res: MedusaResponse) => {
 
   const appId = algoliaService.getAppId();
   const productIndex = await algoliaService.checkIndex(IndexType.PRODUCT);
-  res.status(200).json({ appId, productIndex });
+  const sellerIndex = await algoliaService.checkIndex(IndexType.SELLER);
+  res.status(200).json({ appId, productIndex, sellerIndex });
 };

packages/modules/algolia/src/subscribers/algolia-sellers-changed.ts

@@ -0,0 +1,34 @@
+import { SubscriberArgs, SubscriberConfig } from "@medusajs/framework";
+
+import { ALGOLIA_MODULE, AlgoliaModuleService } from "../modules/algolia";
+import { AlgoliaEvents, IndexType } from "@mercurjs/framework";
+
+import {
+  filterSellersByStatus,
+  findAndTransformAlgoliaSellers,
+} from "./utils";
+
+export default async function algoliaSellersChangedHandler({
+  event,
+  container,
+}: SubscriberArgs<{ ids: string[] }>) {
+  const algolia = container.resolve<AlgoliaModuleService>(ALGOLIA_MODULE);
+
+  const { actives, other } = await filterSellersByStatus(
+    container,
+    event.data.ids
+  );
+
+  const sellersToInsert = actives.length
+    ? await findAndTransformAlgoliaSellers(container, actives)
+    : [];
+
+  await algolia.batch(IndexType.SELLER, sellersToInsert, other);
+}
+
+export const config: SubscriberConfig = {
+  event: AlgoliaEvents.SELLERS_CHANGED,
+  context: {
+    subscriberId: "algolia-sellers-changed-handler",
+  },
+};

packages/modules/algolia/src/subscribers/utils/algolia-sellers.ts

@@ -0,0 +1,49 @@
+import { z } from 'zod'
+
+import { MedusaContainer } from "@medusajs/framework";
+
+import {
+  ContainerRegistrationKeys,
+  arrayDifference,
+} from "@medusajs/framework/utils";
+
+import { AlgoliaSellerValidator, StoreStatus } from '@mercurjs/framework'
+
+export async function filterSellersByStatus(
+  container: MedusaContainer,
+  ids: string[] = []
+) {
+  const query = container.resolve(ContainerRegistrationKeys.QUERY);
+
+  const { data: sellers } = await query.graph({
+    entity: "seller",
+    fields: ["id", "store_status"],
+    filters: {
+      id: ids,
+    },
+  });
+
+  const actives = sellers.filter((s) => s.store_status === StoreStatus.ACTIVE);
+  const other = arrayDifference(sellers, actives);
+
+  return {
+    actives: sellers.map((p) => p.id),
+    other: other.map((p) => p.id),
+  };
+}
+
+export async function findAndTransformAlgoliaSellers(
+  container: MedusaContainer,
+  ids: string[] = []
+) {
+  const query = container.resolve(ContainerRegistrationKeys.QUERY)
+  const { data: sellers } = await query.graph({
+    entity: 'seller',
+    fields: ['id', 'name', 'handle', 'description', 'photo'],
+    filters: {
+      id: ids
+    }
+  })
+
+  return z.array(AlgoliaSellerValidator).parse(sellers)
+}

packages/modules/algolia/src/subscribers/utils/index.ts

@@ -1,2 +1,3 @@
 export * from './algolia-product'
 export * from './algolia-reviews'
+export * from './algolia-sellers'

packages/modules/b2c-core/src/subscribers/algolia-seller-created.ts

@@ -0,0 +1,21 @@
+import { SubscriberArgs, SubscriberConfig } from '@medusajs/framework'
+import { AlgoliaEvents, Modules, SellerEvents } from '@mercurjs/framework'
+
+export default async function sellerCreatedHandler({
+    event,
+    container
+}: SubscriberArgs<{ ids: string[] }>) {
+    const eventBus = container.resolve(Modules.EVENT_BUS)
+
+    await eventBus.emit({
+        name: AlgoliaEvents.SELLERS_CHANGED,
+        data: { ids: event.data.ids }
+    })
+}
+
+export const config: SubscriberConfig = {
+    event: SellerEvents.SELLER_CREATED,
+    context: {
+        subscriberId: 'seller-created-handler'
+    }
+}

packages/modules/b2c-core/src/subscribers/algolia-seller-updated.ts

@@ -0,0 +1,21 @@
+import { SubscriberArgs, SubscriberConfig } from '@medusajs/framework'
+import { AlgoliaEvents, Modules, SellerEvents } from '@mercurjs/framework'
+
+export default async function sellerUpdatedHandler({
+    event,
+    container
+}: SubscriberArgs<{ ids: string[] }>) {
+    const eventBus = container.resolve(Modules.EVENT_BUS)
+
+    await eventBus.emit({
+        name: AlgoliaEvents.SELLERS_CHANGED,
+        data: { ids: event.data.ids }
+    })
+}
+
+export const config: SubscriberConfig = {
+    event: SellerEvents.SELLER_UPDATED,
+    context: {
+        subscriberId: 'seller-updated-handler'
+    }
+}

packages/modules/b2c-core/src/workflows/seller/workflows/create-seller.ts

@@ -1,12 +1,12 @@
 import { transform } from "@medusajs/framework/workflows-sdk";
-import { setAuthAppMetadataStep } from "@medusajs/medusa/core-flows";
+import { emitEventStep, setAuthAppMetadataStep } from "@medusajs/medusa/core-flows";
 import {
   WorkflowResponse,
   createHook,
   createWorkflow,
 } from "@medusajs/workflows-sdk";
 
-import { CreateMemberDTO, CreateSellerDTO } from "@mercurjs/framework";
+import { CreateMemberDTO, CreateSellerDTO, SellerEvents } from "@mercurjs/framework";
 
 import {
   createMemberStep,
@@ -47,6 +47,14 @@ export const createSellerWorkflow = createWorkflow(
     const sellerCreatedHook = createHook("sellerCreated", {
       sellerId: seller.id,
     });
+
+    emitEventStep({
+      eventName: SellerEvents.SELLER_CREATED,
+      data: {
+        ids: [seller.id],
+      }
+    });
+
     return new WorkflowResponse(seller, { hooks: [sellerCreatedHook] });
   }
 );

packages/modules/b2c-core/src/workflows/seller/workflows/update-seller.ts

@@ -1,12 +1,31 @@
-import { WorkflowResponse, createWorkflow } from '@medusajs/workflows-sdk'
+import {
+  WorkflowResponse,
+  createHook, createWorkflow
+} from '@medusajs/workflows-sdk'
 
-import { UpdateSellerDTO } from '@mercurjs/framework'
+import { SellerEvents, UpdateSellerDTO } from '@mercurjs/framework'
 
 import { updateSellerStep } from '../steps'
+import { emitEventStep } from '@medusajs/medusa/core-flows'
 
 export const updateSellerWorkflow = createWorkflow(
   'update-seller',
   function (input: UpdateSellerDTO) {
-    return new WorkflowResponse(updateSellerStep(input))
+    const seller = updateSellerStep(input)
+
+    const sellerUpdatedHook = createHook("sellerUpdated", {
+      sellerId: seller.id,
+    });
+
+    emitEventStep({
+      eventName: SellerEvents.SELLER_UPDATED,
+      data: {
+        ids: [seller.id],
+      }
+    })
+
+    return new WorkflowResponse(seller, {
+      hooks: [sellerUpdatedHook],
+    });
   }
 )