How to Integrate Replit with WooCommerce

1import os
2from flask import Flask, request, jsonify
3from woocommerce import API
4
5app = Flask(__name__)
6
7# Initialize WooCommerce API client
8wcapi = API(
9    url=os.environ["WC_STORE_URL"],
10    consumer_key=os.environ["WC_CONSUMER_KEY"],
11    consumer_secret=os.environ["WC_CONSUMER_SECRET"],
12    version="wc/v3",
13    timeout=30
14)
15
16
17@app.route("/products")
18def list_products():
19    """List products with optional filtering."""
20    page = request.args.get("page", 1)
21    per_page = min(int(request.args.get("per_page", 20)), 100)
22    status = request.args.get("status", "publish")
23
24    response = wcapi.get("products", params={
25        "page": page,
26        "per_page": per_page,
27        "status": status
28    })
29    if response.status_code != 200:
30        return jsonify({"error": response.json()}), response.status_code
31    return jsonify({
32        "total_pages": response.headers.get("X-WP-TotalPages"),
33        "total": response.headers.get("X-WP-Total"),
34        "products": response.json()
35    })
36
37
38@app.route("/products", methods=["POST"])
39def create_product():
40    """Create a new product."""
41    data = request.get_json()
42    response = wcapi.post("products", data)
43    return jsonify(response.json()), response.status_code
44
45
46@app.route("/products/batch", methods=["POST"])
47def batch_update_products():
48    """Batch update multiple products."""
49    data = request.get_json()
50    # data format: {"update": [{"id": 1, "regular_price": "19.99"}, ...]}
51    response = wcapi.post("products/batch", data)
52    return jsonify(response.json()), response.status_code
53
54
55@app.route("/orders")
56def list_orders():
57    """List orders with optional status filter."""
58    page = request.args.get("page", 1)
59    per_page = min(int(request.args.get("per_page", 20)), 100)
60    status = request.args.get("status", "any")
61
62    response = wcapi.get("orders", params={
63        "page": page,
64        "per_page": per_page,
65        "status": status
66    })
67    if response.status_code != 200:
68        return jsonify({"error": response.json()}), response.status_code
69    return jsonify({
70        "total_pages": response.headers.get("X-WP-TotalPages"),
71        "orders": response.json()
72    })
73
74
75@app.route("/orders/<int:order_id>")
76def get_order(order_id):
77    """Get a single order by ID."""
78    response = wcapi.get(f"orders/{order_id}")
79    return jsonify(response.json()), response.status_code
80
81
82@app.route("/orders/<int:order_id>/status", methods=["PUT"])
83def update_order_status(order_id):
84    """Update order status."""
85    data = request.get_json()
86    new_status = data.get("status")
87    if not new_status:
88        return jsonify({"error": "status is required"}), 400
89    # Valid statuses: pending, processing, on-hold, completed, cancelled, refunded, failed
90    response = wcapi.put(f"orders/{order_id}", {"status": new_status})
91    return jsonify(response.json()), response.status_code
92
93
94if __name__ == "__main__":
95    app.run(host="0.0.0.0", port=3000, debug=True)

1const express = require('express');
2const crypto = require('crypto');
3const WooCommerceRestApi = require('@woocommerce/woocommerce-rest-api').default;
4
5const app = express();
6
7const WC_STORE_URL = process.env.WC_STORE_URL;
8const WC_CONSUMER_KEY = process.env.WC_CONSUMER_KEY;
9const WC_CONSUMER_SECRET = process.env.WC_CONSUMER_SECRET;
10const WC_WEBHOOK_SECRET = process.env.WC_WEBHOOK_SECRET || '';
11
12const api = new WooCommerceRestApi({
13  url: WC_STORE_URL,
14  consumerKey: WC_CONSUMER_KEY,
15  consumerSecret: WC_CONSUMER_SECRET,
16  version: 'wc/v3'
17});
18
19// Webhook handler — use raw body for signature verification
20app.post('/webhook', express.raw({ type: 'application/json' }), (req, res) => {
21  // Verify webhook signature if secret is configured
22  if (WC_WEBHOOK_SECRET) {
23    const signature = req.headers['x-wc-webhook-signature'];
24    const expected = crypto
25      .createHmac('sha256', WC_WEBHOOK_SECRET)
26      .update(req.body)
27      .digest('base64');
28    if (signature !== expected) {
29      return res.status(401).json({ error: 'Invalid webhook signature' });
30    }
31  }
32
33  const event = JSON.parse(req.body);
34  const topic = req.headers['x-wc-webhook-topic'];
35
36  console.log(`WooCommerce webhook: ${topic}`);
37
38  switch (topic) {
39    case 'order.created':
40    case 'order.updated':
41      console.log(`Order ${event.id} status: ${event.status}, total: ${event.total}`);
42      // Add downstream logic: notify fulfillment, update CRM, etc.
43      break;
44    case 'product.created':
45    case 'product.updated':
46      console.log(`Product ${event.id}: ${event.name} — stock: ${event.stock_quantity}`);
47      break;
48    case 'customer.created':
49      console.log(`New customer: ${event.email}`);
50      break;
51    default:
52      console.log(`Unhandled topic: ${topic}`);
53  }
54
55  res.json({ received: true });
56});
57
58// Use JSON parser for non-webhook routes
59app.use(express.json());
60
61// List products
62app.get('/products', async (req, res) => {
63  try {
64    const response = await api.get('products', {
65      per_page: Number(req.query.per_page) || 20,
66      page: Number(req.query.page) || 1,
67      status: req.query.status || 'publish'
68    });
69    res.json({
70      total: response.headers['x-wp-total'],
71      total_pages: response.headers['x-wp-totalpages'],
72      products: response.data
73    });
74  } catch (err) {
75    res.status(err.response?.status || 500).json({ error: err.message });
76  }
77});
78
79// Get order by ID
80app.get('/orders/:id', async (req, res) => {
81  try {
82    const response = await api.get(`orders/${req.params.id}`);
83    res.json(response.data);
84  } catch (err) {
85    res.status(err.response?.status || 500).json({ error: err.message });
86  }
87});
88
89// Update order status
90app.put('/orders/:id/status', async (req, res) => {
91  const { status } = req.body;
92  if (!status) return res.status(400).json({ error: 'status is required' });
93  try {
94    const response = await api.put(`orders/${req.params.id}`, { status });
95    res.json(response.data);
96  } catch (err) {
97    res.status(err.response?.status || 500).json({ error: err.message });
98  }
99});
100
101app.listen(3000, '0.0.0.0', () => {
102  console.log('WooCommerce integration server running on port 3000');
103});

1[[ports]]
2internalPort = 3000
3externalPort = 80
4
5[deployment]
6run = ["node", "server.js"]
7deploymentTarget = "cloudrun"