Use google-auth-library to make oauth requests in SSE transport in typescript client.

- The library authenticates with Google oauth, we extract the request headers and attach it to the SSE transport.

Change-Id: I67039203efb71dbc4f00ceb0788ffcf1baeeab52
Reviewed-on: https://skia-review.googlesource.com/c/buildbot/+/1011262
Reviewed-by: Jeff Yoon <[email protected]>
Auto-Submit: Ashwin Verleker <[email protected]>
Commit-Queue: Ashwin Verleker <[email protected]>

Author: ashwinpvg

mcp/Makefile

@@ -1,14 +1,14 @@
 include ../make/bazel.mk
 
 run-auth-proxy:
-	bazelisk run //kube/cmd/auth-proxy -- \
+	bazelisk run -c dbg //kube/cmd/auth-proxy -- \
 		--prom-port=:20003 \
 		--role=editor=google.com \
 		--port=:8000 \
 		--target_port=:8080 \
 		--local \
 		--self_sign_localhost_tls \
-		--passive \
+		--authtype=oauth2 \
 		--use_http1
 
 run-perf-mcp:

mcp/client/lib/BUILD.bazel

@@ -8,6 +8,7 @@ ts_library(
         ":settings_ts_lib",
         "//:node_modules/@google/generative-ai",
         "//:node_modules/@modelcontextprotocol/sdk",
+        "//:node_modules/google-auth-library",
     ],
 )
 

mcp/client/lib/mcp-client.ts

@@ -4,6 +4,7 @@ import { StdioClientTransport } from '@modelcontextprotocol/sdk/client/stdio.js'
 import { ServerConfig } from './settings';
 import { SSEClientTransport } from '@modelcontextprotocol/sdk/client/sse.js';
 import { StreamableHTTPClientTransport } from '@modelcontextprotocol/sdk/client/streamableHttp.js';
+import { GoogleAuth } from 'google-auth-library';
 
 export class MCPClient {
   private client: Client;
@@ -69,7 +70,16 @@ export class MCPClient {
             e instanceof Error ? e.message : String(e)
           }. Falling back to SSE.`
         );
-        this.transport = new SSEClientTransport(new URL(serverConfig.url));
+        const auth = new GoogleAuth({
+          scopes: 'https://www.googleapis.com/auth/userinfo.email',
+        });
+        const client = await auth.getClient();
+        const headers = await client.getRequestHeaders();
+        this.transport = new SSEClientTransport(new URL(serverConfig.url), {
+          requestInit: {
+            headers: headers,
+          },
+        });
       }
     } else {
       throw new Error(`Invalid server config for ${serverName}: No command or URL provided.`);