chore: generate

Co-authored-by: Aiden Cline <rekram1-node@users.noreply.github.com>

packages/cli/test/fixture/standalone-owner.ts

@@ -14,7 +14,7 @@ await Effect.runPromise(
       const response = yield* Effect.promise(() =>
         fetch(new URL("/api/health", endpoint.url), { headers: Service.headers(endpoint) }),
       )
-      console.log(`${endpoint.pid} ${endpoint.url} ${response.status}`)
+      console.log(`STANDALONE_READY ${endpoint.pid} ${endpoint.url} ${response.status}`)
       return yield* Effect.never
     }),
   ),

packages/cli/test/standalone.test.ts

@@ -9,8 +9,11 @@ test("standalone server exits when its owner is killed", async () => {
     stdout: "pipe",
     stderr: "pipe",
   })
-  const line = await Promise.race([readLine(owner.stdout), Bun.sleep(10_000).then(() => undefined)])
-  const [rawPID, url, status] = line?.split(" ") ?? []
+  const line = await Promise.race([
+    readLine(owner.stdout, "STANDALONE_READY "),
+    Bun.sleep(10_000).then(() => undefined),
+  ])
+  const [, rawPID, url, status] = line?.split(" ") ?? []
   const pid = Number(rawPID)
 
   try {
@@ -29,7 +32,7 @@ test("standalone server exits when its owner is killed", async () => {
   }
 })
 
-async function readLine(stream: ReadableStream<Uint8Array>) {
+async function readLine(stream: ReadableStream<Uint8Array>, prefix: string) {
   const reader = stream.getReader()
   const decoder = new TextDecoder()
   const chunks: string[] = []
@@ -38,14 +41,14 @@ async function readLine(stream: ReadableStream<Uint8Array>) {
     if (result.done) break
     chunks.push(decoder.decode(result.value, { stream: true }))
     const output = chunks.join("")
-    const newline = output.indexOf("\n")
-    if (newline !== -1) {
+    const line = output.split("\n").find((line) => line.startsWith(prefix))
+    if (line) {
       reader.releaseLock()
-      return output.slice(0, newline)
+      return line
     }
   }
   reader.releaseLock()
-  return chunks.join("") + decoder.decode()
+  return (chunks.join("") + decoder.decode()).split("\n").find((line) => line.startsWith(prefix))
 }
 
 async function waitForExit(pid: number, attempts = 100): Promise<boolean> {