Snapshot Ready

import requests
import csv
from io import StringIO

@app.route('/api/snapshotReady', methods=['POST'])
def handle_snapshot_ready():
    try:
        payload = request.get_json()
        message_id = payload['message_id']

        # Check if already processed
        if is_message_processed(message_id):
            return 'OK', 200

        # Extract snapshot info
        snapshot_data = payload['data']
        download_url = snapshot_data['download_url']
        snapshot_id = snapshot_data['snapshot_id']
        snapshot_type = snapshot_data['snapshot_type']

        # Download the snapshot file
        response = requests.get(download_url)
        response.raise_for_status()

        # Parse CSV data
        csv_data = StringIO(response.text)
        reader = csv.DictReader(csv_data)

        # Process each row
        for row in reader:
            sku_id = row['customer_identifier']
            location = row['location_id']
            status = row['inventory_status']
            quantity = int(row['quantity'])

            # Update your inventory system
            update_inventory_snapshot(sku_id, location, status, quantity)

        # Mark as processed
        mark_message_processed(message_id)
        logger.info(f"Processed snapshot {snapshot_id}")

        return 'OK', 200

    except Exception as e:
        logger.error(f"Snapshot webhook error: {e}")
        return 'Error', 500

const axios = require('axios');
const csv = require('csv-parser');
const { Readable } = require('stream');

app.post('/api/snapshotReady', async (req, res) => {
  try {
    const payload = req.body;
    const messageId = payload.message_id;

    // Check if already processed
    if (await isMessageProcessed(messageId)) {
      return res.status(200).send('OK');
    }

    // Extract snapshot info
    const snapshotData = payload.data;
    const downloadUrl = snapshotData.download_url;
    const snapshotId = snapshotData.snapshot_id;

    // Download the snapshot file
    const response = await axios.get(downloadUrl);

    // Parse CSV data
    const rows = [];
    await new Promise((resolve, reject) => {
      Readable.from(response.data)
        .pipe(csv())
        .on('data', (row) => rows.push(row))
        .on('end', resolve)
        .on('error', reject);
    });

    // Process each row
    for (const row of rows) {
      await updateInventorySnapshot(
        row.customer_identifier,
        row.location_id,
        row.inventory_status,
        parseInt(row.quantity)
      );
    }

    // Mark as processed
    await markMessageProcessed(messageId);
    console.log(`Processed snapshot ${snapshotId}`);

    res.status(200).send('OK');

  } catch (error) {
    console.error('Snapshot webhook error:', error);
    res.status(500).send('Error');
  }
});