@@ -3,8 +3,8 @@ const getMessageTraits = require('./components/messageTraits');
3
3
const { definitionsToMessages, nestedAnnotation } = require ( './components/messages' ) ;
4
4
const getChannels = require ( './channels' ) ;
5
5
const cds = require ( '@sap/cds/lib' ) ;
6
+ const { join } = require ( 'path' ) ;
6
7
const messages = require ( "./message" ) ;
7
- const defaultConfig = require ( "./config.json" )
8
8
const presetMapping = {
9
9
'event_spec_version' : 'x-sap-event-spec-version' ,
10
10
'event_source' : 'x-sap-event-source' ,
@@ -19,9 +19,20 @@ module.exports = function processor(csn, options = {}) {
19
19
envConf = cds . env . export . asyncapi ;
20
20
}
21
21
if ( ! cds . env ?. export ?. asyncapi ?. application_namespace ) {
22
- envConf [ "application_namespace" ] = defaultConfig . application_namespace ;
22
+ const packageJson = require ( join ( cds . root , 'package.json' ) ) ;
23
+ const appName = packageJson . name . replace ( / \s / g, "-" ) ;
24
+ envConf [ "application_namespace" ] = `customer.${ appName } `
23
25
console . info ( messages . APPLICATION_NAMESPACE ) ;
24
26
}
27
+
28
+ if ( cds . env . ord ?. namespace ) {
29
+ const ordNamespace = _getNamespace ( cds . env . ord . namespace ) ;
30
+ const asyncapiNamespace = _getNamespace ( envConf . application_namespace ) ;
31
+ if ( ordNamespace !== asyncapiNamespace ) {
32
+ console . warn ( messages . NAMESPACE_MISMATCH )
33
+ }
34
+ }
35
+
25
36
_serviceErrorHandling ( csn , options ) ;
26
37
27
38
const applicationNamespace = envConf . application_namespace ;
@@ -249,3 +260,7 @@ function* _iterate(services, csn, applicationNamespace, presets) {
249
260
yield [ generatedAsyncAPI , { file : key } ] ;
250
261
}
251
262
}
263
+
264
+ function _getNamespace ( fullNamespace ) {
265
+ return fullNamespace . split ( '.' ) . slice ( 0 , 2 ) . join ( '.' ) ;
266
+ }
0 commit comments