cds-plugin.js

const cds = require('@sap/cds')
if (!cds.env.requires?.notifications?.enabled) return 

const { buildNotificationFromEvent } = require('./lib/utils')
cds.build?.register?.('notifications', require("./lib/build"))

cds.on("loaded", m => {
  for (const def of Object.values(m.definitions)) {
    if (def.kind !== 'event') continue
    if (!Object.keys(def).some(k => k === '@notification' || k.startsWith('@notification.'))) continue
    if (!def.elements) def.elements = {}
    if (!def.elements.recipients) {
      def.elements.recipients = { items: { type: 'cds.String' } }
    }
  }
})

cds.on('serving', service => {
  if (service.name === 'notifications' || service instanceof cds.DatabaseService) return
  service.on('*', async (req, next) => {
    let def = req.target ?? service.events?.[req.event]
    if (!def || def.kind !== 'event') return next()
    if (!Object.keys(def).some(k => k === '@notification' || k.startsWith('@notification.'))) return next()
    if (!def.name) def = { ...def, name: req.event }
    const notifications = await cds.connect.to('notifications')
    const notification = await buildNotificationFromEvent(def, req.data)
    try {
      await notifications.notify(notification)
    } catch (err) {
      const LOG = cds.log('notifications')
      LOG._error && LOG.error('Failed to send notification for event', def.name, err)
    }
    return next()
  })
})

cds.once("served", async () => {
  const { validateNotificationTypes, readFile } = require("./lib/utils")
  const { createNotificationTypesMap } = require("./lib/notificationTypes")
  const { notificationTypesFromModel } = require("./lib/compile")
  const production = cds.env.profiles?.includes("production")

  const typesPath = cds.env.requires?.notifications?.types
  const kind = cds.env.requires?.notifications?.kind
  const needsProcessing = kind === 'notify-to-rest' || !production
  if (!needsProcessing) return

  const model = cds.context?.model ?? cds.model
  const notificationTypes = [
    ...notificationTypesFromModel(model),
    ...( typesPath ? readFile(typesPath) : [] )
  ]

  if (validateNotificationTypes(notificationTypes)) {
    if (kind === 'notify-to-rest') {
      const { processNotificationTypes } = require('./lib/notificationTypes')
      // deploy automatically on startup
      await processNotificationTypes(notificationTypes)
    } else if (!production) {
      const notificationTypesMap = createNotificationTypesMap(notificationTypes, true)
      cds.notifications = { local: { types: notificationTypesMap } }
    }
  }

  require("@sap-cloud-sdk/util").setGlobalLogLevel("error")
})