const app = new App();                                                                                                                                                              
const stack = new Stack(app, 'aws-stepfunctions-tasks-eventbridge-put-events-integ');                                                                                               
                                                                                                                                                                                    
const eventBus = new events.EventBus(stack, 'EventBus', {                                                                                                                           
  eventBusName: 'MyEventBus1',                                                                                                                                                      
});                                                                                                                                                                                 
                                                                                                                                                                                    
const putEventsTask = new stepfunctions_tasks.EventBridgePutEvents(stack, 'Put Custom Events', {                                                                                    
  entries: [{                                                                                                                                                                       
    // Entry with no event bus specified                                                                                                                                            
    detail: sfn.TaskInput.fromObject({                                                                                                                                              
      Message: 'Hello from Step Functions!',                                                                                                                                        
    }),                                                                                                                                                                             
    detailType: 'MessageFromStepFunctions',                                                                                                                                         
    source: 'step.functions',                                                                                                                                                       
  }, {                                                                                                                                                                              
    // Entry with EventBus provided as object                                                                                                                                       
    detail: sfn.TaskInput.fromObject({                                                                                                                                              
      Message: 'Hello from Step Functions!',                                                                                                                                        
    }),                                                                                                                                                                             
    eventBus,                                                                                                                                                                       
    detailType: 'MessageFromStepFunctions',                                                                                                                                         
    source: 'step.functions',                                                                                                                                                       
  }],                                                                                                                                                                               
});                                                                                                                                                                                 
                                                                                                                                                                                    
const sm = new sfn.StateMachine(stack, 'StateMachine', {                                                                                                                            
  definition: putEventsTask,
  timeout: Duration.seconds(30),             
});    

new IntegTest(app, 'IntegTest', {
  testCases: [                               
    new IntegTestCase(app, 'TestCase', {
      stacks: [stack],                       
    }),                                        
  ],                                         
});       

const assert = new DeployAssert(
  stack,
);

// Start an execution
const start = assert.queryAws({
  api: 'startExecution',
  service: 'StepFunctions',
  parameters: {
    stateMachineArn: sm.stateMachineArn,
  },
});

// describe the results of the execution
const describe = assert.queryAws({
  api: 'describeExecution',
  service: 'StepFunctions',
  parameters: {
    executionArn: start.getAttString('executionArn'),
  },
});

// assert the results
assert.registerAssertion(describe.assertEqual({
  status: 'SUCCEEDED',
}, 'success'));