feat: add cloudrunner.PubsubHTTPHandler top-level method

Make Pub/Sub HTTP handlers part of the main module interface.

cloudpubsub/httphandler.go

@@ -15,9 +15,9 @@ import (
 	"google.golang.org/protobuf/types/known/timestamppb"
 )
 
-// NewHTTPHandler creates a new HTTP handler for Cloud Pub/Sub push messages.
+// HTTPHandler creates a new HTTP handler for Cloud Pub/Sub push messages.
 // See: https://cloud.google.com/pubsub/docs/push
-func NewHTTPHandler(fn func(context.Context, *pubsub.PubsubMessage) error) http.Handler {
+func HTTPHandler(fn func(context.Context, *pubsub.PubsubMessage) error) http.Handler {
 	return httpHandlerFn(fn)
 }
 

cloudpubsub/httphandler_test.go

@@ -44,7 +44,7 @@ func TestNewHTTPHandler(t *testing.T) {
 		actualMessage = message
 		return nil
 	}
-	server := httptest.NewServer(NewHTTPHandler(fn))
+	server := httptest.NewServer(HTTPHandler(fn))
 	defer server.Close()
 	request, err := http.NewRequest(http.MethodPost, server.URL, strings.NewReader(example))
 	assert.NilError(t, err)

pubsubhttphandler.go

@@ -0,0 +1,15 @@
+package cloudrunner
+
+import (
+	"context"
+	"net/http"
+
+	"go.einride.tech/cloudrunner/cloudpubsub"
+	"google.golang.org/genproto/googleapis/pubsub/v1"
+)
+
+// PubsubHTTPHandler creates a new HTTP handler for Cloud Pub/Sub push messages.
+// See: https://cloud.google.com/pubsub/docs/push
+func PubsubHTTPHandler(fn func(context.Context, *pubsub.PubsubMessage) error) http.Handler {
+	return cloudpubsub.HTTPHandler(fn)
+}