Skip to content

Commit

Permalink
Add connection handler
Browse files Browse the repository at this point in the history
  • Loading branch information
Miguel0888 committed Jan 18, 2025
1 parent f0e2ba0 commit d2d044c
Show file tree
Hide file tree
Showing 2 changed files with 34 additions and 5 deletions.
11 changes: 11 additions & 0 deletions src/main/java/selineer/controller/MainController.java
Original file line number Diff line number Diff line change
Expand Up @@ -31,6 +31,17 @@ public void setupListeners(JButton navigateButton, JTextField addressBar, JCombo
JOptionPane.showMessageDialog(null, "Bitte eine URL eingeben und den Browser auswählen.");
}
});
browserSelector.addActionListener(e -> {
String selectedBrowser = (String) browserSelector.getSelectedItem();
if ("Chrome".equals(selectedBrowser)) { // Prüfen, ob der ausgewählte Browser korrekt ist
if (browserService.getWebSocketClient() == null || !browserService.getWebSocketClient().isOpen()) {
System.out.println("Verbinde mit dem Browser...");
browserService.connectToBrowser();
} else {
System.out.println("Bereits verbunden mit dem Browser.");
}
}
});
}

}
28 changes: 23 additions & 5 deletions src/main/java/selineer/service/BrowserService.java
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ public void connectToBrowser() {
webSocketClient = new WebSocketClient(new URI(wsUrl)) {
@Override
public void onOpen(ServerHandshake handshake) {
System.out.println("Verbindung zum Browser hergestellt.");
System.out.println("WebSocket-Verbindung hergestellt!");
}

@Override
Expand All @@ -51,31 +51,41 @@ public void onMessage(String message) {

@Override
public void onClose(int code, String reason, boolean remote) {
System.out.println("Verbindung geschlossen: " + reason);
System.out.println("WebSocket-Verbindung geschlossen: " + reason);
}

@Override
public void onError(Exception ex) {
System.out.println("Fehler in der WebSocket-Verbindung:");
ex.printStackTrace();
}
};
webSocketClient.connect();

// Warte, bis die Verbindung tatsächlich aufgebaut wurde
while (!webSocketClient.isOpen()) {
Thread.sleep(100); // 100ms warten, bis Verbindung offen ist
}
System.out.println("WebSocket-Client ist jetzt aktiv.");
} else {
System.out.println("WebSocket-URL konnte nicht abgerufen werden.");
}
} catch (Exception e) {
e.printStackTrace();
}
}
}


public void navigateTo(String url) {
if (webSocketClient != null && webSocketClient.isOpen()) {
String command = "{\"id\":1,\"method\":\"Page.navigate\",\"params\":{\"url\":\"" + url + "\"}}";
webSocketClient.send(command);
System.out.println("Navigiere zu URL: " + url);
} else {
System.out.println("WebSocket-Verbindung nicht aktiv.");
System.out.println("WebSocket-Verbindung nicht aktiv. Kann nicht zu URL navigieren: " + url);
}
}


public void closeBrowser() {
if (webSocketClient != null) {
Expand Down Expand Up @@ -103,12 +113,20 @@ public String getWebSocketDebuggerUrl() {

if (jsonArray.isArray() && jsonArray.size() > 0) {
JsonNode firstPage = jsonArray.get(0);
return firstPage.get("webSocketDebuggerUrl").asText();
String webSocketDebuggerUrl = firstPage.get("webSocketDebuggerUrl").asText();
System.out.println("WebSocket-URL: " + webSocketDebuggerUrl);
return webSocketDebuggerUrl;
} else {
System.out.println("Keine WebSocket-URLs verfügbar.");
}
} catch (Exception e) {
e.printStackTrace();
}
return null;
}

public WebSocketClient getWebSocketClient() {
return webSocketClient;
}

}

0 comments on commit d2d044c

Please sign in to comment.