forgotten

Author: pauxiel

package-lock.json

@@ -26,6 +26,7 @@
     "rxjs": "^7.8.2",
     "serverless-export-env": "^2.2.0",
     "serverless-export-outputs": "^1.0.2",
+    "serverless-plugin-extrinsic-functions": "^1.1.1",
     "vitest": "^4.0.10"
   },
   "dependencies": {

package.json

@@ -286,13 +286,14 @@ resources:
 
   Conditions:
     IsE2eTest:
-      Fn::Equals:
+      Fn::StartsWith:
         - ${sls:stage}
         - dev
 
 plugins:
   - serverless-export-env
   - serverless-export-outputs
+  - serverless-plugin-extrinsic-functions
 
 custom:
   export-env:

serverless.yml

@@ -1,52 +1,49 @@
-import { describe, it, expect, beforeAll, afterAll, vi } from 'vitest'
+import { describe, it, expect, beforeAll, afterAll } from 'vitest'
 import * as when from '../steps/when.mjs'
 import * as given from '../steps/given.mjs'
 import * as teardown from '../steps/teardown.mjs'
-import { EventBridgeClient } from '@aws-sdk/client-eventbridge'
-
-const mockSend = vi.fn()
-EventBridgeClient.prototype.send = mockSend
+import { startListening } from '../messages.mjs'
 
 describe('Given an authenticated user', () => {
-  let user
+  let user, listener
 
   beforeAll(async () => {
     user = await given.an_authenticated_user()
+    listener = startListening()
   })
 
   afterAll(async () => {
     await teardown.an_authenticated_user(user)
+    await listener.stop()
   })
 
   describe(`When we invoke the POST /orders endpoint`, () => {
     let resp
 
     beforeAll(async () => {
-      mockSend.mockClear()
-      mockSend.mockReturnValue({})
-
       resp = await when.we_invoke_place_order(user, 'Fangtasia')
     })
 
     it(`Should return 200`, async () => {
       expect(resp.statusCode).toEqual(200)
     })
 
-    if (process.env.TEST_MODE === 'handler') {
-      it(`Should publish a message to EventBridge bus`, async () => {
-        expect(mockSend).toHaveBeenCalledTimes(1)
-        const [ putEventsCmd ] = mockSend.mock.calls[0]
-        expect(putEventsCmd.input).toEqual({
-          Entries: [
-            expect.objectContaining({
-              Source: 'big-mouth',
-              DetailType: 'order_placed',
-              Detail: expect.stringContaining(`"restaurantName":"Fangtasia"`),
-              EventBusName: process.env.bus_name
-            })
-          ]
-        })
+    it(`Should publish a message to EventBridge bus`, async () => {
+      const { orderId } = resp.body
+      const expectedMsg = JSON.stringify({
+        source: 'big-mouth',
+        'detail-type': 'order_placed',
+        detail: {
+          orderId,
+          restaurantName: 'Fangtasia'
+        }
       })
-    }
+
+      await listener.waitForMessage(x => 
+        x.sourceType === 'eventbridge' &&
+        x.source === process.env.bus_name &&
+        x.message === expectedMsg
+      )
+    }, 10000)
   })
-})
+})