Skip to content

Commit

Permalink
Revert ". (#14)" (#17)
Browse files Browse the repository at this point in the history
This reverts commit 28fa61b.
  • Loading branch information
johannes-vogel authored Nov 12, 2024
1 parent 28fa61b commit e7f4dab
Showing 1 changed file with 2 additions and 10 deletions.
12 changes: 2 additions & 10 deletions cds-plugin.js
Original file line number Diff line number Diff line change
Expand Up @@ -135,8 +135,6 @@ class EventBroker extends cds.MessagingService {

this.auth = {} // { kind: 'cert', validationCert?, privateKey? } or { kind: 'ias', ias }

console.log('cds.env.requires:', cds.env.requires)

// determine auth.kind
if (this.options.x509) {
if (!this.options.x509.cert && !this.options.x509.certPath)
Expand All @@ -157,8 +155,6 @@ class EventBroker extends cds.MessagingService {
} else this.auth.kind = 'cert'
}

console.log('this.auth:', this.auth)

if (!this.auth.kind || (this.auth.kind === 'ias' && !this.auth.ias))
throw new Error(`${this.name}: Event Broker requires your app to be bound to an IAS instance.`)

Expand Down Expand Up @@ -335,19 +331,15 @@ class EventBroker extends cds.MessagingService {
Object.assign(msg.headers, headers)
if (this.isMultitenancy) msg.tenant = tenant

// for cds.context.http
msg._ = {}
msg._.req = req
msg._.res = res

const context = { user: cds.User.privileged, _: msg._ }
if (msg.tenant) context.tenant = msg.tenant


await this.tx(context, tx => {
if (cds.context.http?.req?.headers?.authorization) delete cds.context.http.req.headers.authorization // potential destination lookup fails if IAS token is used
return tx.emit(msg)
})

await this.tx(context, tx => tx.emit(msg))
this.LOG.debug('Event processed successfully.')
return res.status(200).json({ message: 'OK' })
} catch (e) {
Expand Down

0 comments on commit e7f4dab

Please sign in to comment.