From baa11e20bc899e8b28d05f7a544caedcda0aac5e Mon Sep 17 00:00:00 2001
From: Syer10 <syer10@users.noreply.github.com>
Date: Sat, 5 Aug 2023 23:03:17 -0400
Subject: [PATCH 1/9] Use Selenium as a WebView in the browser

---
 server/build.gradle.kts                       |   2 +
 .../suwayomi/tachidesk/global/GlobalAPI.kt    |   6 +
 .../global/controller/WebViewController.kt    |  46 ++++++
 .../suwayomi/tachidesk/global/impl/WebView.kt | 143 ++++++++++++++++++
 server/src/main/resources/selenium.html       |  90 +++++++++++
 5 files changed, 287 insertions(+)
 create mode 100644 server/src/main/kotlin/suwayomi/tachidesk/global/controller/WebViewController.kt
 create mode 100644 server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt
 create mode 100644 server/src/main/resources/selenium.html

diff --git a/server/build.gradle.kts b/server/build.gradle.kts
index 51e7d8d3c..5a21df51a 100644
--- a/server/build.gradle.kts
+++ b/server/build.gradle.kts
@@ -75,6 +75,8 @@ dependencies {
     implementation(libs.cron4j)
 
     implementation(libs.cronUtils)
+
+    implementation("org.seleniumhq.selenium:selenium-java:4.11.0")
 }
 
 application {
diff --git a/server/src/main/kotlin/suwayomi/tachidesk/global/GlobalAPI.kt b/server/src/main/kotlin/suwayomi/tachidesk/global/GlobalAPI.kt
index 174eb78ff..170250d5d 100644
--- a/server/src/main/kotlin/suwayomi/tachidesk/global/GlobalAPI.kt
+++ b/server/src/main/kotlin/suwayomi/tachidesk/global/GlobalAPI.kt
@@ -10,8 +10,10 @@ package suwayomi.tachidesk.global
 import io.javalin.apibuilder.ApiBuilder.get
 import io.javalin.apibuilder.ApiBuilder.patch
 import io.javalin.apibuilder.ApiBuilder.path
+import io.javalin.apibuilder.ApiBuilder.ws
 import suwayomi.tachidesk.global.controller.GlobalMetaController
 import suwayomi.tachidesk.global.controller.SettingsController
+import suwayomi.tachidesk.global.controller.WebViewController
 
 object GlobalAPI {
     fun defineEndpoints() {
@@ -23,5 +25,9 @@ object GlobalAPI {
             get("about", SettingsController.about)
             get("check-update", SettingsController.checkUpdate)
         }
+        path("webview") {
+            get("", WebViewController.webview)
+            ws("", WebViewController::webviewWS)
+        }
     }
 }
diff --git a/server/src/main/kotlin/suwayomi/tachidesk/global/controller/WebViewController.kt b/server/src/main/kotlin/suwayomi/tachidesk/global/controller/WebViewController.kt
new file mode 100644
index 000000000..fc069ad7f
--- /dev/null
+++ b/server/src/main/kotlin/suwayomi/tachidesk/global/controller/WebViewController.kt
@@ -0,0 +1,46 @@
+package suwayomi.tachidesk.global.controller
+
+/*
+ * Copyright (C) Contributors to the Suwayomi project
+ *
+ * This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at https://mozilla.org/MPL/2.0/. */
+
+import io.javalin.http.ContentType
+import io.javalin.http.HttpCode
+import io.javalin.websocket.WsConfig
+import suwayomi.tachidesk.global.impl.WebView
+import suwayomi.tachidesk.server.util.handler
+import suwayomi.tachidesk.server.util.withOperation
+
+object WebViewController {
+    /** returns some static info about the current app build */
+    val webview = handler(
+        documentWith = {
+            withOperation {
+                summary("WebView")
+                description("Opens and browses WebView")
+            }
+        },
+        behaviorOf = { ctx ->
+            ctx.contentType(ContentType.TEXT_HTML)
+            ctx.result(javaClass.getResourceAsStream("/selenium.html")!!)
+        },
+        withResults = {
+            mime<String>(HttpCode.OK, "text/html")
+        }
+    )
+
+    fun webviewWS(ws: WsConfig) {
+        ws.onConnect { ctx ->
+            WebView.addClient(ctx)
+        }
+        ws.onMessage { ctx ->
+            WebView.handleRequest(ctx)
+        }
+        ws.onClose { ctx ->
+            WebView.removeClient(ctx)
+        }
+    }
+}
diff --git a/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt b/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt
new file mode 100644
index 000000000..c9c15fa43
--- /dev/null
+++ b/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt
@@ -0,0 +1,143 @@
+package suwayomi.tachidesk.global.impl
+
+import io.javalin.websocket.WsContext
+import io.javalin.websocket.WsMessageContext
+import kotlinx.coroutines.GlobalScope
+import kotlinx.coroutines.asCoroutineDispatcher
+import kotlinx.coroutines.cancel
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.isActive
+import kotlinx.coroutines.launch
+import kotlinx.serialization.SerialName
+import kotlinx.serialization.Serializable
+import kotlinx.serialization.json.Json
+import kotlinx.serialization.json.JsonObject
+import kotlinx.serialization.json.double
+import kotlinx.serialization.json.jsonPrimitive
+import org.eclipse.jetty.websocket.api.CloseStatus
+import org.openqa.selenium.By
+import org.openqa.selenium.Dimension
+import org.openqa.selenium.OutputType
+import org.openqa.selenium.TakesScreenshot
+import org.openqa.selenium.WebDriver
+import org.openqa.selenium.chrome.ChromeDriver
+import org.openqa.selenium.interactions.Actions
+import suwayomi.tachidesk.manga.impl.update.Websocket
+import uy.kohesive.injekt.injectLazy
+import java.io.Closeable
+import java.util.concurrent.Executors
+
+@Serializable
+sealed class WebViewEvent {
+    @SerialName("click")
+    data class Click(
+        val x: Int,
+        val y: Int
+    ) : WebViewEvent()
+
+    @SerialName("keypress")
+    data class KeyPress(
+        val key: String
+    ) : WebViewEvent()
+}
+
+object WebView : Websocket<String>() {
+    val json: Json by injectLazy()
+
+    var driver: SeleniumScreenshotServer? = null
+
+    override fun addClient(ctx: WsContext) {
+        if (clients.isNotEmpty()) {
+            clients.forEach {
+                it.value.closeSession(CloseStatus(1001, "Other client connected"))
+            }
+            clients.clear()
+        } else {
+            driver = SeleniumScreenshotServer()
+        }
+        super.addClient(ctx)
+    }
+
+    override fun removeClient(ctx: WsContext) {
+        super.removeClient(ctx)
+        if (clients.isEmpty()) {
+            driver?.close()
+            driver = null
+        }
+    }
+
+    override fun notifyClient(ctx: WsContext, value: String?) {
+        if (value != null) {
+            ctx.send(value)
+        }
+    }
+
+    override fun handleRequest(ctx: WsMessageContext) {
+        try {
+            val event = json.decodeFromString<JsonObject>(ctx.message())
+            driver?.handleEvent(event)
+        } catch (e: Exception) {
+            e.printStackTrace()
+        }
+    }
+}
+
+class SeleniumScreenshotServer : Closeable {
+    companion object {
+        const val width = 1200
+        const val height = 800
+    }
+
+    private val driver: WebDriver = ChromeDriver()
+    init {
+        driver.manage().window().size = Dimension(width, height)
+        driver.get("https://google.com")
+    }
+    private val actions = Actions(driver)
+    private val executor = Executors.newSingleThreadExecutor().asCoroutineDispatcher()
+
+    init {
+        GlobalScope.launch(executor) {
+            try {
+                while (isActive) {
+                    // Capture screenshot
+                    val screenshot =
+                        (driver as TakesScreenshot).getScreenshotAs(OutputType.BASE64)
+
+                    // Send image data over the socket
+                    WebView.notifyAllClients(screenshot)
+                    delay(1000) // Adjust interval as needed
+                }
+            } catch (e: Exception) {
+            }
+        }
+    }
+
+    fun handleEvent(jsonObject: JsonObject) {
+        when (jsonObject["type"]!!.jsonPrimitive.content) {
+            "click" -> {
+                val element = driver.findElement(By.tagName("body"))
+                val x = jsonObject["x"]!!.jsonPrimitive.double.toInt()
+                val y = jsonObject["y"]!!.jsonPrimitive.double.toInt()
+                if (x in 0..width && y in 0..height) {
+                    actions.moveToLocation(x, y).click().perform()
+                }
+            }
+            "keypress" -> {
+                val key = jsonObject["key"]!!.jsonPrimitive.content
+                actions.keyDown(key).keyUp(key)
+            }
+            "back" -> {
+                driver.navigate().back()
+            }
+            "forward" -> {
+                driver.navigate().forward()
+            }
+        }
+    }
+
+    override fun close() {
+        driver.close()
+        executor.cancel()
+    }
+}
diff --git a/server/src/main/resources/selenium.html b/server/src/main/resources/selenium.html
new file mode 100644
index 000000000..a450c20d1
--- /dev/null
+++ b/server/src/main/resources/selenium.html
@@ -0,0 +1,90 @@
+<!DOCTYPE html>
+<html lang="en">
+<head>
+    <title>WebSocket Stream with Click Events</title>
+    <style>
+        body {
+            display: flex;
+            justify-content: center;
+            align-items: center;
+            height: 100vh;
+            margin: 0;
+        }
+        #controls {
+            display: flex;
+            gap: 10px;
+            margin-bottom: 10px;
+        }
+        #streamContainer {
+            text-align: center;
+        }
+    </style>
+</head>
+<body>
+<div id="controls">
+    <button id="backButton">Back</button>
+    <button id="forwardButton">Forward</button>
+</div>
+<div id="streamContainer"></div>
+
+<script>
+    const streamContainer = document.getElementById('streamContainer');
+    const backButton = document.getElementById('backButton');
+    const forwardButton = document.getElementById('forwardButton');
+    const socket = new WebSocket(window.location.href.replace(/^http/,'ws'));
+
+    socket.onopen = () => {
+        console.log('WebSocket connection opened');
+    };
+
+    socket.onmessage = (event) => {
+        const imageData = event.data; // Assuming you're sending image data as binary
+        const img = new Image();
+        img.src = 'data:image/jpeg;base64,' + imageData; // Display the image data
+        streamContainer.innerHTML = ''; // Clear previous content
+        streamContainer.appendChild(img);
+    };
+
+    socket.onclose = (event) => {
+        if (event.wasClean) {
+            console.log(`WebSocket connection closed cleanly, code=${event.code}, reason=${event.reason}`);
+        } else {
+            console.error('WebSocket connection died');
+        }
+    };
+
+    socket.onerror = (error) => {
+        console.error('WebSocket error:', error);
+    };
+
+    // Handle click events
+    streamContainer.addEventListener('click', (event) => {
+        const rect = streamContainer.getBoundingClientRect();
+        const clickX = event.clientX - rect.left;
+        const clickY = event.clientY - rect.top;
+
+        // Send click coordinates to the server
+        socket.send(JSON.stringify({ type: 'click', x: clickX, y: clickY }));
+    });
+
+    // Handle keyboard events
+    document.addEventListener('keydown', (event) => {
+        const key = event.key;
+
+        event.preventDefault();
+
+        // Send key press event to the server
+        socket.send(JSON.stringify({ type: 'keypress', key: key }));
+    });
+
+    // Handle button clicks
+    backButton.addEventListener('click', () => {
+        socket.send(JSON.stringify({ type: 'back' }));
+    });
+
+    forwardButton.addEventListener('click', () => {
+        socket.send(JSON.stringify({ type: 'forward' }));
+    });
+</script>
+</body>
+</html>

From ae55d313ca76861ecc9a6669090c5aede54f95ca Mon Sep 17 00:00:00 2001
From: Syer10 <syer10@users.noreply.github.com>
Date: Sun, 6 Aug 2023 00:20:06 -0400
Subject: [PATCH 2/9] Get basic key input working

---
 .../kotlin/suwayomi/tachidesk/global/impl/WebView.kt | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

diff --git a/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt b/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt
index c9c15fa43..384b63892 100644
--- a/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt
+++ b/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt
@@ -17,6 +17,7 @@ import kotlinx.serialization.json.jsonPrimitive
 import org.eclipse.jetty.websocket.api.CloseStatus
 import org.openqa.selenium.By
 import org.openqa.selenium.Dimension
+import org.openqa.selenium.Keys
 import org.openqa.selenium.OutputType
 import org.openqa.selenium.TakesScreenshot
 import org.openqa.selenium.WebDriver
@@ -93,7 +94,6 @@ class SeleniumScreenshotServer : Closeable {
         driver.manage().window().size = Dimension(width, height)
         driver.get("https://google.com")
     }
-    private val actions = Actions(driver)
     private val executor = Executors.newSingleThreadExecutor().asCoroutineDispatcher()
 
     init {
@@ -120,12 +120,18 @@ class SeleniumScreenshotServer : Closeable {
                 val x = jsonObject["x"]!!.jsonPrimitive.double.toInt()
                 val y = jsonObject["y"]!!.jsonPrimitive.double.toInt()
                 if (x in 0..width && y in 0..height) {
-                    actions.moveToLocation(x, y).click().perform()
+                    Actions(driver).moveToLocation(x, y).click().perform()
                 }
             }
             "keypress" -> {
                 val key = jsonObject["key"]!!.jsonPrimitive.content
-                actions.keyDown(key).keyUp(key)
+                val keys: CharSequence = when (key) {
+                    "Backspace" -> Keys.BACK_SPACE
+                    "Tab" -> Keys.TAB
+                    "Enter" -> Keys.ENTER
+                    else -> key
+                }
+                Actions(driver).keyDown(keys).keyUp(keys).perform()
             }
             "back" -> {
                 driver.navigate().back()

From ee8fe560b478d03521889fbafee9dd8e77b7ac7d Mon Sep 17 00:00:00 2001
From: Syer10 <syer10@users.noreply.github.com>
Date: Sun, 6 Aug 2023 00:27:53 -0400
Subject: [PATCH 3/9] Make webview headless

---
 .../suwayomi/tachidesk/global/impl/WebView.kt     | 15 ++++++++++-----
 1 file changed, 10 insertions(+), 5 deletions(-)

diff --git a/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt b/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt
index 384b63892..539dbc97b 100644
--- a/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt
+++ b/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt
@@ -22,6 +22,7 @@ import org.openqa.selenium.OutputType
 import org.openqa.selenium.TakesScreenshot
 import org.openqa.selenium.WebDriver
 import org.openqa.selenium.chrome.ChromeDriver
+import org.openqa.selenium.chrome.ChromeOptions
 import org.openqa.selenium.interactions.Actions
 import suwayomi.tachidesk.manga.impl.update.Websocket
 import uy.kohesive.injekt.injectLazy
@@ -89,7 +90,11 @@ class SeleniumScreenshotServer : Closeable {
         const val height = 800
     }
 
-    private val driver: WebDriver = ChromeDriver()
+    private val driver: WebDriver = run {
+        val options = ChromeOptions()
+        options.addArguments("--headless")
+        ChromeDriver(options)
+    }
     init {
         driver.manage().window().size = Dimension(width, height)
         driver.get("https://google.com")
@@ -98,17 +103,17 @@ class SeleniumScreenshotServer : Closeable {
 
     init {
         GlobalScope.launch(executor) {
-            try {
-                while (isActive) {
+            while (isActive) {
+                try {
                     // Capture screenshot
                     val screenshot =
                         (driver as TakesScreenshot).getScreenshotAs(OutputType.BASE64)
-
                     // Send image data over the socket
                     WebView.notifyAllClients(screenshot)
                     delay(1000) // Adjust interval as needed
+                } catch (e: Exception) {
+                    e.printStackTrace()
                 }
-            } catch (e: Exception) {
             }
         }
     }

From e0085f1d76ee42360f6e6375323fd0c57373fb2d Mon Sep 17 00:00:00 2001
From: Syer10 <syer10@users.noreply.github.com>
Date: Sun, 6 Aug 2023 11:24:17 -0400
Subject: [PATCH 4/9] Open source, manga, or chapter in webview

---
 .../suwayomi/tachidesk/global/impl/WebView.kt | 41 +++++++++++--------
 server/src/main/resources/selenium.html       | 14 +++++++
 2 files changed, 37 insertions(+), 18 deletions(-)

diff --git a/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt b/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt
index 539dbc97b..4de0dcb13 100644
--- a/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt
+++ b/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt
@@ -1,5 +1,6 @@
 package suwayomi.tachidesk.global.impl
 
+import eu.kanade.tachiyomi.source.online.HttpSource
 import io.javalin.websocket.WsContext
 import io.javalin.websocket.WsMessageContext
 import kotlinx.coroutines.GlobalScope
@@ -8,14 +9,15 @@ import kotlinx.coroutines.cancel
 import kotlinx.coroutines.delay
 import kotlinx.coroutines.isActive
 import kotlinx.coroutines.launch
-import kotlinx.serialization.SerialName
-import kotlinx.serialization.Serializable
 import kotlinx.serialization.json.Json
 import kotlinx.serialization.json.JsonObject
 import kotlinx.serialization.json.double
+import kotlinx.serialization.json.intOrNull
 import kotlinx.serialization.json.jsonPrimitive
+import kotlinx.serialization.json.longOrNull
 import org.eclipse.jetty.websocket.api.CloseStatus
-import org.openqa.selenium.By
+import org.jetbrains.exposed.sql.select
+import org.jetbrains.exposed.sql.transactions.transaction
 import org.openqa.selenium.Dimension
 import org.openqa.selenium.Keys
 import org.openqa.selenium.OutputType
@@ -25,24 +27,13 @@ import org.openqa.selenium.chrome.ChromeDriver
 import org.openqa.selenium.chrome.ChromeOptions
 import org.openqa.selenium.interactions.Actions
 import suwayomi.tachidesk.manga.impl.update.Websocket
+import suwayomi.tachidesk.manga.impl.util.source.GetCatalogueSource.getCatalogueSourceOrNull
+import suwayomi.tachidesk.manga.model.table.ChapterTable
+import suwayomi.tachidesk.manga.model.table.MangaTable
 import uy.kohesive.injekt.injectLazy
 import java.io.Closeable
 import java.util.concurrent.Executors
 
-@Serializable
-sealed class WebViewEvent {
-    @SerialName("click")
-    data class Click(
-        val x: Int,
-        val y: Int
-    ) : WebViewEvent()
-
-    @SerialName("keypress")
-    data class KeyPress(
-        val key: String
-    ) : WebViewEvent()
-}
-
 object WebView : Websocket<String>() {
     val json: Json by injectLazy()
 
@@ -121,7 +112,6 @@ class SeleniumScreenshotServer : Closeable {
     fun handleEvent(jsonObject: JsonObject) {
         when (jsonObject["type"]!!.jsonPrimitive.content) {
             "click" -> {
-                val element = driver.findElement(By.tagName("body"))
                 val x = jsonObject["x"]!!.jsonPrimitive.double.toInt()
                 val y = jsonObject["y"]!!.jsonPrimitive.double.toInt()
                 if (x in 0..width && y in 0..height) {
@@ -144,6 +134,21 @@ class SeleniumScreenshotServer : Closeable {
             "forward" -> {
                 driver.navigate().forward()
             }
+            "loadsource" -> {
+                val sourceId = jsonObject["source"]!!.jsonPrimitive.longOrNull ?: return
+                val source = getCatalogueSourceOrNull(sourceId) as? HttpSource ?: return
+                driver.get(source.baseUrl)
+            }
+            "loadmanga" -> {
+                val mangaId = jsonObject["manga"]!!.jsonPrimitive.intOrNull ?: return
+                val manga = transaction { MangaTable.select { MangaTable.id eq mangaId }.firstOrNull() } ?: return
+                driver.get(manga[MangaTable.realUrl] ?: return)
+            }
+            "loadchapter" -> {
+                val chapterId = jsonObject["chapter"]!!.jsonPrimitive.intOrNull ?: return
+                val chapter = transaction { ChapterTable.select { ChapterTable.id eq chapterId }.firstOrNull() } ?: return
+                driver.get(chapter[ChapterTable.realUrl] ?: return)
+            }
         }
     }
 
diff --git a/server/src/main/resources/selenium.html b/server/src/main/resources/selenium.html
index a450c20d1..3b40fc7fb 100644
--- a/server/src/main/resources/selenium.html
+++ b/server/src/main/resources/selenium.html
@@ -33,7 +33,21 @@
     const forwardButton = document.getElementById('forwardButton');
     const socket = new WebSocket(window.location.href.replace(/^http/,'ws'));
 
+    // Read the 'source' query parameter from the URL
+    const queryParams = new URLSearchParams(window.location.search);
+    const source = queryParams.get('source');
+    const manga = queryParams.get('manga');
+    const chapter = queryParams.get('chapter');
+
     socket.onopen = () => {
+        if (source !== undefined && source !== null) {
+            socket.send(JSON.stringify({ type: 'loadsource', source: source }));
+        } else if (manga !== undefined && manga !== null) {
+            socket.send(JSON.stringify({ type: 'loadmanga', manga: manga }));
+        } else if (chapter !== undefined && chapter !== null) {
+            socket.send(JSON.stringify({ type: 'loadchapter', chapter: chapter }));
+        }
+
         console.log('WebSocket connection opened');
     };
 

From 27e047e8572da70ac1520d90df4f05e47697b872 Mon Sep 17 00:00:00 2001
From: Syer10 <syer10@users.noreply.github.com>
Date: Sun, 6 Aug 2023 12:22:39 -0400
Subject: [PATCH 5/9] Put back and forward on top

---
 server/src/main/resources/selenium.html | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/server/src/main/resources/selenium.html b/server/src/main/resources/selenium.html
index 3b40fc7fb..830af752c 100644
--- a/server/src/main/resources/selenium.html
+++ b/server/src/main/resources/selenium.html
@@ -5,8 +5,9 @@
     <style>
         body {
             display: flex;
-            justify-content: center;
+            flex-direction: column;
             align-items: center;
+            justify-content: center;
             height: 100vh;
             margin: 0;
         }

From 76a220e55ad310f180985113223986ed8dc18116 Mon Sep 17 00:00:00 2001
From: Syer10 <syer10@users.noreply.github.com>
Date: Sun, 6 Aug 2023 12:23:49 -0400
Subject: [PATCH 6/9] Properly close the driver

---
 .../suwayomi/tachidesk/global/impl/WebView.kt     | 15 +++++++++++++--
 1 file changed, 13 insertions(+), 2 deletions(-)

diff --git a/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt b/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt
index 4de0dcb13..b8b29a6fb 100644
--- a/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt
+++ b/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt
@@ -37,7 +37,7 @@ import java.util.concurrent.Executors
 object WebView : Websocket<String>() {
     val json: Json by injectLazy()
 
-    var driver: SeleniumScreenshotServer? = null
+    private var driver: SeleniumScreenshotServer? = null
 
     override fun addClient(ctx: WsContext) {
         if (clients.isNotEmpty()) {
@@ -102,6 +102,10 @@ class SeleniumScreenshotServer : Closeable {
                     // Send image data over the socket
                     WebView.notifyAllClients(screenshot)
                     delay(1000) // Adjust interval as needed
+                } catch (e: NoSuchSessionException) {
+                    ensureActive()
+                } catch (e: CancellationException) {
+                    throw e
                 } catch (e: Exception) {
                     e.printStackTrace()
                 }
@@ -153,7 +157,14 @@ class SeleniumScreenshotServer : Closeable {
     }
 
     override fun close() {
-        driver.close()
         executor.cancel()
+        try {
+            driver.quit()
+        } catch (_: Exception) {
+        }
+        try {
+            driver.close()
+        } catch (_: Exception) {
+        }
     }
 }

From 74416e0223a6194d3ef0a45951fba995a54572c9 Mon Sep 17 00:00:00 2001
From: Syer10 <syer10@users.noreply.github.com>
Date: Sun, 6 Aug 2023 12:24:10 -0400
Subject: [PATCH 7/9] Sync cookies

---
 .../suwayomi/tachidesk/global/impl/WebView.kt | 75 ++++++++++++++++++-
 1 file changed, 71 insertions(+), 4 deletions(-)

diff --git a/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt b/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt
index b8b29a6fb..7d9bea82a 100644
--- a/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt
+++ b/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt
@@ -1,12 +1,16 @@
 package suwayomi.tachidesk.global.impl
 
+import eu.kanade.tachiyomi.network.NetworkHelper
 import eu.kanade.tachiyomi.source.online.HttpSource
 import io.javalin.websocket.WsContext
 import io.javalin.websocket.WsMessageContext
+import kotlinx.coroutines.CancellationException
 import kotlinx.coroutines.GlobalScope
+import kotlinx.coroutines.SupervisorJob
 import kotlinx.coroutines.asCoroutineDispatcher
 import kotlinx.coroutines.cancel
 import kotlinx.coroutines.delay
+import kotlinx.coroutines.ensureActive
 import kotlinx.coroutines.isActive
 import kotlinx.coroutines.launch
 import kotlinx.serialization.json.Json
@@ -18,8 +22,10 @@ import kotlinx.serialization.json.longOrNull
 import org.eclipse.jetty.websocket.api.CloseStatus
 import org.jetbrains.exposed.sql.select
 import org.jetbrains.exposed.sql.transactions.transaction
+import org.openqa.selenium.Cookie
 import org.openqa.selenium.Dimension
 import org.openqa.selenium.Keys
+import org.openqa.selenium.NoSuchSessionException
 import org.openqa.selenium.OutputType
 import org.openqa.selenium.TakesScreenshot
 import org.openqa.selenium.WebDriver
@@ -32,7 +38,12 @@ import suwayomi.tachidesk.manga.model.table.ChapterTable
 import suwayomi.tachidesk.manga.model.table.MangaTable
 import uy.kohesive.injekt.injectLazy
 import java.io.Closeable
+import java.net.HttpCookie
+import java.net.URI
+import java.util.Date
 import java.util.concurrent.Executors
+import kotlin.time.Duration.Companion.milliseconds
+import kotlin.time.Duration.Companion.seconds
 
 object WebView : Websocket<String>() {
     val json: Json by injectLazy()
@@ -79,6 +90,8 @@ class SeleniumScreenshotServer : Closeable {
     companion object {
         const val width = 1200
         const val height = 800
+
+        private val networkHelper: NetworkHelper by injectLazy()
     }
 
     private val driver: WebDriver = run {
@@ -88,8 +101,9 @@ class SeleniumScreenshotServer : Closeable {
     }
     init {
         driver.manage().window().size = Dimension(width, height)
-        driver.get("https://google.com")
+        driver.navigate().to("https://google.com")
     }
+    private val job = SupervisorJob()
     private val executor = Executors.newSingleThreadExecutor().asCoroutineDispatcher()
 
     init {
@@ -111,6 +125,12 @@ class SeleniumScreenshotServer : Closeable {
                 }
             }
         }
+        GlobalScope.launch(job) {
+            while (true) {
+                delay(5.seconds)
+                flush()
+            }
+        }
     }
 
     fun handleEvent(jsonObject: JsonObject) {
@@ -141,22 +161,30 @@ class SeleniumScreenshotServer : Closeable {
             "loadsource" -> {
                 val sourceId = jsonObject["source"]!!.jsonPrimitive.longOrNull ?: return
                 val source = getCatalogueSourceOrNull(sourceId) as? HttpSource ?: return
-                driver.get(source.baseUrl)
+                driver.navigate().to(source.baseUrl)
+                addCookiesFor(driver.currentUrl)
+                driver.navigate().refresh()
             }
             "loadmanga" -> {
                 val mangaId = jsonObject["manga"]!!.jsonPrimitive.intOrNull ?: return
                 val manga = transaction { MangaTable.select { MangaTable.id eq mangaId }.firstOrNull() } ?: return
-                driver.get(manga[MangaTable.realUrl] ?: return)
+                driver.navigate().to(manga[MangaTable.realUrl] ?: return)
+                addCookiesFor(driver.currentUrl)
+                driver.navigate().refresh()
             }
             "loadchapter" -> {
                 val chapterId = jsonObject["chapter"]!!.jsonPrimitive.intOrNull ?: return
                 val chapter = transaction { ChapterTable.select { ChapterTable.id eq chapterId }.firstOrNull() } ?: return
-                driver.get(chapter[ChapterTable.realUrl] ?: return)
+                driver.navigate().to(chapter[ChapterTable.realUrl] ?: return)
+                addCookiesFor(driver.currentUrl)
+                driver.navigate().refresh()
             }
         }
     }
 
     override fun close() {
+        job.cancel()
+        flush()
         executor.cancel()
         try {
             driver.quit()
@@ -167,4 +195,43 @@ class SeleniumScreenshotServer : Closeable {
         } catch (_: Exception) {
         }
     }
+
+    private fun flush() {
+        driver.manage().cookies.forEach {
+            networkHelper.cookieStore.add(
+                URI("http://" + it.domain),
+                HttpCookie(it.name, it.value).apply {
+                    path = it.path
+                    domain = it.domain
+                    maxAge = if (it.expiry == null) {
+                        -1
+                    } else {
+                        (it.expiry.time.milliseconds - System.currentTimeMillis().milliseconds).inWholeSeconds
+                    }
+                    isHttpOnly = it.isHttpOnly
+                    secure = it.isSecure
+                }
+            )
+        }
+    }
+
+    private fun addCookiesFor(uri: String) {
+        networkHelper.cookieStore.get(URI(uri)).forEach {
+            driver.manage().addCookie(
+                Cookie(
+                    it.name,
+                    it.value,
+                    it.domain,
+                    it.path,
+                    if (it.maxAge == -1L) {
+                        null
+                    } else {
+                        Date(System.currentTimeMillis() + it.maxAge.seconds.inWholeMilliseconds)
+                    },
+                    it.secure,
+                    it.isHttpOnly
+                )
+            )
+        }
+    }
 }

From dc95ce4f6ff77819794adf3a68573cac2b44bdc9 Mon Sep 17 00:00:00 2001
From: Syer10 <syer10@users.noreply.github.com>
Date: Mon, 7 Aug 2023 00:01:25 -0400
Subject: [PATCH 8/9] Add playwright screenshot server

---
 .../interceptor/CloudflareInterceptor.kt      |   2 +-
 .../suwayomi/tachidesk/global/impl/WebView.kt | 281 ++++++++++++++----
 2 files changed, 230 insertions(+), 53 deletions(-)

diff --git a/server/src/main/kotlin/eu/kanade/tachiyomi/network/interceptor/CloudflareInterceptor.kt b/server/src/main/kotlin/eu/kanade/tachiyomi/network/interceptor/CloudflareInterceptor.kt
index 9960720de..4036106fb 100644
--- a/server/src/main/kotlin/eu/kanade/tachiyomi/network/interceptor/CloudflareInterceptor.kt
+++ b/server/src/main/kotlin/eu/kanade/tachiyomi/network/interceptor/CloudflareInterceptor.kt
@@ -204,7 +204,7 @@ object CFClearance {
     }
 
     // ref: https://github.com/vvanglro/cf-clearance/blob/44124a8f06d8d0ecf2bf558a027082ff88dab435/cf_clearance/stealth.py#L76
-    private fun applyStealthInitScripts(page: Page) {
+    fun applyStealthInitScripts(page: Page) {
         for (script in stealthInitScripts) {
             page.addInitScript(script)
         }
diff --git a/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt b/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt
index 7d9bea82a..26f6c04e7 100644
--- a/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt
+++ b/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt
@@ -1,10 +1,16 @@
 package suwayomi.tachidesk.global.impl
 
+import com.microsoft.playwright.Browser
+import com.microsoft.playwright.BrowserType
+import com.microsoft.playwright.Playwright
+import com.microsoft.playwright.options.ScreenSize
 import eu.kanade.tachiyomi.network.NetworkHelper
+import eu.kanade.tachiyomi.network.interceptor.CFClearance
 import eu.kanade.tachiyomi.source.online.HttpSource
 import io.javalin.websocket.WsContext
 import io.javalin.websocket.WsMessageContext
 import kotlinx.coroutines.CancellationException
+import kotlinx.coroutines.CompletableDeferred
 import kotlinx.coroutines.GlobalScope
 import kotlinx.coroutines.SupervisorJob
 import kotlinx.coroutines.asCoroutineDispatcher
@@ -23,7 +29,6 @@ import org.eclipse.jetty.websocket.api.CloseStatus
 import org.jetbrains.exposed.sql.select
 import org.jetbrains.exposed.sql.transactions.transaction
 import org.openqa.selenium.Cookie
-import org.openqa.selenium.Dimension
 import org.openqa.selenium.Keys
 import org.openqa.selenium.NoSuchSessionException
 import org.openqa.selenium.OutputType
@@ -42,13 +47,15 @@ import java.net.HttpCookie
 import java.net.URI
 import java.util.Date
 import java.util.concurrent.Executors
+import kotlin.io.encoding.Base64
+import kotlin.io.encoding.ExperimentalEncodingApi
 import kotlin.time.Duration.Companion.milliseconds
 import kotlin.time.Duration.Companion.seconds
 
 object WebView : Websocket<String>() {
     val json: Json by injectLazy()
 
-    private var driver: SeleniumScreenshotServer? = null
+    private var driver: ScreenShotWebViewEventListener? = null
 
     override fun addClient(ctx: WsContext) {
         if (clients.isNotEmpty()) {
@@ -57,7 +64,7 @@ object WebView : Websocket<String>() {
             }
             clients.clear()
         } else {
-            driver = SeleniumScreenshotServer()
+            driver = PlaywrightScreenshotServer() // SeleniumScreenshotServer()
         }
         super.addClient(ctx)
     }
@@ -86,7 +93,54 @@ object WebView : Websocket<String>() {
     }
 }
 
-class SeleniumScreenshotServer : Closeable {
+interface ScreenShotWebViewEventListener : Closeable {
+    fun handleEvent(jsonObject: JsonObject) {
+        when (jsonObject["type"]!!.jsonPrimitive.content) {
+            "click" -> {
+                val x = jsonObject["x"]!!.jsonPrimitive.double.toInt()
+                val y = jsonObject["y"]!!.jsonPrimitive.double.toInt()
+                onClick(x, y)
+            }
+            "keypress" -> {
+                val key = jsonObject["key"]!!.jsonPrimitive.content
+                keyPress(key)
+            }
+            "back" -> {
+                back()
+            }
+            "forward" -> {
+                forward()
+            }
+            "loadsource" -> {
+                val sourceId = jsonObject["source"]!!.jsonPrimitive.longOrNull ?: return
+                val source = getCatalogueSourceOrNull(sourceId) as? HttpSource ?: return
+                loadUrl(source.baseUrl)
+            }
+            "loadmanga" -> {
+                val mangaId = jsonObject["manga"]!!.jsonPrimitive.intOrNull ?: return
+                val manga = transaction { MangaTable.select { MangaTable.id eq mangaId }.firstOrNull() } ?: return
+                loadUrl(manga[MangaTable.realUrl] ?: return)
+            }
+            "loadchapter" -> {
+                val chapterId = jsonObject["chapter"]!!.jsonPrimitive.intOrNull ?: return
+                val chapter = transaction { ChapterTable.select { ChapterTable.id eq chapterId }.firstOrNull() } ?: return
+                loadUrl(chapter[ChapterTable.realUrl] ?: return)
+            }
+        }
+    }
+
+    fun onClick(x: Int, y: Int)
+
+    fun keyPress(key: String)
+
+    fun back()
+
+    fun forward()
+
+    fun loadUrl(url: String)
+}
+
+class SeleniumScreenshotServer : Closeable, ScreenShotWebViewEventListener {
     companion object {
         const val width = 1200
         const val height = 800
@@ -96,11 +150,17 @@ class SeleniumScreenshotServer : Closeable {
 
     private val driver: WebDriver = run {
         val options = ChromeOptions()
-        options.addArguments("--headless")
+        options.addArguments(
+            "--headless",
+            "--no-default-browser-check",
+            "--no-first-run",
+            "--no-sandbox",
+            "--test-type",
+            "--window-size=$width,$height"
+        )
         ChromeDriver(options)
     }
     init {
-        driver.manage().window().size = Dimension(width, height)
         driver.navigate().to("https://google.com")
     }
     private val job = SupervisorJob()
@@ -133,55 +193,36 @@ class SeleniumScreenshotServer : Closeable {
         }
     }
 
-    fun handleEvent(jsonObject: JsonObject) {
-        when (jsonObject["type"]!!.jsonPrimitive.content) {
-            "click" -> {
-                val x = jsonObject["x"]!!.jsonPrimitive.double.toInt()
-                val y = jsonObject["y"]!!.jsonPrimitive.double.toInt()
-                if (x in 0..width && y in 0..height) {
-                    Actions(driver).moveToLocation(x, y).click().perform()
-                }
-            }
-            "keypress" -> {
-                val key = jsonObject["key"]!!.jsonPrimitive.content
-                val keys: CharSequence = when (key) {
-                    "Backspace" -> Keys.BACK_SPACE
-                    "Tab" -> Keys.TAB
-                    "Enter" -> Keys.ENTER
-                    else -> key
-                }
-                Actions(driver).keyDown(keys).keyUp(keys).perform()
-            }
-            "back" -> {
-                driver.navigate().back()
-            }
-            "forward" -> {
-                driver.navigate().forward()
-            }
-            "loadsource" -> {
-                val sourceId = jsonObject["source"]!!.jsonPrimitive.longOrNull ?: return
-                val source = getCatalogueSourceOrNull(sourceId) as? HttpSource ?: return
-                driver.navigate().to(source.baseUrl)
-                addCookiesFor(driver.currentUrl)
-                driver.navigate().refresh()
-            }
-            "loadmanga" -> {
-                val mangaId = jsonObject["manga"]!!.jsonPrimitive.intOrNull ?: return
-                val manga = transaction { MangaTable.select { MangaTable.id eq mangaId }.firstOrNull() } ?: return
-                driver.navigate().to(manga[MangaTable.realUrl] ?: return)
-                addCookiesFor(driver.currentUrl)
-                driver.navigate().refresh()
-            }
-            "loadchapter" -> {
-                val chapterId = jsonObject["chapter"]!!.jsonPrimitive.intOrNull ?: return
-                val chapter = transaction { ChapterTable.select { ChapterTable.id eq chapterId }.firstOrNull() } ?: return
-                driver.navigate().to(chapter[ChapterTable.realUrl] ?: return)
-                addCookiesFor(driver.currentUrl)
-                driver.navigate().refresh()
-            }
+    override fun onClick(x: Int, y: Int) {
+        if (x in 0..width && y in 0..height) {
+            Actions(driver).moveToLocation(x, y).click().perform()
         }
     }
 
+    override fun keyPress(key: String) {
+        val keys: CharSequence = when (key) {
+            "Backspace" -> Keys.BACK_SPACE
+            "Tab" -> Keys.TAB
+            "Enter" -> Keys.ENTER
+            else -> key
+        }
+        Actions(driver).keyDown(keys).keyUp(keys).perform()
+    }
+
+    override fun back() {
+        driver.navigate().back()
+    }
+
+    override fun forward() {
+        driver.navigate().forward()
+    }
+
+    override fun loadUrl(url: String) {
+        driver.navigate().to(url)
+        addCookiesFor(driver.currentUrl)
+        driver.navigate().refresh()
+    }
+
     override fun close() {
         job.cancel()
         flush()
@@ -235,3 +276,139 @@ class SeleniumScreenshotServer : Closeable {
         }
     }
 }
+
+@OptIn(ExperimentalEncodingApi::class)
+class PlaywrightScreenshotServer : Closeable, ScreenShotWebViewEventListener {
+    companion object {
+        const val width = 1200
+        const val height = 800
+
+        private val networkHelper: NetworkHelper by injectLazy()
+    }
+
+    private val driver: Browser = run {
+        Playwright.create().chromium().launch(
+            BrowserType.LaunchOptions().apply {
+                this.setHeadless(true)
+            }
+        )
+    }
+    val page = driver.newPage(
+        Browser.NewPageOptions().apply {
+            baseURL = "https://google.com"
+            screenSize = ScreenSize(width, height)
+        }
+    )
+    private val job = SupervisorJob()
+    private val executor = Executors.newSingleThreadExecutor().asCoroutineDispatcher()
+
+    init {
+        CFClearance.applyStealthInitScripts(page)
+        GlobalScope.launch(executor) {
+            val completableDeferred = CompletableDeferred<Unit>()
+            page.onRequestFinished {
+                completableDeferred.complete(Unit)
+            }
+            completableDeferred.await()
+            while (isActive) {
+                try {
+                    // Capture screenshot
+                    val screenshot = Base64.encode(page.screenshot())
+                    // Send image data over the socket
+                    WebView.notifyAllClients(screenshot)
+                    delay(1000) // Adjust interval as needed
+                } catch (e: NoSuchSessionException) {
+                    ensureActive()
+                } catch (e: CancellationException) {
+                    throw e
+                } catch (e: Exception) {
+                    e.printStackTrace()
+                }
+            }
+        }
+        GlobalScope.launch(job) {
+            while (true) {
+                delay(5.seconds)
+                flush()
+            }
+        }
+    }
+
+    override fun onClick(x: Int, y: Int) {
+        if (x in 0..width && y in 0..height) {
+            page.mouse().click(x.toDouble(), y.toDouble())
+        }
+    }
+
+    override fun keyPress(key: String) {
+        page.keyboard().press(key)
+    }
+
+    override fun back() {
+        page.goBack()
+    }
+
+    override fun forward() {
+        page.goForward()
+    }
+
+    override fun loadUrl(url: String) {
+        page.navigate(url)
+        addCookiesFor(page.url())
+        page.reload()
+    }
+
+    override fun close() {
+        job.cancel()
+        flush()
+        executor.cancel()
+        try {
+            page.close()
+        } catch (_: Exception) {
+        }
+        try {
+            driver.close()
+        } catch (_: Exception) {
+        }
+    }
+
+    private fun flush() {
+        page.context().cookies().forEach {
+            networkHelper.cookieStore.add(
+                URI("http://" + it.domain),
+                HttpCookie(it.name, it.value).apply {
+                    path = it.path
+                    domain = it.domain
+                    maxAge = if (it.expires == null) {
+                        -1
+                    } else {
+                        it.expires.seconds.inWholeSeconds
+                    }
+                    isHttpOnly = it.httpOnly
+                    secure = it.secure
+                }
+            )
+        }
+    }
+
+    private fun addCookiesFor(uri: String) {
+        page.context().addCookies(
+            networkHelper.cookieStore.get(URI(uri)).map {
+                com.microsoft.playwright.options.Cookie(
+                    it.name,
+                    it.value
+                ).apply {
+                    domain = it.domain
+                    path = it.path
+                    expires = if (it.maxAge == -1L) {
+                        null
+                    } else {
+                        (System.currentTimeMillis().milliseconds + it.maxAge.seconds).inWholeSeconds.toDouble()
+                    }
+                    secure = it.secure
+                    httpOnly = it.isHttpOnly
+                }
+            }
+        )
+    }
+}

From 3f5f38c96571edcdf45653c908ae730096890187 Mon Sep 17 00:00:00 2001
From: Syer10 <syer10@users.noreply.github.com>
Date: Sat, 16 Sep 2023 12:54:34 -0400
Subject: [PATCH 9/9] Jcef wip

---
 server/build.gradle.kts                       |   1 +
 .../suwayomi/tachidesk/global/impl/WebView.kt | 127 +++++++++++++++++-
 2 files changed, 127 insertions(+), 1 deletion(-)

diff --git a/server/build.gradle.kts b/server/build.gradle.kts
index 509431b27..684747226 100644
--- a/server/build.gradle.kts
+++ b/server/build.gradle.kts
@@ -81,6 +81,7 @@ dependencies {
     implementation(libs.cronUtils)
 
     implementation("org.seleniumhq.selenium:selenium-java:4.11.0")
+    implementation("me.friwi:jcefmaven:110.0.25.1")
 }
 
 application {
diff --git a/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt b/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt
index 26f6c04e7..75d918aa4 100644
--- a/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt
+++ b/server/src/main/kotlin/suwayomi/tachidesk/global/impl/WebView.kt
@@ -17,6 +17,7 @@ import kotlinx.coroutines.asCoroutineDispatcher
 import kotlinx.coroutines.cancel
 import kotlinx.coroutines.delay
 import kotlinx.coroutines.ensureActive
+import kotlinx.coroutines.future.await
 import kotlinx.coroutines.isActive
 import kotlinx.coroutines.launch
 import kotlinx.serialization.json.Json
@@ -25,6 +26,11 @@ import kotlinx.serialization.json.double
 import kotlinx.serialization.json.intOrNull
 import kotlinx.serialization.json.jsonPrimitive
 import kotlinx.serialization.json.longOrNull
+import me.friwi.jcefmaven.CefAppBuilder
+import me.friwi.jcefmaven.MavenCefAppHandlerAdapter
+import me.friwi.jcefmaven.impl.progress.ConsoleProgressHandler
+import org.cef.browser.CefBrowser
+import org.cef.handler.CefLoadHandlerAdapter
 import org.eclipse.jetty.websocket.api.CloseStatus
 import org.jetbrains.exposed.sql.select
 import org.jetbrains.exposed.sql.transactions.transaction
@@ -42,11 +48,15 @@ import suwayomi.tachidesk.manga.impl.util.source.GetCatalogueSource.getCatalogue
 import suwayomi.tachidesk.manga.model.table.ChapterTable
 import suwayomi.tachidesk.manga.model.table.MangaTable
 import uy.kohesive.injekt.injectLazy
+import java.awt.Dimension
+import java.io.ByteArrayOutputStream
 import java.io.Closeable
+import java.io.File
 import java.net.HttpCookie
 import java.net.URI
 import java.util.Date
 import java.util.concurrent.Executors
+import javax.imageio.ImageIO
 import kotlin.io.encoding.Base64
 import kotlin.io.encoding.ExperimentalEncodingApi
 import kotlin.time.Duration.Companion.milliseconds
@@ -64,7 +74,7 @@ object WebView : Websocket<String>() {
             }
             clients.clear()
         } else {
-            driver = PlaywrightScreenshotServer() // SeleniumScreenshotServer()
+            driver = JCefScreenshotServer() // PlaywrightScreenshotServer() // SeleniumScreenshotServer()
         }
         super.addClient(ctx)
     }
@@ -412,3 +422,118 @@ class PlaywrightScreenshotServer : Closeable, ScreenShotWebViewEventListener {
         )
     }
 }
+
+@OptIn(ExperimentalEncodingApi::class)
+class JCefScreenshotServer : Closeable, ScreenShotWebViewEventListener {
+    companion object {
+        const val width = 1200
+        const val height = 800
+
+        private val networkHelper: NetworkHelper by injectLazy()
+    }
+
+    val app = run {
+        // Create a new CefAppBuilder instance
+        val builder = CefAppBuilder()
+
+        // Configure the builder instance
+        builder.setInstallDir(File("jcef-bundle")) // Default
+        builder.setProgressHandler(ConsoleProgressHandler()) // Default
+        builder.addJcefArgs("--disable-gpu") // Just an example
+        builder.cefSettings.windowless_rendering_enabled = true // Default - select OSR mode
+
+        // Set an app handler. Do not use CefApp.addAppHandler(...), it will break your code on MacOSX!
+        builder.setAppHandler(object : MavenCefAppHandlerAdapter() {})
+
+        // Build a CefApp instance using the configuration above
+        builder.build()
+    }
+    val client = app.createClient()
+    val browser = client.createBrowser("https://google.com", true, false).apply {
+        uiComponent.size = Dimension(width, height)
+    }
+
+    private val job = SupervisorJob()
+    private val executor = Executors.newSingleThreadExecutor().asCoroutineDispatcher()
+    init {
+        GlobalScope.launch(executor) {
+            val completableDeferred = CompletableDeferred<Unit>()
+            client.addLoadHandler(object : CefLoadHandlerAdapter() {
+                override fun onLoadingStateChange(
+                    browser: CefBrowser,
+                    isLoading: Boolean,
+                    canGoBack: Boolean,
+                    canGoForward: Boolean
+                ) {
+                    if (!isLoading) {
+                        completableDeferred.complete(Unit)
+                    }
+                }
+            })
+            completableDeferred.await()
+            while (isActive) {
+                try {
+                    // Capture screenshot
+                    val image = browser.createScreenshot(true).await()
+                    val stream = ByteArrayOutputStream()
+                    ImageIO.write(image, "jpg", stream)
+                    val screenshot = Base64.encode(stream.toByteArray())
+
+                    // Send image data over the socket
+                    WebView.notifyAllClients(screenshot)
+                    delay(1000) // Adjust interval as needed
+                } catch (e: NoSuchSessionException) {
+                    ensureActive()
+                } catch (e: CancellationException) {
+                    throw e
+                } catch (e: Exception) {
+                    e.printStackTrace()
+                }
+            }
+        }
+        GlobalScope.launch(job) {
+            while (true) {
+                delay(5.seconds)
+                // flush()
+            }
+        }
+    }
+
+    override fun onClick(x: Int, y: Int) {
+        val frame = browser.mainFrame
+
+        // Create and dispatch a synthetic click event at the specified coordinates
+        val javascriptCode = "var event = new MouseEvent('click', {" +
+            "  view: window," +
+            "  bubbles: true," +
+            "  cancelable: true," +
+            "  clientX: " + x + "," +
+            "  clientY: " + y + "," +
+            "});" +
+            "document.elementFromPoint(" + x + "," + y + ").dispatchEvent(event);"
+        frame.executeJavaScript(javascriptCode, frame.url, 0)
+    }
+
+    override fun keyPress(key: String) {
+        TODO("Not yet implemented")
+    }
+
+    override fun back() {
+        browser.goBack()
+    }
+
+    override fun forward() {
+        browser.goForward()
+    }
+
+    override fun loadUrl(url: String) {
+        browser.loadURL(url)
+    }
+
+    override fun close() {
+        job.cancel()
+        // flush()
+        executor.cancel()
+        app.dispose()
+    }
+}