Skip to content

Commit 77d7c77

Browse files
authored
chore: prep v0.2.0 (#37)
@David-Kunz i aligned the coding with cap-js/event-broker#27
1 parent b224452 commit 77d7c77

3 files changed

Lines changed: 8 additions & 13 deletions

File tree

CHANGELOG.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,12 +4,12 @@ All notable changes to this project will be documented in this file.
44
This project adheres to [Semantic Versioning](http://semver.org/).
55
The format is based on [Keep a Changelog](http://keepachangelog.com/).
66

7-
## Version 0.2.0 - tbd
7+
## Version 0.2.0 - 2025-06-05
88

99
### Added
1010

1111
- Configuration option `skipManagement` to skip creation of queue and subscription
12-
- Prerequisite for inboxing messages
12+
- Prerequisite for inboxing incoming messages in `@sap/cds^9`
1313

1414
## Version 0.1.0 - 2025-03-28
1515

cds-plugin.js

Lines changed: 5 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
const cds = require('@sap/cds')
2+
const CDS_8 = cds.version.split('.')[0] < 9
23

34
const solace = require('solclientjs')
45
const EventEmitter = require('events')
@@ -131,11 +132,8 @@ const normalizeIncomingMessage = message => {
131132
headers = {}
132133
}
133134

134-
return {
135-
data,
136-
headers,
137-
inbound: true //> NOTE: needed for cds^8
138-
}
135+
if (CDS_8) return { data, headers, inbound: true }
136+
return { data, headers }
139137
}
140138

141139
const getAppMetadata = () => {
@@ -300,11 +298,8 @@ module.exports = class AdvancedEventMesh extends cds.MessagingService {
300298
msg.event = event
301299
try {
302300
// NOTE: processInboundMsg doesn't exist in cds^8
303-
if (this.processInboundMsg) {
304-
await this.processInboundMsg({ user: cds.User.privileged }, msg)
305-
} else {
306-
await this.tx({ user: cds.User.privileged }, tx => tx.emit(msg))
307-
}
301+
if (CDS_8) await this.tx({ user: cds.User.privileged }, tx => tx.emit(msg))
302+
else await this.processInboundMsg({ user: cds.User.privileged }, msg)
308303
message.acknowledge()
309304
} catch (e) {
310305
e.message = 'ERROR occurred in asynchronous event processing: ' + e.message

package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "@cap-js/advanced-event-mesh",
3-
"version": "0.1.0",
3+
"version": "0.2.0",
44
"description": "CDS plugin providing integration with SAP Integration Suite, advanced event mesh",
55
"repository": {
66
"type": "git",

0 commit comments

Comments
 (0)