How to Integrate Replit with eBay API

1// ebay-auth.js — eBay OAuth token manager
2const BASE_URL = process.env.EBAY_ENVIRONMENT === 'production'
3  ? 'https://api.ebay.com'
4  : 'https://api.sandbox.ebay.com';
5
6let tokenCache = { token: null, expiresAt: 0 };
7
8async function getAccessToken() {
9  // Return cached token if still valid (with 60s buffer)
10  if (tokenCache.token && Date.now() < tokenCache.expiresAt - 60000) {
11    return tokenCache.token;
12  }
13
14  const clientId = process.env.EBAY_CLIENT_ID;
15  const clientSecret = process.env.EBAY_CLIENT_SECRET;
16  if (!clientId || !clientSecret) {
17    throw new Error('EBAY_CLIENT_ID or EBAY_CLIENT_SECRET not set in Secrets');
18  }
19
20  const credentials = Buffer.from(`${clientId}:${clientSecret}`).toString('base64');
21  const response = await fetch(`${BASE_URL}/identity/v1/oauth2/token`, {
22    method: 'POST',
23    headers: {
24      'Authorization': `Basic ${credentials}`,
25      'Content-Type': 'application/x-www-form-urlencoded'
26    },
27    body: 'grant_type=client_credentials&scope=https%3A%2F%2Fapi.ebay.com%2Foauth%2Fapi_scope'
28  });
29
30  if (!response.ok) {
31    const error = await response.text();
32    throw new Error(`eBay token error ${response.status}: ${error}`);
33  }
34
35  const data = await response.json();
36  tokenCache = {
37    token: data.access_token,
38    expiresAt: Date.now() + (data.expires_in * 1000)
39  };
40
41  return tokenCache.token;
42}
43
44// Browse API: search eBay listings
45async function searchListings(query, limit = 10, marketplaceId = 'EBAY_US') {
46  const token = await getAccessToken();
47  const params = new URLSearchParams({ q: query, limit });
48  const url = `${BASE_URL}/buy/browse/v1/item_summary/search?${params}`;
49
50  const response = await fetch(url, {
51    headers: {
52      'Authorization': `Bearer ${token}`,
53      'X-EBAY-C-MARKETPLACE-ID': marketplaceId,
54      'Content-Type': 'application/json'
55    }
56  });
57
58  if (!response.ok) {
59    const error = await response.text();
60    throw new Error(`eBay Browse API error ${response.status}: ${error}`);
61  }
62
63  return response.json();
64}
65
66module.exports = { getAccessToken, searchListings };

1// server.js — eBay search API server
2const express = require('express');
3const { searchListings } = require('./ebay-auth');
4
5const app = express();
6app.use(express.json());
7
8// GET /search?q=laptop&limit=20&marketplace=EBAY_US
9app.get('/search', async (req, res) => {
10  const { q, limit = 10, marketplace = 'EBAY_US' } = req.query;
11  if (!q) {
12    return res.status(400).json({ error: 'q (search query) is required' });
13  }
14  try {
15    const data = await searchListings(q, parseInt(limit), marketplace);
16    const items = (data.itemSummaries || []).map(item => ({
17      title: item.title,
18      price: item.price?.value,
19      currency: item.price?.currency,
20      condition: item.condition,
21      itemId: item.itemId,
22      url: item.itemWebUrl,
23      seller: item.seller?.username,
24      imageUrl: item.image?.imageUrl
25    }));
26    res.json({
27      total: data.total || 0,
28      query: q,
29      items
30    });
31  } catch (err) {
32    console.error('eBay search error:', err.message);
33    res.status(500).json({ error: err.message });
34  }
35});
36
37const PORT = process.env.PORT || 3000;
38app.listen(PORT, '0.0.0.0', () => {
39  console.log(`eBay API server running on port ${PORT}`);
40});

1# app.py — eBay API server in Python
2import os
3import base64
4import time
5import requests
6from flask import Flask, request, jsonify
7
8app = Flask(__name__)
9
10BASE_URL = (
11    'https://api.ebay.com'
12    if os.environ.get('EBAY_ENVIRONMENT') == 'production'
13    else 'https://api.sandbox.ebay.com'
14)
15
16_token_cache = {'token': None, 'expires_at': 0}
17
18def get_access_token():
19    if _token_cache['token'] and time.time() < _token_cache['expires_at'] - 60:
20        return _token_cache['token']
21
22    client_id = os.environ['EBAY_CLIENT_ID']
23    client_secret = os.environ['EBAY_CLIENT_SECRET']
24    credentials = base64.b64encode(f'{client_id}:{client_secret}'.encode()).decode()
25
26    resp = requests.post(
27        f'{BASE_URL}/identity/v1/oauth2/token',
28        headers={
29            'Authorization': f'Basic {credentials}',
30            'Content-Type': 'application/x-www-form-urlencoded'
31        },
32        data='grant_type=client_credentials&scope=https%3A%2F%2Fapi.ebay.com%2Foauth%2Fapi_scope',
33        timeout=10
34    )
35    resp.raise_for_status()
36    data = resp.json()
37    _token_cache['token'] = data['access_token']
38    _token_cache['expires_at'] = time.time() + data['expires_in']
39    return _token_cache['token']
40
41def search_listings(query, limit=10, marketplace='EBAY_US'):
42    token = get_access_token()
43    resp = requests.get(
44        f'{BASE_URL}/buy/browse/v1/item_summary/search',
45        headers={
46            'Authorization': f'Bearer {token}',
47            'X-EBAY-C-MARKETPLACE-ID': marketplace
48        },
49        params={'q': query, 'limit': limit},
50        timeout=15
51    )
52    resp.raise_for_status()
53    return resp.json()
54
55@app.route('/search')
56def search():
57    q = request.args.get('q')
58    limit = int(request.args.get('limit', 10))
59    marketplace = request.args.get('marketplace', 'EBAY_US')
60    if not q:
61        return jsonify({'error': 'q parameter required'}), 400
62    try:
63        data = search_listings(q, limit, marketplace)
64        items = [{
65            'title': i.get('title'),
66            'price': i.get('price', {}).get('value'),
67            'currency': i.get('price', {}).get('currency'),
68            'condition': i.get('condition'),
69            'url': i.get('itemWebUrl')
70        } for i in data.get('itemSummaries', [])]
71        return jsonify({'total': data.get('total', 0), 'query': q, 'items': items})
72    except requests.HTTPError as e:
73        return jsonify({'error': str(e)}), 500
74
75if __name__ == '__main__':
76    app.run(host='0.0.0.0', port=3000)