feat(inbox): allow inboxing inbound messages (#27)

requires @sap/cds 8.9.1.

---------

Co-authored-by: sjvans <[email protected]>
Co-authored-by: D050513 <[email protected]>

Author: David-Kunz

CHANGELOG.md

@@ -4,6 +4,12 @@ All notable changes to this project will be documented in this file.
 This project adheres to [Semantic Versioning](http://semver.org/).
 The format is based on [Keep a Changelog](http://keepachangelog.com/).
 
+## Version 0.1.3 - tbd
+
+### Added
+
+- Prerequisite for inboxing incoming messages in `@sap/cds^9`
+
 ## Version 0.1.2 - 2024-12-12
 
 ### Fixed

cds-plugin.js

@@ -1,4 +1,6 @@
 const cds = require('@sap/cds')
+const CDS_8 = cds.version.split('.')[0] < 9
+
 const express = require('express')
 const https = require('https')
 const crypto = require('crypto')
@@ -25,11 +27,8 @@ const normalizeIncomingMessage = message => {
     headers = {}
   }
 
-  return {
-    data,
-    headers,
-    inbound: true
-  }
+  if (CDS_8) return { data, headers, inbound: true }
+  return { data, headers }
 }
 
 const usedWebhookEndpoints = new Set()
@@ -337,7 +336,8 @@ class EventBroker extends cds.MessagingService {
       const context = { user: cds.User.privileged, _: msg._ }
       if (msg.tenant) context.tenant = msg.tenant
 
-      await this.tx(context, tx => tx.emit(msg))
+      if (CDS_8) await this.tx(context, tx => tx.emit(msg))
+      else await this.processInboundMsg(context, msg)
       this.LOG._debug && this.LOG.debug('Event processed successfully.')
       return res.status(200).json({ message: 'OK' })
     } catch (e) {