sdk-v3: Migrate CloudwatchLogs to V3

GH-641

Author: abetomo

lib/cloudwatch_logs.js

@@ -1,49 +1,39 @@
 'use strict'
 
+const {
+  CloudWatchLogsClient,
+  CreateLogGroupCommand,
+  PutRetentionPolicyCommand
+} = require('@aws-sdk/client-cloudwatch-logs')
+
 class CloudWatchLogs {
-  constructor (aws, region) {
-    // Authenticated `aws` object in `lib/main.js`
-    this.lambda = new aws.Lambda({
-      region,
-      apiVersion: '2015-03-31'
-    })
-    this.cloudwatchlogs = new aws.CloudWatchLogs({
-      apiVersion: '2014-03-28'
-    })
+  constructor (config) {
+    this.client = new CloudWatchLogsClient(config)
   }
 
   _logGroupName (params) {
     return `/aws/lambda/${params.FunctionName}`
   }
 
   _createLogGroup (params) {
-    return new Promise((resolve, reject) => {
-      this.cloudwatchlogs.createLogGroup({
+    try {
+      return this.client.send(new CreateLogGroupCommand({
         logGroupName: this._logGroupName(params)
-      }, (err, data) => {
-        if (err) {
-          if (err.code === 'ResourceAlreadyExistsException') {
-            // If it exists it will result in an error but there is no problem.
-            return resolve({})
-          }
-          return reject(err)
-        }
-
-        resolve(data)
-      })
-    })
+      }))
+    } catch (err) {
+      if (err.code === 'ResourceAlreadyExistsException') {
+        // If it exists it will result in an error but there is no problem.
+        return {}
+      }
+      throw err
+    }
   }
 
   _putRetentionPolicy (params) {
-    return new Promise((resolve, reject) => {
-      this.cloudwatchlogs.putRetentionPolicy({
-        logGroupName: this._logGroupName(params),
-        retentionInDays: params.retentionInDays
-      }, (err, data) => {
-        if (err) return reject(err)
-        resolve(data)
-      })
-    })
+    return this.client.send(new PutRetentionPolicyCommand({
+      logGroupName: this._logGroupName(params),
+      retentionInDays: params.retentionInDays
+    }))
   }
 
   setLogsRetentionPolicy (params) {

lib/main.js

@@ -971,11 +971,12 @@ they may not work as expected in the Lambda environment.
     }
     console.log(params)
 
-    const lambdaClient = new LambdaClient({ region })
+    const config = { region }
+    const lambdaClient = new LambdaClient(config)
     // Migrating to v3.
     const scheduleEvents = new ScheduleEvents(aws.sdk, region)
     const s3Events = new S3Events(aws.sdk, region)
-    const cloudWatchLogs = new CloudWatchLogs(aws.sdk, region)
+    const cloudWatchLogs = new CloudWatchLogs(config)
 
     const existsFunction = await (async () => {
       try {