chore: update

Author: webfansplz

packages/kit/src/client/rpc.ts

@@ -15,6 +15,7 @@ function isNumeric(str: string | number | undefined) {
 export interface DevToolsRpcClientOptions {
   connectionMeta?: ConnectionMeta
   baseURL?: string[]
+  cacheResponse?: boolean
   wsOptions?: Partial<WebSocketRpcClientOptions>
   rpcOptions?: Partial<BirpcOptions<DevToolsRpcServerFunctions>>
 }
@@ -25,6 +26,7 @@ export interface ClientRpcReturn {
   connectionMeta: ConnectionMeta
   rpc: DevToolsRpcClient
   clientRpc: DevToolsClientRpcHost
+  invalidateCache: () => void
 }
 
 export async function getDevToolsRpcClient(
@@ -36,6 +38,8 @@ export async function getDevToolsRpcClient(
   } = options
   const urls = Array.isArray(baseURL) ? baseURL : [baseURL]
   let connectionMeta: ConnectionMeta | undefined = options.connectionMeta
+  let cacheResponseEnabled = options.cacheResponse ?? false
+  const responseCacheMap = new Map<string, unknown>()
 
   if (!connectionMeta) {
     const errors: Error[] = []
@@ -71,15 +75,43 @@ export async function getDevToolsRpcClient(
         url,
         ...options.wsOptions,
       }),
-      rpcOptions,
+      rpcOptions: {
+        ...rpcOptions,
+        onRequest: async (req, next, resolve) => {
+          await rpcOptions.onRequest?.(req, next, resolve)
+          if (cacheResponseEnabled) {
+            const cacheKey = `${req.m}-${JSON.stringify(req.a)}`
+            if (responseCacheMap.has(cacheKey)) {
+              resolve(responseCacheMap.get(cacheKey))
+            }
+            else {
+              responseCacheMap.set(cacheKey, await next(req))
+            }
+          }
+          else {
+            await next(req)
+          }
+        },
+      },
     },
   )
   // @ts-expect-error assign to readonly property
   context.rpc = rpc
 
+  function invalidateCache(key?: string) {
+    if (key) {
+      responseCacheMap.delete(key)
+    }
+    else {
+      cacheResponseEnabled = false
+      responseCacheMap.clear()
+    }
+  }
+
   return {
     connectionMeta,
     rpc,
     clientRpc,
+    invalidateCache,
   }
 }

packages/vite/src/app/composables/rpc.ts

@@ -14,7 +14,6 @@ export const connectionState = reactive<{
 })
 
 const rpc = shallowRef<ClientRpcReturn['rpc']>(undefined!)
-const responseCacheMap = new Map<string, unknown>()
 
 export async function connect() {
   const runtimeConfig = useRuntimeConfig()
@@ -24,6 +23,7 @@ export async function connect() {
         '/.devtools/',
         runtimeConfig.app.baseURL,
       ],
+      cacheResponse: true,
       connectionMeta: runtimeConfig.app.connection,
       wsOptions: {
         onConnected: () => {
@@ -41,15 +41,6 @@ export async function connect() {
           connectionState.error = e
           console.error(`[vite-devtools] RPC error on executing "${name}":`)
         },
-        onRequest: async (req, next, resolve) => {
-          const cacheKey = `${req.m}-${JSON.stringify(req.a)}`
-          if (responseCacheMap.has(cacheKey)) {
-            resolve(responseCacheMap.get(cacheKey))
-          }
-          else {
-            responseCacheMap.set(cacheKey, await next(req))
-          }
-        },
       },
     })