-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathserver.ts
136 lines (123 loc) · 3.73 KB
/
server.ts
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
136
// @ts-ignore
// Virtual entry point for the app
import * as remixBuild from 'virtual:remix/server-build';
import {
createCartHandler,
cartGetIdDefault,
cartSetIdDefault,
createStorefrontClient,
storefrontRedirect,
} from '@shopify/hydrogen';
import {
createRequestHandler,
getStorefrontHeaders,
} from '@shopify/remix-oxygen';
import {createPackClient, PackSession, handleRequest} from '@pack/hydrogen';
import {AppSession} from '~/lib/session.server';
import {getOxygenEnv} from '~/lib/utils';
import defaultThemeData from '~/config/default-theme-data.json';
import {DEFAULT_LOCALE} from '~/lib/constants';
/**
* Export a fetch handler in module format.
*/
export default {
async fetch(
request: Request,
env: Env,
executionContext: ExecutionContext,
): Promise<Response> {
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 = (p: Promise<any>) => executionContext.waitUntil(p);
const [cache, session, packSession] = await Promise.all([
caches.open('hydrogen'),
AppSession.init(request, [env.SESSION_SECRET]),
PackSession.init(request, [env.SESSION_SECRET]),
]);
/**
* Get Oxygen Environment data.
*/
const oxygen = getOxygenEnv(request);
/**
* Create Hydrogen's Storefront client.
*/
const {storefront} = createStorefrontClient({
cache,
waitUntil,
i18n: DEFAULT_LOCALE,
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 cart handler.
* Do not interact with if Hydrogen's useCart hook is being used.
*/
const cart = createCartHandler({
storefront,
getCartId: cartGetIdDefault(request.headers),
setCartId: cartSetIdDefault(),
});
/**
* Create Pack client.
*/
// check if the PACK_SECRET_TOKEN is set
if (!env.PACK_SECRET_TOKEN) {
throw new Error('PACK_SECRET_TOKEN environment variable is not set');
}
const pack = createPackClient({
cache,
waitUntil,
token: env.PACK_SECRET_TOKEN,
storeId: env.PACK_STOREFRONT_ID,
session: packSession,
contentEnvironment: env.PUBLIC_PACK_CONTENT_ENVIRONMENT,
defaultThemeData,
});
/**
* Create a Remix request handler and pass
* Hydrogen's Storefront client to the loader context.
*/
const response = await handleRequest(
pack,
request,
createRequestHandler({
build: remixBuild,
mode: process.env.NODE_ENV,
getLoadContext: () => ({
cache,
waitUntil,
session,
storefront,
cart,
env,
oxygen,
pack,
}),
}),
);
if (session.isPending) {
response.headers.set('Set-Cookie', await session.commit());
}
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) {
console.error(error);
return new Response('An unexpected error occurred', {status: 500});
}
},
};