neoris/openvidu-livekit-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update webhook endpoint in application servers

Browse Source
This commit is contained in:
juancarmore 2024-07-08 14:30:38 +02:00
parent c49475c25f
commit b263c0a0b3
8 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
application-server/dotnet/Program.cs
View File

@ -53,7 +53,7 @@ app.MapPost("/token", async (HttpRequest request) =>
} }
}); });
app.MapPost("/webhook", async (HttpRequest request) => app.MapPost("/livekit/webhook", async (HttpRequest request) =>
{ {
var body = new StreamReader(request.Body); var body = new StreamReader(request.Body);
string postData = await body.ReadToEndAsync(); string postData = await body.ReadToEndAsync();

2
application-server/go/main.go
View File

@ -72,6 +72,6 @@ func main() {
router := gin.Default() router := gin.Default()
router.Use(cors.Default()) router.Use(cors.Default())
router.POST("/token", createToken) router.POST("/token", createToken)
router.POST("/webhook", receiveWebhook) router.POST("/livekit/webhook", receiveWebhook)
router.Run(":" + SERVER_PORT) router.Run(":" + SERVER_PORT)
} }

2
application-server/java/src/main/java/io/openvidu/basic/java/Controller.java
View File

@ -47,7 +47,7 @@ public class Controller {
return ResponseEntity.ok(Map.of("token", token.toJwt())); return ResponseEntity.ok(Map.of("token", token.toJwt()));
} }
@PostMapping(value = "/webhook", consumes = "application/webhook+json") @PostMapping(value = "/livekit/webhook", consumes = "application/webhook+json")
public ResponseEntity<String> receiveWebhook(@RequestHeader("Authorization") String authHeader, @RequestBody String body) { public ResponseEntity<String> receiveWebhook(@RequestHeader("Authorization") String authHeader, @RequestBody String body) {
WebhookReceiver webhookReceiver = new WebhookReceiver(LIVEKIT_API_KEY, LIVEKIT_API_SECRET); WebhookReceiver webhookReceiver = new WebhookReceiver(LIVEKIT_API_KEY, LIVEKIT_API_SECRET);
try { try {

2
application-server/node/index.js
View File

@ -35,7 +35,7 @@ const webhookReceiver = new WebhookReceiver(
LIVEKIT_API_SECRET LIVEKIT_API_SECRET
); );
app.post("/webhook", async (req, res) => { app.post("/livekit/webhook", async (req, res) => {
try { try {
const event = await webhookReceiver.receive( const event = await webhookReceiver.receive(
req.body, req.body,

2
application-server/php/index.php
View File

@ -44,7 +44,7 @@ if (isset($_SERVER["REQUEST_METHOD"]) && $_SERVER["REQUEST_METHOD"] === "POST" &
$webhookReceiver = (new WebhookReceiver($LIVEKIT_API_KEY, $LIVEKIT_API_SECRET)); $webhookReceiver = (new WebhookReceiver($LIVEKIT_API_KEY, $LIVEKIT_API_SECRET));
if (isset($_SERVER["REQUEST_METHOD"]) && $_SERVER["REQUEST_METHOD"] === "POST" && $_SERVER["PATH_INFO"] === "/webhook") { if (isset($_SERVER["REQUEST_METHOD"]) && $_SERVER["REQUEST_METHOD"] === "POST" && $_SERVER["PATH_INFO"] === "/livekit/webhook") {
$headers = getallheaders(); $headers = getallheaders();
$authHeader = $headers["Authorization"]; $authHeader = $headers["Authorization"];
$body = file_get_contents("php://input"); $body = file_get_contents("php://input");

2
application-server/python/app.py
View File

@ -35,7 +35,7 @@ token_verifier = TokenVerifier(LIVEKIT_API_KEY, LIVEKIT_API_SECRET)
webhook_receiver = WebhookReceiver(token_verifier) webhook_receiver = WebhookReceiver(token_verifier)
@app.post("/webhook") @app.post("/livekit/webhook")
def receive_webhook(): def receive_webhook():
auth_token = request.headers.get("Authorization") auth_token = request.headers.get("Authorization")

2
application-server/ruby/app.rb
View File

@ -33,7 +33,7 @@ post '/token' do
return json({token: token.to_jwt}) return json({token: token.to_jwt})
end end
post '/webhook' do post '/livekit/webhook' do
auth_header = request.env['HTTP_AUTHORIZATION'] auth_header = request.env['HTTP_AUTHORIZATION']
token_verifier = LiveKit::TokenVerifier.new(api_key: LIVEKIT_API_KEY, api_secret: LIVEKIT_API_SECRET) token_verifier = LiveKit::TokenVerifier.new(api_key: LIVEKIT_API_KEY, api_secret: LIVEKIT_API_SECRET)
begin begin

2
application-server/rust/src/main.rs
View File

@ -26,7 +26,7 @@ async fn main() {
let app = Router::new() let app = Router::new()
.route("/token", post(create_token)) .route("/token", post(create_token))
.route("/webhook", post(receive_webhook)) .route("/livekit/webhook", post(receive_webhook))
.layer(cors); .layer(cors);
let listener = TcpListener::bind("0.0.0.0:".to_string() + &server_port) let listener = TcpListener::bind("0.0.0.0:".to_string() + &server_port)