Add debugging

Author: gnoff

packages/edge-config/src/index.ts

@@ -63,21 +63,33 @@ const getFileSystemEdgeConfig = trace(
     connection: Connection,
   ): Promise<EmbeddedEdgeConfig | null> {
     // can't optimize non-vercel hosted edge configs
-    if (connection.type !== 'vercel') return null;
+    if (connection.type !== 'vercel') {
+      // eslint-disable-next-line -- debugging
+      console.log('getFileSystemEdgeConfig: skipping non-vercel');
+      return null;
+    }
     // can't use fs optimizations outside of lambda
-    if (!process.env.AWS_LAMBDA_FUNCTION_NAME) return null;
+    if (!process.env.AWS_LAMBDA_FUNCTION_NAME) {
+      // eslint-disable-next-line -- debugging
+      console.log('getFileSystemEdgeConfig: skipping non-lambda');
+      return null;
+    }
 
     try {
       const content = await readFileTraced(
         `/opt/edge-config/${connection.id}.json`,
         'utf-8',
       );
 
+      // eslint-disable-next-line -- debugging
+      console.log('getFileSystemEdgeConfig: readFileTraced');
       return cachedJsonParseTraced(
         connection.id,
         content,
       ) as EmbeddedEdgeConfig;
     } catch {
+      // eslint-disable-next-line -- debugging
+      console.log('getFileSystemEdgeConfig: error -> null');
       return null;
     }
   },
@@ -107,9 +119,13 @@ const getPrivateEdgeConfig = trace(
       typeof privateEdgeConfig === 'object' &&
       typeof privateEdgeConfig.get === 'function'
     ) {
+      // eslint-disable-next-line -- debugging
+      console.log('getPrivateEdgeConfig: using privateEdgeConfig from symbol');
       return privateEdgeConfig.get(connection.id);
     }
 
+    // eslint-disable-next-line -- debugging
+    console.log('getPrivateEdgeConfig: skipping');
     return null;
   },
   {
@@ -142,10 +158,20 @@ function createGetInMemoryEdgeConfig(
 
   return trace(
     (localOptions) => {
-      if (localOptions?.consistentRead || !shouldUseDevelopmentCache)
+      // eslint-disable-next-line -- debugging
+      console.log(`getInMemoryEdgeConfig: called`);
+      if (localOptions?.consistentRead || !shouldUseDevelopmentCache) {
+        // eslint-disable-next-line -- debugging
+        console.log('getInMemoryEdgeConfig: skipping', {
+          localOptions,
+          shouldUseDevelopmentCache,
+        });
         return Promise.resolve(null);
+      }
 
       if (!latestRequest) {
+        // eslint-disable-next-line -- debugging
+        console.log(`getInMemoryEdgeConfig: creating new instance`);
         latestRequest = fetchWithCachedResponse(
           `${connection.baseUrl}/items?version=${connection.version}`,
           {
@@ -183,6 +209,9 @@ function createGetInMemoryEdgeConfig(
             latestRequest = null;
           },
         );
+      } else {
+        // eslint-disable-next-line -- debugging
+        console.log(`getInMemoryEdgeConfig: using existing`);
       }
 
       if (!embeddedEdgeConfigPromise) {
@@ -216,7 +245,11 @@ async function getLocalEdgeConfig(
   connection: Connection,
   options?: EdgeConfigFunctionsOptions,
 ): Promise<EmbeddedEdgeConfig | null> {
-  if (options?.consistentRead) return null;
+  if (options?.consistentRead) {
+    // eslint-disable-next-line -- debugging
+    console.log('getLocalEdgeConfig: skipping for consistentRead');
+    return null;
+  }
 
   const edgeConfig =
     (await getPrivateEdgeConfig(connection)) ||
@@ -368,6 +401,8 @@ export const createClient = trace(
             if (localOptions?.consistentRead)
               addConsistentReadHeader(localHeaders);
 
+            // eslint-disable-next-line -- debugging
+            console.log('fetching edge config from network');
             return fetchWithCachedResponse(
               `${baseUrl}/item/${key}?version=${version}`,
               {

packages/edge-config/src/utils/io-boundary.ts

@@ -26,12 +26,28 @@ export function withIOBoundary<
   F extends (...args: any[]) => Promise<any>,
 >(fn: F): F {
   async function bounded(this: unknown, ...args: unknown[]): Promise<unknown> {
+    // eslint-disable-next-line -- debugging
+    const {
+      workUnitAsyncStorage,
+    } = require('next/dist/server/app-render/work-unit-async-storage.external');
+
+    const tag = performance.now().toString(16);
+    // eslint-disable-next-line -- debugging
+    console.log(`${tag}, withIOBoundary: start`);
     const boundary = getCurrentBoundary();
     try {
       /* eslint-disable @typescript-eslint/no-unsafe-return -- we're wrapping */
-      return await fn.call(this, ...args);
+      // eslint-disable-next-line -- debugging
+      const result = await fn.call(this, ...args);
+      // eslint-disable-next-line -- debugging
+      console.log(`${tag}, withIOBoundary: end`);
+      return result;
     } finally {
+      // eslint-disable-next-line -- debugging
+      console.log(`${tag}, withIOBoundary: finally`);
       await boundary;
+      // eslint-disable-next-line -- debugging
+      console.log(`${tag}, withIOBoundary: awaited boundary`);
     }
   }