talksik/streaming-prototyping
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

making it log and work with local livekit server

Browse Source
This commit is contained in:
talksik
2023-06-30 15:26:34 -07:00
parent 05f936c15b
commit a2be27ad11
2 changed files with 11 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
2023-06-30_15-26.png
BIN
View File
Binary file not shown.
Side by Side

After

Width:  |  Height:  |  Size: 6.1 MiB

src/main.rs
+11 -8
View File
@@ -1,20 +1,23 @@
use livekit::prelude::*; use livekit::prelude::*;
use std::env;
// Connect to a room using the specified env variables // Connect to a room using the specified env variables
// and print all incoming events // and print all incoming events
#[tokio::main] #[tokio::main]
async fn main() { async fn main() {
env_logger::init(); // run livekit-server locally: livekit-server --dev
let url = "ws://localhost:7880";
// run livekit-cli command:
// livekit-cli create-token \
// --api-key devkey --api-secret secret \
// --join --room my-first-room --identity user1 \
// --valid-for 24h
let token = "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJleHAiOjE2ODgyNDk3NzEsImlzcyI6ImRldmtleSIsIm5hbWUiOiJ1c2VyMSIsIm5iZiI6MTY4ODE2MzM3MSwic3ViIjoidXNlcjEiLCJ2aWRlbyI6eyJyb29tIjoibXktZmlyc3Qtcm9vbSIsInJvb21Kb2luIjp0cnVlfX0.HLDtRZbgca9UTVjV0d8Ms1ukv_eCH11AoCqyN_fyt88";
let url = env::var("0.0.0.0:7880").expect("LIVEKIT_URL is not set"); let (room, mut rx) = Room::connect(url, token, RoomOptions::default()).await.unwrap();
let token = env::var("LIVEKIT_TOKEN").expect("LIVEKIT_TOKEN is not set"); println!("Connected to room: {} - {}", room.name(), room.sid());
let (room, mut rx) = Room::connect(&url, &token, RoomOptions::default()).await.unwrap();
log::info!("Connected to room: {} - {}", room.name(), room.sid());
while let Some(msg) = rx.recv().await { while let Some(msg) = rx.recv().await {
log::info!("Event: {:?}", msg); println!("Event: {:?}", msg);
} }
} }