diff --git a/packages/bookshop/package.json b/packages/bookshop/package.json index 1c0aea93..d14fec46 100644 --- a/packages/bookshop/package.json +++ b/packages/bookshop/package.json @@ -21,9 +21,6 @@ "--credentials": { "destination": "cap-api098" } - }, - "messaging": { - "kind": "file-based-messaging" } } } diff --git a/packages/bookshop/srv/cat-service.cds b/packages/bookshop/srv/cat-service.cds index 79c9d34a..36975e82 100644 --- a/packages/bookshop/srv/cat-service.cds +++ b/packages/bookshop/srv/cat-service.cds @@ -18,9 +18,9 @@ service CatalogService { Country }; - event ContactDetailsChanged { + event OrdersOutdated { 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 7aa6a059..08f88457 100644 --- a/packages/bookshop/srv/cat-service.js +++ b/packages/bookshop/srv/cat-service.js @@ -11,9 +11,8 @@ module.exports = cds.service.impl(async function () { 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 })) - const payload = { orders } - this.emit('ContactDetailsChanged', payload) - console.log('<< Emitting message', payload) + this.emit('OrdersOutdated', { orders }) + console.log('<< Emitting message', { orders }) }) /** Add some discount for overstocked books */