Reimagine retail: Unleash agility and innovation withCatalyst Serverless

	// syncInventory.js
	// This is an Event Function in Catalyst Serverless
	// It updates inventory in real-time when a change is detected in the system (e.g.,
	// via DataStore insert/update)
	
	const catalyst = require('zcatalyst-sdk-node');
	
	module.exports = async (event, context) => {
		const app = catalyst.initialize(context);
		const datastore = app.datastore();
		const inventoryTable = datastore.table('Inventory');
	
		try {
			// --- EVENT FUNCTION METHOD USED ---
			// event.getData(): Get data from the event payload
			const { sku, quantity } = event.getData(); // Example: { sku: 'TSHIRT001', quantity: 15 }
	
			// event.getSource(): Identify the source component (e.g., 'DataStore', 'Cache')
			console.log('Triggered by:', event.getSource());
	
			// event.getAction(): Get what triggered the function (e.g., INSERT, UPDATE)
			console.log('Triggered action:', event.getAction());
	
			// event.getTime(): Timestamp of the event
			console.log('Event occurred at:', event.getTime());
	
			// event.getProjectDetails(): Optional - log project info for audit/debug
			const project = event.getProjectDetails();
			console.log(`Project: ${project.project_name} (${project.project_id})`);
	
			// Fetch and update inventory
			const query = inventoryTable.query().where('SKU', '=', sku);
			const rows = await query.execute();
	
			if (!rows.length) return context.closeWithFailure();
	
			await inventoryTable.updateRow({
				ROWID: rows[0].ROWID,
				Quantity: quantity
			});
	
			// --- Cron Function's Context Module Method Used ---
			// context.closeWithSuccess(): Mark function execution as successful
			context.closeWithSuccess();
	
		} catch (err) {
			console.error('Inventory sync failed:', err);
	
			// --- CONTEXT METHOD USED ---
			// context.closeWithFailure(): Mark function execution as failed
			context.closeWithFailure();
		}
	};