listStorageChannels.js

/**
 * This function lists all storage-configured signaling channel ARNs and their associated stream's ARN.
 */
async function listStorageChannels(formValues) {
    $('#logs-header')[0].scrollIntoView({
        block: 'start',
    });

    try {
        console.log('[LIST_STORAGE_CHANNELS] Attempting to list all storage-configured signaling channels and their associated stream');

        // Create KVS client
        const kinesisVideoClient = new AWS.KinesisVideo.KinesisVideoClient({
            region: formValues.region,
            credentials: {
                accessKeyId: formValues.accessKeyId,
                secretAccessKey: formValues.secretAccessKey,
                sessionToken: formValues.sessionToken,
            },
            endpoint: formValues.endpoint,
            logger: formValues.logAwsSdkCalls ? console : undefined,
        });

        // Get all signaling channels
        const result = await kinesisVideoClient.send(new AWS.KinesisVideo.ListSignalingChannelsCommand());
        const allChannels = result.ChannelInfoList;

        // Grab channel ARNs
        const allChannelARNs = allChannels.map(channel => {
            return channel.ChannelARN;
        });

        let progressCounter = 0;
        const output = [];
        // Print channel ARN and its storage stream ARN if media storage is enabled for the channel
        for (const channelARN of allChannelARNs) {
            const request = {
                ChannelARN: channelARN,
            };
            const storageResult = await kinesisVideoClient.send(new AWS.KinesisVideo.DescribeMediaStorageConfigurationCommand(request));
            if (storageResult.MediaStorageConfiguration.Status === 'ENABLED') {
                output.push({
                    ChannelARN: channelARN,
                    StreamARN: storageResult.MediaStorageConfiguration.StreamARN,
                });
            }
            console.log('[LIST_STORAGE_CHANNELS] Progress:', ++progressCounter, '/', allChannelARNs.length);
            await new Promise(res => setTimeout(res, 500)); // To avoid getting rate limited
        }

        console.log('[LIST_STORAGE_CHANNELS] You have', output.length, 'channels configured for storage:');
        console.log('[LIST_STORAGE_CHANNELS]', output);
    } catch (e) {
        console.error('[LIST_STORAGE_CHANNELS] Encountered error:', e);
    }
}