Add tokenless livestreams (#165)

## Description

Describe your changes in detail.

## Motivation and Context

Why is this change required? What problem does it solve? If it fixes an
open
issue, please link to the issue here.

## Types of changes

- [ ] Bug fix (non-breaking change which fixes an issue)
- [ ] New feature (non-breaking change which adds functionality)
- [ ] Breaking change (fix or feature that would cause existing
functionality to
      not work as expected)

Author: AHGIJMKLKKZNPJKQR

examples/room-manager/openapi.yaml

@@ -36,6 +36,12 @@ paths:
           in: query
           name: roomType
           required: false
+        - schema:
+            type: boolean
+            default: false
+          in: query
+          name: public
+          required: false
       responses:
         "200":
           description: Default Response

examples/room-manager/src/plugins/fishjam.ts

@@ -4,6 +4,7 @@ import {
   FishjamClient,
   PeerId,
   Room,
+  RoomConfig,
   RoomConfigRoomTypeEnum,
   RoomId,
   RoomNotFoundException,
@@ -17,7 +18,12 @@ import { PeerAccessData } from '../schema';
 declare module 'fastify' {
   interface FastifyInstance {
     fishjam: {
-      getPeerAccess: (roomName: string, peerName: string, roomType?: RoomConfigRoomTypeEnum) => Promise<PeerAccessData>;
+      getPeerAccess: (
+        roomName: string,
+        peerName: string,
+        roomType?: RoomConfigRoomTypeEnum,
+        isPublic?: boolean
+      ) => Promise<PeerAccessData>;
       handleFishjamMessage: (notification: ServerMessage) => Promise<void>;
       getLivestreamViewerToken: (roomName: string) => Promise<ViewerToken>;
     };
@@ -40,9 +46,16 @@ export const fishjamPlugin = fastifyPlugin(async (fastify: FastifyInstance): Pro
   async function getPeerAccess(
     roomName: string,
     peerName: string,
-    roomType: RoomConfigRoomTypeEnum = 'conference'
+    roomType: RoomConfigRoomTypeEnum = 'conference',
+    isPublic: boolean = false
   ): Promise<PeerAccessData> {
-    const room = await findOrCreateRoomInFishjam(roomName, roomType);
+    const config: RoomConfig = {
+      maxPeers: fastify.config.MAX_PEERS,
+      videoCodec: fastify.config.ROOM_VIDEO_CODEC as RoomConfigVideoCodecEnum,
+      roomType,
+      public: isPublic,
+    };
+    const room = await findOrCreateRoomInFishjam(roomName, config);
     const peerAccess = peerNameToAccessMap.get(peerName);
 
     const peer = room.peers.find((peer) => peer.id === peerAccess?.peer.id);
@@ -138,7 +151,7 @@ export const fishjamPlugin = fastifyPlugin(async (fastify: FastifyInstance): Pro
     return peerAccess;
   }
 
-  async function findOrCreateRoomInFishjam(roomName: string, roomType: RoomConfigRoomTypeEnum): Promise<Room> {
+  async function findOrCreateRoomInFishjam(roomName: string, roomConfig: RoomConfig): Promise<Room> {
     const roomId = roomNameToRoomIdMap.get(roomName);
 
     if (roomId) {
@@ -158,14 +171,10 @@ export const fishjamPlugin = fastifyPlugin(async (fastify: FastifyInstance): Pro
       name: 'Creating room in Fishjam',
       roomId,
       roomName,
-      roomType,
+      ...roomConfig,
     });
 
-    const newRoom = await fishjamClient.createRoom({
-      maxPeers: fastify.config.MAX_PEERS,
-      videoCodec: fastify.config.ROOM_VIDEO_CODEC as RoomConfigVideoCodecEnum,
-      roomType,
-    });
+    const newRoom = await fishjamClient.createRoom(roomConfig);
 
     roomNameToRoomIdMap.set(roomName, newRoom.id);
 

examples/room-manager/src/routes/rooms.ts

@@ -7,7 +7,12 @@ import { httpToWebsocket, removeTrailingSlash } from '../utils';
 
 async function getRoomAccessHandler(fastify: FastifyInstance, params: GetPeerAccessQueryParams, res: FastifyReply) {
   try {
-    const accessData = await fastify.fishjam.getPeerAccess(params.roomName, params.peerName, params.roomType);
+    const accessData = await fastify.fishjam.getPeerAccess(
+      params.roomName,
+      params.peerName,
+      params.roomType,
+      params.public
+    );
     const url = httpToWebsocket(fastify.config.FISHJAM_URL);
 
     // When creating a URL object from a URL without a path (e.g., `http://localhost:5002`),

examples/room-manager/src/schema.ts

@@ -13,6 +13,7 @@ export interface GetPeerAccessQueryParams {
   roomName: string;
   peerName: string;
   roomType: RoomConfigRoomTypeEnum;
+  public: boolean;
 }
 
 export interface PeerAccessData {
@@ -42,7 +43,8 @@ const parameterSchema = S.object()
     S.string()
       .enum(['conference', 'audio_only', 'livestream'] satisfies RoomConfigRoomTypeEnum[])
       .default('conference')
-  );
+  )
+  .prop('public', S.boolean().default(false));
 
 export const peerEndpointSchema: FastifySchema = {
   querystring: parameterSchema,

packages/fishjam-openapi/src/generated/api.ts

@@ -4,7 +4,7 @@
  * Fishjam Media Server
  * No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator)
  *
- * The version of the OpenAPI document: 0.17.0
+ * The version of the OpenAPI document: 0.18.0
  * 
  *
  * NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).
@@ -871,6 +871,12 @@ export interface RoomConfig {
      * @memberof RoomConfig
      */
     'maxPeers'?: number | null;
+    /**
+     * True if livestream viewers can omit specifying a token.
+     * @type {boolean}
+     * @memberof RoomConfig
+     */
+    'public'?: boolean;
     /**
      * The use-case of the room. If not provided, this defaults to conference.
      * @type {string}

packages/fishjam-openapi/src/generated/base.ts

@@ -4,7 +4,7 @@
  * Fishjam Media Server
  * No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator)
  *
- * The version of the OpenAPI document: 0.17.0
+ * The version of the OpenAPI document: 0.18.0
  * 
  *
  * NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).

packages/fishjam-openapi/src/generated/common.ts

@@ -4,7 +4,7 @@
  * Fishjam Media Server
  * No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator)
  *
- * The version of the OpenAPI document: 0.17.0
+ * The version of the OpenAPI document: 0.18.0
  * 
  *
  * NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).

packages/fishjam-openapi/src/generated/configuration.ts

@@ -4,7 +4,7 @@
  * Fishjam Media Server
  * No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator)
  *
- * The version of the OpenAPI document: 0.17.0
+ * The version of the OpenAPI document: 0.18.0
  * 
  *
  * NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).

packages/fishjam-openapi/src/generated/index.ts

@@ -4,7 +4,7 @@
  * Fishjam Media Server
  * No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator)
  *
- * The version of the OpenAPI document: 0.17.0
+ * The version of the OpenAPI document: 0.18.0
  * 
  *
  * NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech).