Yasuke/moto
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Modify Rule.send_to_targets() to handle event_bus_name as ARN (#3804)

Browse Source 
* Modify Rule.send_to_targets() to handle event_bus_name as ARN

* Apply black formatting

Co-authored-by: Tom Noble <tom.noble@bjss.com>
This commit is contained in:
Tom Noble 2021-03-28 10:33:47 +00:00 committed by GitHub
parent 9f9716ee01
commit f549f1d087
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 29 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
moto/events/models.py
View File

@ -82,6 +82,7 @@ class Rule(CloudFormationModel):
self.targets.pop(index)
def send_to_targets(self, event_bus_name, event):
event_bus_name = event_bus_name.split("/")[-1]
if event_bus_name != self.event_bus_name:
return

28
tests/test_events/test_events.py
View File

@ -1318,6 +1318,34 @@ def test_archive_actual_events():
response["SizeBytes"].should.be.greater_than(0)
@mock_events
def test_archive_event_with_bus_arn():
# given
client = boto3.client("events", "eu-central-1")
event_bus_arn = "arn:aws:events:eu-central-1:{}:event-bus/default".format(
ACCOUNT_ID
)
archive_name = "mock_archive"
event_with_bus_arn = {
"Source": "source",
"DetailType": "type",
"Detail": '{ "key1": "value1" }',
"EventBusName": event_bus_arn,
}
client.create_archive(ArchiveName=archive_name, EventSourceArn=event_bus_arn)
# when
response = client.put_events(Entries=[event_with_bus_arn])
# then
response["FailedEntryCount"].should.equal(0)
response["Entries"].should.have.length_of(1)
response = client.describe_archive(ArchiveName=archive_name)
response["EventCount"].should.equal(1)
response["SizeBytes"].should.be.greater_than(0)
@mock_events
def test_start_replay():
# given