fix(controller): import image from remote registry

This change allows us to import an image from a remote repository,
thanks to a new feature implemented in
https://github.com/deis/docker-registry/compare/repository-import.

Though the infrastructure in place allows us to import an image from the public index,
the endpoints are closed-source and therefore are not implmented in the upstream
repository-import branch.

Author: Matthew Fisher

controller/api/models.py

@@ -10,6 +10,7 @@
 import logging
 import os
 import subprocess
+from urlparse import urlparse
 
 from celery.canvas import group
 from django.conf import settings
@@ -483,14 +484,37 @@ def new(self, user, config=None, build=None, summary=None):
             owner=user, app=self.app, config=config,
             build=build, version=new_version, image=target_image, summary=summary)
         # publish release to registry as new docker image
-        if self.build.sha:
-            publish_release(self.build.image,
-                            self.build.sha,
+        if build.sha:
+            publish_release(build.image,
+                            build.sha,
                             config.values,
                             self.app.id,
                             tag)
         else:
-            publish_release(self.build.image,
+            # we assume that the image is not present on our registry,
+            # so shell out a task to pull in the repository
+            url = urlparse(build.image)
+            repository_name = url.path[1:]
+            if url.hostname and url.port:
+                tasks.import_repository.delay(
+                    '{}://{}:{}'.format(url.scheme, url.hostname, url.port),
+                    repository_name,
+                    self.app.id,
+                ).get()
+            elif url.hostname:
+                tasks.import_repository.delay(
+                    '{}://{}'.format(url.scheme, url.hostname),
+                    repository_name,
+                    self.app.id,
+                ).get()
+            else:
+                # assume only the repository path is given, which means that
+                # it's on the public index
+                tasks.import_repository.delay(settings.PUBLIC_INDEX_URL,
+                                              build.image,
+                                              self.app.id,
+                ).get()
+            publish_release(self.app.id,
                             'latest',
                             config.values,
                             self.app.id,

controller/api/tasks.py

@@ -7,9 +7,11 @@
 
 from __future__ import unicode_literals
 
+import requests
 import threading
 
 from celery import task
+from django.conf import settings
 
 
 @task
@@ -34,6 +36,21 @@ def deploy_release(app, release):
     [t.join() for t in threads]
 
 
+@task
+def import_repository(src_index, src_repository, target_repository):
+    """Imports an image from a remote into our own private registry"""
+
+    data = {
+        'src_index': src_index,
+        'src_repository': src_repository,
+    }
+    response = requests.post(
+        '{}/v1/repositories/{}/tags'.format(settings.REGISTRY_URL,
+                                            target_repository),
+        data=data,
+    )
+
+
 @task
 def start_containers(containers):
     create_threads = []