// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.

import { createChannelAdapter } from "@typeagent/agent-rpc/channel";
import { ShellWindow } from "./shellWindow.js";
import type {
    BrowserControl,
    SearchProvider,
} from "browser-typeagent/agent/types";
import { createContentScriptRpcClient } from "browser-typeagent/contentScriptRpc/client";
import { app, ipcMain, net } from "electron";
import path from "node:path";
import fs from "node:fs/promises";
import { openai } from "aiclient";
import {
    indexesOfNearest,
    NormalizedEmbedding,
    SimilarityType,
    generateEmbedding,
} from "typeagent";

type InlineBrowserControl = {
    control: BrowserControl;
    close: () => void;
};
export function createInlineBrowserControl(
    shellWindow: ShellWindow,
): InlineBrowserControl {
    // Helper function to get the active browser WebContents for automation
    function getActiveBrowserWebContents() {
        const activeBrowserView = shellWindow.getActiveBrowserView();
        if (!activeBrowserView) {
            throw new Error(
                "No browser tabs are currently open. Please open a browser tab to continue.",
            );
        }
        return activeBrowserView.webContentsView.webContents;
    }
    const contentScriptRpcChannel = createChannelAdapter((message) => {
        const webContents = getActiveBrowserWebContents();
        webContents.send("inline-browser-rpc-call", message);
    });

    // Handle RPC replies from browser views
    const onReply = (_, message) => {
        // REVIEW: should verify the sender is the browser view we did the rpc call to.
        contentScriptRpcChannel.notifyMessage(message);
    };
    ipcMain.on("inline-browser-rpc-reply", onReply);

    const contentScriptControl = createContentScriptRpcClient(
        contentScriptRpcChannel.channel,
    );
    const control: BrowserControl = {
        async openWebPage(url: string, options?: { newTab?: boolean }) {
            const activeTab = shellWindow.getActiveBrowserView();
            if (options?.newTab || !activeTab) {
                await shellWindow.createBrowserTab(new URL(url), {
                    background: options?.newTab === true ? false : true,
                });
            } else {
                let resolvedUrl = new URL(url);
                if (resolvedUrl.protocol === "typeagent-browser:") {
                    resolvedUrl =
                        shellWindow.resolveCustomProtocolUrl(resolvedUrl);
                }
                activeTab.webContentsView.webContents.loadURL(
                    resolvedUrl.toString(),
                );
            }
            return Promise.resolve();
        },
        async closeWebPage() {
            // Always use multi-tab browser
            const activeBrowserView = shellWindow.getActiveBrowserView();
            if (!activeBrowserView) {
                throw new Error(
                    "No browser tabs are currently open. Please open a browser tab to continue.",
                );
            }

            if (!shellWindow.closeBrowserTab(activeBrowserView.id)) {
                throw new Error("Failed to close active browser tab.");
            }
        },
        async closeAllWebPages() {
            shellWindow.getAllBrowserTabs().forEach((tab) => {
                shellWindow.closeBrowserTab(tab.id);
            });
        },
        async switchTabs(
            tabDescription: string,
            tabIndex?: number,
        ): Promise<boolean> {
            const tabs = shellWindow.getAllBrowserTabs();

            if (tabs.length <= 1) {
                throw new Error("No other tabs to switch to!");
            }

            // if an index is specified prefer it over the description
            if (tabIndex) {
                if (tabIndex - 1 < tabs.length && tabIndex - 1 >= 0) {
                    const targetTab = tabs[tabIndex - 1];
                    shellWindow.switchBrowserTab(targetTab.id);
                    return true;
                } else {
                    throw new Error(`There is no tab with index ${tabIndex}.`);
                }
            }

            // try to get tab by description
            const ids: string[] = [];
            const score_threshold = 0.85;
            const titleEmbedding: NormalizedEmbedding[] = [];
            const urlEmbedding: NormalizedEmbedding[] = [];
            const embeddingModel = openai.createEmbeddingModel();
            const queryEmbedding = await generateEmbedding(
                embeddingModel,
                tabDescription,
            );

            for (let i = 0; i < tabs.length; i++) {
                const tab = tabs[i];
                ids.push(tab.id.toString());
                titleEmbedding.push(
                    await generateEmbedding(
                        embeddingModel,
                        tab.webContentsView.webContents.getTitle(),
                    ),
                );
                urlEmbedding.push(
                    await generateEmbedding(
                        embeddingModel,
                        tab.webContentsView.webContents.getURL(),
                    ),
                );
            }

            const topNTitle = indexesOfNearest(
                titleEmbedding,
                queryEmbedding,
                1,
                SimilarityType.Dot,
            );
            const topNUrl = indexesOfNearest(
                urlEmbedding,
                queryEmbedding,
                1,
                SimilarityType.Dot,
            );

            const idx =
                topNTitle[0].score > topNUrl[0].score
                    ? topNTitle[0].item
                    : topNUrl[0].item;
            const maxScore = Math.max(topNTitle[0].score, topNUrl[0].score);

            if (maxScore < score_threshold) {
                throw new Error(
                    `No matching tabs found for '${tabDescription}'.`,
                );
            }

            return await shellWindow.switchBrowserTab(ids[idx]);
        },
        async goForward() {
            if (!shellWindow.browserGoForward()) {
                throw new Error(
                    "Cannot go forward in browser history. No active browser tab or no forward history available.",
                );
            }
        },
        async goBack() {
            if (!shellWindow.browserGoBack()) {
                throw new Error(
                    "Cannot go back in browser history. No active browser tab or no back history available.",
                );
            }
        },
        async reload() {
            if (!shellWindow.browserReload()) {
                throw new Error(
                    "Cannot reload page. No browser tabs are currently open.",
                );
            }
        },
        async getPageUrl() {
            const webContents = getActiveBrowserWebContents();
            return webContents.getURL();
        },
        setAgentStatus(isBusy: boolean, message: string) {
            console.log(`${message} (isBusy: ${isBusy})`);
        },
        async scrollUp() {
            return contentScriptControl.scrollUp();
        },
        async scrollDown() {
            return contentScriptControl.scrollDown();
        },
        async zoomIn() {
            const url = await this.getPageUrl();
            if (url.startsWith("https://paleobiodb.org/")) {
                return contentScriptControl.runPaleoBioDbAction({
                    actionName: "zoomIn",
                });
            }
            const webContents = getActiveBrowserWebContents();
            webContents.setZoomFactor(webContents.getZoomFactor() + 0.1);
        },
        async zoomOut() {
            const url = await this.getPageUrl();
            if (url.startsWith("https://paleobiodb.org/")) {
                return contentScriptControl.runPaleoBioDbAction({
                    actionName: "zoomOut",
                });
            }
            const webContents = getActiveBrowserWebContents();
            webContents.setZoomFactor(webContents.getZoomFactor() - 0.1);
        },
        async zoomReset() {
            const webContents = getActiveBrowserWebContents();
            webContents.setZoomFactor(1.0);
        },
        async followLinkByPosition(position: number, openInNewTab?: boolean) {
            const url =
                await contentScriptControl.getPageLinksByPosition(position);
            if (url) {
                if (openInNewTab) {
                    // Create new tab for the URL
                    shellWindow.createBrowserTab(new URL(url), {
                        background: false,
                    });
                } else {
                    // Navigate current tab or create new tab if none exists
                    const activeBrowserView =
                        shellWindow.getActiveBrowserView();
                    if (activeBrowserView) {
                        activeBrowserView.webContentsView.webContents.loadURL(
                            url,
                        );
                    } else {
                        shellWindow.createBrowserTab(new URL(url), {
                            background: false,
                        });
                    }
                }
            }
            return url;
        },
        async followLinkByText(keywords: string, openInNewTab?: boolean) {
            const url =
                await contentScriptControl.getPageLinksByQuery(keywords);
            if (url) {
                if (openInNewTab) {
                    // Create new tab for the URL
                    shellWindow.createBrowserTab(new URL(url), {
                        background: false,
                    });
                } else {
                    // Navigate current tab or create new tab if none exists
                    const activeBrowserView =
                        shellWindow.getActiveBrowserView();
                    if (activeBrowserView) {
                        activeBrowserView.webContentsView.webContents.loadURL(
                            url,
                        );
                    } else {
                        shellWindow.createBrowserTab(new URL(url), {
                            background: false,
                        });
                    }
                }
            }
            return url;
        },
        async closeWindow() {
            throw new Error(
                "Closing the inline browser window is not supported.",
            );
        },
        async search(
            query: string,
            sites: string[],
            searchProvider: SearchProvider,
            options: { waitForPageLoad?: boolean; newTab?: boolean } = {},
        ): Promise<URL> {
            // append any site specific scoping
            if (sites && sites.length > 0) {
                sites.forEach((site) => {
                    query += ` site:${site}`;
                });
            }

            // craft the search URL
            const searchUrl = new URL(
                searchProvider
                    ? searchProvider.url.replace(
                          "%s",
                          encodeURIComponent(query),
                      )
                    : "https://www.bing.com/search?q=" +
                      encodeURIComponent(query),
            );

            // Always use tabs
            const activeTab = shellWindow.getActiveBrowserView();
            if (options?.newTab || !activeTab) {
                await shellWindow.createBrowserTab(searchUrl, {
                    background: false,
                    waitForPageLoad: options?.waitForPageLoad,
                });
            } else {
                activeTab.webContentsView.webContents.loadURL(
                    searchUrl.toString(),
                );
            }

            return searchUrl;
        },
        async readPageContent() {
            throw new Error("Reading page is not supported in inline browser.");
        },
        async stopReadPageContent() {
            throw new Error(
                "Stopping reading page is not supported in inline browser.",
            );
        },
        async captureScreenshot() {
            const webContents = getActiveBrowserWebContents();
            const image = await webContents.capturePage();
            return `data:image/png;base64,${image.toPNG().toString("base64")}`;
        },
        async getPageTextContent(): Promise<string> {
            const webContents = getActiveBrowserWebContents();
            return webContents.executeJavaScript("document.body.innerText");
        },
        async getAutoIndexSetting(): Promise<boolean> {
            try {
                const activeBrowserView = shellWindow.getActiveBrowserView();
                if (!activeBrowserView) {
                    return false;
                }
                const webContents =
                    activeBrowserView.webContentsView.webContents;
                const result = await webContents.executeJavaScript(`
                    (async () => {
                        try {
                            const storage = await window.electronAPI.getStorage(['autoIndexing']);
                            return storage.autoIndexing === true;
                        } catch (error) {
                            console.error('Failed to get autoIndex setting:', error);
                            return false;
                        }
                    })()
                `);

                return result;
            } catch (error) {
                console.error(
                    "Failed to get autoIndex setting from storage:",
                    error,
                );
                return false;
            }
        },
        async getBrowserSettings() {
            try {
                const activeBrowserView = shellWindow.getActiveBrowserView();
                if (!activeBrowserView) {
                    // No tabs open yet — return defaults without error
                    return {
                        autoIndexing: false,
                        extractionMode: "content",
                    };
                }
                const webContents =
                    activeBrowserView.webContentsView.webContents;
                const result = await webContents.executeJavaScript(`
                    (async () => {
                        try {
                            if (window.electronAPI) {
                                const storage = await window.electronAPI.getStorage([
                                    'autoIndexing',
                                    'extractionMode'
                                ]);

                                return {
                                    autoIndexing: storage.autoIndexing === true,
                                    extractionMode: storage.extractionMode || 'content'
                                };
                            } else {
                                console.error('electronAPI not available');
                                return {
                                    autoIndexing: false,
                                    extractionMode: 'content'
                                };
                            }
                        } catch (error) {
                            console.error('Failed to get browser settings:', error);
                            return {
                                autoIndexing: false,
                                extractionMode: 'content'
                            };
                        }
                    })()
                `);

                return result;
            } catch (error) {
                console.error(
                    "Failed to get browser settings from storage:",
                    error,
                );
                return {
                    autoIndexing: false,
                    extractionMode: "content",
                };
            }
        },
        async getHtmlFragments(
            useTimestampIds?: boolean,
            compressionMode?: string,
        ): Promise<any[]> {
            try {
                const webContents = getActiveBrowserWebContents();

                // Call the runBrowserAction function that is exposed via contextBridge in webView.ts
                const result = await webContents.executeJavaScript(`
                    (async () => {
                        try {
                            // Check if browserConnect is available (exposed via contextBridge)
                            if (window.browserConnect && typeof window.browserConnect.runBrowserAction === 'function') {
                                // Determine fullHTML based on compression mode
                                const fullHTML = ${compressionMode ? `"${compressionMode}" === "None"` : "false"};
                                // For knowledge extraction, disable text extraction since textpro will handle HTML-to-markdown conversion
                                const extractText = ${compressionMode ? `"${compressionMode}" !== "knowledgeExtraction"` : "true"};
                                const response = await window.browserConnect.runBrowserAction({
                                    actionName: "getHTML",
                                    parameters: {
                                        fullHTML: fullHTML,
                                        downloadAsFile: false,
                                        extractText: extractText,
                                        useTimestampIds: ${useTimestampIds === true}
                                    }
                                });
                                return response;
                            } else if (window.browserConnect && typeof window.browserConnect.getTabHTMLFragments === 'function') {
                                // Fallback to direct getTabHTMLFragments if available
                                const compressionModeValue = ${compressionMode ? `"${compressionMode}"` : '"automation"'};
                                const extractText = ${compressionMode ? `"${compressionMode}" !== "knowledgeExtraction"` : "true"};
                                const fragments = await window.browserConnect.getTabHTMLFragments(compressionModeValue, extractText);
                                return {
                                    message: "OK",
                                    data: fragments
                                };
                            } else {
                                throw new Error('browserConnect API with HTML fragment extraction not available in webView context');
                            }
                        } catch (error) {
                            console.error('Failed to get HTML fragments:', error);
                            throw error;
                        }
                    })()
                `);

                // Extract the data from the response format
                if (result && result.data) {
                    return Array.isArray(result.data) ? result.data : [];
                }
                return [];
            } catch (error) {
                console.error(
                    "Failed to get HTML fragments from inline browser:",
                    error,
                );
                return [];
            }
        },

        async clickOn(cssSelector: string): Promise<any> {
            return await contentScriptControl.clickOn(cssSelector);
        },

        async setDropdown(
            cssSelector: string,
            optionLabel: string,
        ): Promise<any> {
            return await contentScriptControl.setDropdown(
                cssSelector,
                optionLabel,
            );
        },

        async enterTextIn(
            textValue: string,
            cssSelector?: string,
            submitForm?: boolean,
        ): Promise<any> {
            return await contentScriptControl.enterTextIn(
                textValue,
                cssSelector,
                submitForm,
            );
        },

        async awaitPageLoad(timeout?: number): Promise<string> {
            const webContents = getActiveBrowserWebContents();

            // Wait for Electron webContents to be ready if still loading
            if (webContents.isLoading()) {
                await new Promise((resolve) => {
                    const handler = () => {
                        webContents.removeListener("did-finish-load", handler);
                        resolve(undefined);
                    };
                    webContents.on("did-finish-load", handler);
                });
            }

            // Wait for incremental content updates via contentScript
            await contentScriptControl.awaitPageLoad(timeout);

            return webContents.getURL();
        },

        async awaitPageInteraction(timeout?: number): Promise<void> {
            return await contentScriptControl.awaitPageInteraction(timeout);
        },

        async downloadImage(
            cssSelector?: string,
            imageDescription?: string,
            filename?: string,
        ): Promise<string> {
            const webContents = getActiveBrowserWebContents();

            const imageUrl: string | null =
                await webContents.executeJavaScript(`
                (function() {
                    let img = null;
                    const selector = ${JSON.stringify(cssSelector ?? null)};
                    const desc = ${JSON.stringify(imageDescription?.toLowerCase() ?? null)};
                    if (selector) {
                        const el = document.querySelector(selector);
                        img = el instanceof HTMLImageElement ? el : null;
                    } else if (desc) {
                        img = Array.from(document.querySelectorAll('img')).find(el =>
                            el.alt?.toLowerCase().includes(desc) ||
                            el.title?.toLowerCase().includes(desc)
                        ) || null;
                    }
                    if (!img) return null;
                    const src = img.currentSrc || img.src;
                    return src ? new URL(src, location.href).href : null;
                })()`);

            if (!imageUrl) {
                throw new Error(
                    cssSelector
                        ? `No image found with selector '${cssSelector}'`
                        : `No image found matching description '${imageDescription}'`,
                );
            }

            const resolvedFilename = filename ?? `image_${Date.now()}.png`;
            const filePath = path.join(
                app.getPath("downloads"),
                resolvedFilename,
            );
            const response = await net.fetch(imageUrl);
            await fs.writeFile(
                filePath,
                Buffer.from(await response.arrayBuffer()),
            );
            return filePath;
        },
        async runBrowserAction(
            actionName: string,
            _parameters: any,
            _schemaName?: string,
        ): Promise<any> {
            throw new Error(
                `runBrowserAction not implemented for inline browser: ${actionName}`,
            );
        },
    };
    return {
        control,
        close: () => {
            contentScriptRpcChannel.notifyDisconnected();
            ipcMain.removeListener("inline-browser-rpc-reply", onReply);
        },
    };
}
