/*!
 * Copyright (c) 2024 PLANKA Software GmbH
 * Licensed under the Fair Use License: https://github.com/plankanban/planka/blob/master/LICENSE.md
 */

const { execFile } = require('child_process');
const path = require('path');
const util = require('util');

const PYTHON_PATH =
  process.platform === 'win32'
    ? path.join(sails.config.appPath, '.venv', 'Scripts', 'python.exe')
    : path.join(sails.config.appPath, '.venv', 'bin', 'python');

const promisifyExecFile = util.promisify(execFile);

module.exports = {
  inputs: {
    services: {
      type: 'json',
      required: true,
    },
    title: {
      type: 'string',
      required: true,
    },
    bodyByFormat: {
      type: 'json',
      required: true,
    },
  },

  async fn(inputs) {
    const { appriseEnabled, appriseAllowedSchemas, appriseBlockedSchemas } = sails.config.custom;

    if (!appriseEnabled) {
      return;
    }

    const schemaConfig = JSON.stringify({
      allowedSchemas: appriseAllowedSchemas,
      blockedSchemas: appriseBlockedSchemas,
    });

    try {
      await promisifyExecFile(
        PYTHON_PATH,
        [
          path.join(sails.config.appPath, 'utils', 'send_notifications.py'),
          JSON.stringify(inputs.services),
          inputs.title,
          JSON.stringify(inputs.bodyByFormat),
          schemaConfig,
        ],
        {
          env: {
            HTTP_PROXY: sails.config.custom.outgoingProxy,
            HTTPS_PROXY: sails.config.custom.outgoingProxy,
          },
        },
      );
    } catch (error) {
      sails.log.error(`Error sending notifications:\n${error.stderr || error.message}`);
    }
  },
};