Integrate Mailchimp Campaigns with Notion Databases

NOTION_TOKEN='you_notion_api_key'
MAILCHIMP_API_KEY='your_mailchimp_api_key'
NOTION_DATABASE_ID='your_database_id'

npm install @notionhq/client dotenv

{
    "name": "mailchimp_notion_integration",
    "version": "1.0.0",
    "main": "src/main.js",
    "scripts": {
      "start": "node src/main.js"
    },
    "dependencies": {
      "@notionhq/client": "^1.0.0",
      "dotenv": "^8.2.0"
    }
  }

// mailchimp.js
const Mailchimp = require('mailchimp-api-v3');
const dotenv = require('dotenv');

dotenv.config();

const mailchimp = new Mailchimp(process.env.MAILCHIMP_API_KEY);

module.exports = mailchimp;

// notion.js
const { Client } = require('@notionhq/client');
const dotenv = require('dotenv');

dotenv.config();

const notion = new Client({ auth: process.env.NOTION_TOKEN });
const databaseId = process.env.NOTION_DATABASE_ID;

module.exports = { notion, databaseId };

// mailchimpIntegration.js
const mailchimp = require('../config/mailchimp');

async function getMailchimpCampaigns() {
  try {
    const response = await mailchimp.get('/campaigns');
    const campaigns = response.campaigns;
    return campaigns.map(campaign => ({
      id: campaign.id,
      list_id: campaign.recipients.list_id,
      campaign_name: campaign.settings.title
    }));
  } catch (error) {
    console.error('Error fetching Mailchimp campaigns:', error);
    return [];
  }
}

async function getMailchimpSubscribers(list_id) {
  try {
    const response = await mailchimp.get(`/lists/${list_id}/members`);
    return response.members.map(member => ({
      name: member.full_name,
      email: member.email_address
    }));
  } catch (error) {
    console.error('Error fetching Mailchimp subscribers:', error);
    return [];
  }
}

module.exports = { getMailchimpCampaigns, getMailchimpSubscribers };

// notionIntegration.js
const { notion, databaseId } = require('../config/notion');

async function addToNotionDatabase(databaseId, campaignName, name, email) {
  try {
    await notion.pages.create({
      parent: { database_id: databaseId },
      properties: {
        'Campaign Name': {
          title: [
            {
              text: {
                content: campaignName
              }
            }
          ]
        },
        'Name': {
          rich_text: [
            {
              text: {
                content: name
              }
            }
          ]
        },
        'Email': {
          rich_text: [
            {
              text: {
                content: email
              }
            }
          ]
        }
      }
    });
  } catch (error) {
    console.error('Error adding to Notion database:', error);
  }
}

module.exports = { addToNotionDatabase };

require('dotenv').config();

const { getMailchimpCampaigns, getMailchimpSubscribers } = require('./integrations/mailchimpIntegration');
const { addToNotionDatabase } = require('./integrations/notionIntegration');

const NOTION_DATABASE_ID = process.env.NOTION_DATABASE_ID;

async function fillNotionDatabase() {
  const campaigns = await getMailchimpCampaigns();

  for (const campaign of campaigns) {
    const subscribers = await getMailchimpSubscribers(campaign.list_id);

    for (const subscriber of subscribers) {
      await addToNotionDatabase(NOTION_DATABASE_ID, campaign.campaign_name, subscriber.name, subscriber.email);
      console.log(`Added to Notion: Campaign: ${campaign.campaign_name}, Name: ${subscriber.name}, Email: ${subscriber.email}`);
    }
  }
}

fillNotionDatabase();

npm start