serverless/test/utils/event-bridge.js
2024-05-29 11:51:04 -04:00

32 lines
783 B
JavaScript

'use strict'
const awsRequest = require('@serverless/test/aws-request')
const EventBridgeService = require('aws-sdk').EventBridge
async function createEventBus(name) {
return awsRequest(EventBridgeService, 'createEventBus', { Name: name })
}
async function deleteEventBus(name) {
return awsRequest(EventBridgeService, 'deleteEventBus', { Name: name })
}
async function describeEventBus(name) {
return awsRequest(EventBridgeService, 'describeEventBus', { Name: name })
}
async function putEvents(EventBusName, Entries) {
Entries.map((entry) => (entry.EventBusName = EventBusName))
const params = {
Entries,
}
return awsRequest(EventBridgeService, 'putEvents', params)
}
module.exports = {
createEventBus,
deleteEventBus,
describeEventBus,
putEvents,
}