Stream deployment logs

package.json

@@ -11,7 +11,7 @@
     "@oclif/core": "^4",
     "@oclif/plugin-help": "^6",
     "@oclif/plugin-plugins": "^5",
-    "@trpc/client": "^11.0.0-rc.477",
+    "@trpc/client": "^11.0.0-rc.666",
     "@vercel/nft": "^0.27.4",
     "adm-zip": "^0.5.16",
     "jszip": "^3.10.1",

src/commands/deploy/index.ts

@@ -3,6 +3,7 @@ import {Blob} from 'node:buffer'
 import {FormData, fetch} from 'undici'
 import * as path from 'node:path';
 import * as fs from 'node:fs/promises';
+import {format} from "node:util";
 import {safely} from "../../lib/utils.js";
 import {BaseCommand} from "../../baseCommand.js";
 
@@ -90,7 +91,7 @@ export default class Deploy extends BaseCommand<typeof Deploy> {
         this.debug('Uploaded package', uploadResponse);
 
         this.debug('Creating version');
-        const [errorWithCreatingVersion, versionResponse] = await safely(this.apiClient.createComputeServiceVersion.mutate({
+        const [errorWithCreatingVersion, versionResponseFeed] = await safely(this.apiClient.createComputeServiceVersion.mutate({
             projectId: packageUploadUrlResponse.projectId,
             serviceId: packageUploadUrlResponse.serviceId,
             uploadToken: packageUploadUrlResponse.uploadToken,
@@ -100,9 +101,8 @@ export default class Deploy extends BaseCommand<typeof Deploy> {
             this.error(`Error creating version: ${errorWithCreatingVersion.message}`);
         }
 
-        this.debug('Created version', versionResponse);
-        const deployedHostnames = versionResponse?.routingConfig?.hostnames?.map((h: string) => `https://${h}/`)
-        this.log('Deployed version');
-        this.log(deployedHostnames.join('\n'))
+        for await (const chunk of versionResponseFeed) {
+            this.log(format(chunk));
+        }
     }
 }

src/lib/api.ts

@@ -1,5 +1,6 @@
 import * as crypto from 'node:crypto'
-import {type CreateTRPCClient, createTRPCClient, httpBatchLink} from "@trpc/client";
+// eslint-disable-next-line camelcase
+import {type CreateTRPCClient, createTRPCClient, unstable_httpBatchStreamLink} from "@trpc/client";
 // @ts-ignore: TS6059
 // eslint-disable-next-line import/no-unresolved
 import {AppRouter} from "@site/src/routes/api/[any]/router.js";
@@ -13,7 +14,7 @@ export const getTrpcClient = (origin: string, privateKey: crypto.KeyObject, keyI
 
     trpcClient = createTRPCClient<AppRouter>({
         links: [
-            httpBatchLink({
+            unstable_httpBatchStreamLink({
                 url: new URL('/api/', origin).toString(),
                 async fetch(...params) {
                     const request = new Request(...params);