Fixed tests and prepared for mocha

reviews/test/messaging.test.js

@@ -0,0 +1,67 @@
+const _model = __dirname+'/..'
+const cds = require ('@sap/cds')
+const {expect} = require('chai').use(require('chai-subset'))
+
+describe('messaging tests', ()=>{
+
+    it ('should bootstrap sqlite in-memory db', async()=>{
+        const db = await cds.deploy (_model) .to ('sqlite::memory:')
+        expect (db.model) .not.undefined
+    })
+
+    let srv
+    it ('should serve reviews services', async()=>{
+        srv = await cds.serve('ReviewsService') .from (_model)
+        expect (srv.name) .to.match (/ReviewsService/)
+    })
+
+    let N=0, received=[], M=0
+    it ('should add messaging event handlers', ()=>{
+        srv.on('reviewed', (msg)=> received.push(msg))
+    })
+
+    it ('should add more messaging event handlers', ()=>{
+        srv.on('reviewed', ()=> ++M)
+    })
+
+    it ('should add review', async ()=>{
+        const review = { subject: "201", title: "Captivating", rating: ++N }
+        const response = await srv.create ('Reviews') .entries (review)
+        expect (response) .to.containSubset (review)
+    },100)
+
+    it ('should add more reviews', ()=> Promise.all ([
+        // REVISIT: mass operation should trigger one message per entry
+        // srv.create('Reviews').entries(
+        //     { ID: 111 + (++N),  subject: "201", title: "Captivating", rating: N },
+        //     { ID: 111 + (++N),  subject: "201", title: "Captivating", rating: N },
+        //     { ID: 111 + (++N),  subject: "201", title: "Captivating", rating: N },
+        //     { ID: 111 + (++N),  subject: "201", title: "Captivating", rating: N },
+        // ),
+        srv.create ('Reviews') .entries (
+            { ID: 111 + (++N),  subject: "201", title: "Captivating", rating: N }
+        ),
+        srv.create ('Reviews') .entries (
+            { ID: 111 + (++N),  subject: "201", title: "Captivating", rating: N }
+        ),
+        srv.create ('Reviews') .entries (
+            { ID: 111 + (++N),  subject: "201", title: "Captivating", rating: N }
+        ),
+        srv.create ('Reviews') .entries (
+            { ID: 111 + (++N),  subject: "201", title: "Captivating", rating: N }
+        ),
+    ]) ,100)
+
+    it ('should have received all messages', async()=> {
+        await new Promise((done)=>setImmediate(done))
+        expect(M).equals(N)
+        expect(received.length).equals(N)
+        expect(received.map(m=>m.data)).to.deep.equal([
+            { subject: '201', rating: 1 },
+            { subject: '201', rating: 1.5 },
+            { subject: '201', rating: 2 },
+            { subject: '201', rating: 2.5 },
+            { subject: '201', rating: 3 },
+        ])
+    })
+})

reviews/test/requests.http

@@ -0,0 +1,32 @@
+#################################################
+#
+#   Reviews Service
+#
+
+
+### Use this one for ReviewsService running as a separate process
+# Note: use 5005 instead of 4004 in case of separate service
+POST http://localhost:5005/reviews/Reviews
+# POST http://localhost:4004/reviews/Reviews
+Content-Type: application/json;IEEE754Compatible=true
+
+{"subject":"201", "rating":"4", "title":"boo"}
+
+### Direct Request to ReviewsService
+# Note: use 5005 instead of 4004 in case of separate service
+GET http://localhost:5005/reviews/Reviews?
+# GET http://localhost:4004/reviews/Reviews?
+# &$filter=subject eq '201'
+
+
+### Request to CatalogService > delegated to ReviewsService
+GET http://localhost:4004/browse/Books(201)/reviews
+
+### Alternative OData URL
+GET http://localhost:4004/browse/Books/201/reviews
+
+###
+GET http://localhost:4004/browse/Books(201)?
+&$select=ID,title,rating
+# &$expand=reviews
+# Note: the latter only works in case of ReviewsService in same process