set whipclient publish token=user.token for /wh[i,e]p/{uuid} api.go h…

…andler

server/api/api.go

@@ -6,7 +6,7 @@ import (
 	"net/url"
 
 	woomMiddleware "woom/server/api/middleware"
-	"woom/server/api/v1"
+	v1 "woom/server/api/v1"
 	"woom/server/helper"
 	"woom/static"
 
@@ -49,16 +49,15 @@ func NewApi(rdb *redis.Client, secret string, live777Url string, live777Token st
 		r.Post("/room/{roomId}/stream", handle.CreateRoomStream)
 		r.Patch("/room/{roomId}/stream/{streamId}", handle.UpdateRoomStream)
 		r.Delete("/room/{roomId}/stream/{streamId}", handle.DestroyRoomStream)
+		r.HandleFunc("/whip/{uuid}", handler(proxy, live777Url, live777Token))
+		r.HandleFunc("/whep/{uuid}", handler(proxy, live777Url, live777Token))
 	})
 
 	r.Post("/user/", handle.CreateUser)
 
 	//r.Post("/room/{roomId}/message", handle.CreateMessage)
 	//r.Get("/room/{roomId}/message", handle.ShowMessage)
 
-	r.HandleFunc("/whip/{uuid}", handler(proxy, live777Url, live777Token))
-	r.HandleFunc("/whep/{uuid}", handler(proxy, live777Url, live777Token))
-
 	r.Handle("/*", http.StripPrefix("/", http.FileServer(helper.NewSinglePageApp("index.html", http.FS(static.Dist)))))
 	return r
 }

webapp/components/use/whip.ts

@@ -1,6 +1,6 @@
 import { useSyncExternalStore } from 'react'
 import { event, Context, Data } from './whxp'
-import { Stream, StreamState } from '../../lib/api'
+import { Stream, StreamState, token} from '../../lib/api'
 import { WHIPClient } from 'whip-whep/whip'
 import {
   deviceNone,
@@ -9,6 +9,7 @@ import {
   asyncGetVideoStream,
 } from '../../lib/device'
 
+
 interface WHIPData extends Data {
   setUserName: (name: string) => void,
   setSyncUserStatus: (callback: (userStatus: Stream) => void) => void,
@@ -188,7 +189,7 @@ class WHIPContext extends Context {
 
     try {
       const url = location.origin + `/whip/${id}`
-      await client.publish(pc, url)
+      await client.publish(pc, url, token)
     } catch (e) {
       console.log(e)
       userStatus.state = StreamState.Failed

webapp/lib/api.ts

@@ -132,6 +132,8 @@ export {
   delStream,
 
   StreamState,
+
+  token,
 }
 
 export type {