Pass url through

pkg/sink/sink.go

@@ -185,6 +185,7 @@ func (r Sink) executeInterceptors(t *triggersv1.EventListenerTrigger, in *http.R
 	request := &http.Request{
 		Method: http.MethodPost,
 		Header: in.Header,
+		URL:    in.URL,
 		Body:   ioutil.NopCloser(bytes.NewBuffer(event)),
 	}
 
@@ -221,6 +222,7 @@ func (r Sink) executeInterceptors(t *triggersv1.EventListenerTrigger, in *http.R
 		request = &http.Request{
 			Method: http.MethodPost,
 			Header: resp.Header,
+			URL:    in.URL,
 			Body:   ioutil.NopCloser(resp.Body),
 		}
 	}

pkg/sink/sink_test.go

@@ -310,6 +310,12 @@ func TestHandleEventWithInterceptors(t *testing.T) {
 						},
 						EventTypes: []string{"pull_request"},
 					},
+				}, {
+					CEL: &triggersv1.CELInterceptor{
+						Overlays: []triggersv1.CELOverlay{
+							{Key: "new", Expression: "body.repository.url"},
+						},
+					},
 				}},
 			}},
 		},
@@ -379,6 +385,97 @@ func TestHandleEventWithInterceptors(t *testing.T) {
 	}
 }
 
+func TestHandleEventPassesURLThrough(t *testing.T) {
+	eventBody := json.RawMessage(`{"head_commit": {"id": "testrevision"}, "repository": {"url": "testurl"}}`)
+	pipelineResource := pipelinev1alpha1.PipelineResource{
+		TypeMeta: metav1.TypeMeta{
+			APIVersion: "tekton.dev/v1alpha1",
+			Kind:       "PipelineResource",
+		},
+		ObjectMeta: metav1.ObjectMeta{
+			Name:      "my-pipelineresource",
+			Namespace: namespace,
+		},
+		Spec: pipelinev1alpha1.PipelineResourceSpec{
+			Type: pipelinev1alpha1.PipelineResourceTypeGit,
+			Params: []pipelinev1alpha1.ResourceParam{{
+				Name:  "url",
+				Value: "$(tt.params.url)",
+			}},
+		},
+	}
+	pipelineResourceBytes, err := json.Marshal(pipelineResource)
+	if err != nil {
+		t.Fatalf("Error unmarshalling pipelineResource: %s", err)
+	}
+
+	tt := bldr.TriggerTemplate("tt", namespace,
+		bldr.TriggerTemplateSpec(
+			bldr.TriggerTemplateParam("url", "", ""),
+			bldr.TriggerResourceTemplate(runtime.RawExtension{Raw: pipelineResourceBytes}),
+		))
+	tb := bldr.TriggerBinding("tb", namespace,
+		bldr.TriggerBindingSpec(
+			bldr.TriggerBindingParam("url", "$(body.repository.url)"),
+		))
+
+	el := &triggersv1.EventListener{
+		ObjectMeta: metav1.ObjectMeta{
+			Name:      "el",
+			Namespace: namespace,
+		},
+		Spec: triggersv1.EventListenerSpec{
+			Triggers: []triggersv1.EventListenerTrigger{{
+				Bindings: []*triggersv1.EventListenerBinding{{Name: "tb", Kind: "TriggerBinding"}},
+				Template: triggersv1.EventListenerTemplate{Name: "tt"},
+				Interceptors: []*triggersv1.EventInterceptor{{
+					CEL: &triggersv1.CELInterceptor{
+						Overlays: []triggersv1.CELOverlay{
+							{Key: "new", Expression: "body.repository.url"},
+						},
+					},
+				}},
+			}},
+		},
+	}
+	secret := &corev1.Secret{
+		ObjectMeta: metav1.ObjectMeta{
+			Name:      "secret",
+			Namespace: namespace,
+		},
+		Data: map[string][]byte{
+			"secretKey": []byte("secret"),
+		},
+	}
+
+	resources := test.Resources{
+		TriggerBindings:  []*triggersv1.TriggerBinding{tb},
+		TriggerTemplates: []*triggersv1.TriggerTemplate{tt},
+		EventListeners:   []*triggersv1.EventListener{el},
+		Secrets:          []*corev1.Secret{secret},
+	}
+	sink, _ := getSinkAssets(t, resources, el.Name, DefaultAuthOverride{})
+	ts := httptest.NewServer(http.HandlerFunc(sink.HandleEvent))
+	defer ts.Close()
+
+	req, err := http.NewRequest("POST", ts.URL, bytes.NewReader(eventBody))
+	if err != nil {
+		t.Fatalf("Error creating Post request: %s", err)
+	}
+	req.Header.Add("Content-Type", "application/json")
+	req.Header.Add("X-Github-Event", "pull_request")
+	// This was generated by using SHA1 and hmac from go stdlib on secret and payload.
+	// https://play.golang.org/p/8D2E-Yz3zWf for a sample.
+	// TODO(dibyom): Add helper method that does this instead of link above
+	req.Header.Add("X-Hub-Signature", "sha1=c0f3a2bbd1cdb062ba4f54b2a1cad3d171b7a129")
+
+	resp, err := http.DefaultClient.Do(req)
+	if err != nil {
+		t.Fatalf("Error sending Post request: %v", err)
+	}
+	checkSinkResponse(t, resp, el.Name)
+}
+
 // nameInterceptor is an HTTP server that reads a "Name" from the header, and
 // writes the name in its body as {"name": "VALUE"}.
 // It expects a request with the header "Name".