How to Integrate Replit with Shutterstock API

1// check-shutterstock-secrets.js
2const required = ['SHUTTERSTOCK_CLIENT_ID', 'SHUTTERSTOCK_CLIENT_SECRET'];
3for (const key of required) {
4  if (!process.env[key]) {
5    throw new Error(`Missing secret: ${key}. Set it in Replit Secrets (lock icon 🔒).`);
6  }
7}
8const auth = Buffer.from(
9  `${process.env.SHUTTERSTOCK_CLIENT_ID}:${process.env.SHUTTERSTOCK_CLIENT_SECRET}`
10).toString('base64');
11console.log('Shutterstock auth header ready.');
12console.log('Client ID:', process.env.SHUTTERSTOCK_CLIENT_ID);

1// shutterstock.js — Shutterstock API integration for Node.js on Replit
2const axios = require('axios');
3const express = require('express');
4
5const app = express();
6app.use(express.json());
7
8// Build Basic Auth header once
9const authHeader = 'Basic ' + Buffer.from(
10  `${process.env.SHUTTERSTOCK_CLIENT_ID}:${process.env.SHUTTERSTOCK_CLIENT_SECRET}`
11).toString('base64');
12
13const sstockApi = axios.create({
14  baseURL: 'https://api.shutterstock.com',
15  headers: {
16    'Authorization': authHeader,
17    'Accept': 'application/json'
18  }
19});
20
21// Search images
22app.get('/api/images/search', async (req, res) => {
23  const {
24    query, per_page = 20, page = 1,
25    image_type, orientation, sort = 'popular',
26    safe = 'true', color
27  } = req.query;
28  
29  if (!query) return res.status(400).json({ error: 'query parameter required' });
30  
31  const params = {
32    query, per_page: Math.min(parseInt(per_page), 100),
33    page: parseInt(page), sort, safe
34  };
35  if (image_type) params.image_type = image_type;
36  if (orientation) params.orientation = orientation;
37  if (color) params.color = color.replace('#', '');
38  
39  try {
40    const response = await sstockApi.get('/v2/images/search', { params });
41    const { data } = response;
42    
43    // Return simplified results with preview URLs
44    const images = data.data.map(img => ({
45      id: img.id,
46      description: img.description,
47      contributor: img.contributor?.id,
48      aspect: img.aspect,
49      image_type: img.media_type,
50      is_editorial: img.is_editorial,
51      preview_url: img.assets?.preview?.url,
52      thumb_url: img.assets?.small_thumb?.url,
53      large_thumb_url: img.assets?.large_thumb?.url
54    }));
55    
56    res.json({
57      images,
58      total_count: data.total_count,
59      page: data.page,
60      per_page: data.per_page,
61      total_pages: Math.ceil(data.total_count / data.per_page)
62    });
63  } catch (err) {
64    if (err.response?.status === 429) {
65      const reset = err.response.headers['x-ratelimit-reset'];
66      return res.status(429).json({ error: 'Rate limit exceeded', resetAt: reset });
67    }
68    res.status(err.response?.status || 500).json({ error: err.response?.data || err.message });
69  }
70});
71
72// Search videos
73app.get('/api/videos/search', async (req, res) => {
74  const { query, per_page = 10, page = 1, duration_from, duration_to } = req.query;
75  if (!query) return res.status(400).json({ error: 'query required' });
76  
77  const params = { query, per_page: Math.min(parseInt(per_page), 50), page: parseInt(page) };
78  if (duration_from) params.duration_from = duration_from;
79  if (duration_to) params.duration_to = duration_to;
80  
81  try {
82    const response = await sstockApi.get('/v2/videos/search', { params });
83    const videos = response.data.data.map(v => ({
84      id: v.id,
85      description: v.description,
86      duration: v.duration,
87      aspect: v.aspect,
88      preview_url: v.assets?.preview_mp4?.url,
89      thumb_url: v.assets?.thumb_webm?.url
90    }));
91    res.json({ videos, total_count: response.data.total_count });
92  } catch (err) {
93    res.status(err.response?.status || 500).json({ error: err.response?.data || err.message });
94  }
95});
96
97// Get image details by ID
98app.get('/api/images/:imageId', async (req, res) => {
99  try {
100    const response = await sstockApi.get(`/v2/images/${req.params.imageId}`);
101    res.json(response.data);
102  } catch (err) {
103    res.status(err.response?.status || 500).json({ error: err.response?.data || err.message });
104  }
105});
106
107app.listen(3000, '0.0.0.0', () => console.log('Shutterstock server running on port 3000'));

1# shutterstock_api.py — Shutterstock API integration for Python on Replit
2import os
3import requests
4from flask import Flask, request, jsonify
5
6app = Flask(__name__)
7
8CLIENT_ID = os.environ['SHUTTERSTOCK_CLIENT_ID']
9CLIENT_SECRET = os.environ['SHUTTERSTOCK_CLIENT_SECRET']
10BASE_URL = 'https://api.shutterstock.com'
11
12# requests handles Basic Auth encoding with the auth tuple
13session = requests.Session()
14session.auth = (CLIENT_ID, CLIENT_SECRET)
15session.headers.update({'Accept': 'application/json'})
16
17def search_images(query: str, per_page: int = 20, page: int = 1,
18                  image_type: str = None, orientation: str = None,
19                  sort: str = 'popular') -> dict:
20    params = {'query': query, 'per_page': min(per_page, 100),
21              'page': page, 'sort': sort, 'safe': 'true'}
22    if image_type:
23        params['image_type'] = image_type
24    if orientation:
25        params['orientation'] = orientation
26    
27    response = session.get(f'{BASE_URL}/v2/images/search', params=params)
28    response.raise_for_status()
29    data = response.json()
30    
31    images = [{
32        'id': img['id'],
33        'description': img.get('description', ''),
34        'aspect': img.get('aspect'),
35        'image_type': img.get('media_type'),
36        'is_editorial': img.get('is_editorial', False),
37        'preview_url': img.get('assets', {}).get('preview', {}).get('url'),
38        'thumb_url': img.get('assets', {}).get('small_thumb', {}).get('url')
39    } for img in data.get('data', [])]
40    
41    return {
42        'images': images,
43        'total_count': data.get('total_count', 0),
44        'page': data.get('page', page),
45        'per_page': data.get('per_page', per_page)
46    }
47
48@app.route('/api/images/search')
49def image_search():
50    query = request.args.get('query')
51    if not query:
52        return jsonify({'error': 'query parameter required'}), 400
53    try:
54        results = search_images(
55            query=query,
56            per_page=int(request.args.get('per_page', 20)),
57            page=int(request.args.get('page', 1)),
58            image_type=request.args.get('image_type'),
59            orientation=request.args.get('orientation'),
60            sort=request.args.get('sort', 'popular')
61        )
62        return jsonify(results)
63    except requests.HTTPError as e:
64        if e.response.status_code == 429:
65            return jsonify({'error': 'Rate limit exceeded'}), 429
66        return jsonify({'error': str(e)}), e.response.status_code
67
68if __name__ == '__main__':
69    app.run(host='0.0.0.0', port=3000)