chore: upgrade to tshy 4 and TypeScript 6

Hoist tshy to a single root devDependency (4.1.2) instead of one per public
package, and move the repo from TypeScript 5.5.4 to 6.0.3.

Most of the TS6 work was absorbed by bumping @types/node to 20.19.19, which
brings the generic Buffer typings TS6 expects and clears the Buffer/Uint8Array
assignability errors at the source. The rest: drop the deprecated
downlevelIteration, modernize moduleResolution on the database/emails/tsql
configs (plus an explicit rootDir for database), and patch tsup so it only
passes the deprecated baseUrl when configured so redis-worker's declaration
build runs under TS6.

Also a few genuine type fixes (clickhouse row typing, OTLP response bodies,
realtime stream ingest types) and one real bug: the dev CLI read error.status
off an eventsource error that only exposes code, so the HTTP status never
showed.

Author: ericallam

.configs/tsconfig.base.json

@@ -26,7 +26,6 @@
     "esModuleInterop": true,
     "emitDecoratorMetadata": false,
     "experimentalDecorators": false,
-    "downlevelIteration": true,
     "isolatedModules": true,
     "noUncheckedIndexedAccess": true,
 

apps/webapp/app/routes/otel.v1.logs.ts

@@ -19,7 +19,7 @@ export async function action({ request }: ActionFunctionArgs) {
 
       const exportResponse = await otlpExporter.exportLogs(exportRequest);
 
-      return new Response(ExportLogsServiceResponse.encode(exportResponse).finish(), {
+      return new Response(ExportLogsServiceResponse.encode(exportResponse).finish().slice(), {
         status: 200,
       });
     } else {

apps/webapp/app/routes/otel.v1.metrics.ts

@@ -24,7 +24,7 @@ export async function action({ request }: ActionFunctionArgs) {
 
       const exportResponse = await otlpExporter.exportMetrics(exportRequest);
 
-      return new Response(ExportMetricsServiceResponse.encode(exportResponse).finish(), {
+      return new Response(ExportMetricsServiceResponse.encode(exportResponse).finish().slice(), {
         status: 200,
       });
     } else {

apps/webapp/app/routes/otel.v1.traces.ts

@@ -19,7 +19,7 @@ export async function action({ request }: ActionFunctionArgs) {
 
       const exportResponse = await otlpExporter.exportTraces(exportRequest);
 
-      return new Response(ExportTraceServiceResponse.encode(exportResponse).finish(), {
+      return new Response(ExportTraceServiceResponse.encode(exportResponse).finish().slice(), {
         status: 200,
       });
     } else {

apps/webapp/app/services/realtime/redisRealtimeStreams.server.ts

@@ -284,7 +284,7 @@ export class RedisRealtimeStreams implements StreamIngestor, StreamResponder {
   }
 
   async ingestData(
-    stream: ReadableStream<Uint8Array>,
+    stream: ReadableStream<Uint8Array<ArrayBuffer>>,
     runId: string,
     streamId: string,
     clientId: string,

apps/webapp/app/services/realtime/s2realtimeStreams.server.ts

@@ -111,7 +111,7 @@ export class S2RealtimeStreams implements StreamResponder, StreamIngestor {
   }
 
   ingestData(
-    stream: ReadableStream<Uint8Array>,
+    stream: ReadableStream<Uint8Array<ArrayBuffer>>,
     runId: string,
     streamId: string,
     clientId: string,

apps/webapp/app/services/realtime/types.ts

@@ -12,7 +12,7 @@ export interface StreamIngestor {
   ): Promise<{ responseHeaders?: Record<string, string> }>;
 
   ingestData(
-    stream: ReadableStream<Uint8Array>,
+    stream: ReadableStream<Uint8Array<ArrayBuffer>>,
     runId: string,
     streamId: string,
     clientId: string,

apps/webapp/test/setup-test-env.ts

@@ -17,7 +17,6 @@
     "skipLibCheck": true,
     "experimentalDecorators": true,
     "emitDecoratorMetadata": true,
-    "baseUrl": ".",
     "paths": {
       "~/*": ["./app/*"],
       "@/*": ["./*"]

apps/webapp/tsconfig.json

@@ -492,7 +492,7 @@ export class ClickhouseClient implements ClickhouseReader, ClickhouseWriter {
           }
 
           for (const row of rows) {
-            const rowData = row.json();
+            const rowData = row.json<unknown[]>();
 
             const hydratedRow: Record<string, any> = {};
             for (let i = 0; i < req.columns.length; i++) {