How to connect Replit with Slack

1// src/utils/slack.js
2async function sendSlackNotification(message) {
3  const webhookUrl = process.env.SLACK_WEBHOOK_URL;
4  if (!webhookUrl) {
5    console.warn('SLACK_WEBHOOK_URL not set. Skipping notification.');
6    return;
7  }
8
9  try {
10    const response = await fetch(webhookUrl, {
11      method: 'POST',
12      headers: { 'Content-Type': 'application/json' },
13      body: JSON.stringify({ text: message }),
14    });
15
16    if (!response.ok) {
17      console.error('Slack notification failed:', response.status);
18    }
19  } catch (error) {
20    console.error('Failed to send Slack notification:', error.message);
21  }
22}
23
24module.exports = { sendSlackNotification };

1// Rich notification with Block Kit formatting
2async function sendRichNotification({ title, fields, color }) {
3  const webhookUrl = process.env.SLACK_WEBHOOK_URL;
4  if (!webhookUrl) return;
5
6  const blocks = [
7    {
8      type: 'header',
9      text: { type: 'plain_text', text: title }
10    },
11    {
12      type: 'section',
13      fields: fields.map(f => ({
14        type: 'mrkdwn',
15        text: `*${f.label}:*\n${f.value}`
16      }))
17    },
18    {
19      type: 'context',
20      elements: [{
21        type: 'mrkdwn',
22        text: `Sent from Replit at ${new Date().toISOString()}`
23      }]
24    }
25  ];
26
27  try {
28    await fetch(webhookUrl, {
29      method: 'POST',
30      headers: { 'Content-Type': 'application/json' },
31      body: JSON.stringify({ blocks }),
32    });
33  } catch (error) {
34    console.error('Slack rich notification failed:', error.message);
35  }
36}
37
38// Usage example
39sendRichNotification({
40  title: 'New User Signup',
41  fields: [
42    { label: 'Email', value: 'alice@example.com' },
43    { label: 'Plan', value: 'Pro' },
44    { label: 'Source', value: 'Google Ads' },
45  ],
46});

1// In your user registration route
2const { sendSlackNotification } = require('../utils/slack');
3
4router.post('/register', async (req, res, next) => {
5  try {
6    const { email, name } = req.body;
7    const result = await db.query(
8      'INSERT INTO users (email, name) VALUES ($1, $2) RETURNING *',
9      [email, name]
10    );
11    const user = result.rows[0];
12    res.status(201).json(user);
13
14    // Fire-and-forget — do not await
15    sendSlackNotification(
16      `New user registered: ${user.name} (${user.email})`
17    );
18  } catch (err) {
19    next(err);
20  }
21});
22
23// In your error handler
24function errorHandler(err, req, res, next) {
25  console.error(err.message);
26  sendSlackNotification(
27    `Error in ${req.method} ${req.path}: ${err.message}`
28  );
29  res.status(500).json({ error: 'Internal server error' });
30}