diff --git a/packages/core/core-flows/src/invite/workflows/refresh-invite-tokens.ts b/packages/core/core-flows/src/invite/workflows/refresh-invite-tokens.ts index 165acd9eab..8118c95aff 100644 --- a/packages/core/core-flows/src/invite/workflows/refresh-invite-tokens.ts +++ b/packages/core/core-flows/src/invite/workflows/refresh-invite-tokens.ts @@ -3,8 +3,11 @@ import { WorkflowData, WorkflowResponse, createWorkflow, + transform, } from "@medusajs/workflows-sdk" +import { InviteWorkflowEvents } from "@medusajs/utils" +import { emitEventStep } from "../../common" import { refreshInviteTokensStep } from "../steps/refresh-invite-tokens" export const refreshInviteTokensWorkflowId = "refresh-invite-tokens-workflow" @@ -16,6 +19,19 @@ export const refreshInviteTokensWorkflow = createWorkflow( ( input: WorkflowData ): WorkflowResponse => { - return new WorkflowResponse(refreshInviteTokensStep(input.invite_ids)) + const invites = refreshInviteTokensStep(input.invite_ids) + + const invitesIdEvents = transform({ invites }, ({ invites }) => { + return invites.map((v) => { + return { id: v.id } + }) + }) + + emitEventStep({ + eventName: InviteWorkflowEvents.RESENT, + data: invitesIdEvents, + }) + + return new WorkflowResponse(invites) } ) diff --git a/packages/core/utils/src/core-flows/events.ts b/packages/core/utils/src/core-flows/events.ts index 3c1b16e4c2..84d361b3be 100644 --- a/packages/core/utils/src/core-flows/events.ts +++ b/packages/core/utils/src/core-flows/events.ts @@ -44,6 +44,7 @@ export const InviteWorkflowEvents = { ACCEPTED: "invite.accepted", CREATED: "invite.created", DELETED: "invite.deleted", + RESENT: "invite.resent", } export const RegionWorkflowEvents = {