update example

Author: chenosaurus

examples/local_audio/full_duplex.py

@@ -3,7 +3,7 @@
 import logging
 from dotenv import load_dotenv, find_dotenv
 
-from livekit import rtc
+from livekit import api, rtc
 
 
 async def main() -> None:
@@ -13,8 +13,9 @@ async def main() -> None:
     load_dotenv(find_dotenv())
 
     url = os.getenv("LIVEKIT_URL")
-    token = os.getenv("LIVEKIT_TOKEN")
-    if not url or not token:
+    api_key = os.getenv("LIVEKIT_API_KEY")
+    api_secret = os.getenv("LIVEKIT_API_SECRET")
+    if not url or not api_key or not api_secret:
         raise RuntimeError("LIVEKIT_URL and LIVEKIT_TOKEN must be set in env")
 
     room = rtc.Room()
@@ -99,6 +100,19 @@ def on_participant_disconnected(participant: rtc.RemoteParticipant):
         logging.info("participant disconnected: %s", participant.identity)
 
     room.on("participant_disconnected", on_participant_disconnected)
+    
+    token = (
+        api.AccessToken(api_key, api_secret)
+        .with_identity("local-audio")
+        .with_name("Local Audio")
+        .with_grants(
+            api.VideoGrants(
+                room_join=True,
+                room="local-audio",
+            )
+        )
+        .to_jwt()
+    )
 
     try:
         await room.connect(url, token)

examples/local_audio/publish_mic.py

@@ -3,7 +3,7 @@
 import logging
 from dotenv import load_dotenv, find_dotenv
 
-from livekit import rtc
+from livekit import api, rtc
 
 
 async def main() -> None:
@@ -13,16 +13,30 @@ async def main() -> None:
     load_dotenv(find_dotenv())
 
     url = os.getenv("LIVEKIT_URL")
-    token = os.getenv("LIVEKIT_TOKEN")
-    if not url or not token:
-        raise RuntimeError("LIVEKIT_URL and LIVEKIT_TOKEN must be set in env")
+    api_key = os.getenv("LIVEKIT_API_KEY")
+    api_secret = os.getenv("LIVEKIT_API_SECRET")
+    if not url or not api_key or not api_secret:
+        raise RuntimeError("LIVEKIT_URL and LIVEKIT_API_KEY and LIVEKIT_API_SECRET must be set in env")
 
     room = rtc.Room()
 
     # Create media devices helper and open default microphone with AEC enabled
     devices = rtc.MediaDevices()
     mic = devices.open_input(enable_aec=True)
-
+    
+    token = (
+        api.AccessToken(api_key, api_secret)
+        .with_identity("local-audio")
+        .with_name("Local Audio")
+        .with_grants(
+            api.VideoGrants(
+                room_join=True,
+                room="local-audio",
+            )
+        )
+        .to_jwt()
+    )
+    
     try:
         await room.connect(url, token)
         logging.info("connected to room %s", room.name)