Merge pull request #557 from sm43/add-test-for-adapter

Author: chmouel

pkg/adapter/adapter_test.go

@@ -1,14 +1,21 @@
 package adapter
 
 import (
+	"bytes"
+	"context"
 	"encoding/json"
 	"net/http"
+	"net/http/httptest"
 	"testing"
 
 	"github.com/google/go-github/v43/github"
+	"github.com/openshift-pipelines/pipelines-as-code/pkg/params"
+	"github.com/openshift-pipelines/pipelines-as-code/pkg/params/clients"
+	testclient "github.com/openshift-pipelines/pipelines-as-code/pkg/test/clients"
 	"go.uber.org/zap"
 	zapobserver "go.uber.org/zap/zaptest/observer"
 	"gotest.tools/v3/assert"
+	rtesting "knative.dev/pkg/reconciler/testing"
 )
 
 func getLogger() *zap.SugaredLogger {
@@ -17,6 +24,95 @@ func getLogger() *zap.SugaredLogger {
 	return logger
 }
 
+func TestHandleEvent(t *testing.T) {
+	ctx, _ := rtesting.SetupFakeContext(t)
+	cs, _ := testclient.SeedTestData(t, ctx, testclient.Data{})
+
+	l := listener{
+		run: &params.Run{
+			Clients: clients.Clients{
+				PipelineAsCode: cs.PipelineAsCode,
+				Log:            getLogger(),
+			},
+		},
+		logger: getLogger(),
+	}
+
+	ts := httptest.NewServer(l.handleEvent())
+	defer ts.Close()
+
+	// valid push event
+	testEvent := github.PushEvent{Pusher: &github.User{ID: github.Int64(101)}}
+	event, err := json.Marshal(testEvent)
+	assert.NilError(t, err)
+
+	// invalid push event which will be skipped
+	skippedEvent, err := json.Marshal(github.PushEvent{})
+	assert.NilError(t, err)
+
+	tests := []struct {
+		name        string
+		event       []byte
+		eventType   string
+		requestType string
+		statusCode  int
+	}{
+		{
+			name:        "get http call",
+			requestType: "GET",
+			event:       []byte("event"),
+			statusCode:  200,
+		},
+		{
+			name:        "invalid json body",
+			requestType: "POST",
+			event:       []byte("some random string for invalid json body"),
+			statusCode:  400,
+		},
+		{
+			name:        "valid event",
+			requestType: "POST",
+			eventType:   "push",
+			event:       event,
+			statusCode:  202,
+		},
+		{
+			name:        "skip event",
+			requestType: "POST",
+			eventType:   "push",
+			event:       skippedEvent,
+			statusCode:  200,
+		},
+		{
+			name:        "git provider not detected",
+			requestType: "POST",
+			eventType:   "",
+			event:       event,
+			statusCode:  200,
+		},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			req, err := http.NewRequestWithContext(context.TODO(), tt.requestType, ts.URL, bytes.NewReader(tt.event))
+			if err != nil {
+				t.Fatalf("error creating request: %s", err)
+			}
+			req.Header.Set("X-Github-Event", tt.eventType)
+
+			resp, err := http.DefaultClient.Do(req)
+			if err != nil {
+				t.Fatalf("error sending request: %s", err)
+			}
+			defer resp.Body.Close()
+
+			if resp.StatusCode != tt.statusCode {
+				t.Fatalf("expected status code : %v but got %v ", tt.statusCode, resp.StatusCode)
+			}
+		})
+	}
+}
+
 func TestWhichProvider(t *testing.T) {
 	l := listener{
 		logger: getLogger(),