slack.js

Go to the documentation of this file.

/**
 * @file slack.js
 * @module routes/slack
 * @description Slack integration configuration endpoints. Manages tenant-specific Slack webhook
 * settings for notifications and alerting. Stores webhook URLs in integrations table.
 * @requires express
 * @requires services/db
 * @author RMM-PSA Development Team
 * @copyright 2026 RMM-PSA Platform
 * @license Proprietary
 */
 
/**
 * @apiDefine Slack Slack Integration
 * Slack notification integration configuration
 */
 
const express = require('express');
const router = express.Router();
const pool = require('../services/db');
 
/**
 * @api {post} /api/slack/settings/:tenant_id Save Slack settings
 * @apiName SaveSlackSettings
 * @apiGroup Slack
 * @apiDescription Save or update Slack webhook URL for a tenant. Webhook URL used for
 * sending notifications to Slack channels. Stored in integrations table with type='slack'.
 * @apiParam {string} tenant_id Tenant ID
 * @apiParam {object} slack Slack configuration object
 * @apiParam {string} slack.webhookUrl Slack incoming webhook URL
 * @apiSuccess {boolean} success=true Settings saved successfully
 * @apiError {string} error="Missing Slack webhook URL" (400) webhookUrl not provided
 * @apiError {string} error="Failed to save Slack settings" (500) Database save failed
 * @apiExample {curl} Example:
 *   curl -X POST http://localhost:3000/api/slack/settings/123 \\
 *     -H "Content-Type: application/json" \\
 *     -d '{"slack": {"webhookUrl": "https://hooks.slack.com/services/T00000000/B00000000/XXXXXXXXXXXXXXXXXXXX"}}'
 * @apiSuccessExample {json} Success-Response:
 *   HTTP/1.1 200 OK
 *   {
 *     "success": true
 *   }
 */
router.post('/settings/:tenant_id', async (req, res) => {
  const { tenant_id } = req.params;
  const { slack } = req.body;
  if (!slack || !slack.webhookUrl) return res.status(400).json({ error: 'Missing Slack webhook URL' });
  try {
    await pool.query(
      `INSERT INTO integrations (tenant_id, integration_type, config, is_active)
       VALUES ($1, 'slack', $2, true)
       ON CONFLICT (tenant_id, integration_type)
       DO UPDATE SET config = EXCLUDED.config, is_active = true`,
      [tenant_id, JSON.stringify(slack)]
    );
    res.json({ success: true });
  } catch (err) {
    res.status(500).json({ error: 'Failed to save Slack settings', details: err.message });
  }
});
 
/**
 * @api {get} /api/slack/settings/:tenant_id Get Slack settings
 * @apiName GetSlackSettings
 * @apiGroup Slack
 * @apiDescription Retrieve Slack webhook configuration for a tenant. Returns the config
 * object containing webhookUrl.
 * @apiParam {string} tenant_id Tenant ID
 * @apiSuccess {object} config Slack configuration object
 * @apiSuccess {string} config.webhookUrl Slack incoming webhook URL
 * @apiError {string} error="Slack not configured for tenant" (404) No Slack config found
 * @apiError {string} error="Failed to fetch Slack settings" (500) Database query failed
 * @apiExample {curl} Example:
 *   curl -X GET http://localhost:3000/api/slack/settings/123
 * @apiSuccessExample {json} Success-Response:
 *   HTTP/1.1 200 OK
 *   {
 *     "webhookUrl": "https://hooks.slack.com/services/T00000000/B00000000/XXXXXXXXXXXXXXXXXXXX"
 *   }
 */
router.get('/settings/:tenant_id', async (req, res) => {
  const { tenant_id } = req.params;
  try {
    const result = await pool.query(
      `SELECT config FROM integrations WHERE tenant_id = $1 AND integration_type = 'slack' AND is_active = true LIMIT 1`,
      [tenant_id]
    );
    if (!result.rows.length) return res.status(404).json({ error: 'Slack not configured for tenant' });
    res.json(result.rows[0].config);
  } catch (err) {
    res.status(500).json({ error: 'Failed to fetch Slack settings', details: err.message });
  }
});
 
module.exports = router;