diff --git a/server/socket/webrtc.ts b/server/socket/webrtc.ts index bfdcf13..501e10e 100644 --- a/server/socket/webrtc.ts +++ b/server/socket/webrtc.ts @@ -148,7 +148,7 @@ export default function (io: SocketServer, router: types.Router) { } }) - socket.on('produce', async ({ transportId, kind, rtpParameters }, cb) => { + socket.on('produce', async ({ transportId, kind, rtpParameters, appData }, cb) => { if (!socket.data.joined) { consola.error('Peer not joined yet') cb({ error: 'Peer not joined yet' }) @@ -166,7 +166,7 @@ export default function (io: SocketServer, router: types.Router) { } try { - const producer = await transport.produce({ kind, rtpParameters, appData: { socketId: socket.id } }) + const producer = await transport.produce({ kind, rtpParameters, appData: { ...appData, socketId: socket.id } }) socket.data.producers.set(producer.id, producer) diff --git a/server/types/webrtc.ts b/server/types/webrtc.ts index f2cd206..e2dfd6e 100644 --- a/server/types/webrtc.ts +++ b/server/types/webrtc.ts @@ -55,6 +55,7 @@ export interface ClientToServerEvents { transportId: types.WebRtcTransport['id'] kind: types.MediaKind rtpParameters: types.RtpParameters + appData: { source: 'share' | string } }, cb: EventCallback<{ id: types.Producer['id'] }> ) => void