diff --git a/trigger/http/native_webhook_trigger.go b/trigger/http/native_webhook_trigger.go
index 9b79dd06..93955a5c 100644
--- a/trigger/http/native_webhook_trigger.go
+++ b/trigger/http/native_webhook_trigger.go
@@ -13,8 +13,8 @@ import (
 
 // nativeHandler - used to trigger event directly
 func (s *TriggerServer) nativeHandler(resp http.ResponseWriter, req *http.Request) {
-	event := types.Event{}
-	if err := json.NewDecoder(req.Body).Decode(&event); err != nil {
+	repo := types.Repository{}
+	if err := json.NewDecoder(req.Body).Decode(&repo); err != nil {
 		log.WithFields(log.Fields{
 			"error": err,
 		}).Error("failed to decode request")
@@ -22,18 +22,21 @@ func (s *TriggerServer) nativeHandler(resp http.ResponseWriter, req *http.Reques
 		return
 	}
 
-	if event.Repository.Name == "" {
+	event := types.Event{}
+
+	if repo.Name == "" {
 		resp.WriteHeader(http.StatusBadRequest)
 		fmt.Fprintf(resp, "repository name cannot be empty")
 		return
 	}
 
-	if event.Repository.Tag == "" {
+	if repo.Tag == "" {
 		resp.WriteHeader(http.StatusBadRequest)
 		fmt.Fprintf(resp, "repository tag cannot be empty")
 		return
 	}
 
+	event.Repository = repo
 	event.CreatedAt = time.Now()
 	event.TriggerName = "native"
 	s.trigger(event)
diff --git a/trigger/http/native_webhook_trigger_test.go b/trigger/http/native_webhook_trigger_test.go
index 7add8d3a..49a6159e 100644
--- a/trigger/http/native_webhook_trigger_test.go
+++ b/trigger/http/native_webhook_trigger_test.go
@@ -33,7 +33,7 @@ func TestNativeWebhookHandler(t *testing.T) {
 	srv := NewTriggerServer(&Opts{Providers: providers})
 	srv.registerRoutes(srv.router)
 
-	req, err := http.NewRequest("POST", "/v1/webhooks/native", bytes.NewBuffer([]byte(`{"repository": {"name": "gcr.io/v2-namespace/hello-world", "tag": "1.1.1"}}`)))
+	req, err := http.NewRequest("POST", "/v1/webhooks/native", bytes.NewBuffer([]byte(`{"name": "gcr.io/v2-namespace/hello-world", "tag": "1.1.1"}`)))
 	if err != nil {
 		t.Fatalf("failed to create req: %s", err)
 	}
@@ -61,7 +61,7 @@ func TestNativeWebhookHandlerNoRepoName(t *testing.T) {
 	srv := NewTriggerServer(&Opts{Providers: providers})
 	srv.registerRoutes(srv.router)
 
-	req, err := http.NewRequest("POST", "/v1/webhooks/native", bytes.NewBuffer([]byte(`{"repository": { "tag": "1.1.1"}}`)))
+	req, err := http.NewRequest("POST", "/v1/webhooks/native", bytes.NewBuffer([]byte(`{ "tag": "1.1.1"}`)))
 	if err != nil {
 		t.Fatalf("failed to create req: %s", err)
 	}