How to Integrate Replit with UserTesting

1import os
2import requests
3
4API_KEY = os.environ['USERTESTING_API_KEY']
5BASE_URL = 'https://api.usertesting.com/v1'
6
7headers = {
8    'Authorization': f'Bearer {API_KEY}',
9    'Accept': 'application/json',
10    'Content-Type': 'application/json'
11}
12
13# Test: list your UserTesting studies
14response = requests.get(f'{BASE_URL}/tests', headers=headers, params={'per_page': 5})
15
16if response.status_code == 200:
17    data = response.json()
18    tests = data.get('tests', [])
19    print(f'API key valid. Found {len(tests)} recent studies:')
20    for test in tests:
21        print(f'  - [{test.get("id")}] {test.get("name")} — Status: {test.get("status")}')
22elif response.status_code == 401:
23    print('Error: API key invalid or API access not enabled on your account.')
24else:
25    print(f'Error: {response.status_code} — {response.text}')

1import os
2import requests
3import statistics
4
5API_KEY = os.environ['USERTESTING_API_KEY']
6BASE_URL = 'https://api.usertesting.com/v1'
7TEST_ID = os.environ.get('USERTESTING_TEST_ID', 'YOUR_TEST_ID_HERE')
8
9headers = {
10    'Authorization': f'Bearer {API_KEY}',
11    'Accept': 'application/json'
12}
13
14def get_test_sessions(test_id):
15    """Fetch all sessions for a test."""
16    sessions = []
17    page = 1
18    while True:
19        resp = requests.get(
20            f'{BASE_URL}/tests/{test_id}/sessions',
21            headers=headers,
22            params={'page': page, 'per_page': 50, 'status': 'complete'}
23        )
24        resp.raise_for_status()
25        data = resp.json()
26        page_sessions = data.get('sessions', [])
27        sessions.extend(page_sessions)
28        if len(page_sessions) < 50:
29            break  # no more pages
30        page += 1
31    return sessions
32
33def get_session_tasks(test_id, session_id):
34    """Fetch task results for a session."""
35    resp = requests.get(
36        f'{BASE_URL}/tests/{test_id}/sessions/{session_id}/tasks',
37        headers=headers
38    )
39    resp.raise_for_status()
40    return resp.json().get('tasks', [])
41
42def summarize_test(test_id):
43    print(f'Fetching sessions for test {test_id}...')
44    sessions = get_test_sessions(test_id)
45    print(f'Found {len(sessions)} completed sessions')
46
47    task_completions = {}
48    task_durations = {}
49
50    for session in sessions[:10]:  # sample first 10 for demo
51        tasks = get_session_tasks(test_id, session['id'])
52        for task in tasks:
53            task_title = task.get('title', 'Unknown Task')
54            completed = task.get('completed', False)
55            duration = task.get('duration_seconds', 0)
56
57            if task_title not in task_completions:
58                task_completions[task_title] = []
59                task_durations[task_title] = []
60
61            task_completions[task_title].append(1 if completed else 0)
62            if duration > 0:
63                task_durations[task_title].append(duration)
64
65    print('\nTask Summary:')
66    print('-' * 60)
67    for task_title in task_completions:
68        completions = task_completions[task_title]
69        durations = task_durations[task_title]
70        completion_rate = sum(completions) / len(completions) * 100
71        avg_duration = statistics.mean(durations) if durations else 0
72        print(f'Task: {task_title[:40]}')
73        print(f'  Completion rate: {completion_rate:.0f}%')
74        print(f'  Avg duration: {avg_duration:.0f}s')
75        print()
76
77summarize_test(TEST_ID)

1// Node.js Express report delivery service
2const express = require('express');
3const app = express();
4app.use(express.json());
5
6const API_KEY = process.env.USERTESTING_API_KEY;
7const SLACK_WEBHOOK_URL = process.env.SLACK_WEBHOOK_URL;
8const BASE_URL = 'https://api.usertesting.com/v1';
9
10const headers = {
11  'Authorization': `Bearer ${API_KEY}`,
12  'Accept': 'application/json'
13};
14
15async function fetchTests() {
16  const res = await fetch(`${BASE_URL}/tests?status=active&per_page=10`, { headers });
17  const data = await res.json();
18  return data.tests || [];
19}
20
21async function fetchSessionCount(testId) {
22  const res = await fetch(`${BASE_URL}/tests/${testId}/sessions?status=complete&per_page=1`, { headers });
23  const data = await res.json();
24  return data.total_count || 0;
25}
26
27async function buildReport() {
28  const tests = await fetchTests();
29  const lines = ['*UserTesting Weekly Summary*', ''];
30
31  for (const test of tests) {
32    const completed = await fetchSessionCount(test.id);
33    lines.push(`*${test.name}*`);
34    lines.push(`  Sessions: ${completed} | Status: ${test.status}`);
35    lines.push('');
36  }
37  lines.push(`_Report generated at ${new Date().toLocaleString()}_`);
38  return lines.join('\n');
39}
40
41app.get('/report', async (req, res) => {
42  try {
43    const report = await buildReport();
44    res.type('text/plain').send(report);
45  } catch (err) {
46    res.status(500).json({ error: err.message });
47  }
48});
49
50app.post('/send-report', async (req, res) => {
51  try {
52    const report = await buildReport();
53    if (SLACK_WEBHOOK_URL) {
54      await fetch(SLACK_WEBHOOK_URL, {
55        method: 'POST',
56        headers: { 'Content-Type': 'application/json' },
57        body: JSON.stringify({ text: report })
58      });
59    }
60    res.json({ sent: true, lines: report.split('\n').length });
61  } catch (err) {
62    res.status(500).json({ error: err.message });
63  }
64});
65
66app.listen(3000, '0.0.0.0', () => console.log('UserTesting report server running'));