Skip to main content
Skip to main content

How to Create a Notification Provider

In this document, you’ll learn how to create a Notification Provider in Medusa.

Note

If you’re unfamiliar with the Notification architecture in Medusa, it is recommended to check out the architecture overview first.

Prerequisites​

Before you start creating a Notification Provider, you need to either install a Medusa backend, or create it in a plugin. The Medusa backend must also have an event bus module installed, which is available when using the default Medusa backend starter.

Create a Notification Provider​

Creating a Notification Provider is as simple as creating a TypeScript or JavaScript file in src/services. The name of the file is the name of the provider (for example, sendgrid.ts). A Notification Provider is essentially a Service that extends the AbstractNotificationService from @medusajs/medusa.

For example, create the file src/services/email-sender.ts with the following content:

src/services/email-sender.ts
import { AbstractNotificationService } from "@medusajs/medusa"
import { EntityManager } from "typeorm"

class EmailSenderService extends AbstractNotificationService {
  protected manager_: EntityManager
  protected transactionManager_: EntityManager

  sendNotification(
    event: string, 
    data: unknown, 
    attachmentGenerator: unknown
  ): Promise<{ 
      to: string; 
      status: string; 
      data: Record<string, unknown>; 
    }> {
    throw new Error("Method not implemented.")
  }
  resendNotification(
    notification: unknown,
    config: unknown,
    attachmentGenerator: unknown
  ): Promise<{
      to: string; 
      status: string; 
      data: Record<string, unknown>; 
    }> {
    throw new Error("Method not implemented.")
  }

}

export default EmailSenderService

Where EmailSenderService is the name of your Notification Provider Service.

Notification Providers must extend NotificationService from medusa-interfaces.

Info

Following the naming convention of Services, the name of the file should be the slug name of the Notification Provider, and the name of the class should be the camel case name of the Notification Provider suffixed with “Service”. In the example above, the name of the file should be email-sender.js. You can learn more in the service documentation.

identifier​

Notification Provider Services must have a static property identifier.

The NotificationProvider entity has 2 properties: identifier and is_installed. The value of the identifier property in the Service class is used when the Notification Provider is created in the database.

The value of this property is also used later when you want to subscribe the Notification Provider to events in a Loader.

For example, in the class you created in the previous code snippet you can add the following property:

class EmailSenderService extends AbstractNotificationService {
  static identifier = "email-sender"
  // ...
}

constructor​

You can use the constructor of your Notification Provider to have access to different Services in Medusa through dependency injection.

You can also use the constructor to initialize your integration with the third-party provider. For example, if you use a client to connect to the third-party provider’s APIs, you can initialize it in the constructor and use it in other methods in the Service.

Additionally, if you’re creating your Notification Provider as an external plugin to be installed on any Medusa backend and you want to access the options added for the plugin, you can access it in the constructor. The options are passed as a second parameter.

Info

You can learn more about plugins and how to create them in the Plugins documentation.

Continuing on with the previous example, if you want to use the OrderService later when sending notifications, you can inject it into the constructor:

import { 
  AbstractNotificationService, 
  OrderService,
} from "@medusajs/medusa"

class EmailSenderService extends AbstractNotificationService {
  protected manager_: EntityManager
  protected transactionManager_: EntityManager
  static identifier = "email-sender"
  protected orderService: OrderService

  constructor(container, options) {
    super(container)
    // you can access options here in case you're
    // using a plugin

    this.orderService = container.orderService
  }

  // ...
}

sendNotification​

When an event is triggered that your Notification Provider is registered as a handler for, the NotificationService in Medusa’s core will execute the sendNotification method of your Notification Provider.

In this method, you can perform the necessary operation to send the Notification. Following the example above, you can send an email to the customer when they place an order.

This method receives three parameters:

  1. eventName: This is the name of the event that was triggered. For example, order.placed.
  2. eventData: This is the data payload of the event that was triggered. For example, if the order.placed event is triggered, the eventData object contains the property id which is the ID of the order that was placed.
  3. attachmentGenerator: If you’ve previously attached a generator to the NotificationService using the registerAttachmentGenerator method, you have access to it here. You can use the attachmentGenerator to generate on-demand invoices or other documents. The default value of this parameter is null.
Info

You can learn more about what events are triggered in Medusa and their data payload in the Events List documentation.

This method must return an object containing two properties:

  1. to: a string that represents the receiver of the Notification. For example, if you sent an email to the customer then to is the email address of the customer. In other cases, it might be a phone number or a username.
  2. data: an object that contains the data used to send the Notification. For example, if you sent an order confirmation email to the customer, then the data object might include the order items or the subject of the email. This data is necessary if the notification is resent later as you can use the same data.

Continuing with the previous example you can have the following implementation of the sendNotification method:

class EmailSenderService extends AbstractNotificationService {
  // ...
  async sendNotification(
    event: string,
    data: any,
    attachmentGenerator: unknown
  ): Promise<{ 
      to: string; 
      status: string; 
      data: Record<string, unknown>; 
    }> {
    if (event === "order.placed") {
      // retrieve order
      const order = await this.orderService.retrieve(data.id)
      // TODO send email

      console.log("Notification sent")
      return {
        to: order.email,
        status: "done",
        data: {
          // any data necessary to send the email
          // for example:
          subject: "You placed a new order!",
          items: order.items,
        },
      }
    }
  }
}

In this code snippet, you check first if the event is order.placed. This can be helpful if you’re handling multiple events using the same Notification Provider.

You then retrieve the order using the ID and send the email. Here, the logic related to sending the email is not implemented as it is generally specific to your Notification Provider.

Finally, you return an object with the to property set to the customer email and the data property is an object that contains data necessary to send the email such as a subject or items.

Note

The to and data properties are used in the NotificationService in Medusa’s core to create a new Notification record in the database. You can learn more about the Notification entity in the Architecture Overview documentation.

resendNotification​

Using the Resend Notification API Route, an admin user can resend a Notification to the customer. The NotificationService in Medusa’s core then executes the resendNotification method in your Notification Provider.

This method receives three parameters:

  1. notification: This is the original Notification record that was created after you sent the notification with sendNotification. You can get an overview of the entity and its attributes in the architecture overview, but most notably it includes the to and data attributes which are populated originally using the to and data properties of the object you return in sendNotification.
  2. config: In the Resend Notification API Route you may specify an alternative receiver of the notification using the to request body parameter. For example, you may want to resend the order confirmation email to a different email. If that’s the case, you have access to it in the config parameter object. Otherwise, config will be an empty object.
  3. attachmentGenerator: If you’ve previously attached a generator to the Notification Service using the registerAttachmentGenerator method, you have access to it here. You can use the attachmentGenerator to generate on-demand invoices or other documents. The default value of this parameter is null.

Similarly to the sendNotification method, this method must return an object containing two properties:

  1. to: a string that represents the receiver of the Notification. You can either return the same to available in the notification parameter or the updated one in the config parameter.
  2. data: an object that contains the data used to send the Notification. You can either return the same data in the notification parameter or make any necessary updates to it.

Continuing with the previous example you can have the following implementation of the resendNotification method:

class EmailSenderService extends AbstractNotificationService {
  // ...
  async resendNotification(
    notification: any,
    config: any,
    attachmentGenerator: unknown
  ): Promise<{ 
      to: string; 
      status: string; 
      data: Record<string, unknown>; 
    }> {
    // check if the receiver should be changed
    const to: string = config.to ? config.to : notification.to

    // TODO resend the notification using the same data
    // that is saved under notification.data

    console.log("Notification resent")
    return {
      to,
      status: "done",
      data: notification.data, // make changes to the data
    }
  }
}

In the above snippet, you check if the to should be changed by checking if the config parameter has a to property. Otherwise, you keep the same to address stored in the notification parameter.

You then resend the email. Here, the logic related to sending the email is not implemented as it is generally specific to your Notification Provider.

Finally, you return an object with the to property set to the email (either new or old) and the data property is the same data used before to send the original notification. you can alternatively make any changes to the data.

Note

The to and data properties are used in the NotificationService in Medusa’s core to create a new Notification record in the database. No changes are made to the original Notification record created after the sendNotification method. This new record is associated with the original Notification record using the parent_id attribute in the entity. You can learn more about the Notification entity in the Architecture Overview documentation.

Subscribe with Loaders​

After creating your Notification Provider Service, you must create a Loader that registers this Service as a notification handler of events.

Following the previous example, to make sure the email-sender Notification Provider handles the order.placed event, create the file src/loaders/notification.ts with the following content:

src/loaders/notification.ts
import { 
  MedusaContainer, 
  NotificationService,
} from "@medusajs/medusa"

export default async (
  container: MedusaContainer
): Promise<void> => {
  const notificationService = container.resolve<
    NotificationService
  >("notificationService")

  notificationService.subscribe(
    "order.placed", 
    "email-sender"
  )
}

This loader accesses the notificationService through the MedusaContainer. The notificationService has a subscribe method that accepts 2 parameters. The first one is the name of the event to subscribe to, and the second is the identifier of the Notification Provider that's subscribing to that event.

Test Sending Notifications with your Notification Provider​

Make sure you have an event bus module configured in your Medusa backend. You can learn more on how to do that in the Configurations guide.

Then, run the build command in the root directory of your Medusa backend:

npm run build

Next, start your Medusa backend:

npx medusa develop

Try now to place an order either using the REST APIs or using the storefront.

Tip

If you don’t have a storefront installed you can get started with the Next.js Starter Template in minutes.

After placing an order, you can see in your console the message “Notification Sent”. If you added your own notification sending logic, you should receive an email or alternatively the type of notification you’ve set up.

Test Resending Notifications with your Notification Provider​

To test resending a notification, first, retrieve the ID of the notification you just sent using the List Notifications API Route. You can pass as a body parameter the to or event_name parameters to filter out the notification you just sent.

Tip

You must be authenticated as an admin user before sending this request. You can use the Authenticate a User API Route to get authenticated.

List Notifications Request

Then, send a request to the Resend Notification API Route using the ID retrieved from the previous request. You can pass the to parameter in the body to change the receiver of the notification. You should see the message “Notification Resent” in your console and if you implemented your own logic for resending the notification it will be resent.

Resend Notifications Request

This request returns the same notification object as the List Notifications API Route, but it now has a new object in the resends array. This is the resent notification. If you supplied a to parameter in the request body, you should see its value in the to property of the resent notification object.

See Also​

Was this section helpful?
© 2023 Medusa, Inc. All rights reserved.