remove per event filtering

Author: tvarney13

internal/dev_server/events/base.go

@@ -0,0 +1,5 @@
+package events
+
+type Base struct {
+	Kind string `json:"kind"`
+}

internal/dev_server/events/filter.go

@@ -3,16 +3,17 @@ package sdk
 import (
 	"context"
 	"encoding/json"
+	"io"
+	"log"
+	"net/http"
+
 	"github.com/google/uuid"
 	"github.com/launchdarkly/ldcli/internal/dev_server/events"
 	"github.com/launchdarkly/ldcli/internal/dev_server/model"
 	"github.com/pkg/errors"
-	"io"
-	"log"
-	"net/http"
 )
 
-func newSdkEventObserver(updateChan chan<- Message, ctx context.Context, filter events.Filter) sdkEventObserver {
+func newSdkEventObserver(updateChan chan<- Message, ctx context.Context) sdkEventObserver {
 	debugSessionKey := uuid.New().String()
 	db := model.EventStoreFromContext(ctx)
 	err := db.CreateDebugSession(ctx, debugSessionKey)
@@ -23,15 +24,13 @@ func newSdkEventObserver(updateChan chan<- Message, ctx context.Context, filter
 		debugSessionKey: debugSessionKey,
 		ctx:             ctx,
 		updateChan:      updateChan,
-		filter:          filter,
 	}
 }
 
 type sdkEventObserver struct {
 	ctx             context.Context
 	debugSessionKey string
 	updateChan      chan<- Message
-	filter          events.Filter
 }
 
 func (o sdkEventObserver) Handle(message interface{}) {
@@ -47,10 +46,6 @@ func (o sdkEventObserver) Handle(message interface{}) {
 		return
 	}
 
-	if !o.filter.Matches(event) {
-		return
-	}
-
 	db := model.EventStoreFromContext(o.ctx)
 
 	err = db.WriteEvent(o.ctx, o.debugSessionKey, event.Kind, str)
@@ -93,15 +88,8 @@ func SdkEventsTeeHandler(writer http.ResponseWriter, request *http.Request) {
 		Message{Event: TYPE_PUT, Data: []byte{}},
 	)
 	defer close(updateChan)
-	filter := events.Filter{}
-
-	query := request.URL.Query()
-	kind := query.Get("kind")
-	if kind != "" {
-		filter.Kind = &kind
-	}
 
-	observerId := observers.RegisterObserver(newSdkEventObserver(updateChan, request.Context(), filter))
+	observerId := observers.RegisterObserver(newSdkEventObserver(updateChan, request.Context()))
 	defer func() {
 		ok := observers.DeregisterObserver(observerId)
 		if !ok {