You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

265 lines
7.7 KiB

4 weeks ago
  1. import { stringify } from 'querystring'
  2. import Vue from 'vue'
  3. import fetch from 'node-fetch'
  4. import middleware from './middleware.js'
  5. import {
  6. applyAsyncData,
  7. middlewareSeries,
  8. sanitizeComponent,
  9. getMatchedComponents,
  10. promisify
  11. } from './utils.js'
  12. import fetchMixin from './mixins/fetch.server'
  13. import { createApp, NuxtError } from './index.js'
  14. import NuxtLink from './components/nuxt-link.server.js' // should be included after ./index.js
  15. // Update serverPrefetch strategy
  16. Vue.config.optionMergeStrategies.serverPrefetch = Vue.config.optionMergeStrategies.created
  17. // Fetch mixin
  18. if (!Vue.__nuxt__fetch__mixin__) {
  19. Vue.mixin(fetchMixin)
  20. Vue.__nuxt__fetch__mixin__ = true
  21. }
  22. // Component: <NuxtLink>
  23. Vue.component(NuxtLink.name, NuxtLink)
  24. Vue.component('NLink', NuxtLink)
  25. if (!global.fetch) { global.fetch = fetch }
  26. const noopApp = () => new Vue({ render: h => h('div') })
  27. function urlJoin () {
  28. return Array.prototype.slice.call(arguments).join('/').replace(/\/+/g, '/')
  29. }
  30. const createNext = ssrContext => (opts) => {
  31. ssrContext.redirected = opts
  32. // If nuxt generate
  33. if (!ssrContext.res) {
  34. ssrContext.nuxt.serverRendered = false
  35. return
  36. }
  37. opts.query = stringify(opts.query)
  38. opts.path = opts.path + (opts.query ? '?' + opts.query : '')
  39. const routerBase = '/'
  40. if (!opts.path.startsWith('http') && (routerBase !== '/' && !opts.path.startsWith(routerBase))) {
  41. opts.path = urlJoin(routerBase, opts.path)
  42. }
  43. // Avoid loop redirect
  44. if (opts.path === ssrContext.url) {
  45. ssrContext.redirected = false
  46. return
  47. }
  48. ssrContext.res.writeHead(opts.status, {
  49. Location: opts.path
  50. })
  51. ssrContext.res.end()
  52. }
  53. // This exported function will be called by `bundleRenderer`.
  54. // This is where we perform data-prefetching to determine the
  55. // state of our application before actually rendering it.
  56. // Since data fetching is async, this function is expected to
  57. // return a Promise that resolves to the app instance.
  58. export default async (ssrContext) => {
  59. // Create ssrContext.next for simulate next() of beforeEach() when wanted to redirect
  60. ssrContext.redirected = false
  61. ssrContext.next = createNext(ssrContext)
  62. // Used for beforeNuxtRender({ Components, nuxtState })
  63. ssrContext.beforeRenderFns = []
  64. // Nuxt object (window{{globals.context}}, defaults to window.__NUXT__)
  65. ssrContext.nuxt = { layout: 'default', data: [], fetch: [], error: null, serverRendered: true, routePath: '' }
  66. // Create the app definition and the instance (created for each request)
  67. const { app, router } = await createApp(ssrContext)
  68. const _app = new Vue(app)
  69. // Add ssr route path to nuxt context so we can account for page navigation between ssr and csr
  70. ssrContext.nuxt.routePath = app.context.route.path
  71. // Add meta infos (used in renderer.js)
  72. ssrContext.meta = _app.$meta()
  73. // Keep asyncData for each matched component in ssrContext (used in app/utils.js via this.$ssrContext)
  74. ssrContext.asyncData = {}
  75. const beforeRender = async () => {
  76. // Call beforeNuxtRender() methods
  77. await Promise.all(ssrContext.beforeRenderFns.map(fn => promisify(fn, { Components, nuxtState: ssrContext.nuxt })))
  78. }
  79. const renderErrorPage = async () => {
  80. // Load layout for error page
  81. const layout = (NuxtError.options || NuxtError).layout
  82. const errLayout = typeof layout === 'function' ? layout.call(NuxtError, app.context) : layout
  83. ssrContext.nuxt.layout = errLayout || 'default'
  84. await _app.loadLayout(errLayout)
  85. _app.setLayout(errLayout)
  86. await beforeRender()
  87. return _app
  88. }
  89. const render404Page = () => {
  90. app.context.error({ statusCode: 404, path: ssrContext.url, message: 'This page could not be found' })
  91. return renderErrorPage()
  92. }
  93. const s = Date.now()
  94. // Components are already resolved by setContext -> getRouteData (app/utils.js)
  95. const Components = getMatchedComponents(router.match(ssrContext.url))
  96. /*
  97. ** Call global middleware (nuxt.config.js)
  98. */
  99. let midd = []
  100. midd = midd.map((name) => {
  101. if (typeof name === 'function') {
  102. return name
  103. }
  104. if (typeof middleware[name] !== 'function') {
  105. app.context.error({ statusCode: 500, message: 'Unknown middleware ' + name })
  106. }
  107. return middleware[name]
  108. })
  109. await middlewareSeries(midd, app.context)
  110. // ...If there is a redirect or an error, stop the process
  111. if (ssrContext.redirected) {
  112. return noopApp()
  113. }
  114. if (ssrContext.nuxt.error) {
  115. return renderErrorPage()
  116. }
  117. /*
  118. ** Set layout
  119. */
  120. let layout = Components.length ? Components[0].options.layout : NuxtError.layout
  121. if (typeof layout === 'function') {
  122. layout = layout(app.context)
  123. }
  124. await _app.loadLayout(layout)
  125. if (ssrContext.nuxt.error) {
  126. return renderErrorPage()
  127. }
  128. layout = _app.setLayout(layout)
  129. ssrContext.nuxt.layout = _app.layoutName
  130. /*
  131. ** Call middleware (layout + pages)
  132. */
  133. midd = []
  134. layout = sanitizeComponent(layout)
  135. if (layout.options.middleware) {
  136. midd = midd.concat(layout.options.middleware)
  137. }
  138. Components.forEach((Component) => {
  139. if (Component.options.middleware) {
  140. midd = midd.concat(Component.options.middleware)
  141. }
  142. })
  143. midd = midd.map((name) => {
  144. if (typeof name === 'function') {
  145. return name
  146. }
  147. if (typeof middleware[name] !== 'function') {
  148. app.context.error({ statusCode: 500, message: 'Unknown middleware ' + name })
  149. }
  150. return middleware[name]
  151. })
  152. await middlewareSeries(midd, app.context)
  153. // ...If there is a redirect or an error, stop the process
  154. if (ssrContext.redirected) {
  155. return noopApp()
  156. }
  157. if (ssrContext.nuxt.error) {
  158. return renderErrorPage()
  159. }
  160. /*
  161. ** Call .validate()
  162. */
  163. let isValid = true
  164. try {
  165. for (const Component of Components) {
  166. if (typeof Component.options.validate !== 'function') {
  167. continue
  168. }
  169. isValid = await Component.options.validate(app.context)
  170. if (!isValid) {
  171. break
  172. }
  173. }
  174. } catch (validationError) {
  175. // ...If .validate() threw an error
  176. app.context.error({
  177. statusCode: validationError.statusCode || '500',
  178. message: validationError.message
  179. })
  180. return renderErrorPage()
  181. }
  182. // ...If .validate() returned false
  183. if (!isValid) {
  184. // Don't server-render the page in generate mode
  185. if (ssrContext._generate) {
  186. ssrContext.nuxt.serverRendered = false
  187. }
  188. // Render a 404 error page
  189. return render404Page()
  190. }
  191. // If no Components found, returns 404
  192. if (!Components.length) {
  193. return render404Page()
  194. }
  195. // Call asyncData & fetch hooks on components matched by the route.
  196. const asyncDatas = await Promise.all(Components.map((Component) => {
  197. const promises = []
  198. // Call asyncData(context)
  199. if (Component.options.asyncData && typeof Component.options.asyncData === 'function') {
  200. const promise = promisify(Component.options.asyncData, app.context)
  201. promise.then((asyncDataResult) => {
  202. ssrContext.asyncData[Component.cid] = asyncDataResult
  203. applyAsyncData(Component)
  204. return asyncDataResult
  205. })
  206. promises.push(promise)
  207. } else {
  208. promises.push(null)
  209. }
  210. // Call fetch(context)
  211. if (Component.options.fetch && Component.options.fetch.length) {
  212. promises.push(Component.options.fetch(app.context))
  213. } else {
  214. promises.push(null)
  215. }
  216. return Promise.all(promises)
  217. }))
  218. if (process.env.DEBUG && asyncDatas.length) console.debug('Data fetching ' + ssrContext.url + ': ' + (Date.now() - s) + 'ms')
  219. // datas are the first row of each
  220. ssrContext.nuxt.data = asyncDatas.map(r => r[0] || {})
  221. // ...If there is a redirect or an error, stop the process
  222. if (ssrContext.redirected) {
  223. return noopApp()
  224. }
  225. if (ssrContext.nuxt.error) {
  226. return renderErrorPage()
  227. }
  228. // Call beforeNuxtRender methods & add store state
  229. await beforeRender()
  230. return _app
  231. }