Construct LogEvent filter from params. Validate buildStartLiveTailCom…

…mand in unit tests

packages/core/src/awsService/cloudWatchLogs/registry/liveTailSession.ts

@@ -49,6 +49,7 @@ export class LiveTailSession {
     public constructor(configuration: LiveTailSessionConfiguration) {
         this._logGroupArn = configuration.logGroupArn
         this.logStreamFilter = configuration.logStreamFilter
+        this.logEventFilterPattern = configuration.logEventFilterPattern
         this.liveTailClient = {
             cwlClient: new CloudWatchLogsClient({
                 credentials: configuration.awsCredentials,
@@ -120,7 +121,7 @@ export class LiveTailSession {
         return this.endTime - this.startTime
     }
 
-    private buildStartLiveTailCommand(): StartLiveTailCommand {
+    public buildStartLiveTailCommand(): StartLiveTailCommand {
         let logStreamNamePrefix = undefined
         let logStreamName = undefined
         if (this.logStreamFilter) {

packages/core/src/test/awsService/cloudWatchLogs/registry/liveTailSession.test.ts

@@ -0,0 +1,97 @@
+/*!
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0
+ */
+import assert from 'assert'
+import { LiveTailSession } from '../../../../awsService/cloudWatchLogs/registry/liveTailSession'
+import { StartLiveTailCommand } from '@aws-sdk/client-cloudwatch-logs'
+describe('LiveTailSession', async function () {
+    const testLogGroupArn = 'arn:aws:test-log-group'
+    const testRegion = 'test-region'
+    const testFilter = 'test-filter'
+    const testAwsCredentials = {} as any as AWS.Credentials
+    it('correctly builds StartLiveTailCommand: no stream Filter, no event filter.', function () {
+        const session = new LiveTailSession({
+            logGroupArn: testLogGroupArn,
+            region: testRegion,
+            awsCredentials: testAwsCredentials,
+        })
+        assert.strictEqual(
+            JSON.stringify(session.buildStartLiveTailCommand()),
+            JSON.stringify(
+                new StartLiveTailCommand({
+                    logGroupIdentifiers: [testLogGroupArn],
+                    logEventFilterPattern: undefined,
+                    logStreamNamePrefixes: undefined,
+                    logStreamNames: undefined,
+                })
+            )
+        )
+    })
+    it('correctly builds StartLiveTailCommand: with prefix stream Filter', function () {
+        const session = new LiveTailSession({
+            logGroupArn: testLogGroupArn,
+            logStreamFilter: {
+                type: 'prefix',
+                filter: 'test-filter',
+            },
+            region: testRegion,
+            awsCredentials: testAwsCredentials,
+        })
+        assert.strictEqual(
+            JSON.stringify(session.buildStartLiveTailCommand()),
+            JSON.stringify(
+                new StartLiveTailCommand({
+                    logGroupIdentifiers: [testLogGroupArn],
+                    logEventFilterPattern: undefined,
+                    logStreamNamePrefixes: [testFilter],
+                    logStreamNames: undefined,
+                })
+            )
+        )
+    })
+    it('correctly builds StartLiveTailCommand: with specific stream Filter', function () {
+        const session = new LiveTailSession({
+            logGroupArn: testLogGroupArn,
+            logStreamFilter: {
+                type: 'specific',
+                filter: 'test-filter',
+            },
+            region: testRegion,
+            awsCredentials: testAwsCredentials,
+        })
+        assert.strictEqual(
+            JSON.stringify(session.buildStartLiveTailCommand()),
+            JSON.stringify(
+                new StartLiveTailCommand({
+                    logGroupIdentifiers: [testLogGroupArn],
+                    logEventFilterPattern: undefined,
+                    logStreamNamePrefixes: undefined,
+                    logStreamNames: [testFilter],
+                })
+            )
+        )
+    })
+    it('correctly builds StartLiveTailCommand: with log event Filter', function () {
+        const session = new LiveTailSession({
+            logGroupArn: testLogGroupArn,
+            logStreamFilter: {
+                type: 'all',
+            },
+            logEventFilterPattern: 'test-filter',
+            region: testRegion,
+            awsCredentials: testAwsCredentials,
+        })
+        assert.strictEqual(
+            JSON.stringify(session.buildStartLiveTailCommand()),
+            JSON.stringify(
+                new StartLiveTailCommand({
+                    logGroupIdentifiers: [testLogGroupArn],
+                    logEventFilterPattern: testFilter,
+                    logStreamNamePrefixes: undefined,
+                    logStreamNames: undefined,
+                })
+            )
+        )
+    })
+})