Apply signaling component

CMake/Dependencies/libcorejson-CMakeLists.txt

@@ -0,0 +1,24 @@
+cmake_minimum_required(VERSION 3.6.3)
+
+project(libcorejson NONE)
+
+if (BUILD_STATIC_LIBS OR WIN32)
+  set(LIBCOREJSON_SHARED_LIBS OFF)
+else()
+  set(LIBCOREJSON_SHARED_LIBS ON)
+endif()
+
+include(ExternalProject)
+ExternalProject_Add(libcorejson
+    GIT_REPOSITORY    https://github.com/FreeRTOS/coreJSON.git
+    GIT_TAG           dc1ab9130a1fb99b801a2a1fa8e9f42239f752be
+    PREFIX            ${CMAKE_CURRENT_BINARY_DIR}/build
+    PATCH_COMMAND     git apply --ignore-whitespace ${CMAKE_CURRENT_LIST_DIR}/libcorejson-add-cmakelists.patch
+    CMAKE_ARGS
+        -DCMAKE_INSTALL_PREFIX=${OPEN_SRC_INSTALL_PREFIX}
+        -DCMAKE_BUILD_TYPE=${CMAKE_BUILD_TYPE}
+        -DBUILD_SHARED_LIBS=${LIBCOREJSON_SHARED_LIBS}
+        "-DCMAKE_C_FLAGS=${CMAKE_C_FLAGS} -fPIC"
+    BUILD_ALWAYS      TRUE
+    TEST_COMMAND      ""
+)

CMake/Dependencies/libcorejson-add-cmakelists.patch

@@ -0,0 +1,31 @@
+diff --git a/CMakeLists.txt b/CMakeLists.txt
+new file mode 100644
+index 0000000..9a5f850
+--- /dev/null
++++ b/CMakeLists.txt
+@@ -0,0 +1,25 @@
++cmake_minimum_required(VERSION 3.6.3)
++project(corejson C)
++
++include(jsonFilePaths.cmake)
++
++if(BUILD_SHARED_LIBS)
++    add_library(corejson SHARED ${JSON_SOURCES})
++else()
++    add_library(corejson STATIC ${JSON_SOURCES})
++endif()
++
++target_include_directories(corejson PUBLIC
++                           ${JSON_INCLUDE_PUBLIC_DIRS})
++
++# install header files
++install(
++    FILES ${JSON_INCLUDE_PUBLIC_DIRS}/core_json.h
++    DESTINATION include/corejson)
++
++install(
++    TARGETS corejson
++    ARCHIVE DESTINATION "${CMAKE_INSTALL_LIBDIR}"
++    LIBRARY DESTINATION "${CMAKE_INSTALL_LIBDIR}"
++    RUNTIME DESTINATION "${CMAKE_INSTALL_BINDIR}")
++

CMake/Dependencies/libkvssignaling-CMakeLists.txt

@@ -0,0 +1,23 @@
+cmake_minimum_required(VERSION 3.6.3)
+
+project(libkvssignaling NONE)
+
+include(ExternalProject)
+if (BUILD_STATIC_LIBS OR WIN32)
+  set(LIBKVSSIGNALING_SHARED_LIBS OFF)
+else()
+  set(LIBKVSSIGNALING_SHARED_LIBS ON)
+endif()
+
+ExternalProject_Add(libkvssignaling
+    GIT_REPOSITORY    https://github.com/ActoryOu/amazon-kinesis-video-streams-signaling-public.git
+    GIT_TAG           aggarg_suggestions
+    PREFIX            ${CMAKE_CURRENT_BINARY_DIR}/build
+    CMAKE_ARGS
+        -DCMAKE_INSTALL_PREFIX=${OPEN_SRC_INSTALL_PREFIX}
+        -DCMAKE_C_FLAGS=${CMAKE_C_FLAGS}
+        -DBUILD_SHARED_LIBS=${LIBKVSSIGNALING_SHARED_LIBS}
+        -DCMAKE_BUILD_TYPE=${CMAKE_BUILD_TYPE}
+    BUILD_ALWAYS      TRUE
+    TEST_COMMAND      ""
+)

CMake/Utilities.cmake

@@ -16,7 +16,9 @@ function(build_dependency lib_name)
       kvsCommonLws
       kvssdp
       kvsstun
-      kvsrtp)
+      kvsrtp
+      corejson
+      kvssignaling)
   list(FIND supported_libs ${lib_name} index)
   if(${index} EQUAL -1)
     message(WARNING "${lib_name} is not supported to build from source")

CMakeLists.txt

@@ -225,11 +225,24 @@ if(BUILD_DEPENDENCIES)
   build_dependency(kvsrtp ${BUILD_ARGS})
 
   set(BUILD_ARGS
+      -DBUILD_STATIC_LIBS=${BUILD_STATIC_LIBS}
       -DCMAKE_BUILD_TYPE=${CMAKE_BUILD_TYPE}
       -DCMAKE_C_FLAGS=${CMAKE_C_FLAGS})
 
-  build_dependency(usrsctp ${BUILD_ARGS})
+  build_dependency(corejson ${BUILD_ARGS})
+
+  set(BUILD_ARGS
+      -DBUILD_STATIC_LIBS=${BUILD_STATIC_LIBS}
+      -DCMAKE_BUILD_TYPE=${CMAKE_BUILD_TYPE}
+      "-DCMAKE_C_FLAGS=${CMAKE_C_FLAGS} -I${OPEN_SRC_INSTALL_PREFIX}/include/corejson")
 
+  build_dependency(kvssignaling ${BUILD_ARGS})
+
+  set(BUILD_ARGS
+      -DCMAKE_BUILD_TYPE=${CMAKE_BUILD_TYPE}
+      -DCMAKE_C_FLAGS=${CMAKE_C_FLAGS})
+
+  build_dependency(usrsctp ${BUILD_ARGS})
 
   if(BUILD_TEST)
     build_dependency(gtest)
@@ -412,6 +425,8 @@ target_link_libraries(
           kvssdp
           kvsstun
           kvsrtp
+          corejson
+          kvssignaling
           ${CMAKE_THREAD_LIBS_INIT}
           ${OPENSSL_SSL_LIBRARY}
           ${OPENSSL_CRYPTO_LIBRARY}
@@ -436,6 +451,8 @@ target_link_libraries(
         kvssdp
         kvsstun
         kvsrtp
+        corejson
+        kvssignaling
   PRIVATE kvspicUtils
          kvspicState
          ${CMAKE_THREAD_LIBS_INIT}

samples/CMakeLists.txt

@@ -61,13 +61,13 @@ add_executable(
   kvsWebrtcClientMaster
   Common.c
   kvsWebRTCClientMaster.c)
-target_link_libraries(kvsWebrtcClientMaster kvsWebrtcClient kvsWebrtcSignalingClient ${EXTRA_DEPS} kvsCommonLws kvspicUtils websockets kvssdp kvsstun kvsrtp)
+target_link_libraries(kvsWebrtcClientMaster kvsWebrtcClient kvsWebrtcSignalingClient ${EXTRA_DEPS} kvsCommonLws kvspicUtils websockets kvssdp kvsstun kvsrtp kvssignaling corejson)
 
 add_executable(
   kvsWebrtcClientViewer
   Common.c
   kvsWebRTCClientViewer.c)
-target_link_libraries(kvsWebrtcClientViewer kvsWebrtcClient kvsWebrtcSignalingClient ${EXTRA_DEPS} kvsCommonLws kvspicUtils websockets kvssdp kvsstun kvsrtp)
+target_link_libraries(kvsWebrtcClientViewer kvsWebrtcClient kvsWebrtcSignalingClient ${EXTRA_DEPS} kvsCommonLws kvspicUtils websockets kvssdp kvsstun kvsrtp kvssignaling corejson)
 
 add_executable(
         discoverNatBehavior
@@ -81,7 +81,7 @@ if(GST_FOUND)
     GstAudioVideoReceiver.c
     kvsWebRTCClientMasterGstSample.c
   )
-  target_link_libraries(kvsWebrtcClientMasterGstSample kvsWebrtcClient kvsWebrtcSignalingClient ${EXTRA_DEPS} ${GST_SAMPLE_LIBRARIES} kvsCommonLws kvspicUtils websockets kvssdp kvsstun kvsrtp)
+  target_link_libraries(kvsWebrtcClientMasterGstSample kvsWebrtcClient kvsWebrtcSignalingClient ${EXTRA_DEPS} ${GST_SAMPLE_LIBRARIES} kvsCommonLws kvspicUtils websockets kvssdp kvsstun kvsrtp kvssignaling corejson)
 
   install(TARGETS kvsWebrtcClientMasterGstSample
     RUNTIME DESTINATION bin

scripts/check-sample.sh

@@ -12,6 +12,7 @@ set -xv
 
 pwd
 ls -l
+ls -l open-source/lib
 
 pids=""
 cd build/samples

src/source/Signaling/ChannelInfo.c

@@ -317,39 +317,6 @@ PCHAR getStringFromChannelType(SIGNALING_CHANNEL_TYPE type)
     return typeStr;
 }
 
-SIGNALING_CHANNEL_ROLE_TYPE getChannelRoleTypeFromString(PCHAR type, UINT32 length)
-{
-    // Assume the channel Deleting status first
-    SIGNALING_CHANNEL_ROLE_TYPE channelRoleType = SIGNALING_CHANNEL_ROLE_TYPE_UNKNOWN;
-
-    if (0 == STRNCMP(SIGNALING_CHANNEL_ROLE_TYPE_MASTER_STR, type, length)) {
-        channelRoleType = SIGNALING_CHANNEL_ROLE_TYPE_MASTER;
-    } else if (0 == STRNCMP(SIGNALING_CHANNEL_ROLE_TYPE_VIEWER_STR, type, length)) {
-        channelRoleType = SIGNALING_CHANNEL_ROLE_TYPE_VIEWER;
-    }
-
-    return channelRoleType;
-}
-
-PCHAR getStringFromChannelRoleType(SIGNALING_CHANNEL_ROLE_TYPE type)
-{
-    PCHAR typeStr;
-
-    switch (type) {
-        case SIGNALING_CHANNEL_ROLE_TYPE_MASTER:
-            typeStr = SIGNALING_CHANNEL_ROLE_TYPE_MASTER_STR;
-            break;
-        case SIGNALING_CHANNEL_ROLE_TYPE_VIEWER:
-            typeStr = SIGNALING_CHANNEL_ROLE_TYPE_VIEWER_STR;
-            break;
-        default:
-            typeStr = SIGNALING_CHANNEL_ROLE_TYPE_UNKNOWN_STR;
-            break;
-    }
-
-    return typeStr;
-}
-
 // https://docs.aws.amazon.com/kinesisvideostreams-webrtc-dg/latest/devguide/kvswebrtc-how-iam.html#kinesis-using-iam-arn-format
 // Example: arn:aws:kinesisvideo:region:account-id:channel/channel-name/code
 STATUS validateKvsSignalingChannelArnAndExtractChannelName(PChannelInfo pChannelInfo, PUINT16 pStart, PUINT16 pNumChars)

src/source/Signaling/ChannelInfo.h

@@ -23,11 +23,6 @@ extern "C" {
 #define SIGNALING_CHANNEL_TYPE_UNKNOWN_STR       (PCHAR) "UNKOWN"
 #define SIGNALING_CHANNEL_TYPE_SINGLE_MASTER_STR (PCHAR) "SINGLE_MASTER"
 
-// Signaling channel role type string
-#define SIGNALING_CHANNEL_ROLE_TYPE_UNKNOWN_STR (PCHAR) "UNKOWN"
-#define SIGNALING_CHANNEL_ROLE_TYPE_MASTER_STR  (PCHAR) "MASTER"
-#define SIGNALING_CHANNEL_ROLE_TYPE_VIEWER_STR  (PCHAR) "VIEWER"
-
 // Min and max for the message TTL value
 #define MIN_SIGNALING_MESSAGE_TTL_VALUE (5 * HUNDREDS_OF_NANOS_IN_A_SECOND)
 #define MAX_SIGNALING_MESSAGE_TTL_VALUE (120 * HUNDREDS_OF_NANOS_IN_A_SECOND)
@@ -86,25 +81,6 @@ SIGNALING_CHANNEL_TYPE getChannelTypeFromString(PCHAR, UINT32);
  */
 PCHAR getStringFromChannelType(SIGNALING_CHANNEL_TYPE);
 
-/**
- * Returns the signaling channel Role from a string
- *
- * @param - PCHAR - IN - String representation of the channel role
- * @param - UINT32 - IN - String length
- *
- * @return - Signaling channel type
- */
-SIGNALING_CHANNEL_ROLE_TYPE getChannelRoleTypeFromString(PCHAR, UINT32);
-
-/**
- * Returns the signaling channel role type string
- *
- * @param - SIGNALING_CHANNEL_TYPE - IN - Signaling channel type
- *
- * @return - Signaling channel type string
- */
-PCHAR getStringFromChannelRoleType(SIGNALING_CHANNEL_ROLE_TYPE);
-
 /**
  * Determines whether or not the channel arn is valid
  * If VALID it extracts the channel name