-
Notifications
You must be signed in to change notification settings - Fork 1
/
Copy pathserver.js
135 lines (121 loc) · 3.84 KB
/
server.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
// @ts-ignore
// Virtual entry point for the app
import * as remixBuild from 'virtual:remix/server-build';
import {
cartGetIdDefault,
cartSetIdDefault,
createCartHandler,
createCustomerAccountClient,
createStorefrontClient,
storefrontRedirect,
} from '@shopify/hydrogen';
import { createRequestHandler, getStorefrontHeaders, } from '@shopify/remix-oxygen';
import { AppSession } from '~/lib/session';
import { CART_QUERY_FRAGMENT } from '~/lib/fragments';
/**
* Export a fetch handler in module format.
*/
export default {
/**
* @param {Request} request
* @param {Env} env
* @param {ExecutionContext} executionContext
*/
async fetch(request, env, executionContext) {
try {
/**
* Open a cache instance in the worker and a custom session instance.
*/
if (!env?.SESSION_SECRET) {
throw new Error('SESSION_SECRET environment variable is not set');
}
const waitUntil = executionContext.waitUntil.bind(executionContext);
const [cache, session] = await Promise.all([
caches.open('hydrogen'),
AppSession.init(request, [env.SESSION_SECRET]),
]);
/**
* Create Hydrogen's Storefront client.
*/
const { storefront } = createStorefrontClient({
cache,
waitUntil,
i18n: getLocaleFromRequest(request),
publicStorefrontToken: env.PUBLIC_STOREFRONT_API_TOKEN,
privateStorefrontToken: env.PRIVATE_STOREFRONT_API_TOKEN,
storeDomain: env.PUBLIC_STORE_DOMAIN,
storefrontId: env.PUBLIC_STOREFRONT_ID,
storefrontHeaders: getStorefrontHeaders(request),
});
/**
* Create a client for Customer Account API.
*/
const customerAccount = createCustomerAccountClient({
waitUntil,
request,
session,
customerAccountId: env.PUBLIC_CUSTOMER_ACCOUNT_API_CLIENT_ID,
customerAccountUrl: env.PUBLIC_CUSTOMER_ACCOUNT_API_URL,
});
/*
* Create a cart handler that will be used to
* create and update the cart in the session.
*/
const cart = createCartHandler({
storefront,
customerAccount,
getCartId: cartGetIdDefault(request.headers),
setCartId: cartSetIdDefault({
maxage: 60 * 60 * 24 * 7
}),
cartQueryFragment: CART_QUERY_FRAGMENT,
});
/**
* Create a Remix request handler and pass
* Hydrogen's Storefront client to the loader context.
*/
const handleRequest = createRequestHandler({
build: remixBuild,
mode: process.env.NODE_ENV,
getLoadContext: () => ({
session,
storefront,
customerAccount,
cart,
env,
waitUntil,
}),
});
const response = await handleRequest(request);
if (response.status === 404) {
/**
* Check for redirects only when there's a 404 from the app.
* If the redirect doesn't exist, then `storefrontRedirect`
* will pass through the 404 response.
*/
return storefrontRedirect({ request, response, storefront });
}
return response;
} catch (error) {
// eslint-disable-next-line no-console
console.error(error);
return new Response('An unexpected error occurred', { status: 500 });
}
},
};
/**
* @returns {I18nLocale}
* @param {Request} request
*/
function getLocaleFromRequest(request) {
const url = new URL(request.url);
const firstPathPart = url.pathname.split('/')[1]?.toUpperCase() ?? '';
let pathPrefix = '';
let [language, country] = ['EN', 'US'];
if (/^[A-Z]{2}-[A-Z]{2}$/i.test(firstPathPart)) {
pathPrefix = '/' + firstPathPart;
[language, country] = firstPathPart.split('-');
}
return { language, country, pathPrefix };
}
/** @typedef {import('@shopify/remix-oxygen').AppLoadContext} AppLoadContext */