sync

3 files changed, 59 insertions, 0 deletions

diff --git a/packages/tui/pkg/client/.gitignore b/packages/tui/pkg/client/.gitignore
new file mode 100644
index 000000000..c56971e89
--- /dev/null
+++ b/packages/tui/pkg/client/.gitignore
@@ -0,0 +1,2 @@
+gen
+generated-*.go
diff --git a/packages/tui/pkg/client/client.go b/packages/tui/pkg/client/client.go
new file mode 100644
index 000000000..bf2d5038e
--- /dev/null
+++ b/packages/tui/pkg/client/client.go
@@ -0,0 +1,4 @@
+package client
+
+//go:generate bun run ../../js/src/index.ts generate
+//go:generate go tool github.com/oapi-codegen/oapi-codegen/v2/cmd/oapi-codegen --package=client --generate=types,client,models -o generated-client.go ./gen/openapi.json
diff --git a/packages/tui/pkg/client/event.go b/packages/tui/pkg/client/event.go
new file mode 100644
index 000000000..f5aab2d26
--- /dev/null
+++ b/packages/tui/pkg/client/event.go
@@ -0,0 +1,53 @@
+package client
+
+import (
+	"bufio"
+	"context"
+	"encoding/json"
+	"net/http"
+	"strings"
+)
+
+func (c *Client) Event(ctx context.Context) (<-chan any, error) {
+	events := make(chan any)
+	req, err := http.NewRequestWithContext(ctx, "GET", c.Server+"event", nil)
+	if err != nil {
+		return nil, err
+	}
+
+	resp, err := http.DefaultClient.Do(req)
+	if err != nil {
+		return nil, err
+	}
+
+	go func() {
+		defer close(events)
+		defer resp.Body.Close()
+
+		scanner := bufio.NewScanner(resp.Body)
+		for scanner.Scan() {
+			line := scanner.Text()
+			if strings.HasPrefix(line, "data: ") {
+				data := strings.TrimPrefix(line, "data: ")
+
+				var event Event
+				if err := json.Unmarshal([]byte(data), &event); err != nil {
+					continue
+				}
+
+				val, err := event.ValueByDiscriminator()
+				if err != nil {
+					continue
+				}
+
+				select {
+				case events <- val:
+				case <-ctx.Done():
+					return
+				}
+			}
+		}
+	}()
+
+	return events, nil
+}