@@ -5,6 +5,7 @@ package integration

 import (

 	"fmt"

 	"testing"

+	"time"

 	kapi "k8s.io/kubernetes/pkg/api"

 	kclient "k8s.io/kubernetes/pkg/client/unversioned"

@@ -114,17 +115,17 @@ func TestTriggers_imageChange(t *testing.T) {

 	configWatch, err := openshiftProjectAdminClient.DeploymentConfigs(testutil.Namespace()).Watch(kapi.ListOptions{})

 	if err != nil {

-		t.Fatalf("Couldn't subscribe to Deployments %v", err)

+		t.Fatalf("Couldn't subscribe to deploymentconfigs %v", err)

 	}

 	defer configWatch.Stop()

 	if imageStream, err = openshiftProjectAdminClient.ImageStreams(testutil.Namespace()).Create(imageStream); err != nil {

-		t.Fatalf("Couldn't create ImageStream: %v", err)

+		t.Fatalf("Couldn't create imagestream: %v", err)

 	}

 	imageWatch, err := openshiftProjectAdminClient.ImageStreams(testutil.Namespace()).Watch(kapi.ListOptions{})

 	if err != nil {

-		t.Fatalf("Couldn't subscribe to ImageStreams: %s", err)

+		t.Fatalf("Couldn't subscribe to imagestreams: %v", err)

 	}

 	defer imageWatch.Stop()

@@ -147,29 +148,29 @@ func TestTriggers_imageChange(t *testing.T) {

 			t.Fatalf("unexpected error: %v", err)

 		}

-		t.Log("Waiting for image stream mapping to be reflected in the IS status...")

+		t.Log("Waiting for image stream mapping to be reflected in the image stream status...")

 	statusLoop:

 		for {

 			select {

 			case event := <-imageWatch.ResultChan():

 				stream := event.Object.(*imageapi.ImageStream)

 				if _, ok := stream.Status.Tags[imageapi.DefaultImageTag]; ok {

-					t.Logf("ImageStream %s now has Status with tags: %#v", stream.Name, stream.Status.Tags)

+					t.Logf("imagestream %q now has status with tags: %#v", stream.Name, stream.Status.Tags)

 					break statusLoop

 				}

-				t.Logf("Still waiting for latest tag status on ImageStream %s", stream.Name)

+				t.Logf("Still waiting for latest tag status on imagestream %q", stream.Name)

 			}

 		}

 	}

 	if config, err = openshiftProjectAdminClient.DeploymentConfigs(testutil.Namespace()).Create(config); err != nil {

-		t.Fatalf("Couldn't create DeploymentConfig: %v", err)

+		t.Fatalf("Couldn't create deploymentconfig: %v", err)

 	}

 	createTagEvent()

 	var newConfig *deployapi.DeploymentConfig

-	t.Log("Waiting for a new deployment config in response to ImageStream update")

+	t.Log("Waiting for a new deployment config in response to imagestream update")

 waitForNewConfig:

 	for {

 		select {

@@ -184,12 +185,155 @@ waitForNewConfig:

 					}

 					break waitForNewConfig

 				}

-				t.Log("Still waiting for a new deployment config in response to ImageStream update")

+				t.Log("Still waiting for a new deployment config in response to imagestream update")

 			}

 		}

 	}

 }

+func TestTriggers_imageChange_nonAutomatic(t *testing.T) {

+	testutil.RequireEtcd(t)

+	_, clusterAdminKubeConfig, err := testserver.StartTestMaster()

+	if err != nil {

+		t.Fatalf("error starting master: %v", err)

+	}

+	openshiftClusterAdminClient, err := testutil.GetClusterAdminClient(clusterAdminKubeConfig)

+	if err != nil {

+		t.Fatalf("error getting cluster admin client: %v", err)

+	}

+	openshiftClusterAdminClientConfig, err := testutil.GetClusterAdminClientConfig(clusterAdminKubeConfig)

+	if err != nil {

+		t.Fatalf("error getting cluster admin client config: %v", err)

+	}

+	openshiftProjectAdminClient, err := testserver.CreateNewProject(openshiftClusterAdminClient, *openshiftClusterAdminClientConfig, testutil.Namespace(), "bob")

+	if err != nil {

+		t.Fatalf("error creating project: %v", err)

+	}

+

+	imageStream := &imageapi.ImageStream{ObjectMeta: kapi.ObjectMeta{Name: deploytest.ImageStreamName}}

+

+	if imageStream, err = openshiftProjectAdminClient.ImageStreams(testutil.Namespace()).Create(imageStream); err != nil {

+		t.Fatalf("Couldn't create imagestream: %v", err)

+	}

+

+	imageWatch, err := openshiftProjectAdminClient.ImageStreams(testutil.Namespace()).Watch(kapi.ListOptions{})

+	if err != nil {

+		t.Fatalf("Couldn't subscribe to imagestreams: %v", err)

+	}

+	defer imageWatch.Stop()

+

+	image := fmt.Sprintf("sha256:%s", deploytest.ImageID)

+	pullSpec := fmt.Sprintf("registry:8080/%s/%s@%s", testutil.Namespace(), deploytest.ImageStreamName, image)

+	// Make a function which can create a new tag event for the image stream and

+	// then wait for the stream status to be asynchronously updated.

+	mapping := &imageapi.ImageStreamMapping{

+		ObjectMeta: kapi.ObjectMeta{Name: imageStream.Name},

+		Tag:        imageapi.DefaultImageTag,

+		Image: imageapi.Image{

+			ObjectMeta: kapi.ObjectMeta{

+				Name: image,

+			},

+			DockerImageReference: pullSpec,

+		},

+	}

+	updated := ""

+

+	createTagEvent := func(mapping *imageapi.ImageStreamMapping) {

+		if err := openshiftProjectAdminClient.ImageStreamMappings(testutil.Namespace()).Create(mapping); err != nil {

+			t.Fatalf("unexpected error: %v", err)

+		}

+

+		t.Log("Waiting for image stream mapping to be reflected in the image stream status...")

+

+		for {

+			select {

+			case event := <-imageWatch.ResultChan():

+				stream := event.Object.(*imageapi.ImageStream)

+				tagEventList, ok := stream.Status.Tags[imageapi.DefaultImageTag]

+				if ok {

+					if updated != tagEventList.Items[0].DockerImageReference {

+						updated = tagEventList.Items[0].DockerImageReference

+						return

+					}

+				}

+				t.Logf("Still waiting for latest tag status update on imagestream %q", stream.Name)

+			}

+		}

+	}

+

+	configWatch, err := openshiftProjectAdminClient.DeploymentConfigs(testutil.Namespace()).Watch(kapi.ListOptions{})

+	if err != nil {

+		t.Fatalf("Couldn't subscribe to deploymentconfigs: %v", err)

+	}

+	defer configWatch.Stop()

+

+	config := deploytest.OkDeploymentConfig(0)

+	config.Namespace = testutil.Namespace()

+	config.Spec.Triggers = []deployapi.DeploymentTriggerPolicy{deploytest.OkImageChangeTrigger()}

+	config.Spec.Triggers[0].ImageChangeParams.Automatic = false

+	if config, err = openshiftProjectAdminClient.DeploymentConfigs(testutil.Namespace()).Create(config); err != nil {

+		t.Fatalf("Couldn't create deploymentconfig: %v", err)

+	}

+

+	createTagEvent(mapping)

+

+	var newConfig *deployapi.DeploymentConfig

+	t.Log("Waiting for the initial deploymentconfig update in response to the imagestream update")

+

+	timeout := time.After(30 * time.Second)

+

+	// This is the initial deployment with automatic=false in its ICT - it should be updated to pullSpec

+out:

+	for {

+		select {

+		case event := <-configWatch.ResultChan():

+			if event.Type != watchapi.Modified {

+				continue

+			}

+

+			newConfig = event.Object.(*deployapi.DeploymentConfig)

+

+			if newConfig.Status.LatestVersion > 0 {

+				t.Fatalf("unexpected latestVersion update - the config has no config change trigger")

+			}

+

+			if e, a := updated, newConfig.Spec.Template.Spec.Containers[0].Image; e == a {

+				break out

+			}

+		case <-timeout:

+			t.Fatalf("timed out waiting for the image update to happen")

+		}

+	}

+

+	t.Log("Waiting for the second imagestream update - it shouldn't update the deploymentconfig")

+

+	// Subsequent updates to the image shouldn't update the pod template image

+	mapping.Image.Name = "sha256:thisupdatedimageshouldneverlandinthepodtemplate"

+	mapping.Image.DockerImageReference = fmt.Sprintf("registry:8080/%s/%s@%s", testutil.Namespace(), deploytest.ImageStreamName, mapping.Image.Name)

+	createTagEvent(mapping)

+

+	for {

+		select {

+		case event := <-configWatch.ResultChan():

+			if event.Type != watchapi.Modified {

+				continue

+			}

+

+			newConfig = event.Object.(*deployapi.DeploymentConfig)

+

+			if newConfig.Status.LatestVersion > 0 {

+				t.Fatalf("unexpected latestVersion update - the config has no config change trigger")

+			}

+

+			if e, a := updated, newConfig.Spec.Template.Spec.Containers[0].Image; e == a {

+				t.Fatalf("unexpected image update, expected initial image to be the same")

+			}

+		case <-timeout:

+			return

+		}

+	}

+}

+

 func TestTriggers_configChange(t *testing.T) {

 	const namespace = "test-triggers-configchange"