diff --git a/reviews/srv/reviews-service.js b/reviews/srv/reviews-service.js index ab197cc6..286b51d2 100644 --- a/reviews/srv/reviews-service.js +++ b/reviews/srv/reviews-service.js @@ -16,9 +16,8 @@ module.exports = cds.service.impl (async function(){ const {rating} = await cds.transaction(req) .run ( SELECT.one (['round(avg(rating),2) as rating']) .from (Reviews) .where ({subject}) ) - const msgTx = messaging.tx(req) global.it || console.log ('< emitting:', 'reviewed', { subject, rating }) - msgTx.emit ('review/reviewed', { subject, rating }) + messaging.tx(req).emit ('review/reviewed', { subject, rating }) }) // Increment counter for reviews considered helpful