b.santos/cloud-cap-samples
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

beautified impl

Browse Source
This commit is contained in:
Daniel
2020-03-08 16:16:27 +01:00
parent 8c50d05776
commit 8613475988
1 changed files with 11 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
reviews/test/bookshop/server.js
View File

@@ -1,28 +1,25 @@
const cds = require ('@sap/cds')
// Mashup services after bootstrapping...
cds.on('listening', async()=>{
// connect to requires services
const ReviewsService = await cds.connect.to ('ReviewsService')
const CatalogService = await cds.connect.to ('CatalogService')
const db = await cds.connect.to ('db')
// import model definitions from connected services to work with subsequently
const { Reviews } = ReviewsService.entities
const { Books } = db.entities
// react on event messages from reviews service
const ReviewsService = await cds.connect.to ('ReviewsService')
const db = await cds.connect.to ('db')
ReviewsService.on ('reviewed', (msg) => {
console.debug ('> received:', msg.event, msg.data)
const { Books } = db.entities('sap.capire.bookshop')
const { subject, rating } = msg.data
const tx = db // TODO: db.transaction (msg)
return tx.run (UPDATE (Books, subject) .with ({rating}))
// return tx.update (Books, subject) .with ({rating})
// return tx.run (UPDATE (Books, subject) .with ({rating}))
return tx.update (Books, subject) .with ({rating})
})
// delegate requests to read reviews to ReviewsService
CatalogService.impl (srv => {
srv.on ('READ', 'Books/reviews', (req) => {
const CatalogService = await cds.connect.to ('CatalogService')
CatalogService.impl (() => {
CatalogService.on ('READ', 'Books/reviews', (req) => {
const { Reviews } = ReviewsService.entities
const [ subject ] = req.params
const tx = ReviewsService.transaction (req)
return tx.run (SELECT.from (Reviews) .where ({subject}))
@@ -31,4 +28,5 @@ cds.on('listening', async()=>{
})
// Delegate bootstrapping to built-in server.js
module.exports = cds.server