Merge pull request #3529 from SalesforceCommerceCloud/add-non-streaming-endpoint

@W-20313656: Ref App endpoint to support streaming testing

Author: lizcross

packages/template-mrt-reference-app/app/ssr.js

@@ -232,6 +232,14 @@ const ssrShared = async (req, res) => {
     }
 }
 
+/**
+ * Express handler that returns a non-streaming response.
+ */
+const streamingLarge = (req, res) => {
+    res.status(200)
+    res.json({streaming: false})
+}
+
 /**
  * Express handler that allocates a lot of memory, and then removes
  * a reference to the objects, such that they may be garbage collected.
@@ -380,6 +388,7 @@ const {handler, app, server} = runtime.createHandler(options, (app) => {
     // before we invoke the handlers)
     app.use((req, res, next) => {
         res.set('Cache-Control', 'no-cache')
+        res.set('Server', 'mrt ref app')
         return next()
     })
 
@@ -398,6 +407,7 @@ const {handler, app, server} = runtime.createHandler(options, (app) => {
     app.get('/isolation', isolationTests)
     app.get('/set-response-headers', responseHeadersTest)
     app.get('/ssr-shared', ssrShared)
+    app.get('/streaming-large', streamingLarge)
 
     // Add a /auth/logout path that will always send a 401 (to allow clearing
     // of browser credentials)

packages/template-mrt-reference-app/app/ssr.test.js

@@ -24,6 +24,7 @@ class AccessDenied extends ServiceException {
 }
 
 describe('server', () => {
+    // eslint-disable-next-line @typescript-eslint/no-unused-vars
     let originalEnv, app, server
     const lambdaMock = mockClient(LambdaClient)
     const s3Mock = mockClient(S3Client)
@@ -61,7 +62,8 @@ describe('server', () => {
         ['/multi-cookies', 200, 'application/json; charset=utf-8'],
         ['/set-response-headers', 200, 'application/json; charset=utf-8'],
         ['/isolation', 200, 'application/json; charset=utf-8'],
-        ['/memtest', 200, 'application/json; charset=utf-8']
+        ['/memtest', 200, 'application/json; charset=utf-8'],
+        ['/streaming-large', 200, 'application/json; charset=utf-8']
     ])('Path %p should render correctly', (path, expectedStatus, expectedContentType) => {
         return request(app)
             .get(path)
@@ -77,6 +79,10 @@ describe('server', () => {
         return request(app).get('/cache/123').expect('Cache-Control', 's-maxage=123')
     })
 
+    test('All responses have Server header set to "mrt ref app"', () => {
+        return request(app).get('/').expect('Server', 'mrt ref app')
+    })
+
     test('Path "/headers" echoes request headers', async () => {
         const response = await request(app).get('/headers').set('Random-Header', 'random')
 
@@ -171,4 +177,10 @@ describe('server', () => {
             'This file is used in the E2E tests to verify that correct header values are set.'
         )
     })
+
+    test('Path "/streaming-large" returns streaming: false', async () => {
+        const response = await request(app).get('/streaming-large')
+        expect(response.status).toBe(200)
+        expect(response.body).toEqual({streaming: false})
+    })
 })