Skip to content

feat: Add SQLite cache and admin UI for admin events #22

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
kinsleykajiva wants to merge 6 commits into
base: master
Choose a base branch
from
Open

feat: Add SQLite cache and admin UI for admin events #22

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
466012e
feat: Add SQLite cache and admin UI for admin events
google-labs-jules[bot] Aug 26, 2025
1edf63c
docs: Add example usage for JanusAdminUI in Main.java
google-labs-jules[bot] Aug 26, 2025
100c0c5
feat: Overhaul Admin UI with Auth, WebSockets, and New Design
google-labs-jules[bot] Aug 26, 2025
746bb10
feat: Overhaul Admin UI with Auth, WebSockets, and New Design
google-labs-jules[bot] Aug 26, 2025
01df42f
fix: Address UI styling and WebSocket timeout issues
google-labs-jules[bot] Aug 26, 2025
7eb5bb1
fix: Correct Javalin API usage and improve WebSocket stability
google-labs-jules[bot] Aug 26, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
15 changes: 15 additions & 0 deletions pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -68,6 +68,21 @@
<artifactId>jspecify</artifactId>
<version>1.0.0</version>
</dependency>
<dependency>
<groupId>org.xerial</groupId>
<artifactId>sqlite-jdbc</artifactId>
<version>3.46.0.0</version>
</dependency>
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>2.11.0</version>
</dependency>
<dependency>
<groupId>io.javalin</groupId>
<artifactId>javalin-bundle</artifactId>
<version>6.1.3</version>
</dependency>
</dependencies>
<build>
<plugins>
Expand Down
267 changes: 41 additions & 226 deletions src/main/java/io/github/kinsleykajiva/Main.java
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,252 +1,67 @@
package io.github.kinsleykajiva;

import io.github.kinsleykajiva.janus.JanusClient;
import io.github.kinsleykajiva.janus.JanusConfiguration;
import io.github.kinsleykajiva.janus.JanusSession;
import io.github.kinsleykajiva.janus.ServerInfo;
import io.github.kinsleykajiva.janus.admin.JanusAdminClient;
import io.github.kinsleykajiva.admin_ui.JanusAdminUI;
import io.github.kinsleykajiva.janus.admin.JanusAdminConfiguration;
import io.github.kinsleykajiva.janus.admin.messages.ListSessionsResponse;
import io.github.kinsleykajiva.janus.handle.impl.VideoRoomHandle;
import io.github.kinsleykajiva.janus.plugins.videoroom.events.*;
import io.github.kinsleykajiva.janus.plugins.videoroom.listeners.JanusVideoRoomListener;
import io.github.kinsleykajiva.janus.plugins.videoroom.models.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.net.URI;
import java.util.concurrent.TimeUnit;

public class Main {
private static final Logger logger = LoggerFactory.getLogger(Main.class);

public static void main(String[] args) {
// Enable debug logging for more details
// Enable info logging for more details
System.setProperty("org.slf4j.simpleLogger.defaultLogLevel", "INFO");

// Configure the Janus client
JanusConfiguration config = new JanusConfiguration(
"localhost", // Replace with your Janus server IP
8188,
"/janus",
false,
true
);

// 1. Configure the Janus Admin client
// Replace with your Janus admin websocket URI and secret
JanusAdminConfiguration adminConfig = new JanusAdminConfiguration(
URI.create("ws://localhost:7188/janus"),
"janusoverlord"
);

JanusClient client = new JanusClient(config);

// Add shutdown hook to ensure proper cleanup
Runtime.getRuntime().addShutdownHook(new Thread(() -> {
logger.info("Shutting down JanusClient...");
client.disconnect();
}));

try {
// 1. Connect to Janus
logger.info("Connecting to Janus server at {}...", config.getUri());
client.connect().get(10, TimeUnit.SECONDS);

// 2. Get Server Info
ServerInfo serverInfo = client.getServerInfo().get();
logger.info("Server Info: Janus v{}", serverInfo.versionString());

// 3. Create a Session
logger.info("Creating Janus session...");
JanusSession session = client.createSession().get();
logger.info("Session created with ID: {}", session.getSessionId());

// Run the VideoRoom example
// runVideoRoomExample(session);

// Run the Admin Client Example
runAdminClientExample(adminConfig);


// Keep the application running to listen for more events
logger.info("Example finished. Application will exit in 10 seconds.");
Thread.sleep(10000);
// 2. Initialize the Admin UI feature
// This will start caching admin events and prepare the web server.
// Using default constructor:
// - Cache folder: 'cache/' in the application's root directory.
// - Web UI port: A random available port.
// - Authentication: Disabled by default.
logger.info("Initializing Janus Admin UI...");

// To enable authentication, provide a username and password
final String username = "admin";
final String password = "password";
logger.info("Admin UI credentials: username='{}', password='{}'", username, password);
final JanusAdminUI adminUI = new JanusAdminUI(adminConfig, "cache", 0, username, password);

// To run without authentication:
// final JanusAdminUI adminUI = new JanusAdminUI(adminConfig);


// 3. Add a shutdown hook for graceful exit
// This ensures the web server and client are disconnected properly.
Runtime.getRuntime().addShutdownHook(new Thread(() -> {
logger.info("Shutting down Janus Admin UI...");
adminUI.stop();
}));

// 4. Start the UI server
// The server will run in the background.
adminUI.start();
logger.info("Admin UI server has been started. Check the console logs above for the exact port number.");
logger.info("You can now access the UI in your browser.");
logger.info("Press Enter in this console to stop the application.");

// 5. Keep the application running
// The web server is on a background thread, so we need to prevent the main thread from exiting.
System.in.read();

} catch (Exception e) {
logger.error("An error occurred: {}", e.getMessage(), e);
logger.error("An error occurred during application startup: {}", e.getMessage(), e);
} finally {
logger.info("Disconnecting client.");
client.disconnect();
}
}

/**
* A comprehensive example demonstrating the VideoRoomHandle workflow.
* @param session An active JanusSession.
* @throws Exception if any operation fails.
*/
public static void runVideoRoomExample(JanusSession session) throws Exception {
System.out.println("\n--- Running VideoRoom Example ---\n");

// 1. Attach to the VideoRoom Plugin
// This creates a handle, which is a context for all subsequent plugin interactions.
System.out.println("Attaching to VideoRoom plugin...");
VideoRoomHandle videoRoomHandle = session.attachToVideoRoom().get();
System.out.println("VideoRoom handle attached with ID: " + videoRoomHandle.getHandleId());

// 2. Add a listener for VideoRoom events
// This is crucial for handling asynchronous responses from the plugin.
videoRoomHandle.addVideoRoomListener(new JanusVideoRoomListener() {
@Override
public void onJoined(JoinedEvent event) {
System.out.printf(">>> Successfully joined room %d as a publisher (My ID: %d)%n",
event.room(), event.id());
if (event.publishers().isEmpty()) {
System.out.println(">>> There are no other active publishers in the room.");
} else {
event.publishers().forEach(publisher ->
System.out.printf(">>> Active publisher in room: %s (ID: %d)%n",
publisher.display(), publisher.id()));
}
}





@Override
public void onPublisherAdded(PublisherAddedEvent event) {
event.publishers().forEach(publisher ->
System.out.printf(">>> EVENT: A new publisher has entered the room: %s (ID: %d)%n",
publisher.display(), publisher.id()));
}

@Override
public void onUnpublished(UnpublishedEvent event) {
System.out.println(">>> EVENT: Publisher " + event.unpublished() + " has unpublished their stream.");
}

@Override
public void onParticipantLeft(ParticipantLeftEvent event) {
System.out.println(">>> EVENT: Participant " + event.leaving() + " has left the room.");
}

@Override
public void onRoomDestroyed(RoomDestroyedEvent event) {
System.out.println(">>> EVENT: Room " + event.room() + " has been destroyed.");
}
});

// 3. Create a new room
System.out.println("Creating a new video room...");
CreateRoomRequest createRequest = new CreateRoomRequest.Builder()
.setDescription("My Java SDK Test Room")
.setPublishers(6)
.build();
CreateRoomResponse createResponse = videoRoomHandle.createRoom(createRequest).get();
final long roomId = createResponse.room();
System.out.println("Room created with ID: " + roomId);
Thread.sleep(500); // Pause for clarity

// 4. Join the room as a publisher
System.out.println("Joining room " + roomId + " as a publisher......");
JoinRoomRequest joinRequest = new JoinRoomRequest.Builder(roomId)
.setDisplay("JavaSDKUser")
.build();
videoRoomHandle.join(joinRequest).get(); // join() is async, the onJoined event will fire

// Give Janus time to process and send the 'joined' event
Thread.sleep(1000);

// 5. List participants (should include us)
System.out.println("Listing participants in room " + roomId + "...");
ListParticipantsRequest listRequest = new ListParticipantsRequest(roomId);
ListParticipantsResponse listResponse = videoRoomHandle.listParticipants(listRequest).get();
System.out.println("Participants found: " + listResponse.participants().size());
listResponse.participants().forEach(p ->
System.out.printf(" - Participant ID: %d, Display: '%s', Publisher: %b%n",
p.id(), p.display(), p.publisher()));
Thread.sleep(500);

// 6. Conceptually "publish" a stream.
// In a real application, this would involve sending a JSEP offer from a WebRTC client.
// The handle's `sendMessage(body, jsep)` would be used. For this example, we just
// simulate the action and then unpublish.
System.out.println("Simulating publishing a stream... (In a real app, this sends a JSEP offer)");
// An `onPublisherAdded` event would be sent to all participants after this.
Thread.sleep(1000);

// 7. Unpublish the stream
System.out.println("Unpublishing the stream...");
// In this example, we comment out the unpublish call.
// The Janus plugin would return an error "Can't unpublish, not published"
// because we never sent a real `publish` request with a JSEP offer.
// videoRoomHandle.unpublish().get();
Thread.sleep(500);

// 8. Leave the room
System.out.println("Leaving the room...");
videoRoomHandle.leave().get(); // An `onParticipantLeft` event will fire for others
Thread.sleep(500);

// 9. Destroy the room
System.out.println("Destroying room " + roomId + "...");
DestroyRoomRequest destroyRequest = new DestroyRoomRequest(roomId, null, true);
videoRoomHandle.destroyRoom(destroyRequest).get(); // An `onRoomDestroyed` event will fire for the handle

System.out.println("\n--- VideoRoom Example Finished ---\n");
}

public static void runAdminClientExample(JanusAdminConfiguration adminConfig) throws Exception {
System.out.println("\n--- Running Admin Client Example ---\n");

JanusAdminClient adminClient = new JanusAdminClient(adminConfig);

adminClient.getAdminMonitor().addListener(event -> {
System.out.println(">>> ADMIN EVENT: " + event.toString(2));
});

System.out.println("Pinging admin endpoint...");
adminClient.ping().thenAccept(response -> {
System.out.println("Ping response: " + response.toString(2));
}).get();

System.out.println("Getting server info...");
adminClient.info().thenAccept(info -> {
System.out.println("Server info: " + info.versionString());
}).get();

System.out.println("Getting status...");
adminClient.getStatus().thenAccept(status -> {
System.out.println("Status: " + status.toString(2));
}).get();

System.out.println("Listing active sessions...");
ListSessionsResponse sessionsResponse = adminClient.listSessions().get();
System.out.println("Active sessions: " + sessionsResponse.getSessionIds());

if (!sessionsResponse.getSessionIds().isEmpty()) {
long firstSessionId = sessionsResponse.getSessionIds().get(0);
System.out.println("Listing handles for session: " + firstSessionId);
adminClient.listHandles(firstSessionId).thenAccept(handles -> {
System.out.println("Handles: " + handles.getHandleIds());
}).get();
logger.info("Application shutting down.");
}

System.out.println("Setting log level to 4...");
adminClient.setLogLevel(4).get();
System.out.println("Log level set.");

System.out.println("Getting status again...");
adminClient.getStatus().thenAccept(status -> {
System.out.println("Status: " + status.toString(2));
}).get();

System.out.println("Setting log level back to 3...");
adminClient.setLogLevel(3).get();
System.out.println("Log level set.");


adminClient.disconnect();
System.out.println("\n--- Admin Client Example Finished ---\n");
}
}
Loading