tweak strapi 4.15.0 webhooks

webhook-runner.js

"use strict";
const createDebugger = require("debug");
const _ = require("lodash");
const workerQueue = require("./worker-queue.js");
const _interopDefault = (e) => e && e.__esModule ? e : { default: e };
const createDebugger__default = /* @__PURE__ */ _interopDefault(createDebugger);
const ___default = /* @__PURE__ */ _interopDefault(_);
const debug = createDebugger__default.default("strapi:webhook");
const defaultConfiguration = {
  defaultHeaders: {}
};
class WebhookRunner {
  eventHub;
  logger;
  config;
  webhooksMap = /* @__PURE__ */ new Map();
  listeners = /* @__PURE__ */ new Map();
  queue;
  fetch;
  constructor({ eventHub, logger, configuration = {}, fetch }) {
    debug("Initialized webhook runner");
    this.eventHub = eventHub;
    this.logger = logger;
    this.fetch = fetch;
    if (typeof configuration !== "object") {
      throw new Error(
        "Invalid configuration provided to the webhookRunner.\nCheck your server.json -> webhooks configuration"
      );
    }
    this.config = ___default.default.merge(defaultConfiguration, configuration);
    this.queue = new workerQueue({ logger, concurrency: 5 });
    this.queue.subscribe(this.executeListener.bind(this));
  }
  deleteListener(event) {
    debug(`Deleting listener for event '${event}'`);
    const fn = this.listeners.get(event);
    if (fn !== void 0) {
      this.eventHub.off(event, fn);
      this.listeners.delete(event);
    }
  }
  createListener(event) {
    debug(`Creating listener for event '${event}'`);
    if (this.listeners.has(event)) {
      this.logger.error(
        `The webhook runner is already listening for the event '${event}'. Did you mean to call .register() ?`
      );
    }
    const listen = async (info) => {
      this.queue.enqueue({ event, info });
    };
    this.listeners.set(event, listen);
    this.eventHub.on(event, listen);
  }
  async executeListener({ event, info }) {
    debug(`Executing webhook for event '${event}'`);
    const webhooks = this.webhooksMap.get(event) || [];
    const activeWebhooks = webhooks.filter((webhook) => webhook.isEnabled === true);
    if (['availability', 'rate', 'rate-plan', 'cabin', 'apaleo-configuration', 'guest', 'booker', 'booking', 'reservation', 'person', 'waitlist-notification', 'sent-notification', 'call', 'sanity-transaction'].includes(info.model)) {
      debug(`skipping '${info.model}'`);
      return;
    }
    for (const webhook of activeWebhooks) {
      await this.run(webhook, event, info).catch((error) => {
        this.logger.error("Error running webhook");
        this.logger.error(error);
      });
    }
  }
  run(webhook, event, info = {}) {
    const { url, headers } = webhook;
    return this.fetch(url, {
      method: "post",
      body: JSON.stringify({
        event,
        createdAt: /* @__PURE__ */ new Date(),
        ...info
      }),
      headers: {
        ...this.config.defaultHeaders,
        ...headers,
        "X-Strapi-Event": event,
        "Content-Type": "application/json"
      },
      timeout: 1e4
    }).then(async (res) => {
      if (res.ok) {
        return {
          statusCode: res.status
        };
      }
      return {
        statusCode: res.status,
        message: await res.text()
      };
    }).catch((err) => {
      return {
        statusCode: 500,
        message: err.message
      };
    });
  }
  add(webhook) {
    debug(`Registering webhook '${webhook.id}'`);
    const { events } = webhook;
    events.forEach((event) => {
      if (this.webhooksMap.has(event)) {
        this.webhooksMap.get(event)?.push(webhook);
      } else {
        this.webhooksMap.set(event, [webhook]);
        this.createListener(event);
      }
    });
  }
  update(webhook) {
    debug(`Refreshing webhook '${webhook.id}'`);
    this.remove(webhook);
    this.add(webhook);
  }
  remove(webhook) {
    debug(`Unregistering webhook '${webhook.id}'`);
    this.webhooksMap.forEach((webhooks, event) => {
      const filteredWebhooks = webhooks.filter((value) => value.id !== webhook.id);
      if (filteredWebhooks.length === 0) {
        this.webhooksMap.delete(event);
        this.deleteListener(event);
      } else {
        this.webhooksMap.set(event, filteredWebhooks);
      }
    });
  }
}
function createWebhookRunner(opts) {
  return new WebhookRunner(opts);
}
module.exports = createWebhookRunner;
//# sourceMappingURL=webhook-runner.js.map

webhook-runner.mjs

import createDebugger from "debug";
import _ from "lodash";
import WorkerQueue from "./worker-queue.mjs";
const debug = createDebugger("strapi:webhook");
const defaultConfiguration = {
  defaultHeaders: {}
};
class WebhookRunner {
  eventHub;
  logger;
  config;
  webhooksMap = /* @__PURE__ */ new Map();
  listeners = /* @__PURE__ */ new Map();
  queue;
  fetch;
  constructor({ eventHub, logger, configuration = {}, fetch }) {
    debug("Initialized webhook runner");
    this.eventHub = eventHub;
    this.logger = logger;
    this.fetch = fetch;
    if (typeof configuration !== "object") {
      throw new Error(
        "Invalid configuration provided to the webhookRunner.\nCheck your server.json -> webhooks configuration"
      );
    }
    this.config = _.merge(defaultConfiguration, configuration);
    this.queue = new WorkerQueue({ logger, concurrency: 5 });
    this.queue.subscribe(this.executeListener.bind(this));
  }
  deleteListener(event) {
    debug(`Deleting listener for event '${event}'`);
    const fn = this.listeners.get(event);
    if (fn !== void 0) {
      this.eventHub.off(event, fn);
      this.listeners.delete(event);
    }
  }
  createListener(event) {
    debug(`Creating listener for event '${event}'`);
    if (this.listeners.has(event)) {
      this.logger.error(
        `The webhook runner is already listening for the event '${event}'. Did you mean to call .register() ?`
      );
    }
    const listen = async (info) => {
      this.queue.enqueue({ event, info });
    };
    this.listeners.set(event, listen);
    this.eventHub.on(event, listen);
  }
  async executeListener({ event, info }) {
    debug(`Executing webhook for event '${event}'`);
    const webhooks = this.webhooksMap.get(event) || [];
    const activeWebhooks = webhooks.filter((webhook) => webhook.isEnabled === true);
    if (['availability', 'rate', 'rate-plan', 'cabin', 'apaleo-configuration', 'guest', 'booker', 'booking', 'reservation', 'person', 'waitlist-notification', 'sent-notification', 'call', 'sanity-transaction'].includes(info.model)) {
      debug(`skipping '${info.model}'`);
      return;
    }
    for (const webhook of activeWebhooks) {
      await this.run(webhook, event, info).catch((error) => {
        this.logger.error("Error running webhook");
        this.logger.error(error);
      });
    }
  }
  run(webhook, event, info = {}) {
    const { url, headers } = webhook;
    return this.fetch(url, {
      method: "post",
      body: JSON.stringify({
        event,
        createdAt: /* @__PURE__ */ new Date(),
        ...info
      }),
      headers: {
        ...this.config.defaultHeaders,
        ...headers,
        "X-Strapi-Event": event,
        "Content-Type": "application/json"
      },
      timeout: 1e4
    }).then(async (res) => {
      if (res.ok) {
        return {
          statusCode: res.status
        };
      }
      return {
        statusCode: res.status,
        message: await res.text()
      };
    }).catch((err) => {
      return {
        statusCode: 500,
        message: err.message
      };
    });
  }
  add(webhook) {
    debug(`Registering webhook '${webhook.id}'`);
    const { events } = webhook;
    events.forEach((event) => {
      if (this.webhooksMap.has(event)) {
        this.webhooksMap.get(event)?.push(webhook);
      } else {
        this.webhooksMap.set(event, [webhook]);
        this.createListener(event);
      }
    });
  }
  update(webhook) {
    debug(`Refreshing webhook '${webhook.id}'`);
    this.remove(webhook);
    this.add(webhook);
  }
  remove(webhook) {
    debug(`Unregistering webhook '${webhook.id}'`);
    this.webhooksMap.forEach((webhooks, event) => {
      const filteredWebhooks = webhooks.filter((value) => value.id !== webhook.id);
      if (filteredWebhooks.length === 0) {
        this.webhooksMap.delete(event);
        this.deleteListener(event);
      } else {
        this.webhooksMap.set(event, filteredWebhooks);
      }
    });
  }
}
function createWebhookRunner(opts) {
  return new WebhookRunner(opts);
}
export {
  createWebhookRunner as default
};
//# sourceMappingURL=webhook-runner.mjs.map