Fetch token credentials before connecting

Co-authored-by: Cursor <cursoragent@cursor.com>

Author: alan-george-lk

token_source/token_source_caching.cpp

@@ -55,11 +55,16 @@ bool cachingTokenSourceConnect() {
 
   livekit::TokenRequestOptions request_options;
   request_options.participant_identity = "robot-a";
+  const auto credentials = token_source->fetch(request_options).get();
+  if (!credentials) {
+    std::cerr << "Failed to fetch credentials: " << credentials.error().message << "\n";
+    return false;
+  }
 
   livekit::Room room;
   ParticipantLogDelegate delegate;
   room.setDelegate(&delegate);
-  if (!room.connect(*token_source, request_options, livekit::RoomOptions())) {
+  if (!room.connect(credentials.value().server_url, credentials.value().participant_token, livekit::RoomOptions())) {
     std::cerr << "Failed to connect to room\n";
     return false;
   }

token_source/token_source_custom.cpp

@@ -71,11 +71,16 @@ bool customTokenSourceConnect() {
         response.participant_token = token;
         return makeReadyFuture(TokenResult::success(std::move(response)));
       });
+  const auto credentials = token_source->fetch(livekit::TokenRequestOptions()).get();
+  if (!credentials) {
+    std::cerr << "Failed to fetch credentials: " << credentials.error().message << "\n";
+    return false;
+  }
 
   livekit::Room room;
   ParticipantLogDelegate delegate;
   room.setDelegate(&delegate);
-  if (!room.connect(*token_source, livekit::TokenRequestOptions(), livekit::RoomOptions())) {
+  if (!room.connect(credentials.value().server_url, credentials.value().participant_token, livekit::RoomOptions())) {
     std::cerr << "Failed to connect to room\n";
     return false;
   }

token_source/token_source_endpoint.cpp

@@ -55,11 +55,16 @@ bool endpointTokenSourceConnect() {
   // These options are sent to your endpoint, which embeds them into the JWT.
   livekit::TokenRequestOptions request_options;
   request_options.participant_identity = "robot-a";
+  const auto credentials = token_source->fetch(request_options).get();
+  if (!credentials) {
+    std::cerr << "Failed to fetch credentials: " << credentials.error().message << "\n";
+    return false;
+  }
 
   livekit::Room room;
   ParticipantLogDelegate delegate;
   room.setDelegate(&delegate);
-  if (!room.connect(*token_source, request_options, livekit::RoomOptions())) {
+  if (!room.connect(credentials.value().server_url, credentials.value().participant_token, livekit::RoomOptions())) {
     std::cerr << "Failed to connect to room\n";
     return false;
   }

token_source/token_source_literal.cpp

@@ -46,11 +46,16 @@ bool literalTokenSourceConnect() {
   // Each fetch() returns these exact credentials; nothing is requested over the
   // network. Room and participant identity are encoded in the token.
   auto token_source = livekit::LiteralTokenSource::create(url, token);
+  const auto credentials = token_source->fetch().get();
+  if (!credentials) {
+    std::cerr << "Failed to fetch credentials: " << credentials.error().message << "\n";
+    return false;
+  }
 
   livekit::Room room;
   ParticipantLogDelegate delegate;
   room.setDelegate(&delegate);
-  if (!room.connect(*token_source, livekit::RoomOptions())) {
+  if (!room.connect(credentials.value().server_url, credentials.value().participant_token, livekit::RoomOptions())) {
     std::cerr << "Failed to connect to room\n";
     return false;
   }

token_source/token_source_sandbox.cpp

@@ -59,11 +59,16 @@ bool sandboxTokenSourceConnect() {
     }
     std::cout << "Requesting sandbox token with agent dispatch: agent_name=" << *request_options.agent_name << "\n";
   }
+  const auto credentials = token_source->fetch(request_options).get();
+  if (!credentials) {
+    std::cerr << "Failed to fetch credentials: " << credentials.error().message << "\n";
+    return false;
+  }
 
   livekit::Room room;
   ParticipantLogDelegate delegate;
   room.setDelegate(&delegate);
-  if (!room.connect(*token_source, request_options, livekit::RoomOptions())) {
+  if (!room.connect(credentials.value().server_url, credentials.value().participant_token, livekit::RoomOptions())) {
     std::cerr << "Failed to connect to room\n";
     return false;
   }