Split out callbacks into their own blueprint. Add build trigger DB information and connect it with some APIs. Stub out the UI to allow for generation of triggers. Split out the triggers into a plugin-ish architecture for easily adding new triggers.

data/model.py

@@ -55,6 +55,10 @@ class InvalidWebhookException(DataModelException):
   pass
 
 
+class InvalidBuildTriggerException(DataModelException):
+  pass
+
+
 def create_user(username, password, email):
   if not validate_email(email):
     raise InvalidEmailAddressException('Invalid email address: %s' % email)
@@ -1352,27 +1356,75 @@ def delete_webhook(namespace_name, repository_name, public_id):
   webhook = get_webhook(namespace_name, repository_name, public_id)
   webhook.delete_instance()
   return webhook
-  
-def list_logs(user_or_organization_name, start_time, end_time, performer = None, repository = None):
-    joined = LogEntry.select().join(User)
-    if repository:
-      joined = joined.where(LogEntry.repository == repository)
 
-    if performer:
-      joined = joined.where(LogEntry.performer == performer)
 
-    return joined.where(
-      User.username == user_or_organization_name,
-      LogEntry.datetime >= start_time,
-      LogEntry.datetime < end_time).order_by(LogEntry.datetime.desc())
+def list_logs(user_or_organization_name, start_time, end_time, performer=None,
+              repository=None):
+  joined = LogEntry.select().join(User)
+  if repository:
+    joined = joined.where(LogEntry.repository == repository)
 
-def log_action(kind_name, user_or_organization_name, performer=None, repository=None,
-               access_token=None, ip=None, metadata={}, timestamp=None):
+  if performer:
+    joined = joined.where(LogEntry.performer == performer)
+
+  return joined.where(
+    User.username == user_or_organization_name,
+    LogEntry.datetime >= start_time,
+    LogEntry.datetime < end_time).order_by(LogEntry.datetime.desc())
+
+
+def log_action(kind_name, user_or_organization_name, performer=None,
+               repository=None, access_token=None, ip=None, metadata={},
+               timestamp=None):
   if not timestamp:
     timestamp = datetime.today()
 
   kind = LogEntryKind.get(LogEntryKind.name == kind_name)
   account = User.get(User.username == user_or_organization_name)
-  entry = LogEntry.create(kind=kind, account=account, performer=performer,
-                          repository=repository, access_token=access_token, ip=ip,
-                          metadata_json=json.dumps(metadata), datetime=timestamp)
+  LogEntry.create(kind=kind, account=account, performer=performer,
+                  repository=repository, access_token=access_token, ip=ip,
+                  metadata_json=json.dumps(metadata), datetime=timestamp)
+
+
+def create_build_trigger(namespace_name, repository_name, service_name,
+                         auth_token, user):
+  service = BuildTriggerService.get(name=service_name)
+  repo = Repository.get(namespace=namespace_name, name=repository_name)
+
+  trigger = RepositoryBuildTrigger.create(repository=repo, service=service,
+                                          auth_token=auth_token,
+                                          connected_user=user)
+  return trigger
+
+
+def get_build_trigger(namespace_name, repository_name, trigger_uuid):
+  try:
+    return (RepositoryBuildTrigger
+      .select(RepositoryBuildTrigger, BuildTriggerService, Repository)
+      .join(BuildTriggerService)
+      .switch(RepositoryBuildTrigger)
+      .join(Repository)
+      .switch(RepositoryBuildTrigger)
+      .join(User)
+      .where(RepositoryBuildTrigger.uuid == trigger_uuid,
+             Repository.namespace == namespace_name,
+             Repository.name == repository_name)
+      .get())
+  except RepositoryBuildTrigger.DoesNotExist:
+    msg = 'No build trigger with uuid: %s' % trigger_uuid
+    raise InvalidBuildTriggerException(msg)
+
+
+def list_build_triggers(namespace_name, repository_name):
+  return (RepositoryBuildTrigger
+    .select(RepositoryBuildTrigger, BuildTriggerService, Repository)
+    .join(BuildTriggerService)
+    .switch(RepositoryBuildTrigger)
+    .join(Repository)
+    .where(Repository.namespace == namespace_name,
+           Repository.name == repository_name))
+
+
+def delete_build_trigger(namespace_name, repository_name, trigger_uuid):
+  trigger = get_build_trigger(namespace_name, repository_name, trigger_uuid)
+  trigger.delete_instance()