feat: streams video recording API extension

build-manifest.sh

@@ -1,6 +1,6 @@
 #!/bin/bash
 
-PRIVMX_ENDPOINT="59babd13b63723000f4f29322e50f3ded110949d"
+PRIVMX_ENDPOINT="devel"
 PSON_CPP="v1.0.7"
 GMP="6.3.0"
 POCO="1.10.1"

scripts/build_api

@@ -6,7 +6,8 @@ if [ -z "$1" ]; then
     echo "$0: Parameter missing. Pass privmx-endpoint version used in build process"
     exit -1;
 fi
-PRIVMX_ENDPOINT_VERSION=$1
+PRIVMX_ENDPOINT_VERSION_IN=$1
+PRIVMX_ENDPOINT_VERSION="${PRIVMX_ENDPOINT_VERSION_IN//\//_}"
 
 source "$SCRIPT_PATH/config.sh"
 source "$EMSDK_DIR/emsdk_env.sh"

scripts/build_privmx_endpoint

@@ -7,11 +7,12 @@ if [ -z "$1" ]; then
     exit -1;
 fi
 VERSION=$1
+VERSION_AS_DIR="${VERSION//\//_}"
 
 source "$SCRIPT_PATH/config.sh"
 source "$EMSDK_DIR/emsdk_env.sh"
 
-PRIVMX_ENDPOINT_DIR="$SOURCE_DIR/privmx-endpoint-$VERSION"
+PRIVMX_ENDPOINT_DIR="$SOURCE_DIR/privmx-endpoint-$VERSION_AS_DIR"
 
 if [ -d "$PRIVMX_ENDPOINT_DIR" ]; then
     echo "$PRIVMX_ENDPOINT_DIR directory exists. Skip download of sources."

scripts/check_dir_checksum

@@ -8,7 +8,7 @@ if [[ $# -ne 1 ]]; then
     exit 2
 fi
 echo "Checking dir: $1"
-DIR_TO_CHECK="$1"
+DIR_TO_CHECK="$1/"
 
 if [[ ! -d "$DIR_TO_CHECK" ]]; then
     echo "Error: '$DIR_TO_CHECK' is not a directory" >&2

src/api/StreamApiNative.ts

@@ -142,6 +142,12 @@ export class StreamApiNative extends BaseNative {
         );
     }
 
+    async enableStreamRoomRecording(ptr: number, args: [string]): Promise<void> {
+        return this.runAsync<void>((taskId) =>
+            this.api.lib.StreamApi_enableStreamRoomRecording(taskId, ptr, args),
+        );
+    }
+
     async publishStream(ptr: number, args: [number]): Promise<Types.StreamPublishResult> {
         const ret = await this.runAsync<Types.StreamPublishResult>((taskId) =>
             this.api.lib.StreamApi_publishStream(taskId, ptr, args),

src/service/StreamApi.ts

@@ -109,6 +109,11 @@ export class StreamApi extends BaseApi {
         return this.native.leaveStreamRoom(this.servicePtr, [streamRoomId]);
     }
 
+    public async enableStreamRoomRecording(streamRoomId: Types.StreamRoomId): Promise<void> {
+        return this.native.enableStreamRoomRecording(this.servicePtr, [streamRoomId]);
+    }
+
+
     public async getStreamRoom(streamRoomId: Types.StreamRoomId): Promise<StreamRoom> {
         return this.native.getStreamRoom(this.servicePtr, [streamRoomId]);
     }

webendpoint-cpp/include/Endpoint.hpp

@@ -192,6 +192,7 @@ API_FUNCTION_HEADER(StreamApi, unpublishStream)
 API_FUNCTION_HEADER(StreamApi, joinStreamRoom)
 API_FUNCTION_HEADER(StreamApi, listStreams)
 API_FUNCTION_HEADER(StreamApi, leaveStreamRoom)
+API_FUNCTION_HEADER(StreamApi, enableStreamRoomRecording)
 
 API_FUNCTION_HEADER(StreamApi, subscribeToRemoteStreams)
 API_FUNCTION_HEADER(StreamApi, modifyRemoteStreamsSubscriptions)

webendpoint-cpp/src/Bindings.cpp

@@ -182,6 +182,7 @@ EMSCRIPTEN_BINDINGS(webendpoint) {
     BINDING_FUNCTION(StreamApi, joinStreamRoom)
     BINDING_FUNCTION(StreamApi, listStreams)
     BINDING_FUNCTION(StreamApi, leaveStreamRoom)
+    BINDING_FUNCTION(StreamApi, enableStreamRoomRecording)
 
     BINDING_FUNCTION(StreamApi, subscribeToRemoteStreams)
     BINDING_FUNCTION(StreamApi, modifyRemoteStreamsSubscriptions)

webendpoint-cpp/src/Endpoint.cpp

@@ -363,6 +363,7 @@ API_FUNCTION(StreamApi, unpublishStream)
 API_FUNCTION(StreamApi, joinStreamRoom)
 API_FUNCTION(StreamApi, listStreams)
 API_FUNCTION(StreamApi, leaveStreamRoom)
+API_FUNCTION(StreamApi, enableStreamRoomRecording)
 
 API_FUNCTION(StreamApi, subscribeToRemoteStreams)
 API_FUNCTION(StreamApi, modifyRemoteStreamsSubscriptions)