import { clipboard } from 'electron/common';
import { BrowserWindow, WebFrameMain, webFrameMain, ipcMain, app, WebContents } from 'electron/main';

import { expect } from 'chai';

import { once } from 'node:events';
import * as http from 'node:http';
import * as path from 'node:path';
import { setTimeout } from 'node:timers/promises';
import * as url from 'node:url';

import { emittedNTimes } from './lib/events-helpers';
import { defer, ifit, listen, waitUntil } from './lib/spec-helpers';
import { closeAllWindows } from './lib/window-helpers';

describe('webFrameMain module', () => {
  const fixtures = path.resolve(__dirname, 'fixtures');
  const subframesPath = path.join(fixtures, 'sub-frames');

  const fileUrl = (filename: string) => url.pathToFileURL(path.join(subframesPath, filename)).href;

  type Server = { server: http.Server; url: string; crossOriginUrl: string };

  /** Creates an HTTP server whose handler embeds the given iframe src. */
  const createServer = async (
    options: {
      headers?: Record<string, string>;
    } = {}
  ): Promise<Server> => {
    const server = http.createServer((req, res) => {
      if (options.headers) {
        for (const [k, v] of Object.entries(options.headers)) {
          res.setHeader(k, v);
        }
      }

      const params = new URLSearchParams(new URL(req.url || '', `http://${req.headers.host}`).search || '');
      if (params.has('frameSrc')) {
        res.end(`<iframe src="${params.get('frameSrc')}"></iframe>`);
      } else {
        res.end('');
      }
    });
    const serverUrl = (await listen(server)).url + '/';
    // HACK: Use 'localhost' instead of '127.0.0.1' so Chromium treats it as
    // a separate origin because differing ports aren't enough 🤔
    const crossOriginUrl = serverUrl.replace('127.0.0.1', 'localhost');
    return {
      server,
      url: serverUrl,
      crossOriginUrl
    };
  };

  afterEach(closeAllWindows);

  describe('WebFrame traversal APIs', () => {
    let w: BrowserWindow;
    let webFrame: WebFrameMain;

    beforeEach(async () => {
      w = new BrowserWindow({ show: false });
      await w.loadFile(path.join(subframesPath, 'frame-with-frame-container.html'));
      webFrame = w.webContents.mainFrame;
    });

    it('can access top frame', () => {
      expect(webFrame.top).to.equal(webFrame);
    });

    it('has no parent on top frame', () => {
      expect(webFrame.parent).to.be.null();
    });

    it('can access immediate frame descendents', () => {
      const { frames } = webFrame;
      expect(frames).to.have.lengthOf(1);
      const subframe = frames[0];
      expect(subframe).not.to.equal(webFrame);
      expect(subframe.parent).to.equal(webFrame);
    });

    it('can access deeply nested frames', () => {
      const subframe = webFrame.frames[0];
      expect(subframe).not.to.equal(webFrame);
      expect(subframe.parent).to.equal(webFrame);
      const nestedSubframe = subframe.frames[0];
      expect(nestedSubframe).not.to.equal(webFrame);
      expect(nestedSubframe).not.to.equal(subframe);
      expect(nestedSubframe.parent).to.equal(subframe);
    });

    it('can traverse all frames in root', () => {
      const urls = webFrame.framesInSubtree.map((frame) => frame.url);
      expect(urls).to.deep.equal([
        fileUrl('frame-with-frame-container.html'),
        fileUrl('frame-with-frame.html'),
        fileUrl('frame.html')
      ]);
    });

    it('can traverse all frames in subtree', () => {
      const urls = webFrame.frames[0].framesInSubtree.map((frame) => frame.url);
      expect(urls).to.deep.equal([fileUrl('frame-with-frame.html'), fileUrl('frame.html')]);
    });

    describe('cross-origin', () => {
      let serverA: Server;
      let serverB: Server;

      before(async () => {
        serverA = await createServer();
        serverB = await createServer();
      });

      after(() => {
        serverA.server.close();
        serverB.server.close();
      });

      it('can access cross-origin frames', async () => {
        await w.loadURL(`${serverA.url}?frameSrc=${serverB.url}`);
        webFrame = w.webContents.mainFrame;
        expect(webFrame.url.startsWith(serverA.url)).to.be.true();
        expect(webFrame.frames[0].url).to.equal(serverB.url);
      });
    });
  });

  describe('WebFrame.url', () => {
    it('should report correct address for each subframe', async () => {
      const w = new BrowserWindow({ show: false });
      await w.loadFile(path.join(subframesPath, 'frame-with-frame-container.html'));
      const webFrame = w.webContents.mainFrame;

      expect(webFrame.url).to.equal(fileUrl('frame-with-frame-container.html'));
      expect(webFrame.frames[0].url).to.equal(fileUrl('frame-with-frame.html'));
      expect(webFrame.frames[0].frames[0].url).to.equal(fileUrl('frame.html'));
    });
  });

  describe('WebFrame.origin', () => {
    it('should be null for a fresh WebContents', () => {
      const w = new BrowserWindow({ show: false });
      expect(w.webContents.mainFrame.origin).to.equal('null');
    });

    it('should be file:// for file frames', async () => {
      const w = new BrowserWindow({ show: false });
      await w.loadFile(path.join(fixtures, 'pages', 'blank.html'));
      expect(w.webContents.mainFrame.origin).to.equal('file://');
    });

    it('should be http:// for an http frame', async () => {
      const w = new BrowserWindow({ show: false });
      const s = await createServer();
      defer(() => s.server.close());
      await w.loadURL(s.url);
      expect(w.webContents.mainFrame.origin).to.equal(s.url.replace(/\/$/, ''));
    });

    it('should show parent origin when child page is about:blank', async () => {
      const w = new BrowserWindow({ show: false });
      await w.loadFile(path.join(fixtures, 'pages', 'blank.html'));
      const webContentsCreated = once(app, 'web-contents-created') as Promise<[any, WebContents]>;
      expect(w.webContents.mainFrame.origin).to.equal('file://');
      await w.webContents.executeJavaScript('window.open("", null, "show=false"), null');
      const [, childWebContents] = await webContentsCreated;
      expect(childWebContents.mainFrame.origin).to.equal('file://');
    });

    it("should show parent frame's origin when about:blank child window opened through cross-origin subframe", async () => {
      const w = new BrowserWindow({ show: false });
      const serverA = await createServer();
      const serverB = await createServer();
      defer(() => {
        serverA.server.close();
        serverB.server.close();
      });
      await w.loadURL(serverA.url + '?frameSrc=' + encodeURIComponent(serverB.url));
      const { mainFrame } = w.webContents;
      expect(mainFrame.origin).to.equal(serverA.url.replace(/\/$/, ''));
      const [childFrame] = mainFrame.frames;
      expect(childFrame.origin).to.equal(serverB.url.replace(/\/$/, ''));
      const webContentsCreated = once(app, 'web-contents-created') as Promise<[any, WebContents]>;
      await childFrame.executeJavaScript('window.open("", null, "show=false"), null');
      const [, childWebContents] = await webContentsCreated;
      expect(childWebContents.mainFrame.origin).to.equal(childFrame.origin);
    });
  });

  describe('WebFrame IDs', () => {
    it('has properties for various identifiers', async () => {
      const w = new BrowserWindow({ show: false });
      await w.loadFile(path.join(subframesPath, 'frame.html'));
      const webFrame = w.webContents.mainFrame;
      expect(webFrame).to.have.property('url').that.is.a('string');
      expect(webFrame).to.have.property('frameTreeNodeId').that.is.a('number');
      expect(webFrame).to.have.property('name').that.is.a('string');
      expect(webFrame).to.have.property('osProcessId').that.is.a('number');
      expect(webFrame).to.have.property('processId').that.is.a('number');
      expect(webFrame).to.have.property('routingId').that.is.a('number');
      expect(webFrame).to.have.property('frameToken').that.is.a('string');
    });
  });

  describe('WebFrame.visibilityState', () => {
    // DISABLED-FIXME(MarshallOfSound): Fix flaky test
    it('should match window state', async () => {
      const w = new BrowserWindow({ show: true });
      await w.loadURL('about:blank');
      const webFrame = w.webContents.mainFrame;

      expect(webFrame.visibilityState).to.equal('visible');
      w.hide();
      await expect(waitUntil(() => webFrame.visibilityState === 'hidden')).to.eventually.be.fulfilled();
    });
  });

  describe('WebFrame.executeJavaScript', () => {
    it('can inject code into any subframe', async () => {
      const w = new BrowserWindow({ show: false });
      await w.loadFile(path.join(subframesPath, 'frame-with-frame-container.html'));
      const webFrame = w.webContents.mainFrame;

      const getUrl = (frame: WebFrameMain) => frame.executeJavaScript('location.href');
      expect(await getUrl(webFrame)).to.equal(fileUrl('frame-with-frame-container.html'));
      expect(await getUrl(webFrame.frames[0])).to.equal(fileUrl('frame-with-frame.html'));
      expect(await getUrl(webFrame.frames[0].frames[0])).to.equal(fileUrl('frame.html'));
    });

    it('can resolve promise', async () => {
      const w = new BrowserWindow({ show: false });
      await w.loadFile(path.join(subframesPath, 'frame.html'));
      const webFrame = w.webContents.mainFrame;
      const p = () => webFrame.executeJavaScript('new Promise(resolve => setTimeout(resolve(42), 2000));');
      const result = await p();
      expect(result).to.equal(42);
    });

    it('can reject with error', async () => {
      const w = new BrowserWindow({ show: false });
      await w.loadFile(path.join(subframesPath, 'frame.html'));
      const webFrame = w.webContents.mainFrame;
      const p = () => webFrame.executeJavaScript('new Promise((r,e) => setTimeout(e("error!"), 500));');
      await expect(p()).to.be.eventually.rejectedWith('error!');
      const errorTypes = new Set([Error, ReferenceError, EvalError, RangeError, SyntaxError, TypeError, URIError]);
      for (const error of errorTypes) {
        await expect(
          webFrame.executeJavaScript(`Promise.reject(new ${error.name}("Wamp-wamp"))`)
        ).to.eventually.be.rejectedWith(/Error/);
      }
    });

    it('can reject when script execution fails', async () => {
      const w = new BrowserWindow({ show: false });
      await w.loadFile(path.join(subframesPath, 'frame.html'));
      const webFrame = w.webContents.mainFrame;
      const p = () => webFrame.executeJavaScript('console.log(test)');
      await expect(p()).to.be.eventually.rejectedWith(/ReferenceError/);
    });
  });

  describe('WebFrame.reload', () => {
    it('reloads a frame', async () => {
      const w = new BrowserWindow({ show: false });
      await w.loadFile(path.join(subframesPath, 'frame.html'));
      const webFrame = w.webContents.mainFrame;

      await webFrame.executeJavaScript('window.TEMP = 1', false);
      expect(webFrame.reload()).to.be.true();
      await once(w.webContents, 'dom-ready');
      expect(await webFrame.executeJavaScript('window.TEMP', false)).to.be.null();
    });
  });

  describe('WebFrame.send', () => {
    it('works', async () => {
      const w = new BrowserWindow({
        show: false,
        webPreferences: {
          preload: path.join(subframesPath, 'preload.js'),
          nodeIntegrationInSubFrames: true
        }
      });
      await w.loadURL('about:blank');
      const webFrame = w.webContents.mainFrame;
      const pongPromise = once(ipcMain, 'preload-pong');
      webFrame.send('preload-ping');
      const [, frameToken] = await pongPromise;
      expect(frameToken).to.equal(webFrame.frameToken);
    });
  });

  describe('RenderFrame lifespan', () => {
    let server: Awaited<ReturnType<typeof createServer>>;
    let w: BrowserWindow;

    before(async () => {
      server = await createServer();
    });
    after(() => {
      server.server.close();
    });
    beforeEach(async () => {
      w = new BrowserWindow({ show: false });
    });
    afterEach(closeAllWindows);

    // TODO(jkleinsc) fix this flaky test on linux
    ifit(process.platform !== 'linux')('throws upon accessing properties when disposed', async () => {
      await w.loadFile(path.join(subframesPath, 'frame-with-frame-container.html'));
      const { mainFrame } = w.webContents;
      w.destroy();
      // Wait for WebContents, and thus RenderFrameHost, to be destroyed.
      await setTimeout();
      expect(() => mainFrame.url).to.throw();
    });

    it('persists through cross-origin navigation', async () => {
      await w.loadURL(server.url);
      const { mainFrame } = w.webContents;
      expect(mainFrame.url).to.equal(server.url);
      await w.loadURL(server.crossOriginUrl);
      expect(w.webContents.mainFrame).to.equal(mainFrame);
      expect(mainFrame.url).to.equal(server.crossOriginUrl);
    });

    it('recovers from renderer crash on same-origin', async () => {
      // Keep reference to mainFrame alive throughout crash and recovery.
      const { mainFrame } = w.webContents;
      await w.webContents.loadURL(server.url);
      const crashEvent = once(w.webContents, 'render-process-gone');
      w.webContents.forcefullyCrashRenderer();
      await crashEvent;
      // A short wait seems to be required to reproduce the crash.
      await setTimeout(100);
      await w.webContents.loadURL(server.url);
      // Log just to keep mainFrame in scope.
      console.log('mainFrame.url', mainFrame.url);
    });

    // Fixed by #34411
    it('recovers from renderer crash on cross-origin', async () => {
      // Keep reference to mainFrame alive throughout crash and recovery.
      const { mainFrame } = w.webContents;
      await w.webContents.loadURL(server.url);
      const crashEvent = once(w.webContents, 'render-process-gone');
      w.webContents.forcefullyCrashRenderer();
      await crashEvent;
      // A short wait seems to be required to reproduce the crash.
      await setTimeout(100);
      await w.webContents.loadURL(server.crossOriginUrl);
      // Log just to keep mainFrame in scope.
      console.log('mainFrame.url', mainFrame.url);
    });

    it('returns null upon accessing senderFrame after cross-origin navigation', async () => {
      w = new BrowserWindow({
        show: false,
        webPreferences: {
          preload: path.join(subframesPath, 'preload.js')
        }
      });
      const preloadPromise = once(ipcMain, 'preload-ran');
      await w.webContents.loadURL(server.url);
      const [event] = await preloadPromise;
      await w.webContents.loadURL(server.crossOriginUrl);
      // senderFrame now points to a disposed RenderFrameHost. It should
      // be null when attempting to access the lazily evaluated property.
      waitUntil(() => {
        return event.senderFrame === null;
      });
    });

    it('is detached when unload handler sends IPC', async () => {
      w = new BrowserWindow({
        show: false,
        webPreferences: {
          preload: path.join(subframesPath, 'preload.js')
        }
      });
      await w.webContents.loadURL(server.url);
      const unloadPromise = new Promise<void>((resolve, reject) => {
        ipcMain.once('preload-unload', (event) => {
          try {
            const { senderFrame } = event;
            expect(senderFrame).to.not.be.null();
            expect(senderFrame!.detached).to.be.true();
            expect(senderFrame!.processId).to.equal(event.processId);
            resolve();
          } catch (error) {
            reject(error);
          }
        });
      });
      await w.webContents.loadURL(server.crossOriginUrl);
      await expect(unloadPromise).to.eventually.be.fulfilled();
    });

    it('disposes detached frame after cross-origin navigation', async () => {
      w = new BrowserWindow({
        show: false,
        webPreferences: {
          preload: path.join(subframesPath, 'preload.js')
        }
      });
      await w.webContents.loadURL(server.url);
      // eslint-disable-next-line prefer-const
      let crossOriginPromise: Promise<void>;
      const unloadPromise = new Promise<void>((resolve, reject) => {
        ipcMain.once('preload-unload', async (event) => {
          try {
            const { senderFrame } = event;
            expect(senderFrame!.detached).to.be.true();
            await crossOriginPromise;
            expect(() => senderFrame!.url).to.throw(/Render frame was disposed/);
            resolve();
          } catch (error) {
            reject(error);
          }
        });
      });
      crossOriginPromise = w.webContents.loadURL(server.crossOriginUrl);
      await expect(unloadPromise).to.eventually.be.fulfilled();
    });

    // Skip test as we don't have an offline repro yet
    it.skip('should not crash due to dangling frames', async () => {
      w = new BrowserWindow({
        show: false,
        webPreferences: {
          preload: path.join(subframesPath, 'preload.js')
        }
      });

      // Persist frame references so WebFrameMain is initialized for each
      const frames: Electron.WebFrameMain[] = [];
      w.webContents.on('frame-created', (_event, details) => {
        console.log('frame-created');
        frames.push(details.frame!);
      });
      w.webContents.on('will-frame-navigate', (event) => {
        console.log('will-frame-navigate', event);
        frames.push(event.frame!);
      });

      // Load document with several speculative subframes
      await w.webContents.loadURL('https://www.ezcater.com/delivery/pizza-catering');

      // Test that no frame will crash due to a dangling render frame host
      const crashTest = () => {
        for (const frame of frames) {
          expect(frame._lifecycleStateForTesting).to.not.equal('Speculative');
          try {
            expect(frame.url).to.be.a('string');
          } catch {
            // Exceptions from non-dangling frames are expected
          }
        }
      };

      crashTest();
      w.webContents.destroy();
      await setTimeout(1);
      crashTest();
    });
  });

  describe('webFrameMain.fromId', () => {
    it('returns undefined for unknown IDs', () => {
      expect(webFrameMain.fromId(0, 0)).to.be.undefined();
    });

    it('can find each frame from navigation events', async () => {
      const w = new BrowserWindow({ show: false });

      // frame-with-frame-container.html, frame-with-frame.html, frame.html
      const didFrameFinishLoad = emittedNTimes(w.webContents, 'did-frame-finish-load', 3);
      w.loadFile(path.join(subframesPath, 'frame-with-frame-container.html'));

      for (const [, isMainFrame, frameProcessId, frameRoutingId] of await didFrameFinishLoad) {
        const frame = webFrameMain.fromId(frameProcessId, frameRoutingId);
        expect(frame).not.to.be.null();
        expect(frame?.processId).to.be.equal(frameProcessId);
        expect(frame?.routingId).to.be.equal(frameRoutingId);
        expect(frame?.top === frame).to.be.equal(isMainFrame);
      }
    });
  });

  describe('webFrameMain.fromFrameToken', () => {
    it('returns null for unknown IDs', () => {
      expect(webFrameMain.fromFrameToken(0, '')).to.be.null();
    });

    it('can find existing frame', async () => {
      const w = new BrowserWindow({ show: false });
      const { mainFrame } = w.webContents;
      const frame = webFrameMain.fromFrameToken(mainFrame.processId, mainFrame.frameToken);
      expect(frame).to.equal(mainFrame);
    });
  });

  describe('webFrameMain.collectJavaScriptCallStack', () => {
    let server: Server;
    before(async () => {
      server = await createServer({
        headers: {
          'Document-Policy': 'include-js-call-stacks-in-crash-reports'
        }
      });
    });
    after(() => {
      server.server.close();
    });

    it('collects call stack during JS execution', async () => {
      const w = new BrowserWindow({ show: false });
      await w.loadURL(server.url);
      const callStackPromise = w.webContents.mainFrame.collectJavaScriptCallStack();
      w.webContents.mainFrame.executeJavaScript('"run a lil js"');
      const callStack = await callStackPromise;
      expect(callStack).to.be.a('string');
    });
  });

  describe('webFrameMain.copyVideoFrameAt', () => {
    const insertVideoInFrame = async (frame: WebFrameMain) => {
      const videoFilePath = url.pathToFileURL(path.join(fixtures, 'cat-spin.mp4')).href;
      await frame.executeJavaScript(`
        const video = document.createElement('video');
        video.src = '${videoFilePath}';
        video.muted = true;
        video.loop = true;
        video.play();
        document.body.appendChild(video);
      `);
    };

    const getFramePosition = async (frame: WebFrameMain) => {
      const point = (await frame.executeJavaScript(
        `(${() => {
          const iframe = document.querySelector('iframe');
          if (!iframe) return;
          const rect = iframe.getBoundingClientRect();
          return { x: Math.floor(rect.x), y: Math.floor(rect.y) };
        }})()`
      )) as Electron.Point;
      expect(point).to.be.an('object');
      return point;
    };

    const copyVideoFrameInFrame = async (frame: WebFrameMain) => {
      const point = (await frame.executeJavaScript(
        `(${() => {
          const video = document.querySelector('video');
          if (!video) return;
          const rect = video.getBoundingClientRect();
          return {
            x: Math.floor(rect.x + rect.width / 2),
            y: Math.floor(rect.y + rect.height / 2)
          };
        }})()`
      )) as Electron.Point;

      expect(point).to.be.an('object');

      // Translate coordinate to be relative of main frame
      if (frame.parent) {
        const framePosition = await getFramePosition(frame.parent);
        point.x += framePosition.x;
        point.y += framePosition.y;
      }

      expect(clipboard.readImage().isEmpty()).to.be.true();
      // wait for video to load
      await frame.executeJavaScript(
        `(${() => {
          const video = document.querySelector('video');
          if (!video) return;
          return new Promise((resolve) => {
            if (video.readyState >= 4) resolve(null);
            else video.addEventListener('canplaythrough', resolve, { once: true });
          });
        }})()`
      );
      frame.copyVideoFrameAt(point.x, point.y);
      await waitUntil(() => clipboard.availableFormats().includes('image/png'));
      expect(clipboard.readImage().isEmpty()).to.be.false();
    };

    beforeEach(() => {
      clipboard.clear();
    });

    // TODO: Re-enable on Windows CI once Chromium fixes the intermittent
    // backwards-time DCHECK hit while copying video frames:
    // DCHECK failed: !delta.is_negative().
    ifit(!(process.platform === 'win32' && process.env.CI))('copies video frame in main frame', async () => {
      const w = new BrowserWindow({ show: false });
      await w.webContents.loadFile(path.join(fixtures, 'blank.html'));
      await insertVideoInFrame(w.webContents.mainFrame);
      await copyVideoFrameInFrame(w.webContents.mainFrame);
      await waitUntil(() => clipboard.availableFormats().includes('image/png'));
    });

    ifit(!(process.platform === 'win32' && process.env.CI))('copies video frame in subframe', async () => {
      const w = new BrowserWindow({ show: false });
      await w.webContents.loadFile(path.join(subframesPath, 'frame-with-frame.html'));
      const subframe = w.webContents.mainFrame.frames[0];
      expect(subframe).to.exist();
      await insertVideoInFrame(subframe);
      await copyVideoFrameInFrame(subframe);
      await waitUntil(() => clipboard.availableFormats().includes('image/png'));
    });
  });

  describe('"frame-created" event', () => {
    it('emits when the main frame is created', async () => {
      const w = new BrowserWindow({ show: false });
      const promise = once(w.webContents, 'frame-created') as Promise<[any, Electron.FrameCreatedDetails]>;
      w.webContents.loadFile(path.join(subframesPath, 'frame.html'));
      const [, details] = await promise;
      expect(details.frame).to.equal(w.webContents.mainFrame);
    });

    it('emits when nested frames are created', async () => {
      const w = new BrowserWindow({ show: false });
      const promise = emittedNTimes(w.webContents, 'frame-created', 2) as Promise<
        [any, Electron.FrameCreatedDetails][]
      >;
      w.webContents.loadFile(path.join(subframesPath, 'frame-container.html'));
      const [[, mainDetails], [, nestedDetails]] = await promise;
      expect(mainDetails.frame).to.equal(w.webContents.mainFrame);
      expect(nestedDetails.frame).to.equal(w.webContents.mainFrame.frames[0]);
    });

    it('is not emitted upon cross-origin navigation', async () => {
      const server = await createServer();
      defer(() => {
        server.server.close();
      });

      const w = new BrowserWindow({ show: false });
      await w.webContents.loadURL(server.url);

      let frameCreatedEmitted = false;

      w.webContents.once('frame-created', () => {
        frameCreatedEmitted = true;
      });

      await w.webContents.loadURL(server.crossOriginUrl);

      expect(frameCreatedEmitted).to.be.false();
    });
  });

  describe('"dom-ready" event', () => {
    it('emits for top-level frame', async () => {
      const w = new BrowserWindow({ show: false });
      const promise = once(w.webContents.mainFrame, 'dom-ready');
      w.webContents.loadURL('about:blank');
      await promise;
    });

    it('emits for sub frame', async () => {
      const w = new BrowserWindow({ show: false });
      const promise = new Promise<void>((resolve) => {
        w.webContents.on('frame-created', (e, { frame }) => {
          frame!.on('dom-ready', () => {
            if (frame!.name === 'frameA') {
              resolve();
            }
          });
        });
      });
      w.webContents.loadFile(path.join(subframesPath, 'frame-with-frame.html'));
      await promise;
    });
  });
});
