feat: add HTTP event streams (#417)

Author: alnr

cmd/cloudx/eventstreams/create.go

@@ -17,7 +17,7 @@ func NewCreateEventStreamCmd() *cobra.Command {
 	c := streamConfig{}
 
 	cmd := &cobra.Command{
-		Use:   "event-stream [--project=PROJECT_ID] --type=sns --aws-iam-role-arn=arn:aws:iam::123456789012:role/MyRole --aws-sns-topic-arn=arn:aws:sns:us-east-1:123456789012:MyTopic",
+		Use:   "event-stream [--project=PROJECT_ID] --type={sns,https} {--aws-iam-role-arn=arn:aws:iam::123456789012:role/MyRole --aws-sns-topic-arn=arn:aws:sns:us-east-1:123456789012:MyTopic, --https-endpoint=https://example.com/webhook}",
 		Short: "Create a new event stream",
 		Args:  cobra.NoArgs,
 		RunE: func(cmd *cobra.Command, args []string) error {

cmd/cloudx/eventstreams/flags.go

@@ -5,6 +5,7 @@ package eventstreams
 
 import (
 	"fmt"
+	"net/url"
 
 	"github.com/spf13/pflag"
 
@@ -14,19 +15,45 @@ import (
 type streamConfig client.CreateEventStreamBody
 
 func (c *streamConfig) Validate() error {
-	switch "" {
-	case c.Type:
+	switch c.Type {
+	case "":
 		return fmt.Errorf("flag --type must be set")
-	case c.RoleArn:
-		return fmt.Errorf("flag --aws-iam-role-arn must be set")
-	case c.TopicArn:
-		return fmt.Errorf("flag --aws-sns-topic-arn must be set")
+	case "sns":
+		if c.RoleArn == nil || *c.RoleArn == "" {
+			return fmt.Errorf("flag --aws-iam-role-arn must be set")
+		}
+		if c.TopicArn == nil || *c.TopicArn == "" {
+			return fmt.Errorf("flag --aws-sns-topic-arn must be set")
+		}
+		if c.HttpsEndpoint != nil && *c.HttpsEndpoint != "" {
+			return fmt.Errorf("flag --https-endpoint cannot be set when type is sns")
+		}
+	case "https":
+		if c.HttpsEndpoint == nil || *c.HttpsEndpoint == "" {
+			return fmt.Errorf("flag --https-endpoint must be set")
+		}
+		e, err := url.Parse(*c.HttpsEndpoint)
+		if err != nil {
+			return fmt.Errorf("invalid URL for flag --https-endpoint: %w", err)
+		}
+		if e.Scheme != "https" {
+			return fmt.Errorf("flag --https-endpoint must have https scheme")
+		}
+		if c.RoleArn != nil && *c.RoleArn != "" {
+			return fmt.Errorf("flag --aws-iam-role-arn cannot be set when type is https")
+		}
+		if c.TopicArn != nil && *c.TopicArn != "" {
+			return fmt.Errorf("flag --aws-sns-topic-arn cannot be set when type is https")
+		}
+	default:
+		return fmt.Errorf("unsupported event stream type: %s", c.Type)
 	}
 	return nil
 }
 
 func registerStreamConfigFlags(f *pflag.FlagSet, c *streamConfig) {
-	f.StringVar(&c.Type, "type", "", `The type of the event stream destination. Only "sns" is supported at the moment.`)
-	f.StringVar(&c.RoleArn, "aws-iam-role-arn", "", "The ARN of the AWS IAM role to assume when publishing messages to the SNS topic.")
-	f.StringVar(&c.TopicArn, "aws-sns-topic-arn", "", "The ARN of the AWS SNS topic.")
+	f.StringVar(&c.Type, "type", "", `The type of the event stream destination. Supported values are "sns" for AWS SNS topics and "https" for generic HTTPS endpoints.`)
+	c.RoleArn = f.String("aws-iam-role-arn", "", "The ARN of the AWS IAM role to assume when publishing messages to the SNS topic.")
+	c.TopicArn = f.String("aws-sns-topic-arn", "", "The ARN of the AWS SNS topic.")
+	c.HttpsEndpoint = f.String("https-endpoint", "", "The URL of the HTTPS endpoint.")
 }

cmd/cloudx/eventstreams/output.go

@@ -15,18 +15,26 @@ type (
 )
 
 func (output) Header() []string {
-	return []string{"ID", "TYPE", "IAM_ROLE_ARN", "SNS_TOPIC_ARN"}
+	return []string{"ID", "TYPE", "IAM_ROLE_ARN", "SNS_TOPIC_ARN", "HTTPS_ENDPOINT"}
 }
 
 func (o output) Columns() []string {
 	return []string{
-		*o.Id,
-		*o.Type,
-		*o.RoleArn,
-		*o.TopicArn,
+		coalesce(o.Id),
+		coalesce(o.Type),
+		coalesce(o.RoleArn),
+		coalesce(o.TopicArn),
+		coalesce(o.HttpsEndpoint.Get()),
 	}
 }
 
+func coalesce(s *string) string {
+	if s == nil {
+		return ""
+	}
+	return *s
+}
+
 func (o output) Interface() interface{} {
 	return o
 }

cmd/cloudx/eventstreams/update.go

@@ -18,7 +18,7 @@ func NewUpdateEventStreamCmd() *cobra.Command {
 	c := streamConfig{}
 
 	cmd := &cobra.Command{
-		Use:   "event-stream id [--project=PROJECT_ID] [--type=sns] [--aws-iam-role-arn=arn:aws:iam::123456789012:role/MyRole] [--aws-sns-topic-arn=arn:aws:sns:us-east-1:123456789012:MyTopic]",
+		Use:   "event-stream id [--project=PROJECT_ID] --type={sns,https} {--aws-iam-role-arn=arn:aws:iam::123456789012:role/MyRole --aws-sns-topic-arn=arn:aws:sns:us-east-1:123456789012:MyTopic, --https-endpoint=https://example.com/webhook}",
 		Args:  cobra.ExactArgs(1),
 		Short: "Update the event stream with the given ID",
 		RunE: func(cmd *cobra.Command, args []string) error {

go.mod

@@ -21,7 +21,7 @@ require (
 	github.com/gofrs/uuid/v3 v3.1.2
 	github.com/gomarkdown/markdown v0.0.0-20240730141124-034f12af3bf6
 	github.com/hashicorp/go-retryablehttp v0.7.8
-	github.com/ory/client-go v1.22.26
+	github.com/ory/client-go v1.22.32
 	github.com/ory/gochimp3 v0.0.0-20200417124117-ccd242db3655
 	github.com/ory/graceful v0.1.4-0.20230301144740-e222150c51d0
 	github.com/ory/herodot v0.10.8

go.sum

@@ -554,8 +554,8 @@ github.com/openzipkin/zipkin-go v0.4.3/go.mod h1:M9wCJZFWCo2RiY+o1eBCEMe0Dp2S5LD
 github.com/orisano/pixelmatch v0.0.0-20220722002657-fb0b55479cde/go.mod h1:nZgzbfBr3hhjoZnS66nKrHmduYNpc34ny7RK4z5/HM0=
 github.com/ory/analytics-go/v5 v5.0.1 h1:LX8T5B9FN8KZXOtxgN+R3I4THRRVB6+28IKgKBpXmAM=
 github.com/ory/analytics-go/v5 v5.0.1/go.mod h1:lWCiCjAaJkKfgR/BN5DCLMol8BjKS1x+4jxBxff/FF0=
-github.com/ory/client-go v1.22.26 h1:BmkdtHswtZQ9/+3QBQDUuTPCpjYVYpXoMo/ZAzRF5Tg=
-github.com/ory/client-go v1.22.26/go.mod h1:7zxu6CcDaf5Khovhrs+eWxY4TVaCnGxlK2C/b48HgNg=
+github.com/ory/client-go v1.22.32 h1:31kLMk6DynhoyjXO7Gx6DRI9VX7RBdCQDxppfCiGtxg=
+github.com/ory/client-go v1.22.32/go.mod h1:G1f+5+m/PJVvl40bsRn0QuyVIcXe7EHiWeM7iWpIDjw=
 github.com/ory/dockertest/v4 v4.0.0-beta.4 h1:QcrNrobOP+5IjSDmS4//EuBtwiFuznQhi5xTe8oFSoM=
 github.com/ory/dockertest/v4 v4.0.0-beta.4/go.mod h1:p9kfE14tzK8+WU4F9YbIZlzhCzQ2pH7H1KIfBKrF3DM=
 github.com/ory/go-acc v0.2.9-0.20230103102148-6b1c9a70dbbe h1:rvu4obdvqR0fkSIJ8IfgzKOWwZ5kOT2UNfLq81Qk7rc=