From a970fe5fd6ff21ab2560a8ebc4576e9e1a8a2ee7 Mon Sep 17 00:00:00 2001
From: Yury Semikhatsky <yurys@chromium.org>
Date: Fri, 8 Oct 2021 14:11:40 -0700
Subject: [PATCH] feat(fetch): log fetch requests/responses to pw:api stream
 (#9403)

---
 src/server/fetch.ts | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

diff --git a/src/server/fetch.ts b/src/server/fetch.ts
index f507be4e20..e8525077c6 100644
--- a/src/server/fetch.ts
+++ b/src/server/fetch.ts
@@ -22,6 +22,7 @@ import url from 'url';
 import zlib from 'zlib';
 import { HTTPCredentials } from '../../types/types';
 import * as channels from '../protocol/channels';
+import { debugLogger } from '../utils/debugLogger';
 import { TimeoutSettings } from '../utils/timeoutSettings';
 import { assert, createGuid, getPlaywrightVersion, monotonicTime } from '../utils/utils';
 import { BrowserContext } from './browserContext';
@@ -192,6 +193,11 @@ export abstract class FetchRequest extends SdkObject {
       const requestConstructor: ((url: URL, options: http.RequestOptions, callback?: (res: http.IncomingMessage) => void) => http.ClientRequest)
         = (url.protocol === 'https:' ? https : http).request;
       const request = requestConstructor(url, options, async response => {
+        if (debugLogger.isEnabled('api')) {
+          debugLogger.log('api', `← ${response.statusCode} ${response.statusMessage}`);
+          for (const [name, value] of Object.entries(response.headers))
+            debugLogger.log('api', `  ${name}: ${value}`);
+        }
         if (response.headers['set-cookie'])
           await this._updateCookiesFromHeader(response.url || url.toString(), response.headers['set-cookie']);
         if (redirectStatus.includes(response.statusCode!)) {
@@ -283,6 +289,14 @@ export abstract class FetchRequest extends SdkObject {
       });
       request.on('error', reject);
 
+      if (debugLogger.isEnabled('api')) {
+        debugLogger.log('api', `→ ${options.method} ${url.toString()}`);
+        if (options.headers) {
+          for (const [name, value] of Object.entries(options.headers))
+            debugLogger.log('api', `  ${name}: ${value}`);
+        }
+      }
+
       if (options.deadline) {
         const rejectOnTimeout = () =>  {
           reject(new Error(`Request timed out after ${options.timeout}ms`));