updated dependencies. Added support for Advanced channel types

cdk/Makefile

@@ -1,4 +1,6 @@
 .DEFAULT_GOAL := help
+ORANGE := \033[38;5;202m
+RESET := \033[0m
 
 .PHONY: help app install bootstrap deploy destroy clean
 
@@ -43,6 +45,7 @@ deploy: ## Deploys the stack
 	node scripts/sanitize-output $(STACK)
 	rm temp_out.json
 	@echo "\n$$(tput bold) ✅ $(STACK) Deployed Successfully $$(tput sgr0)\n"
+	@echo "\n$$(tput bold) $(ORANGE) Attention: Please note that adjustments made to your current cloud stack may not retrospectively affect all previously created resources. $$(tput sgr0)\n$(RESET)"
 	@if [ $(PUBLISH) = true ]; then\
 		echo "Publishing Frontend App...";\
 		npm install --prefix ../web-ui;\

cdk/README.md

@@ -72,3 +72,13 @@ Service Auto Scaling automatically creates and manages CloudWatch alarms for you
 For this reason, please do not create, edit, or delete the CloudWatch alarms that are used with a target tracking scaling policy.
 
 To learn how to hide auto scaling alarms, please consult the "Hide Auto Scaling alarms" user guide available at: [Hide Auto Scaling alarms user guide](https://docs.aws.amazon.com/AmazonCloudWatch/latest/monitoring/hide-autoscaling-alarms.html).
+
+## Stream events API
+
+Amazon IVS sends change events about the status of your streams to Amazon EventBridge. The Stream Events API is an EventBridge rule that updates the DynamoDB Streams table for the UGC application.
+
+When the postStreamEvents function receives an event with a `session created` event name, any existing live stream session in the same channel is updated to offline by removing the `isOpen` attribute from the corresponding DynamoDB record. This logic ensures that a channel cannot have more than one live stream session simultaneously. Subsequently, the new stream session is saved with the `isOpen` attribute set to true.
+
+When a `session ended` event is received, the corresponding stream record is grabbed and updated by removing the `isOpen` attribute.
+
+You can find the Stream events API code in the `/streamEventsApi` folder.

cdk/api/__tests__/buildServer.test.ts

@@ -21,8 +21,9 @@ describe('buildServer', () => {
       });
 
       expect(response.statusCode).toBe(400);
-      expect(response.body).toEqual(
-        '{"statusCode":400,"error":"Bad Request","message":"params/channelOwnerUsername must NOT have more than 100 characters"}'
+      expect(response.statusMessage).toBe('Bad Request');
+      expect(JSON.parse(response.body).message).toBe(
+        'params/channelOwnerUsername must NOT have more than 100 characters'
       );
     });
 

cdk/api/channel/authRouter/createResources.ts

@@ -1,4 +1,8 @@
-import { ChannelType, CreateChannelCommand } from '@aws-sdk/client-ivs';
+import {
+  ChannelType,
+  CreateChannelCommand,
+  TranscodePreset
+} from '@aws-sdk/client-ivs';
 import { CreateRoomCommand } from '@aws-sdk/client-ivschat';
 import { FastifyReply, FastifyRequest } from 'fastify';
 
@@ -39,6 +43,8 @@ const handler = async (
     const createChannelCommand = new CreateChannelCommand({
       name: channelName,
       type: process.env.IVS_CHANNEL_TYPE as ChannelType,
+      preset: process.env
+        .IVS_ADVANCED_CHANNEL_TRANSCODE_PRESET as TranscodePreset,
       tags: { project: process.env.PROJECT_TAG as string }
     });
     const { channel, streamKey } = await ivsClient.send(createChannelCommand);

cdk/cdk.json

@@ -30,6 +30,7 @@
         "deploySeparateContainers": false,
         "enableUserAutoVerify": true,
         "ivsChannelType": "BASIC",
+        "ivsAdvancedChannelTranscodePreset": "",
         "logRetention": 7,
         "maxAzs": 2,
         "minScalingCapacity": 1,
@@ -48,6 +49,7 @@
         "deploySeparateContainers": true,
         "enableUserAutoVerify": false,
         "ivsChannelType": "STANDARD",
+        "ivsAdvancedChannelTranscodePreset": "",
         "maxAzs": 3,
         "minScalingCapacity": 1,
         "natGateways": 2,

cdk/lib/ChannelsStack/cdk-channels-stack.ts

@@ -52,6 +52,7 @@ export class ChannelsStack extends NestedStack {
     const {
       allowedOrigins,
       enableUserAutoVerify,
+      ivsAdvancedChannelTranscodePreset,
       ivsChannelType,
       signUpAllowedDomains
     } = resourceConfig;
@@ -383,6 +384,7 @@ export class ChannelsStack extends NestedStack {
       CHANNEL_ASSETS_BUCKET_NAME: channelAssetsBucket.bucketName,
       CHANNELS_TABLE_NAME: channelsTable.tableName,
       IVS_CHANNEL_TYPE: ivsChannelType,
+      IVS_ADVANCED_CHANNEL_TRANSCODE_PRESET: ivsAdvancedChannelTranscodePreset,
       PROJECT_TAG: tags.project,
       SIGN_UP_ALLOWED_DOMAINS: JSON.stringify(signUpAllowedDomains),
       USER_POOL_CLIENT_ID: userPoolClient.userPoolClientId,