How to Integrate Replit with SurveyMonkey

1const express = require('express');
2const axios = require('axios');
3
4const app = express();
5app.use(express.json());
6
7const ACCESS_TOKEN = process.env.SURVEYMONKEY_ACCESS_TOKEN;
8const SM_BASE_URL = 'https://api.surveymonkey.com/v3';
9
10const smClient = axios.create({
11  baseURL: SM_BASE_URL,
12  headers: {
13    'Authorization': `Bearer ${ACCESS_TOKEN}`,
14    'Content-Type': 'application/json'
15  },
16  timeout: 15000
17});
18
19// List all surveys in the account
20app.get('/api/surveys', async (req, res) => {
21  try {
22    const response = await smClient.get('/surveys', {
23      params: { per_page: 50, include: 'response_count' }
24    });
25    res.json({
26      surveys: response.data.data.map(s => ({
27        id: s.id,
28        title: s.title,
29        response_count: s.response_count,
30        date_created: s.date_created
31      })),
32      total: response.data.total
33    });
34  } catch (error) {
35    console.error('SurveyMonkey error:', error.response?.data || error.message);
36    res.status(500).json({ error: 'Failed to fetch surveys' });
37  }
38});
39
40// Get aggregated response rollups for a survey
41app.get('/api/surveys/:id/rollups', async (req, res) => {
42  try {
43    const response = await smClient.get(`/surveys/${req.params.id}/rollups`);
44    res.json(response.data);
45  } catch (error) {
46    console.error('SurveyMonkey error:', error.response?.data || error.message);
47    res.status(500).json({ error: 'Failed to fetch survey rollups' });
48  }
49});
50
51// Fetch all responses with pagination
52app.get('/api/surveys/:id/responses', async (req, res) => {
53  const surveyId = req.params.id;
54  let allResponses = [];
55  let nextUrl = `/surveys/${surveyId}/responses/bulk?per_page=100`;
56
57  try {
58    while (nextUrl) {
59      const response = await smClient.get(nextUrl);
60      allResponses = allResponses.concat(response.data.data);
61      nextUrl = response.data.links?.next
62        ? response.data.links.next.replace(SM_BASE_URL, '')
63        : null;
64    }
65    res.json({ survey_id: surveyId, total: allResponses.length, responses: allResponses });
66  } catch (error) {
67    console.error('SurveyMonkey error:', error.response?.data || error.message);
68    res.status(500).json({ error: 'Failed to fetch responses' });
69  }
70});
71
72app.listen(3000, '0.0.0.0', () => console.log('SurveyMonkey server running on port 3000'));

1import os
2import requests
3from flask import Flask, jsonify, request
4
5app = Flask(__name__)
6
7ACCESS_TOKEN = os.environ['SURVEYMONKEY_ACCESS_TOKEN']
8SM_BASE_URL = 'https://api.surveymonkey.com/v3'
9
10def sm_get(path, params=None):
11    """Make authenticated GET request to SurveyMonkey API."""
12    headers = {
13        'Authorization': f'Bearer {ACCESS_TOKEN}',
14        'Content-Type': 'application/json'
15    }
16    response = requests.get(
17        f'{SM_BASE_URL}{path}',
18        headers=headers,
19        params=params,
20        timeout=15
21    )
22    response.raise_for_status()
23    return response.json()
24
25@app.route('/api/surveys')
26def list_surveys():
27    try:
28        data = sm_get('/surveys', params={'per_page': 50, 'include': 'response_count'})
29        surveys = [{
30            'id': s['id'],
31            'title': s['title'],
32            'response_count': s.get('response_count', 0),
33            'date_created': s['date_created']
34        } for s in data['data']]
35        return jsonify({'surveys': surveys, 'total': data['total']})
36    except requests.RequestException as e:
37        return jsonify({'error': str(e)}), 500
38
39@app.route('/api/surveys/<survey_id>/rollups')
40def survey_rollups(survey_id):
41    try:
42        data = sm_get(f'/surveys/{survey_id}/rollups')
43        return jsonify(data)
44    except requests.RequestException as e:
45        return jsonify({'error': str(e)}), 500
46
47@app.route('/api/surveys/<survey_id>/responses')
48def survey_responses(survey_id):
49    all_responses = []
50    path = f'/surveys/{survey_id}/responses/bulk'
51    params = {'per_page': 100}
52
53    try:
54        while path:
55            data = sm_get(path, params=params)
56            all_responses.extend(data['data'])
57            next_link = data.get('links', {}).get('next')
58            if next_link:
59                path = next_link.replace(SM_BASE_URL, '')
60                params = None  # params are in the next URL already
61            else:
62                path = None
63
64        return jsonify({
65            'survey_id': survey_id,
66            'total': len(all_responses),
67            'responses': all_responses
68        })
69    except requests.RequestException as e:
70        return jsonify({'error': str(e)}), 500
71
72if __name__ == '__main__':
73    app.run(host='0.0.0.0', port=3000)

1// Add this to your server.js
2
3// Webhook receiver endpoint
4app.post('/webhook', express.json(), async (req, res) => {
5  // Respond quickly to acknowledge receipt
6  res.json({ received: true });
7
8  const event = req.body;
9  console.log('SurveyMonkey webhook received:', event.event_type, event.object_type);
10
11  // Process response_completed events
12  if (event.event_type === 'response_completed' && event.object_type === 'response') {
13    try {
14      // Fetch the full response details
15      const surveyId = event.resources.survey_id;
16      const responseId = event.resources.response_id;
17      const response = await smClient.get(
18        `/surveys/${surveyId}/responses/${responseId}`
19      );
20      const responseData = response.data;
21      console.log('New response received from:', responseData.recipient?.email || 'anonymous');
22      // Add your processing logic here (save to DB, send to CRM, etc.)
23    } catch (err) {
24      console.error('Error processing webhook:', err.message);
25    }
26  }
27});
28
29// Register a webhook subscription (run once to set up)
30async function registerWebhook(surveyId) {
31  const webhookUrl = process.env.REPLIT_DEV_DOMAIN
32    ? `https://${process.env.REPLIT_DEV_DOMAIN}/webhook`
33    : 'https://your-repl-url.repl.co/webhook';
34
35  const response = await smClient.post('/webhooks', {
36    name: 'Replit Response Webhook',
37    event_type: 'response_completed',
38    object_type: 'survey',
39    object_ids: [surveyId],
40    subscription_url: webhookUrl
41  });
42  console.log('Webhook registered:', response.data.id);
43  return response.data;
44}