fix: batch console streaming events (#633)

We previously sent each individual event back one per gRPC streaming
response message. In hindsight this is going to be slower than batching
due to per-message overhead.

backend/controller/console.go

@@ -167,15 +167,11 @@ func (c *ConsoleService) StreamEvents(ctx context.Context, req *connect.Request[
 			return errors.WithStack(err)
 		}
 
-		for index, timelineEvent := range events {
-			more := len(events) > index+1
-			err := stream.Send(&pbconsole.StreamEventsResponse{
-				Event: eventDALToProto(timelineEvent),
-				More:  more,
-			})
-			if err != nil {
-				return errors.WithStack(err)
-			}
+		err = stream.Send(&pbconsole.StreamEventsResponse{
+			Events: slices.Map(events, eventDALToProto),
+		})
+		if err != nil {
+			return errors.WithStack(err)
 		}
 		lastEventTime = thisRequestTime
 		select {

frontend/src/services/console.service.ts

@@ -168,17 +168,12 @@ export const streamEvents = async ({
   onEventsReceived: (events: Event[]) => void
 }) => {
   try {
-    let events: Event[] = []
     for await (const response of client.streamEvents(
-      { updateInterval: { seconds: BigInt(1) }, query: { limit: 1000, filters, order: EventsQuery_Order.DESC } },
+      { updateInterval: { seconds: BigInt(1) }, query: { limit: 200, filters, order: EventsQuery_Order.DESC } },
       { signal: abortControllerSignal },
     )) {
-      if (response.event != null) {
-        events.push(response.event)
-      }
-      if (!response.more) {
-        onEventsReceived(events)
-        events = []
+      if (response.events) {
+        onEventsReceived(response.events)
       }
     }
   } catch (error) {