How to Integrate Replit with Intercom

1// intercom-contacts.js — Node.js contact management
2const INTERCOM_BASE = 'https://api.intercom.io';
3
4async function intercomRequest(method, endpoint, body = null) {
5  const token = process.env.INTERCOM_ACCESS_TOKEN;
6  if (!token) throw new Error('INTERCOM_ACCESS_TOKEN secret not set');
7
8  const options = {
9    method,
10    headers: {
11      'Authorization': `Bearer ${token}`,
12      'Accept': 'application/json',
13      'Content-Type': 'application/json',
14      'Intercom-Version': '2.11'
15    }
16  };
17  if (body) options.body = JSON.stringify(body);
18
19  const response = await fetch(`${INTERCOM_BASE}${endpoint}`, options);
20  const data = await response.json();
21
22  if (!response.ok) {
23    throw new Error(`Intercom API error ${response.status}: ${JSON.stringify(data)}`);
24  }
25  return data;
26}
27
28// Create or update a contact by email (upsert)
29async function upsertContact({ email, name, phone, customAttributes = {} }) {
30  // Search for existing contact first
31  const searchResult = await intercomRequest('POST', '/contacts/search', {
32    query: {
33      field: 'email',
34      operator: '=',
35      value: email
36    }
37  });
38
39  if (searchResult.total_count > 0) {
40    // Update existing contact
41    const contactId = searchResult.data[0].id;
42    const updated = await intercomRequest('PUT', `/contacts/${contactId}`, {
43      name,
44      phone,
45      custom_attributes: customAttributes
46    });
47    console.log(`Updated contact: ${contactId}`);
48    return updated;
49  } else {
50    // Create new contact
51    const created = await intercomRequest('POST', '/contacts', {
52      role: 'user',
53      email,
54      name,
55      phone,
56      custom_attributes: customAttributes
57    });
58    console.log(`Created contact: ${created.id}`);
59    return created;
60  }
61}
62
63// Tag a contact
64async function tagContact(contactId, tagName) {
65  // First, get or create the tag
66  const tags = await intercomRequest('GET', '/tags');
67  let tag = tags.data.find(t => t.name === tagName);
68
69  if (!tag) {
70    tag = await intercomRequest('POST', '/tags', { name: tagName });
71  }
72
73  // Apply tag to contact
74  await intercomRequest('POST', `/contacts/${contactId}/tags`, { id: tag.id });
75  return tag;
76}
77
78module.exports = { upsertContact, tagContact, intercomRequest };

1// server.js — Intercom Express API server
2const express = require('express');
3const { upsertContact, tagContact, intercomRequest } = require('./intercom-contacts');
4
5const app = express();
6app.use(express.json());
7
8// POST /sync-user — call this when a user registers or updates profile
9app.post('/sync-user', async (req, res) => {
10  try {
11    const { email, name, phone, plan, company } = req.body;
12    if (!email) return res.status(400).json({ error: 'email required' });
13
14    const contact = await upsertContact({
15      email,
16      name,
17      phone,
18      customAttributes: {
19        plan: plan || 'free',
20        company: company || ''
21      }
22    });
23
24    // Auto-tag based on plan
25    if (plan === 'enterprise') {
26      await tagContact(contact.id, 'Enterprise');
27    }
28
29    res.json({ success: true, contactId: contact.id });
30  } catch (err) {
31    console.error(err.message);
32    res.status(500).json({ error: err.message });
33  }
34});
35
36// GET /conversations — recent open conversations
37app.get('/conversations', async (req, res) => {
38  try {
39    const result = await intercomRequest('GET',
40      '/conversations?display_as=plaintext&per_page=20');
41    const conversations = result.conversations.map(c => ({
42      id: c.id,
43      subject: c.source?.subject || 'No subject',
44      state: c.state,
45      assignee: c.assignee?.name || 'Unassigned',
46      created_at: new Date(c.created_at * 1000).toISOString()
47    }));
48    res.json({ conversations });
49  } catch (err) {
50    res.status(500).json({ error: err.message });
51  }
52});
53
54// POST /send-message — send proactive message to a user
55app.post('/send-message', async (req, res) => {
56  try {
57    const { email, subject, body, adminId } = req.body;
58    if (!email || !body) {
59      return res.status(400).json({ error: 'email and body required' });
60    }
61
62    // Find the contact
63    const searchResult = await intercomRequest('POST', '/contacts/search', {
64      query: { field: 'email', operator: '=', value: email }
65    });
66
67    if (searchResult.total_count === 0) {
68      return res.status(404).json({ error: 'Contact not found in Intercom' });
69    }
70
71    const contactId = searchResult.data[0].id;
72
73    // Send message as email from admin
74    const message = await intercomRequest('POST', '/messages', {
75      message_type: 'email',
76      subject: subject || 'Message from our team',
77      body,
78      template: 'plain',
79      from: { type: 'admin', id: adminId || process.env.INTERCOM_ADMIN_ID },
80      to: { type: 'user', id: contactId }
81    });
82
83    res.json({ success: true, messageId: message.id });
84  } catch (err) {
85    res.status(500).json({ error: err.message });
86  }
87});
88
89app.listen(3000, '0.0.0.0', () => {
90  console.log('Intercom integration server running on port 3000');
91});

1# webhook_handler.py — Python Flask Intercom webhook receiver
2import os
3import hmac
4import hashlib
5import json
6from flask import Flask, request, jsonify
7
8app = Flask(__name__)
9
10def verify_intercom_signature(payload_body, signature_header):
11    """Verify the webhook is genuinely from Intercom."""
12    client_secret = os.environ.get('INTERCOM_CLIENT_SECRET', '')
13    if not client_secret or not signature_header:
14        return False
15
16    # Intercom sends sha1=<hex_digest>
17    expected = 'sha1=' + hmac.new(
18        client_secret.encode('utf-8'),
19        payload_body,
20        hashlib.sha1
21    ).hexdigest()
22
23    return hmac.compare_digest(expected, signature_header)
24
25@app.route('/intercom-webhook', methods=['POST'])
26def intercom_webhook():
27    # Verify signature
28    signature = request.headers.get('X-Hub-Signature', '')
29    if not verify_intercom_signature(request.data, signature):
30        return jsonify({'error': 'Invalid signature'}), 401
31
32    payload = request.json
33    topic = payload.get('topic', 'unknown')
34    data = payload.get('data', {}).get('item', {})
35
36    print(f'Intercom webhook: topic={topic}')
37
38    if topic == 'conversation.user.created':
39        user_email = data.get('source', {}).get('author', {}).get('email')
40        subject = data.get('source', {}).get('subject', 'No subject')
41        print(f'New conversation from {user_email}: {subject}')
42        # Add your logic: notify Slack, update CRM, etc.
43
44    elif topic == 'conversation.user.replied':
45        conv_id = data.get('id')
46        print(f'User replied on conversation {conv_id}')
47
48    elif topic == 'contact.created':
49        contact_email = data.get('email')
50        print(f'New Intercom contact: {contact_email}')
51
52    # Always return 200 quickly — process async if needed
53    return jsonify({'status': 'received'}), 200
54
55if __name__ == '__main__':
56    app.run(host='0.0.0.0', port=3000)