How to Integrate Replit with 3dcart (now Shift4Shop)

1import os
2import requests
3from typing import Optional
4
5API_TOKEN = os.environ["SHIFT4SHOP_API_TOKEN"]
6STORE_URL = os.environ["SHIFT4SHOP_STORE_URL"].rstrip("/")
7BASE_URL = f"{STORE_URL}/api.php"
8
9HEADERS = {
10    "Authorization": f"Bearer {API_TOKEN}",
11    "Content-Type": "application/json",
12    "Accept": "application/json"
13}
14
15def get_orders(status: Optional[str] = None, limit: int = 20) -> list:
16    """Fetch orders, optionally filtered by status (e.g., 'New', 'Processing', 'Shipped')."""
17    params = {"Route": "Orders", "limit": limit, "offset": 0}
18    if status:
19        params["Status"] = status
20    response = requests.get(BASE_URL, headers=HEADERS, params=params)
21    response.raise_for_status()
22    return response.json()
23
24def get_order(order_id: str) -> dict:
25    """Fetch a single order by order ID."""
26    params = {"Route": f"Orders/{order_id}"}
27    response = requests.get(BASE_URL, headers=HEADERS, params=params)
28    response.raise_for_status()
29    return response.json()
30
31def update_order_status(order_id: str, status: str) -> dict:
32    """Update the status of an order (e.g., 'Processing', 'Shipped', 'Delivered')."""
33    params = {"Route": f"Orders/{order_id}"}
34    data = {"OrderStatus": status}
35    response = requests.put(BASE_URL, headers=HEADERS, params=params, json=data)
36    response.raise_for_status()
37    return response.json()
38
39def get_products(limit: int = 50) -> list:
40    """List all products in the store."""
41    params = {"Route": "Products", "limit": limit, "offset": 0}
42    response = requests.get(BASE_URL, headers=HEADERS, params=params)
43    response.raise_for_status()
44    return response.json()
45
46def update_product_stock(catalog_id: str, new_stock: int) -> dict:
47    """Update the stock level for a product by CatalogID."""
48    params = {"Route": f"Products/{catalog_id}"}
49    data = {"Stock": new_stock}
50    response = requests.put(BASE_URL, headers=HEADERS, params=params, json=data)
51    response.raise_for_status()
52    return response.json()
53
54def get_customers(limit: int = 50) -> list:
55    """List customers from the store."""
56    params = {"Route": "Customers", "limit": limit, "offset": 0}
57    response = requests.get(BASE_URL, headers=HEADERS, params=params)
58    response.raise_for_status()
59    return response.json()
60
61if __name__ == "__main__":
62    # Fetch recent new orders
63    orders = get_orders(status="New", limit=5)
64    print(f"New orders: {len(orders)}")
65    for order in orders:
66        print(f"  Order {order.get('OrderID')} — ${order.get('OrderAmount')} — {order.get('BillingFirstName')} {order.get('BillingLastName')}")
67
68    # List first 5 products with stock levels
69    products = get_products(limit=5)
70    print(f"\nProducts (first 5):")
71    for p in products:
72        print(f"  [{p.get('CatalogID')}] {p.get('Name')} — Stock: {p.get('Stock')}")

1const express = require('express');
2const axios = require('axios');
3
4const app = express();
5app.use(express.json());
6
7const API_TOKEN = process.env.SHIFT4SHOP_API_TOKEN;
8const STORE_URL = (process.env.SHIFT4SHOP_STORE_URL || '').replace(/\/$/, '');
9const BASE_URL = `${STORE_URL}/api.php`;
10
11const shift4 = axios.create({
12  baseURL: BASE_URL,
13  headers: {
14    Authorization: `Bearer ${API_TOKEN}`,
15    'Content-Type': 'application/json',
16    Accept: 'application/json'
17  }
18});
19
20// GET /orders — list recent orders
21app.get('/orders', async (req, res) => {
22  try {
23    const response = await shift4.get('', {
24      params: { Route: 'Orders', limit: req.query.limit || 20, offset: req.query.offset || 0 }
25    });
26    res.json(response.data);
27  } catch (err) {
28    console.error('Shift4Shop error:', err.response?.data);
29    res.status(err.response?.status || 500).json({ error: err.message });
30  }
31});
32
33// GET /orders/:id — fetch a single order
34app.get('/orders/:id', async (req, res) => {
35  try {
36    const response = await shift4.get('', {
37      params: { Route: `Orders/${req.params.id}` }
38    });
39    res.json(response.data);
40  } catch (err) {
41    res.status(err.response?.status || 500).json({ error: err.message });
42  }
43});
44
45// GET /products — list products
46app.get('/products', async (req, res) => {
47  try {
48    const response = await shift4.get('', {
49      params: { Route: 'Products', limit: req.query.limit || 50, offset: req.query.offset || 0 }
50    });
51    res.json(response.data);
52  } catch (err) {
53    res.status(err.response?.status || 500).json({ error: err.message });
54  }
55});
56
57// PUT /products/:id/stock — update product stock
58app.put('/products/:id/stock', async (req, res) => {
59  const { stock } = req.body;
60  if (stock === undefined) {
61    return res.status(400).json({ error: 'stock field required in request body' });
62  }
63  try {
64    const response = await shift4.put('', { Stock: stock }, {
65      params: { Route: `Products/${req.params.id}` }
66    });
67    res.json(response.data);
68  } catch (err) {
69    res.status(err.response?.status || 500).json({ error: err.message });
70  }
71});
72
73// POST /webhook/orders — receive Shift4Shop order webhooks
74app.post('/webhook/orders', (req, res) => {
75  const event = req.body;
76  console.log('Shift4Shop webhook:', JSON.stringify(event, null, 2));
77  // Process order event here
78  res.json({ received: true });
79});
80
81app.listen(3000, '0.0.0.0', () => {
82  console.log('Shift4Shop proxy server running on port 3000');
83});

1from flask import Flask, request, jsonify
2import os
3import json
4
5app = Flask(__name__)
6
7@app.route('/webhook/orders', methods=['POST'])
8def order_webhook():
9    """Receive Shift4Shop order event webhooks."""
10    payload = request.json or {}
11    
12    # Extract order details from payload
13    order_id = payload.get('OrderID', payload.get('order_id', 'unknown'))
14    status = payload.get('OrderStatus', '')
15    customer_email = payload.get('BillingEmail', '')
16    order_total = payload.get('OrderAmount', 0)
17    
18    print(f"Shift4Shop webhook: Order {order_id} | Status: {status} | Customer: {customer_email} | Total: ${order_total}")
19    
20    # Handle different event types
21    if status in ('New', '1'):
22        # New order placed — trigger fulfilment workflow, send confirmation, etc.
23        print(f"New order {order_id} from {customer_email} for ${order_total}")
24    elif status in ('Shipped', '3'):
25        # Order shipped — send tracking notification
26        tracking = payload.get('ShipmentList', [{}])[0].get('TrackingNumber', '')
27        print(f"Order {order_id} shipped, tracking: {tracking}")
28    
29    return jsonify({'received': True}), 200
30
31@app.route('/health', methods=['GET'])
32def health():
33    return jsonify({'status': 'ok'})
34
35if __name__ == '__main__':
36    app.run(host='0.0.0.0', port=3000)