How to Integrate Replit with CoSchedule

1// check-coschedule-secrets.js
2const required = ['COSCHEDULE_API_KEY', 'COSCHEDULE_ORG_ID'];
3for (const key of required) {
4  if (!process.env[key]) {
5    throw new Error(`Missing secret: ${key}. Add it in Replit Secrets (lock icon 🔒).`);
6  }
7}
8console.log('CoSchedule secrets configured.');
9console.log('Org ID:', process.env.COSCHEDULE_ORG_ID);

1// coschedule-client.js — CoSchedule API client for Replit
2const API_KEY = process.env.COSCHEDULE_API_KEY;
3const ORG_ID = process.env.COSCHEDULE_ORG_ID;
4const BASE_URL = 'https://api.coschedule.com/v1';
5
6// Authenticated fetch wrapper
7async function coScheduleRequest(method, path, body = null) {
8  const options = {
9    method,
10    headers: {
11      'Authorization': `Bearer ${API_KEY}`,
12      'Content-Type': 'application/json',
13      'Accept': 'application/json'
14    }
15  };
16  if (body) {
17    options.body = JSON.stringify(body);
18  }
19
20  const response = await fetch(`${BASE_URL}${path}`, options);
21
22  if (response.status === 429) {
23    const retryAfter = response.headers.get('Retry-After') || 60;
24    throw new Error(`Rate limited. Retry after ${retryAfter} seconds.`);
25  }
26
27  if (!response.ok) {
28    const errorBody = await response.text();
29    throw new Error(`CoSchedule API error ${response.status}: ${errorBody}`);
30  }
31
32  return response.json();
33}
34
35// Get upcoming calendar items
36async function getCalendarItems(startDate, endDate) {
37  const params = new URLSearchParams({
38    organization_id: ORG_ID,
39    start_date: startDate, // YYYY-MM-DD format
40    end_date: endDate
41  });
42  return coScheduleRequest('GET', `/calendar-items?${params}`);
43}
44
45// Create a new calendar item
46async function createCalendarItem(title, date, type = 'task') {
47  return coScheduleRequest('POST', '/calendar-items', {
48    organization_id: ORG_ID,
49    title,
50    date,  // YYYY-MM-DD format
51    type   // 'task', 'event', 'social-campaign', etc.
52  });
53}
54
55// Example usage
56(async () => {
57  try {
58    // Get this week's calendar items
59    const today = new Date().toISOString().split('T')[0];
60    const nextWeek = new Date(Date.now() + 7 * 86400000).toISOString().split('T')[0];
61    const items = await getCalendarItems(today, nextWeek);
62    console.log('Upcoming calendar items:', JSON.stringify(items, null, 2));
63
64    // Create a new calendar item
65    const newItem = await createCalendarItem(
66      'Q2 Launch Blog Post',
67      new Date(Date.now() + 3 * 86400000).toISOString().split('T')[0]
68    );
69    console.log('Created item:', newItem.id);
70  } catch (err) {
71    console.error('Error:', err.message);
72  }
73})();
74
75module.exports = { getCalendarItems, createCalendarItem, coScheduleRequest };

1# coschedule_social.py — Schedule social messages via CoSchedule API
2import os
3import requests
4from datetime import datetime, timedelta
5
6API_KEY = os.environ['COSCHEDULE_API_KEY']
7ORG_ID = os.environ['COSCHEDULE_ORG_ID']
8BASE_URL = 'https://api.coschedule.com/v1'
9
10HEADERS = {
11    'Authorization': f'Bearer {API_KEY}',
12    'Content-Type': 'application/json',
13    'Accept': 'application/json'
14}
15
16def get_social_profiles():
17    """Get all connected social profiles and their IDs."""
18    params = {'organization_id': ORG_ID}
19    response = requests.get(f'{BASE_URL}/social-profiles', headers=HEADERS, params=params)
20    response.raise_for_status()
21    return response.json()
22
23def create_calendar_item(title: str, date: str) -> dict:
24    """Create a calendar item and return its data including ID."""
25    payload = {
26        'organization_id': ORG_ID,
27        'title': title,
28        'date': date
29    }
30    response = requests.post(f'{BASE_URL}/calendar-items', headers=HEADERS, json=payload)
31    response.raise_for_status()
32    return response.json()
33
34def schedule_social_message(
35    calendar_item_id: str,
36    social_profile_id: str,
37    message: str,
38    scheduled_at: str  # ISO 8601 datetime string
39) -> dict:
40    """Schedule a social message on a calendar item."""
41    payload = {
42        'calendar_item_id': calendar_item_id,
43        'social_profile_id': social_profile_id,
44        'message': message,
45        'scheduled_at': scheduled_at  # e.g. '2026-04-01T14:00:00Z'
46    }
47    response = requests.post(f'{BASE_URL}/social-messages', headers=HEADERS, json=payload)
48    response.raise_for_status()
49    return response.json()
50
51if __name__ == '__main__':
52    # Create a calendar item for tomorrow
53    tomorrow = (datetime.utcnow() + timedelta(days=1)).strftime('%Y-%m-%d')
54    item = create_calendar_item('Product Launch Announcement', tomorrow)
55    print(f'Created calendar item: {item["id"]}')
56
57    # Get social profiles
58    profiles = get_social_profiles()
59    print(f'Found {len(profiles)} social profiles')
60
61    # Schedule a social message for noon tomorrow
62    if profiles:
63        scheduled_time = f'{tomorrow}T12:00:00Z'
64        msg = schedule_social_message(
65            calendar_item_id=item['id'],
66            social_profile_id=profiles[0]['id'],
67            message='Exciting news! Our new product launches today. Check it out at yoursite.com',
68            scheduled_at=scheduled_time
69        )
70        print(f'Scheduled social message: {msg["id"]}')

1// coschedule-server.js — Express proxy for CoSchedule API
2const express = require('express');
3const app = express();
4app.use(express.json());
5
6const API_KEY = process.env.COSCHEDULE_API_KEY;
7const ORG_ID = process.env.COSCHEDULE_ORG_ID;
8const BASE_URL = 'https://api.coschedule.com/v1';
9
10async function coSchedule(method, path, body = null) {
11  const options = {
12    method,
13    headers: {
14      'Authorization': `Bearer ${API_KEY}`,
15      'Content-Type': 'application/json'
16    }
17  };
18  if (body) options.body = JSON.stringify(body);
19  const res = await fetch(`${BASE_URL}${path}`, options);
20  if (!res.ok) {
21    const errText = await res.text();
22    throw { status: res.status, message: errText };
23  }
24  return res.json();
25}
26
27// Simple in-memory cache
28const cache = new Map();
29function withCache(key, ttlMs, fn) {
30  const cached = cache.get(key);
31  if (cached && Date.now() - cached.ts < ttlMs) return Promise.resolve(cached.data);
32  return fn().then(data => { cache.set(key, { data, ts: Date.now() }); return data; });
33}
34
35// GET /calendar — returns upcoming calendar items
36app.get('/calendar', async (req, res) => {
37  try {
38    const { start, end } = req.query;
39    const params = new URLSearchParams({
40      organization_id: ORG_ID,
41      start_date: start || new Date().toISOString().split('T')[0],
42      end_date: end || new Date(Date.now() + 7 * 86400000).toISOString().split('T')[0]
43    });
44    const data = await coSchedule('GET', `/calendar-items?${params}`);
45    res.json(data);
46  } catch (err) {
47    res.status(err.status || 500).json({ error: err.message });
48  }
49});
50
51// POST /calendar — create a new calendar item
52app.post('/calendar', async (req, res) => {
53  try {
54    const { title, date, type } = req.body;
55    if (!title || !date) return res.status(400).json({ error: 'title and date required' });
56    const item = await coSchedule('POST', '/calendar-items', {
57      organization_id: ORG_ID, title, date, type: type || 'task'
58    });
59    res.status(201).json(item);
60  } catch (err) {
61    res.status(err.status || 500).json({ error: err.message });
62  }
63});
64
65// GET /social-profiles — cached for 10 minutes
66app.get('/social-profiles', async (req, res) => {
67  try {
68    const profiles = await withCache('social-profiles', 600000, () =>
69      coSchedule('GET', `/social-profiles?organization_id=${ORG_ID}`)
70    );
71    res.json(profiles);
72  } catch (err) {
73    res.status(err.status || 500).json({ error: err.message });
74  }
75});
76
77app.listen(3000, '0.0.0.0', () => console.log('CoSchedule proxy running on port 3000'));