How to Integrate Replit with Campaign Monitor

1import os
2import requests
3from typing import Optional
4
5API_KEY = os.environ["CM_API_KEY"]
6LIST_ID = os.environ["CM_LIST_ID"]
7BASE_URL = "https://api.createsend.com/api/v3.3"
8
9# Campaign Monitor Basic Auth: API key as username, 'x' as password
10AUTH = (API_KEY, "x")
11
12def add_subscriber(email: str, name: str = "", custom_fields: list = None) -> dict:
13    """
14    Add or update a subscriber in the list (upsert behavior).
15    custom_fields: list of {"Key": "FieldName", "Value": "value"}
16    """
17    url = f"{BASE_URL}/subscribers/{LIST_ID}.json"
18    payload = {
19        "EmailAddress": email,
20        "Name": name,
21        "CustomFields": custom_fields or [],
22        "Resubscribe": True,        # Re-subscribe if previously unsubscribed
23        "ConsentToTrack": "Yes"    # Required for GDPR compliance tracking
24    }
25    response = requests.post(url, json=payload, auth=AUTH)
26    response.raise_for_status()
27    return response.json()
28
29def get_subscriber(email: str) -> Optional[dict]:
30    """Retrieve subscriber details and status."""
31    url = f"{BASE_URL}/subscribers/{LIST_ID}.json"
32    params = {"email": email}
33    response = requests.get(url, params=params, auth=AUTH)
34    if response.status_code == 400:
35        return None  # Subscriber not found
36    response.raise_for_status()
37    return response.json()
38
39def unsubscribe(email: str) -> None:
40    """Unsubscribe a contact from the list."""
41    url = f"{BASE_URL}/subscribers/{LIST_ID}/unsubscribe.json"
42    payload = {"EmailAddress": email}
43    response = requests.post(url, json=payload, auth=AUTH)
44    response.raise_for_status()
45
46def delete_subscriber(email: str) -> None:
47    """Permanently delete a subscriber (GDPR right to erasure)."""
48    url = f"{BASE_URL}/subscribers/{LIST_ID}.json"
49    params = {"email": email}
50    response = requests.delete(url, params=params, auth=AUTH)
51    response.raise_for_status()
52
53# Example usage
54if __name__ == "__main__":
55    result = add_subscriber(
56        email="user@example.com",
57        name="Jane Doe",
58        custom_fields=[
59            {"Key": "City", "Value": "New York"},
60            {"Key": "Plan", "Value": "Pro"}
61        ]
62    )
63    print(f"Subscriber added: {result}")
64
65    sub = get_subscriber("user@example.com")
66    if sub:
67        print(f"Status: {sub['State']}")

1const axios = require('axios');
2
3const API_KEY = process.env.CM_API_KEY;
4const CLIENT_ID = process.env.CM_CLIENT_ID;
5const LIST_ID = process.env.CM_LIST_ID;
6const BASE_URL = 'https://api.createsend.com/api/v3.3';
7
8// Campaign Monitor uses Basic Auth: API key as username, 'x' as password
9const auth = {
10  username: API_KEY,
11  password: 'x'
12};
13
14async function addSubscriber(email, name) {
15  const url = `${BASE_URL}/subscribers/${LIST_ID}.json`;
16  const response = await axios.post(url, {
17    EmailAddress: email,
18    Name: name,
19    Resubscribe: true,
20    ConsentToTrack: 'Yes'
21  }, { auth });
22  return response.data;
23}
24
25async function createCampaign(subject, fromName, fromEmail, replyTo, htmlContent) {
26  const url = `${BASE_URL}/campaigns/${CLIENT_ID}.json`;
27  const response = await axios.post(url, {
28    Subject: subject,
29    Name: `Campaign - ${new Date().toISOString()}`,
30    FromName: fromName,
31    FromEmail: fromEmail,
32    ReplyTo: replyTo,
33    HtmlUrl: '',
34    Html: htmlContent,
35    ListIDs: [LIST_ID]
36  }, { auth });
37  return response.data; // Returns campaign ID
38}
39
40async function sendCampaignImmediately(campaignId, confirmationEmail) {
41  const url = `${BASE_URL}/campaigns/${campaignId}/send.json`;
42  const response = await axios.post(url, {
43    ConfirmationEmail: confirmationEmail,
44    SendDate: 'Immediately'
45  }, { auth });
46  return response.data;
47}
48
49async function getCampaignStats(campaignId) {
50  const url = `${BASE_URL}/campaigns/${campaignId}/summary.json`;
51  const response = await axios.get(url, { auth });
52  return response.data;
53}
54
55// Express integration example
56const express = require('express');
57const app = express();
58app.use(express.json());
59
60app.post('/subscribe', async (req, res) => {
61  const { email, name } = req.body;
62  try {
63    await addSubscriber(email, name);
64    res.json({ success: true, message: 'Subscriber added successfully' });
65  } catch (error) {
66    console.error('Campaign Monitor error:', error.response?.data || error.message);
67    res.status(500).json({ error: 'Failed to add subscriber' });
68  }
69});
70
71app.listen(3000, '0.0.0.0', () => console.log('Server running on port 3000'));

1import os
2import requests
3
4API_KEY = os.environ["CM_API_KEY"]
5TX_BASE_URL = "https://mail.createsend.com/api/v3.3/transactional"
6AUTH = (API_KEY, "x")
7
8def send_transactional_email(
9    smart_email_id: str,
10    to_email: str,
11    to_name: str,
12    data: dict
13) -> dict:
14    """
15    Send a transactional Smart Email to one recipient.
16    data: dict of merge fields defined in the Smart Email template
17    e.g., {"order_number": "ORD-1234", "total": "$49.99"}
18    """
19    url = f"{TX_BASE_URL}/smartEmail/{smart_email_id}/send"
20    payload = {
21        "To": [f"{to_name} <{to_email}>"],
22        "Data": data,
23        "ConsentToTrack": "Yes"
24    }
25    response = requests.post(url, json=payload, auth=AUTH)
26    response.raise_for_status()
27    return response.json()
28
29# Example: Order confirmation email
30if __name__ == "__main__":
31    smart_email_id = os.environ.get("CM_TX_SMART_EMAIL_ID", "your-smart-email-id")
32    result = send_transactional_email(
33        smart_email_id=smart_email_id,
34        to_email="customer@example.com",
35        to_name="Jane Doe",
36        data={
37            "order_number": "ORD-5678",
38            "order_total": "$99.00",
39            "customer_name": "Jane Doe",
40            "delivery_date": "April 5, 2026"
41        }
42    )
43    print(f"Transactional email sent: {result}")