From 90881558dce03b6900231950074457e94c11bc13 Mon Sep 17 00:00:00 2001 From: D065023 Date: Tue, 28 Jan 2020 18:01:53 +0100 Subject: [PATCH] working --- packages/bookshop/srv/cat-service.cds | 4 ++++ packages/bookshop/srv/cat-service.js | 5 +++-- 2 files changed, 7 insertions(+), 2 deletions(-) diff --git a/packages/bookshop/srv/cat-service.cds b/packages/bookshop/srv/cat-service.cds index 6b1ad122..79c9d34a 100644 --- a/packages/bookshop/srv/cat-service.cds +++ b/packages/bookshop/srv/cat-service.cds @@ -18,6 +18,10 @@ service CatalogService { Country }; + event ContactDetailsChanged { + orders: array of my.Orders + } + @requires_: 'authenticated-user' @insertonly entity Orders as projection on my.Orders; diff --git a/packages/bookshop/srv/cat-service.js b/packages/bookshop/srv/cat-service.js index 173b6a0b..5e9c65c0 100644 --- a/packages/bookshop/srv/cat-service.js +++ b/packages/bookshop/srv/cat-service.js @@ -7,11 +7,12 @@ module.exports = cds.service.impl(async function () { this.after('READ', Books, each => each.stock > 111 && _addDiscount2(each, 11)) this.before('CREATE', Orders, _reduceStock) this.on('READ', Addresses, req => bupaSrv.tx(req).run(req.query)) - this.on('BusinessPartner/Changed', async msg => { + bupaSrv.on('BusinessPartner/Changed', async msg => { console.log('>> Received message', msg.data) const BUSINESSPARTNER = msg.data.KEY[0].BUSINESSPARTNER const orders = await cds.tx(msg).run(SELECT.from(Orders).where({ createdBy: BUSINESSPARTNER })) - console.log(orders) + this.emit('ContactDetailsChanged', { orders }) + console.log('=== EMITTED ====') }) /** Add some discount for overstocked books */