complete API

src/api/server/ajaxRouter.js

@@ -0,0 +1,372 @@
+import express from 'express';
+import jwt from 'jsonwebtoken';
+import CezerinClient from 'cezerin-client';
+import serverSettings from './lib/settings';
+const ajaxRouter = express.Router();
+
+const TOKEN_PAYLOAD = { email: 'store', scopes: ['admin'] };
+const STORE_ACCESS_TOKEN = jwt.sign(TOKEN_PAYLOAD, serverSettings.jwtSecretKey);
+
+const api = new CezerinClient({
+	apiBaseUrl: serverSettings.apiBaseUrl,
+	apiToken: STORE_ACCESS_TOKEN
+});
+
+const DEFAULT_CACHE_CONTROL = 'public, max-age=60';
+const PRODUCTS_CACHE_CONTROL = 'public, max-age=60';
+const PRODUCT_DETAILS_CACHE_CONTROL = 'public, max-age=60';
+
+const getCartCookieOptions = isHttps => ({
+	maxAge: 24 * 60 * 60 * 1000, // 24 hours
+	httpOnly: true,
+	signed: true,
+	secure: isHttps,
+	sameSite: 'strict'
+});
+
+const getIP = req => {
+	let ip = req.get('x-forwarded-for') || req.ip;
+
+	if (ip && ip.includes(', ')) {
+		ip = ip.split(', ')[0];
+	}
+
+	if (ip && ip.includes('::ffff:')) {
+		ip = ip.replace('::ffff:', '');
+	}
+
+	return ip;
+};
+
+const getUserAgent = req => {
+	return req.get('user-agent');
+};
+
+const getVariantFromProduct = (product, variantId) => {
+	if (product.variants && product.variants.length > 0) {
+		return product.variants.find(
+			variant => variant.id.toString() === variantId.toString()
+		);
+	} else {
+		return null;
+	}
+};
+
+const fillCartItemWithProductData = (products, cartItem) => {
+	const product = products.find(p => p.id === cartItem.product_id);
+	if (product) {
+		cartItem.image_url =
+			product.images && product.images.length > 0
+				? product.images[0].url
+				: null;
+		cartItem.path = product.path;
+		cartItem.stock_backorder = product.stock_backorder;
+		cartItem.stock_preorder = product.stock_preorder;
+		if (cartItem.variant_id && cartItem.variant_id.length > 0) {
+			const variant = getVariantFromProduct(product, cartItem.variant_id);
+			cartItem.stock_quantity = variant ? variant.stock_quantity : 0;
+		} else {
+			cartItem.stock_quantity = product.stock_quantity;
+		}
+	}
+	return cartItem;
+};
+
+const fillCartItems = cartResponse => {
+	let cart = cartResponse.json;
+	if (cart && cart.items && cart.items.length > 0) {
+		const productIds = cart.items.map(item => item.product_id);
+		return api.products
+			.list({
+				ids: productIds,
+				fields:
+					'images,enabled,stock_quantity,variants,path,stock_backorder,stock_preorder'
+			})
+			.then(({ status, json }) => {
+				const newCartItem = cart.items.map(cartItem =>
+					fillCartItemWithProductData(json.data, cartItem)
+				);
+				cartResponse.json.items = newCartItem;
+				return cartResponse;
+			});
+	} else {
+		return Promise.resolve(cartResponse);
+	}
+};
+
+ajaxRouter.get('/products', (req, res, next) => {
+	let filter = req.query;
+	filter.enabled = true;
+	api.products.list(filter).then(({ status, json }) => {
+		res
+			.status(status)
+			.header('Cache-Control', PRODUCTS_CACHE_CONTROL)
+			.send(json);
+	});
+});
+
+ajaxRouter.get('/products/:id', (req, res, next) => {
+	api.products.retrieve(req.params.id).then(({ status, json }) => {
+		res
+			.status(status)
+			.header('Cache-Control', PRODUCT_DETAILS_CACHE_CONTROL)
+			.send(json);
+	});
+});
+
+ajaxRouter.get('/cart', (req, res, next) => {
+	const order_id = req.signedCookies.order_id;
+	if (order_id) {
+		api.orders
+			.retrieve(order_id)
+			.then(cartResponse => fillCartItems(cartResponse))
+			.then(({ status, json }) => {
+				json.browser = undefined;
+				res.status(status).send(json);
+			});
+	} else {
+		res.end();
+	}
+});
+
+ajaxRouter.post('/cart/items', (req, res, next) => {
+	const isHttps = req.protocol === 'https';
+	const CART_COOKIE_OPTIONS = getCartCookieOptions(isHttps);
+
+	const order_id = req.signedCookies.order_id;
+	const item = req.body;
+	if (order_id) {
+		api.orders.items
+			.create(order_id, item)
+			.then(cartResponse => fillCartItems(cartResponse))
+			.then(({ status, json }) => {
+				res.status(status).send(json);
+			});
+	} else {
+		let orderDraft = {
+			draft: true,
+			referrer_url: req.signedCookies.referrer_url,
+			landing_url: req.signedCookies.landing_url,
+			browser: {
+				ip: getIP(req),
+				user_agent: getUserAgent(req)
+			},
+			shipping_address: {}
+		};
+
+		api.settings
+			.retrieve()
+			.then(settingsResponse => {
+				const storeSettings = settingsResponse.json;
+				orderDraft.shipping_address.country =
+					storeSettings.default_shipping_country;
+				orderDraft.shipping_address.state =
+					storeSettings.default_shipping_state;
+				orderDraft.shipping_address.city = storeSettings.default_shipping_city;
+				return orderDraft;
+			})
+			.then(orderDraft => {
+				api.orders.create(orderDraft).then(orderResponse => {
+					const orderId = orderResponse.json.id;
+					res.cookie('order_id', orderId, CART_COOKIE_OPTIONS);
+					api.orders.items
+						.create(orderId, item)
+						.then(cartResponse => fillCartItems(cartResponse))
+						.then(({ status, json }) => {
+							res.status(status).send(json);
+						});
+				});
+			});
+	}
+});
+
+ajaxRouter.delete('/cart/items/:item_id', (req, res, next) => {
+	const order_id = req.signedCookies.order_id;
+	const item_id = req.params.item_id;
+	if (order_id && item_id) {
+		api.orders.items
+			.delete(order_id, item_id)
+			.then(cartResponse => fillCartItems(cartResponse))
+			.then(({ status, json }) => {
+				res.status(status).send(json);
+			});
+	} else {
+		res.end();
+	}
+});
+
+ajaxRouter.put('/cart/items/:item_id', (req, res, next) => {
+	const order_id = req.signedCookies.order_id;
+	const item_id = req.params.item_id;
+	const item = req.body;
+	if (order_id && item_id) {
+		api.orders.items
+			.update(order_id, item_id, item)
+			.then(cartResponse => fillCartItems(cartResponse))
+			.then(({ status, json }) => {
+				res.status(status).send(json);
+			});
+	} else {
+		res.end();
+	}
+});
+
+ajaxRouter.put('/cart/checkout', (req, res, next) => {
+	const order_id = req.signedCookies.order_id;
+	if (order_id) {
+		api.orders
+			.checkout(order_id)
+			.then(cartResponse => fillCartItems(cartResponse))
+			.then(({ status, json }) => {
+				res.clearCookie('order_id');
+				res.status(status).send(json);
+			});
+	} else {
+		res.end();
+	}
+});
+
+ajaxRouter.put('/cart', async (req, res, next) => {
+	const cartData = req.body;
+	const {
+		shipping_address: shippingAddress,
+		billing_address: billingAddress
+	} = cartData;
+	const orderId = req.signedCookies.order_id;
+	if (orderId) {
+		if (shippingAddress) {
+			await api.orders.updateShippingAddress(orderId, shippingAddress);
+		}
+		if (billingAddress) {
+			await api.orders.updateBillingAddress(orderId, billingAddress);
+		}
+
+		await api.orders
+			.update(orderId, cartData)
+			.then(cartResponse => fillCartItems(cartResponse))
+			.then(({ status, json }) => {
+				res.status(status).send(json);
+			});
+	} else {
+		res.end();
+	}
+});
+
+ajaxRouter.put('/cart/shipping_address', (req, res, next) => {
+	const order_id = req.signedCookies.order_id;
+	if (order_id) {
+		api.orders
+			.updateShippingAddress(order_id, req.body)
+			.then(cartResponse => fillCartItems(cartResponse))
+			.then(({ status, json }) => {
+				res.status(status).send(json);
+			});
+	} else {
+		res.end();
+	}
+});
+
+ajaxRouter.put('/cart/billing_address', (req, res, next) => {
+	const order_id = req.signedCookies.order_id;
+	if (order_id) {
+		api.orders
+			.updateBillingAddress(order_id, req.body)
+			.then(cartResponse => fillCartItems(cartResponse))
+			.then(({ status, json }) => {
+				res.status(status).send(json);
+			});
+	} else {
+		res.end();
+	}
+});
+
+ajaxRouter.post('/cart/charge', async (req, res, next) => {
+	const order_id = req.signedCookies.order_id;
+	if (order_id) {
+		const client = api.orders.client;
+		const chargeResponse = await client.post(`/orders/${order_id}/charge`);
+		res.status(chargeResponse.status).send(chargeResponse.json);
+	} else {
+		res.end();
+	}
+});
+
+ajaxRouter.get('/pages', (req, res, next) => {
+	api.pages.list(req.query).then(({ status, json }) => {
+		res
+			.status(status)
+			.header('Cache-Control', DEFAULT_CACHE_CONTROL)
+			.send(json);
+	});
+});
+
+ajaxRouter.get('/pages/:id', (req, res, next) => {
+	api.pages.retrieve(req.params.id).then(({ status, json }) => {
+		res
+			.status(status)
+			.header('Cache-Control', DEFAULT_CACHE_CONTROL)
+			.send(json);
+	});
+});
+
+ajaxRouter.get('/sitemap', async (req, res, next) => {
+	let result = null;
+	let filter = req.query;
+	filter.enabled = true;
+
+	const sitemapResponse = await api.sitemap.retrieve(req.query);
+	if (sitemapResponse.status !== 404 || sitemapResponse.json) {
+		result = sitemapResponse.json;
+
+		if (result.type === 'product') {
+			const productResponse = await api.products.retrieve(result.resource);
+			result.data = productResponse.json;
+		} else if (result.type === 'page') {
+			const pageResponse = await api.pages.retrieve(result.resource);
+			result.data = pageResponse.json;
+		}
+	}
+
+	res
+		.status(sitemapResponse.status)
+		.header('Cache-Control', DEFAULT_CACHE_CONTROL)
+		.send(result);
+});
+
+ajaxRouter.get('/payment_methods', (req, res, next) => {
+	const filter = {
+		enabled: true,
+		order_id: req.signedCookies.order_id
+	};
+	api.paymentMethods.list(filter).then(({ status, json }) => {
+		const methods = json.map(item => {
+			delete item.conditions;
+			return item;
+		});
+
+		res.status(status).send(methods);
+	});
+});
+
+ajaxRouter.get('/shipping_methods', (req, res, next) => {
+	const filter = {
+		enabled: true,
+		order_id: req.signedCookies.order_id
+	};
+	api.shippingMethods.list(filter).then(({ status, json }) => {
+		res.status(status).send(json);
+	});
+});
+
+ajaxRouter.get('/payment_form_settings', (req, res, next) => {
+	const order_id = req.signedCookies.order_id;
+	if (order_id) {
+		api.orders.getPaymentFormSettings(order_id).then(({ status, json }) => {
+			res.status(status).send(json);
+		});
+	} else {
+		res.end();
+	}
+});
+
+export default ajaxRouter;