fredy/lib/notification/notify.js

/*
 * Copyright (c) 2026 by Christian Kellner.
 * Licensed under Apache-2.0 with Commons Clause and Attribution/Naming Clause
 */

import fs from 'fs';
import logger from '../services/logger.js';
const path = './adapter';

/** Read every integration existing in ./adapter **/
const adapter = await Promise.all(
  fs
    .readdirSync('./lib/notification/adapter')
    .filter((file) => file.endsWith('.js'))
    .map(async (integPath) => await import(`${path}/${integPath}`)),
);

if (adapter.length === 0) {
  throw new Error('Please specify at least one notification provider');
}
const findAdapter = (notificationAdapter) => {
  return adapter.find((a) => a.config.id === notificationAdapter.id);
};
export const send = (serviceName, newListings, notificationConfig, jobKey, baseUrl) => {
  //this is not being used in tests, therefore adapter are always set
  return notificationConfig
    .map((notificationAdapter) => {
      const found = findAdapter(notificationAdapter);
      if (!found) {
        logger.warn(`Notification adapter '${notificationAdapter.id}' not found for job '${jobKey || ''}'`);
      }
      return found;
    })
    .filter(Boolean)
    .map((a) => a.send({ serviceName, newListings, notificationConfig, jobKey, baseUrl }));
};