Add events.create_event_bus

moto/events/models.py

@@ -5,6 +5,7 @@ import boto3
 
 from moto.core.exceptions import JsonRESTError
 from moto.core import BaseBackend, BaseModel
+from moto.sts.models import ACCOUNT_ID
 
 
 class Rule(BaseModel):
@@ -54,6 +55,18 @@ class Rule(BaseModel):
                 self.targets.pop(index)
 
 
+class EventBus(BaseModel):
+    def __init__(self, region_name, name):
+        self.region = region_name
+        self.name = name
+
+    @property
+    def arn(self):
+        return "arn:aws:events:{region}:{account_id}:event-bus/{name}".format(
+            region=self.region, account_id=ACCOUNT_ID, name=self.name
+        )
+
+
 class EventsBackend(BaseBackend):
     ACCOUNT_ID = re.compile(r"^(\d{1,12}|\*)$")
     STATEMENT_ID = re.compile(r"^[a-zA-Z0-9-_]{1,64}$")
@@ -66,12 +79,19 @@ class EventsBackend(BaseBackend):
         self.next_tokens = {}
         self.region_name = region_name
         self.permissions = {}
+        self.event_buses = {}
+        self.event_sources = {}
+
+        self._add_default_event_bus()
 
     def reset(self):
         region_name = self.region_name
         self.__dict__ = {}
         self.__init__(region_name)
 
+    def _add_default_event_bus(self):
+        self.event_buses["default"] = EventBus(self.region_name, "default")
+
     def _get_rule_by_index(self, i):
         return self.rules.get(self.rules_order[i])
 
@@ -264,6 +284,28 @@ class EventsBackend(BaseBackend):
         policy_json = json.dumps(policy)
         return {"Policy": policy_json, "Name": "default", "Arn": arn}
 
+    def create_event_bus(self, name, event_source_name):
+        if name in self.event_buses:
+            raise JsonRESTError(
+                "ResourceAlreadyExistsException",
+                "Event bus {} already exists.".format(name),
+            )
+
+        if not event_source_name and "/" in name:
+            raise JsonRESTError(
+                "ValidationException", "Event bus name must not contain '/'."
+            )
+
+        if event_source_name and event_source_name not in self.event_sources:
+            raise JsonRESTError(
+                "ResourceNotFoundException",
+                "Event source {} does not exist.".format(event_source_name),
+            )
+
+        self.event_buses[name] = EventBus(self.region_name, name)
+
+        return self.event_buses[name]
+
 
 available_regions = boto3.session.Session().get_available_regions("events")
 events_backends = {region: EventsBackend(region) for region in available_regions}

moto/events/responses.py

@@ -255,3 +255,11 @@ class EventsHandler(BaseResponse):
 
     def describe_event_bus(self):
         return json.dumps(self.events_backend.describe_event_bus())
+
+    def create_event_bus(self):
+        name = self._get_param("Name")
+        event_source_name = self._get_param("EventSourceName")
+
+        event_bus = self.events_backend.create_event_bus(name, event_source_name)
+
+        return json.dumps({"EventBusArn": event_bus.arn}), self.response_headers